src/EventListener/ResponseTerminateListener.php line 52

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventListener;
  7. use App\Services\Metrics\MetricsAdapter;
  8. use Symfony\Component\HttpFoundation\Request;
  9. use Symfony\Component\HttpKernel\KernelEvents;
  10. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Throwable;
  14. class ResponseTerminateListener implements EventSubscriberInterface
  15. {
  16.     private const ACTIONS_BLACK_LIST = [
  17.         'GET /metrics',
  18.         'GET /robots.txt',
  19.         'POST /testHtml',
  20.         'GET /openapi/{fileSource}',
  21.         'GET /docs/file/{fileName}',
  22.         'GET /docs/{fileName}',
  23.         'GET /docs/',
  24.         'GET /.git/HEAD',
  25.         'GET /.git/config',
  26.         'GET /_wdt/aff0a1',
  27.         'GET /_wdt/635e7d',
  28.         'GET /_wdt/572ae2',
  29.         'GET /_wdt/2888d3',
  30.         'GET /_wdt/1a67b1',
  31.         'GET /_wdt/08f54a',
  32.     ];
  34.     private const SUPPORTED_METHODS = [
  35.         Request::METHOD_GET,
  36.         Request::METHOD_POST,
  37.         Request::METHOD_PUT,
  38.         Request::METHOD_PATCH,
  39.         Request::METHOD_DELETE,
  40.     ];
  42.     /**
  43.      * @var MetricsAdapter
  44.      */
  45.     private $metricsAdapter;
  47.     public function __construct(MetricsAdapter $metricsAdapter)
  48.     {
  49.         $this->metricsAdapter = $metricsAdapter;
  50.     }
  52.     public function onKernelTerminate(TerminateEvent $event): void
  53.     {
  54.         try {
  55.             $path = rtrim($event->getRequest()->getPathInfo(), '/');
  56.             $method = $event->getRequest()->getMethod();
  57.             $action = $method . ' ' . $path;
  58.             $requestDuration = round((microtime(true) - $_SERVER['REQUEST_TIME_FLOAT']), 2); // in seconds
  60.             if (strlen($action) > 1 && in_array($method, self::SUPPORTED_METHODS) && !in_array($action, self::ACTIONS_BLACK_LIST)) {
  61.                 $this->metricsAdapter->increaseRequestsMetric(['action' => $action, 'status' => $event->getResponse()->getStatusCode()]);
  62.                 $this->metricsAdapter->increaseRequestDurationMetric($requestDuration, ['action' => $action, 'status' => $event->getResponse()->getStatusCode()]);
  63.                 $this->metricsAdapter->setGaugeMetric('apcu_memory_usage', $this->getApcuMemUsage());
  64.             }
  65.         } catch (Throwable $e) {
  66.         }
  67.     }
  69.     public static function getSubscribedEvents(): array
  70.     {
  71.         return [
  72.             KernelEvents::TERMINATE => ['onKernelTerminate', -100],
  73.         ];
  74.     }
  76.     private function getApcuMemUsage(): float
  77.     {
  78.         $mem = apcu_sma_info();
  79.         $memSize = $mem['num_seg'] * $mem['seg_size'];
  80.         $memAvail = $mem['avail_mem'];
  81.         $memUsed = $memSize - $memAvail;
  82.         // in Mb
  83.         for ($i = 0; $i < 2; $i++) {
  84.             $memUsed /= 1024;
  85.         }
  87.         return round($memUsed, 1);
  88.     }
  89. }