vendor/comalia/gesica_bundle/EventSubscriber/CorrelationIdAuditSubscriber.php line 45

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Comalia\GesicaBundle\EventSubscriber;
  7. use Comalia\GesicaBundle\Service\CorrelationIdService;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpFoundation\Exception\SessionNotFoundException;
  10. use Symfony\Component\HttpFoundation\RequestStack;
  11. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  12. use Symfony\Component\HttpKernel\Event\RequestEvent;
  13. use Symfony\Component\HttpKernel\KernelEvents;
  15. class CorrelationIdAuditSubscriber implements EventSubscriberInterface
  16. {
  17.     /**
  18.      * kernel.request priority
  19.      * 40 : pour déclencher le subscriber avant le correlationIdProcessor
  20.      */
  21.     const REQUEST_POST_READ = 40;
  23.     /**
  24.      * @var CorrelationIdService
  25.      */
  26.     private $correlationIdService;
  28.     /** @var RequestStack */
  29.     private $requestStack;
  31.     /**
  32.      * CorrelationIdAuditSubscriber constructor.
  33.      * @param CorrelationIdService $correlationIdService
  34.      * @param RequestStack $requestStack
  35.      */
  36.     public function __construct(CorrelationIdService $correlationIdService, RequestStack $requestStack)
  37.     {
  38.         $this->correlationIdService = $correlationIdService;
  39.         $this->requestStack = $requestStack;
  40.     }
  42.     /**
  43.      * @param RequestEvent $event
  44.      */
  45.     public function onKernelRequest(RequestEvent $event): void
  46.     {
  47.         $request = $event->getRequest();
  48.         $session = $this->getSession();
  50.         if ($session) {
  51.             if ($request->headers->has('x-correlation-id') === false) {
  52.                 $session->set('x-correlation-id', $this->correlationIdService->getCorrelationId());
  53.                 return;
  54.             }
  56.             $session->set('x-correlation-id', $request->headers->get('x-correlation-id'));
  58.             $request->setSession($session);
  59.         }
  60.     }
  62.     /**
  63.      * @inheritDoc
  64.      */
  65.     public static function getSubscribedEvents(): array
  66.     {
  67.         return [
  68.             KernelEvents::REQUEST => ['onKernelRequest', self::REQUEST_POST_READ]
  69.         ];
  70.     }
  72.     /**
  73.      * @return SessionInterface
  74.      */
  75.     private function getSession(): ?SessionInterface
  76.     {
  77.         try {
  78.             return $this->requestStack->getSession();
  79.         } catch (SessionNotFoundException $ex) {
  80.             return null;
  81.         }
  82.     }
  83. }