src/Shared/Infrastructure/EventSubscriber/RequestPerfSubscriber.php line 50

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Shared\Infrastructure\EventSubscriber;
  7. use App\Shared\Infrastructure\Observability\ObservabilityLogger;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpKernel\Event\RequestEvent;
  10. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  11. use Symfony\Component\HttpKernel\KernelEvents;
  12. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  13. use Throwable;
  15. /**
  16.  * FIX-260526-010 — [OBS-PERF-TRAMITE] medición wall-clock por request HTTP entrante.
  17.  *
  18.  * Captura t0 en kernel.request y dt total en kernel.terminate. Si dt > umbral
  19.  * (3.0s por defecto) emite warning permanente al canal de auditoría con
  20.  * {route, user, dt_ms}. Pensado para correlacionar con [OBS-PERF-HTTP] y
  21.  * detectar la operación concreta que dispara la espera de 5 minutos reportada
  22.  * por Enrique.
  23.  *
  24.  * Garantías:
  25.  *  - Sólo lectura de Request; ningún side-effect en flujo funcional.
  26.  *  - Logger envuelto en try/catch (`safeLog`); errores no propagan.
  27.  *  - Sólo loggea sub-requests `main` (ignora ESI/fragments).
  28.  */
  29. final class RequestPerfSubscriber implements EventSubscriberInterface
  30. {
  31.     private const ATTR_START_TIME = '_obs_perf_t0';
  32.     private float $thresholdSeconds;
  34.     public function __construct(
  35.         private ObservabilityLogger $observabilityLogger,
  36.         private ?TokenStorageInterface $tokenStorage = null,
  37.         float $thresholdSeconds = 3.0
  38.     ) {
  39.         $this->thresholdSeconds = $thresholdSeconds;
  40.     }
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             KernelEvents::REQUEST   => ['onKernelRequest', 1024], // prioridad alta para capturar t0 cuanto antes
  46.             KernelEvents::TERMINATE => ['onKernelTerminate', -1024],
  47.         ];
  48.     }
  50.     public function onKernelRequest(RequestEvent $event): void
  51.     {
  52.         if (!$event->isMainRequest()) {
  53.             return;
  54.         }
  55.         try {
  56.             $event->getRequest()->attributes->set(self::ATTR_START_TIME, microtime(true));
  57.         } catch (Throwable $e) {
  58.             // no-op: observabilidad no rompe flujo.
  59.         }
  60.     }
  62.     public function onKernelTerminate(TerminateEvent $event): void
  63.     {
  64.         try {
  65.             $request = $event->getRequest();
  66.             $t0 = $request->attributes->get(self::ATTR_START_TIME);
  67.             if (!is_float($t0)) {
  68.                 return;
  69.             }
  70.             $dt = microtime(true) - $t0;
  71.             if ($dt < $this->thresholdSeconds) {
  72.                 return;
  73.             }
  75.             $context = [
  76.                 'route'    => $request->attributes->get('_route'),
  77.                 'method'   => $request->getMethod(),
  78.                 'path'     => $request->getPathInfo(),
  79.                 'user'     => $this->resolveUser(),
  80.                 'dt_ms'    => (int) round($dt * 1000),
  81.                 'status'   => $event->getResponse()->getStatusCode(),
  82.             ];
  84.             $this->observabilityLogger->safeLog('warning', '[OBS-PERF-TRAMITE] slow_request', $context);
  85.         } catch (Throwable $e) {
  86.             // swallow.
  87.         }
  88.     }
  90.     private function resolveUser(): ?string
  91.     {
  92.         try {
  93.             if ($this->tokenStorage === null) {
  94.                 return null;
  95.             }
  96.             $token = $this->tokenStorage->getToken();
  97.             if ($token === null) {
  98.                 return null;
  99.             }
  100.             return method_exists($token, 'getUserIdentifier') ? $token->getUserIdentifier() : (string) $token->getUser();
  101.         } catch (Throwable $e) {
  102.             return null;
  103.         }
  104.     }
  105. }