src/EventSubscriber/LoggerSubscriber.php line 70

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use Psr\Log\LoggerInterface;
  6. use Symfony\Component\Console\ConsoleEvents;
  7. use Symfony\Component\HttpKernel\KernelEvents;
  8. use Symfony\Component\HttpKernel\Event\RequestEvent;
  9. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  10. use Symfony\Component\HttpKernel\Event\ExceptionEvent;
  11. use Symfony\Component\Console\Event\ConsoleCommandEvent;
  12. use Symfony\Component\Console\Event\ConsoleErrorEvent;
  13. use Symfony\Component\Console\Event\ConsoleTerminateEvent;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\HttpFoundation\JsonResponse;
  16. use App\Utils\Logging\Logger\CustomJsonFormatter as Formatter;
  18. class LoggerSubscriber implements EventSubscriberInterface
  19. {
  20.     public const SHORT_MESSAGE_CORE_API_RESPONSE = 'CORE API RESPONSE';
  21.     public const SHORT_MESSAGE_CORE_API_REQUEST = 'CORE API INPUT';
  22.     public const SHORT_MESSAGE_CORE_API_ERROR = 'CORE API ERROR';
  24.     public const DIRECTION_CORE_O = 'CORE-O';
  25.     public const DIRECTION_CORE_I = 'CORE-I';
  27.     private $logger;
  28.     private $isExitWithError;
  30.     public function __construct(LoggerInterface $logger)
  31.     {
  32.         $this->logger = $logger;
  33.         $this->isExitWithError = false;
  34.     }
  36.     public function onConsoleError(ConsoleErrorEvent $event): void
  37.     {
  38.         if (!$event->getError()) {
  39.             return;
  40.         }
  41.         $command = $event->getCommand();
  42.         $this->isExitWithError = true;
  43.         $this->logger->error(sprintf('Command: %s execution error: %s', $command ? $command->getName() : 'null', $event->getError()->getMessage()), [
  44.             Formatter::MSG_SUBJECT => $event->getError(),
  45.             Formatter::TYPE => Formatter::TYPE_COMMAND,
  46.         ]);
  47.     }
  49.     public function onConsoleTerminate(ConsoleTerminateEvent $event): void
  50.     {
  51.         if ($this->isExitWithError) {
  52.             return;
  53.         }
  54.         $command = $event->getCommand();
  55.         $this->logger->info('Command end: ' . ($command ? $command->getName() : 'null'), [
  56.             Formatter::MSG_SUBJECT => ['EXIT_CODE' => $event->getExitCode()],
  57.             Formatter::TYPE => Formatter::TYPE_COMMAND,
  58.         ]);
  59.     }
  61.     public function onCommand(ConsoleCommandEvent $event): void
  62.     {
  63.         $command = $event->getCommand();
  64.         $this->logger->info('Command start: ' . ($command ? $command->getName() : 'null'), [
  65.             Formatter::MSG_SUBJECT => $event->getInput()->getArguments(),
  66.             Formatter::TYPE => Formatter::TYPE_COMMAND,
  67.         ]);
  68.     }
  70.     public function onKernelRequest(RequestEvent $event): void
  71.     {
  72.         if ($this->isExitWithError) {
  73.             return;
  74.         }
  75.         $this->logger->info(self::SHORT_MESSAGE_CORE_API_REQUEST, [
  76.             Formatter::MSG_SUBJECT => $event->getRequest(),
  77.             Formatter::MSG_DIRECTION => self::DIRECTION_CORE_I,
  78.             Formatter::TYPE => Formatter::TYPE_REQUEST,
  79.         ]);
  80.     }
  82.     public function onKernelResponse(ResponseEvent $event): void
  83.     {
  84.         if ($this->isExitWithError) {
  85.             return;
  86.         }
  87.         if ($event->getResponse() instanceof JsonResponse) {
  88.             $this->logger->info(self::SHORT_MESSAGE_CORE_API_RESPONSE, [
  89.                 Formatter::MSG_SUBJECT => json_decode($event->getResponse()->getContent() ?? '', true),
  90.                 Formatter::MSG_STATUS_CODE => $event->getResponse()->getStatusCode(),
  91.                 Formatter::MSG_DIRECTION => self::DIRECTION_CORE_O,
  92.                 Formatter::TYPE => Formatter::TYPE_RESPONSE,
  93.             ]);
  95.             return;
  96.         }
  97.         $this->logger->info(self::SHORT_MESSAGE_CORE_API_RESPONSE, [
  98.             Formatter::MSG_SUBJECT => $event->getResponse()->getContent(),
  99.             Formatter::MSG_STATUS_CODE => $event->getResponse()->getStatusCode(),
  100.             Formatter::MSG_DIRECTION => self::DIRECTION_CORE_O,
  101.             Formatter::TYPE => Formatter::TYPE_RESPONSE,
  102.         ]);
  103.     }
  105.     public function onKernelException(ExceptionEvent $event): void
  106.     {
  107.         $this->isExitWithError = true;
  108.         $this->logger->error(self::SHORT_MESSAGE_CORE_API_ERROR, [
  109.             Formatter::MSG_SUBJECT => $event->getThrowable(),
  110.             Formatter::TYPE => Formatter::TYPE_RESPONSE,
  111.         ]);
  112.     }
  114.     public static function getSubscribedEvents(): array
  115.     {
  116.         return [
  117.             KernelEvents::REQUEST => ['onKernelRequest', 7],
  118.             KernelEvents::RESPONSE => ['onKernelResponse', 1],
  119.             KernelEvents::EXCEPTION => 'onKernelException',
  120.             ConsoleEvents::ERROR => 'onConsoleError',
  121.             ConsoleEvents::TERMINATE => 'onConsoleTerminate',
  122.             ConsoleEvents::COMMAND => 'onCommand',
  123.         ];
  124.     }
  125. }