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. }