src/ApiBundle/EventListeners/KernelListener.php line 42

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /*
  6.  * This file is part of the SynergyBot project.
  7.  *
  8.  * For the full copyright and license information,
  9.  * please read the LICENSE.md file that was distributed with this source code.
  10.  *
  11.  * The SymfonyBot project - inspiring people to chat!
  12.  *
  13.  * Copyright (c) 2022.
  14.  */
  16. namespace App\ApiBundle\EventListeners;
  18. use App\ApiBundle\Exception\ApiException;
  19. use App\ApiBundle\Response\ApiResponse;
  20. use App\ClickHouseBundle\Services\ClickHouseService;
  21. use App\CoreBundle\Util\Rand;
  22. use Psr\Log\LoggerAwareInterface;
  23. use Psr\Log\LoggerAwareTrait;
  24. use Symfony\Component\HttpFoundation\Response;
  25. use Symfony\Component\HttpKernel\Event\ExceptionEvent;
  26. use Symfony\Component\HttpKernel\Event\RequestEvent;
  27. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  29. class KernelListener implements LoggerAwareInterface
  30. {
  31.     use LoggerAwareTrait;
  32.     protected bool $isApiClient = false;
  33.     protected bool $isApiPartner = false;
  34.     protected bool $isApi = false;
  35.     protected ?\Throwable $exception = null;
  37.     public function __construct(
  38.         private readonly ClickHouseService $clickhouse)
  39.     {
  40.     }
  42.     public function onKernelRequest(RequestEvent $event)
  43.     {
  44.         $request = $event->getRequest();
  45.         $route = $request->get('_route');
  47.         $this->isApiClient = null !== $route && (false !== mb_stripos((string) $route, 'api_client'));
  48.         $this->isApiPartner = null !== $route && (false !== mb_stripos((string) $route, 'api_partner'));
  49.         $this->isApi = $this->isApiClient || $this->isApiPartner;
  51.         if (!$this->isApi) {
  52.             return;
  53.         }
  55.         $request->request->add([
  56.             '_request_id' => Rand::getRandomSHA1(),
  57.         ]);
  58.     }
  60.     public function onKernelResponse(ResponseEvent $event)
  61.     {
  62.         if (!$this->isApi) {
  63.             return;
  64.         }
  66.         $request = $event->getRequest();
  67.         $requestId = $request->request->get('_request_id');
  68.         $request->request->remove('_request_id');
  70.         $requestParams = implode(\PHP_EOL, [
  71.             'GET: '.http_build_query($request->query->all()),
  72.             'POST: '.http_build_query($request->request->all()),
  73.             'DATA: '.$request->getContent(),
  74.         ]);
  76.         $response = $event->getResponse();
  77.         $currentAt = new \DateTime();
  78.         $exceptionText = $this->exception ? $this->exception->__toString() : '';
  79.         $tableName = $this->isApiClient ? 'client_api_logs' : 'partner_api_logs';
  81.         $this->clickhouse->insert($tableName, [
  82.             [
  83.                 $requestId,
  84.                 $requestId,
  85.                 $currentAt->format('Y-m-d'),
  86.                 $currentAt->format('Y-m-d H:i:s'),
  87.                 $request->getClientIp(),
  88.                 $request->getUri(),
  89.                 $request->getMethod(),
  90.                 $response->getStatusCode(),
  91.                 $requestParams,
  92.                 $response->getContent() ?: '',
  93.                 $exceptionText,
  94.             ],
  95.         ], [
  96.             'request_id',
  97.             'queue_id',
  98.             'created_date',
  99.             'created_at',
  100.             'ip_addr',
  101.             'uri',
  102.             'method',
  103.             'status',
  104.             'request',
  105.             'response',
  106.             'exception',
  107.         ]);
  109.         $event->getResponse()->setStatusCode(200);
  110.     }
  112.     public function onKernelException(ExceptionEvent $event)
  113.     {
  114.         if (!$this->isApi) {
  115.             return;
  116.         }
  118.         $this->exception = $event->getThrowable();
  120.         $status = 0;
  121.         $message = 'Try again later.';
  122.         $httpCode = Response::HTTP_INTERNAL_SERVER_ERROR;
  124.         if ($this->exception instanceof ApiException) {
  125.             $status = $this->exception->getCode();
  126.             $message = $this->exception->getMessage();
  127.             $httpCode = $this->exception->getStatusCode();
  129.             $this->logger->notice(
  130.                 'Api exception',
  131.                 [
  132.                     'code' => $status,
  133.                     'message' => $message,
  134.                     'http_code' => $httpCode,
  135.                     'exception' => $this->exception,
  136.                 ]
  137.             );
  138.         } else {
  139.             $this->logger->critical(
  140.                 'Kernel exception',
  141.                 [
  142.                     'code' => $this->exception->getCode(),
  143.                     'message' => $this->exception->getMessage(),
  144.                     'http_code' => $httpCode,
  145.                     'exception' => $this->exception,
  146.                 ]
  147.             );
  148.         }
  150.         $event->setResponse(new ApiResponse(
  151.             ['success' => false],
  152.             [
  153.                 'code' => $status,
  154.                 'message' => $message,
  155.             ],
  156.             $httpCode
  157.         ));
  158.         $event->getResponse()->setStatusCode($httpCode);
  159.     }
  160. }