src/EventListener/KernelOnTerminateListener.php line 58

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  6. use App\Service\LoggerConfigurationService;
  7. use App\WsProxy\Subscriber\SoapCallCollectorSubscriber;
  8. use Psr\Log\LoggerInterface;
  9. use Symfony\Component\HttpFoundation\Request;
  10. use Symfony\Component\HttpFoundation\Response;
  11. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  13. class KernelOnTerminateListener
  14. {
  15.     private LoggerConfigurationService $loggerConfigurationService;
  16.     private LoggerInterface $logger;
  17.     private LoggerInterface $metricsLogger;
  18.     private SoapCallCollectorSubscriber $soapCollector;
  20.     public function __construct(
  21.         LoggerConfigurationService $loggerConfigurationService,
  22.         LoggerInterface            $lsiGlobalLogger,
  23.         LoggerInterface            $metricsLogger,
  24.         SoapCallCollectorSubscriber $soapCollector
  25.     )
  26.     {
  27.         $this->loggerConfigurationService = $loggerConfigurationService;
  28.         $this->logger = $lsiGlobalLogger;
  29.         $this->metricsLogger = $metricsLogger;
  30.         $this->soapCollector = $soapCollector;
  31.     }
  33.     private function getRequestArray(Request $request): array
  34.     {
  35.         return [
  36.             'attributes' => $request->attributes->all(),
  37.             'request' => $request->request->all(),
  38.             'query' => $request->query->all(),
  39.             'server' => $request->server->all(),
  40.             'cookies' => $request->cookies->all(),
  41.             'headers' => $request->headers->all(),
  42.             'content' => $request->getContent(),
  43.             'pathInfo' => $request->getPathInfo(),
  44.             'getRequestUri' => $request->getRequestUri(),
  45.             'method' => $request->getMethod()
  46.         ];
  47.     }
  49.     private function getResponseArray(Response $response): array
  50.     {
  51.         return [
  52.             'headers' => $response->headers->all(),
  53.             'content' => $response->getContent(),
  54.             'statusCode' => $response->getStatusCode()
  55.         ];
  56.     }
  58.     public function onTerminateEvent(TerminateEvent $event): void
  59.     {
  60.         $this->logMetrics($event);
  61.         $this->logRequests($event);
  62.     }
  64.     private function logRequests(TerminateEvent $event): void
  65.     {
  66.         if (!$this->loggerConfigurationService->isEnabled('request_logger')) {
  67.             return;
  68.         }
  70.         $request = $event->getRequest();
  72.         $routePath = $request->getPathInfo();
  73.         $routeName = $request->get('_route');
  75.         if ($this->loggerConfigurationService->isRoutePathEnabled($routePath, 'request_logger')
  76.             || $this->loggerConfigurationService->isRouteNameEnabled($routeName, 'request_logger')) {
  77.             $requestArray = $this->getRequestArray($event->getRequest());
  78.             $responseArray = $this->getResponseArray($event->getResponse());
  80.             $this->logger->debug('Request', $requestArray);
  81.             $this->logger->debug('Response', $responseArray);
  82.         }
  83.     }
  85.     private function logMetrics(TerminateEvent $event): void
  86.     {
  87.         if (!$this->loggerConfigurationService->isEnabled('metrics_logger')) {
  88.             return;
  89.         }
  91.         $request = $event->getRequest();
  92.         $routePath = $request->getPathInfo();
  94.         if ($this->loggerConfigurationService->isRoutePathEnabled($routePath, 'metrics_logger')) {
  95.             $reqMicroSecond = (int)($request->server->get('REQUEST_TIME_FLOAT')*1000);
  96.             $resMicroSecond = (int)(microtime(true)*1000);
  98.             $arMetrics = [
  99.                 'uri' => $request->getPathInfo(),
  100.                 'method' => $request->getMethod(),
  101.                 'controller' => $request->get('_route'),
  102.                 'req' => $reqMicroSecond,
  103.                 'res' => $resMicroSecond,
  104.                 'dur' => $resMicroSecond - $reqMicroSecond,
  105.                 'soap' => [
  106.                     'calls' => [],
  107.                     'total_req' => 0,
  108.                     'total_time' => 0
  109.                 ]
  110.             ];
  112.             if($this->soapCollector->getCalls() !== []) {
  113.                 $arMetrics['soap']['total_req'] = count($this->soapCollector->getCalls());
  114.                 $arMetrics['soap']['total_time'] = (int)$this->soapCollector->getTotalTiming();
  115.                 foreach ($this->soapCollector->getCalls() as $call) {
  116.                     $arMetrics['soap']['calls'][] = [
  117.                         'method' => $call->getMethod(),
  118.                         'dur' => (int)$call->getTiming()
  119.                     ];
  120.                 }
  121.             }
  123.             $this->metricsLogger->debug('', $arMetrics);
  124.         }
  125.     }
  126. }