src/EventSubscriber/RequestLoggingSubscriber.php line 43

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use Psr\Log\LoggerInterface;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\HttpKernel\Event\RequestEvent;
  8. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  9. use Symfony\Component\HttpKernel\KernelEvents;
  10. use Symfony\Component\Security\Core\Security;
  12. class RequestLoggingSubscriber implements EventSubscriberInterface
  13. {
  14.     public function __construct(
  15.         private readonly LoggerInterface $logger,
  16.         private readonly Security $security,
  17.     ) {
  18.     }
  20.     public static function getSubscribedEvents(): array
  21.     {
  22.         return [
  23.             KernelEvents::REQUEST => ['onKernelRequest', 100],
  24.             KernelEvents::RESPONSE => ['onKernelResponse', -100],
  25.         ];
  26.     }
  28.     public function onKernelRequest(RequestEvent $event): void
  29.     {
  30.         if (!$event->isMainRequest()) {
  31.             return;
  32.         }
  34.         $request = $event->getRequest();
  35.         $requestId = $request->headers->get('X-Request-Id');
  36.         if (!$requestId) {
  37.             $requestId = bin2hex(random_bytes(8));
  38.         }
  39.         $request->attributes->set('_request_id', $requestId);
  40.         $request->attributes->set('_request_start', microtime(true));
  41.     }
  43.     public function onKernelResponse(ResponseEvent $event): void
  44.     {
  45.         if (!$event->isMainRequest()) {
  46.             return;
  47.         }
  49.         $request = $event->getRequest();
  50.         $response = $event->getResponse();
  52.         $requestId = (string) $request->attributes->get('_request_id', '');
  53.         if ($requestId !== '') {
  54.             $response->headers->set('X-Request-Id', $requestId);
  55.         }
  57.         $start = (float) $request->attributes->get('_request_start', microtime(true));
  58.         $durationMs = (microtime(true) - $start) * 1000;
  60.         $user = $this->security->getUser();
  61.         $userId = $user && method_exists($user, 'getId') ? $user->getId() : null;
  63.         $this->logger->info('http_request', [
  64.             'request_id' => $requestId,
  65.             'method' => $request->getMethod(),
  66.             'path' => $request->getPathInfo(),
  67.             'status' => $response->getStatusCode(),
  68.             'duration_ms' => (int) round($durationMs),
  69.             'user_id' => $userId,
  70.             'ip' => $request->getClientIp(),
  71.         ]);
  72.     }
  73. }