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.         private bool $httpLoggingEnabled,
  17.     ) {
  18.     }
  20.     public static function getSubscribedEvents(): array
  21.     {
  22.         return [
  23.             HttpLogEvent::class => 'logHttpEvent',
  24.         ];
  25.     }
  27.     public function logHttpEvent(HttpLogEvent $event): void
  28.     {
  29.         try {
  30.             // must be non-fatal
  31.             $httpLog = $this->buildHttpLog($event);
  32.             // $this->logger->notice(json_encode($httpLog));
  34.             // Local debug: Use one of the following two options
  35.             // $log = json_encode($httpLog);
  36.             // $log = $httpLog->__toString();
  37.             // file_put_contents('/opt/gateway-2/gateway-2/output'.time().'.txt', $log."\n\n", FILE_APPEND | LOCK_EX);
  39.             // TODO: Sanitise sensitive data in http request/response
  40.             // TODO: Restrict to trigger only in booking/cancellation flow
  41.             if ($this->httpLoggingEnabled) {
  42.                 $this->logPublisherService->logHttp($httpLog);
  43.             }
  44.         } catch (\Throwable $e) {
  45.             $this->logger->error('Error when trying to publish logs: '.$e->getMessage());
  46.         }
  47.     }
  49.     private function buildHttpLog(HttpLogEvent $event): HttpLog
  50.     {
  51.         $request = $event->getRequest();
  52.         $response = $event->getResponse();
  54.         $uri = $request->getUri();
  55.         $statusCode = $response->getStatusCode();
  56.         $dateTime = date('c', time());
  58.         return new HttpLog(
  59.             url: $uri,
  60.             request: $request,
  61.             response: $response,
  62.             status: $statusCode,
  63.             dateTime: $dateTime,
  64.         );
  65.     }
  66. }