src/EventListener/LogPublisherSubscriber.php line 26

  1. <?php
  3. namespace App\EventListener;
  5. use App\Event\HttpLogEvent;
  6. use App\Service\LogPublisher\Domain\HttpLog;
  7. use App\Service\LogPublisher\LogPublisherServiceInterface;
  8. use Psr\Log\LoggerInterface;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class LogPublisherSubscriber implements EventSubscriberInterface
  12. {
  13.     public function __construct(
  14.         private LoggerInterface $logger,
  15.         private LogPublisherServiceInterface $logPublisherService,
  16.     ) {
  17.     }
  19.     public static function getSubscribedEvents(): array
  20.     {
  21.         return [
  22.             HttpLogEvent::class => 'logHttpEvent',
  23.         ];
  24.     }
  26.     public function logHttpEvent(HttpLogEvent $event): void
  27.     {
  28.         try {
  29.             // must be non-fatal
  30.             $httpLog = $this->buildHttpLog($event);
  31.             // $this->logger->notice(json_encode($httpLog));
  33.             // Use one of the following two options
  34.             // $log = json_encode($httpLog);
  35.             // $log = $httpLog->__toString();
  36.             // file_put_contents('/opt/gateway-2/gateway-2/output'.time().'.txt', $log."\n\n", FILE_APPEND | LOCK_EX);
  38.             $this->logPublisherService->logHttp($httpLog);
  39.         } catch (\Throwable $e) {
  40.             $this->logger->error('Error when trying to publish logs: '.$e->getMessage());
  41.         }
  42.     }
  44.     private function buildHttpLog(HttpLogEvent $event): HttpLog
  45.     {
  46.         $request = $event->getRequest();
  47.         $response = $event->getResponse();
  49.         $uri = $request->getUri();
  50.         $statusCode = $response->getStatusCode();
  51.         $dateTime = date('c', time());
  53.         return new HttpLog(
  54.             url: $uri,
  55.             request: $request,
  56.             response: $response,
  57.             status: $statusCode,
  58.             dateTime: $dateTime,
  59.         );
  60.     }
  61. }