src/Log/EventSubscriber/RequestSubscriber.php line 58

Open in your IDE?
  1. <?php
  3. namespace App\Log\EventSubscriber;
  5. use App\Api\Response\ApiResponse;
  6. use App\Log\Service\RequestFactory;
  7. use Doctrine\ORM\EntityManagerInterface;
  8. use Symfony\Component\DependencyInjection\ParameterBag\ContainerBagInterface;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\HttpKernel\Event\RequestEvent;
  11. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  12. use Symfony\Component\HttpKernel\KernelEvents;
  14. class RequestSubscriber extends BaseSubscriber implements EventSubscriberInterface
  15. {
  17.     public const ID_KEY = 'request_id';
  18.     protected const EVENTS = [
  19.         KernelEvents::REQUEST => 'onRequest',
  20.         KernelEvents::RESPONSE => 'onResponse'
  21.     ];
  23.     /**
  24.      * @var EntityManagerInterface
  25.      */
  26.     protected EntityManagerInterface $entityManager;
  28.     /**
  29.      * @var RequestFactory
  30.      */
  31.     protected RequestFactory $requestFactory;
  33.     /**
  34.      * RequestSubscriber constructor.
  35.      * @param EntityManagerInterface $entityTaskFactory
  36.      * @param RequestFactory $requestFactory
  37.      * @param ContainerBagInterface $containerBag
  38.      */
  39.     public function __construct(EntityManagerInterface $entityTaskFactory, RequestFactory $requestFactory, ContainerBagInterface $containerBag)
  40.     {
  41.         $this->entityManager = $entityTaskFactory;
  42.         $this->requestFactory = $requestFactory;
  44.         parent::__construct($containerBag);
  45.     }
  47.     /**
  48.      * @return string[]
  49.      */
  50.     public static function getSubscribedEvents(): array
  51.     {
  52.         return self::EVENTS;
  53.     }
  55.     /**
  56.      * @param RequestEvent $event
  57.      */
  58.     public function onRequest(RequestEvent $event): void
  59.     {
  60.         $requestEvent = $event->getRequest();
  61.         if ($event->isMainRequest() && $this->supports($requestEvent->getUri())) {
  62.             $content = $requestEvent->getContent();
  63.             $requestData = $content && json_decode($content, true) ? $requestEvent->toArray() : [$content];
  64.             $request = $this->requestFactory->create($requestEvent->getUri(), $requestData, $requestEvent->getClientIp());
  65.             $event->getRequest()->attributes->set(self::ID_KEY, $request);
  66.         }
  67.     }
  69.     /**
  70.      * @param ResponseEvent $event
  71.      */
  72.     public function onResponse(ResponseEvent $event): void
  73.     {
  74.         $request = $event->getRequest()->attributes->get(self::ID_KEY);
  75.         if ($request) {
  76.             $response = $event->getResponse();
  78.             if ($response instanceof ApiResponse) {
  79.                 $responseData = $this->anonymize($response->getData()) ?: [];
  80.             } else {
  81.                 $content = $response->getContent();
  82.                 $responseData = $content && json_decode($content, true) ?
  83.                     json_decode($content, true) : [$content];
  84.             }
  85.             $complete = !$event->getRequest()->attributes->get(ExceptionSubscriber::EXCEPTION_OCCURRED);
  86.             $this->requestFactory->update($request, $responseData, $response->getStatusCode(), $complete);
  87.         }
  88.     }
  90.     /**
  91.      * @param $data
  92.      * @return array
  93.      */
  94.     protected function anonymize($data): array
  95.     {
  96.         if ($this->getParam('log.anonymization')){
  97.             $keys = $this->getParam('log.anonymization_keys');
  98.             array_walk_recursive($data, static function (&$item, $key) use ($keys) {
  99.                 $item = in_array($key, $keys, true) ?  '-_🙈_-' : $item;
  100.             });
  101.         }
  102.         return $data;
  103.     }
  104. }