src/EventsSubscriber/Exception/HttpErrorLogSubscriber.php line 37

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventsSubscriber\Exception;
  7. use Psr\Log\LoggerInterface;
  8. use Sentry\Severity;
  9. use Sentry\State\HubInterface;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\HttpFoundation\Response;
  12. use Symfony\Component\HttpKernel\Event\ExceptionEvent;
  13. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  14. use Symfony\Component\HttpKernel\Exception\HttpExceptionInterface;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  17. /**
  18.  * Ensures 5xx failures are logged to stderr (CloudWatch). Sentry exception capture is handled by
  19.  * register_error_listener; this subscriber also reports HTTP 500 responses that never threw.
  20.  */
  21. final class HttpErrorLogSubscriber implements EventSubscriberInterface
  22. {
  23.     public function __construct(
  24.         private readonly LoggerInterface $logger,
  25.         private readonly HubInterface $sentryHub,
  26.     ) {
  27.     }
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             KernelEvents::EXCEPTION => ['onKernelException', 0],
  33.             KernelEvents::RESPONSE => ['onKernelResponse', -256],
  34.         ];
  35.     }
  37.     public function onKernelException(ExceptionEvent $event): void
  38.     {
  39.         if (!$event->isMainRequest()) {
  40.             return;
  41.         }
  43.         $exception = $event->getThrowable();
  44.         $statusCode = $exception instanceof HttpExceptionInterface
  45.             ? $exception->getStatusCode()
  46.             : Response::HTTP_INTERNAL_SERVER_ERROR;
  48.         if ($statusCode < Response::HTTP_INTERNAL_SERVER_ERROR) {
  49.             return;
  50.         }
  52.         $request = $event->getRequest();
  53.         $context = $this->buildRequestContext($request, $statusCode);
  55.         $this->logger->error(
  56.             sprintf('Unhandled %d: %s', $statusCode, $exception->getMessage()),
  57.             array_merge($context, ['exception' => $exception]),
  58.         );
  59.     }
  61.     public function onKernelResponse(ResponseEvent $event): void
  62.     {
  63.         if (!$event->isMainRequest()) {
  64.             return;
  65.         }
  67.         $response = $event->getResponse();
  68.         if ($response->getStatusCode() < Response::HTTP_INTERNAL_SERVER_ERROR) {
  69.             return;
  70.         }
  72.         $request = $event->getRequest();
  73.         $context = $this->buildRequestContext($request, $response->getStatusCode());
  75.         $this->logger->error(
  76.             sprintf('HTTP %d response without logged exception', $response->getStatusCode()),
  77.             $context,
  78.         );
  80.         $this->sentryHub->captureMessage(
  81.             sprintf(
  82.                 'HTTP %d on %s %s',
  83.                 $response->getStatusCode(),
  84.                 $request->getMethod(),
  85.                 $request->getPathInfo(),
  86.             ),
  87.             Severity::error(),
  88.         );
  89.     }
  91.     /**
  92.      * @return array<string, mixed>
  93.      */
  94.     private function buildRequestContext(\Symfony\Component\HttpFoundation\Request $request, int $statusCode): array
  95.     {
  96.         return [
  97.             'status_code' => $statusCode,
  98.             'method' => $request->getMethod(),
  99.             'path' => $request->getPathInfo(),
  100.             'query' => $request->query->all(),
  101.             'route' => $request->attributes->get('_route'),
  102.             'request_id' => $request->headers->get('X-Amzn-Trace-Id')
  103.                 ?? $request->headers->get('X-Request-Id'),
  104.         ];
  105.     }
  106. }