vendor/appaydin/pd-activity/Listener/RequestListener.php line 35

Open in your IDE?
  1. <?php
  3. /**
  4.  * This file is part of the pd-admin pd-activity package.
  5.  *
  6.  * @package     pd-activity
  7.  * @license     LICENSE
  8.  * @author      Ramazan APAYDIN <apaydin541@gmail.com>
  9.  * @link        https://github.com/appaydin/pd-activity
  10.  */
  12. namespace Pd\ActivityBundle\Listener;
  14. use Pd\ActivityBundle\Message\HttpLog;
  15. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  18. use Symfony\Component\HttpKernel\KernelEvents;
  19. use Symfony\Component\Messenger\MessageBusInterface;
  20. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  22. class RequestListener implements EventSubscriberInterface
  23. {
  24.     public function __construct(
  25.         private ParameterBagInterface $bag,
  26.         private TokenStorageInterface $tokenStorage,
  27.         private MessageBusInterface $bus
  28.     )
  29.     {
  30.     }
  32.     /**
  33.      * Listen Request.
  34.      */
  35.     public function onKernelResponse(ResponseEvent $event): void
  36.     {
  37.         $request = $event->getRequest();
  39.         if ($event->isMainRequest()) {
  40.             if (!$this->bag->get('pd_activity.log_request') ||
  41.                 \in_array($request->getMethod(), $this->bag->get('pd_activity.request_exclude_methods'), true)) {
  42.                 return;
  43.             }
  45.             // Check Uri Match
  46.             if ($this->bag->get('pd_activity.request_match_uri') &&
  47.                 !preg_match("{{$this->bag->get('pd_activity.request_match_uri')}}", $request->getRequestUri())) {
  48.                 return;
  49.             }
  51.             // Check Ajax Request
  52.             if (!$this->bag->get('pd_activity.log_ajax_request') && $request->isXmlHttpRequest()) {
  53.                 return;
  54.             }
  56.             // Check Content Disposion
  57.             if ($event->getResponse()->headers->has('Content-Disposition')){
  58.                 return;
  59.             }
  61.             // Send JOB
  62.             $this->bus->dispatch(new HttpLog(
  63.                 $request->getMethod(),
  64.                 $request->getRequestUri(),
  65.                 $request->request->all(),
  66.                 $request->getClientIp(),
  67.                 $request->getLocale(),
  68.                 $this->tokenStorage->getToken()?->getUser()->getId()
  69.             ));
  70.         }
  71.     }
  73.     public static function getSubscribedEvents(): array
  74.     {
  75.         return [
  76.             KernelEvents::RESPONSE => [['onKernelResponse']],
  77.         ];
  78.     }
  79. }