src/Listener/Logger/PaymentWebhookRequestAndResponseLogEventListener.php line 49

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  5. namespace App\Listener\Logger;
  8. use App\Payment\PaymentFactory;
  9. use App\Payment\Provider\HyperPay\HyperPayClient;
  10. use App\Service\Payment\PaymentProviderService;
  11. use Psr\Log\LoggerInterface;
  12. use Symfony\Component\HttpFoundation\Request;
  13. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  15. class PaymentWebhookRequestAndResponseLogEventListener
  16. {
  17.     const ROUTES = [
  18.       '/webhook/payment/status'
  19.     ];
  21.     const HTTP_ERROR_CODES_REGEX = '/(^5\\d{2}$)|(^4\\d{2}$)/';
  23.     /**
  24.      * @var LoggerInterface
  25.      */
  26.     private $logger;
  28.     /**
  29.      * @var PaymentFactory
  30.      */
  31.     private $paymentFactory;
  33.     /**
  34.      * @var PaymentProviderService
  35.      */
  36.     private $paymentProviderService;
  38.     public function __construct(
  39.        LoggerInterface $logger,
  40.        PaymentFactory $paymentFactory,
  41.        PaymentProviderService $paymentProviderService
  42.     )
  43.     {
  44.         $this->logger = $logger;
  45.         $this->paymentFactory = $paymentFactory;
  46.         $this->paymentProviderService = $paymentProviderService;
  47.     }
  49.     public function onKernelTerminate(TerminateEvent $event)
  50.     {
  51.         $request = $event->getRequest();
  52.         $response = $event->getResponse();
  54.         if ($this->checkIfRouteMatchesConfig($request->getRequestUri())) {
  55.             if (preg_match(self::HTTP_ERROR_CODES_REGEX, (string)$response->getStatusCode())) {
  56.                 $this->logger->error('data', [
  57.                     'route' => $request->getMethod() . ' ' . $request->getRequestUri(),
  58.                     'status' => $response->getStatusCode(),
  59.                     'request_body' => $request->request->all(),
  60.                     'request_body_decoded' => $this->decodeRequestBody($request),
  61.                     'response' => json_decode($response->getContent(), true),
  62.                     'headers' => $request->headers->all(),
  63.                     'raw_request' => $request->getContent(),
  64.                     'raw_response' => $response->getContent()
  65.                 ]);
  66.             } else {
  67.                 $this->logger->info('data', [
  68.                     'route' => $request->getMethod() . ' ' . $request->getRequestUri(),
  69.                     'status' => $response->getStatusCode(),
  70.                     'request_body' => $request->request->all(),
  71.                     'request_body_decoded' => $this->decodeRequestBody($request),
  72.                     'response' => json_decode($response->getContent(), true),
  73.                     'headers' => $request->headers->all(),
  74.                     'raw_request' => $request->getContent(),
  75.                     'raw_response' => $response->getContent()
  76.                 ]);
  77.             }
  78.         }
  79.     }
  81.     private function checkIfRouteMatchesConfig(string $originRoute): bool
  82.     {
  83.         foreach (self::ROUTES as $route) {
  84.             if (strpos($originRoute, $route) !== false) {
  85.                 return true;
  86.             }
  87.         }
  88.         return false;
  89.     }
  91.     private function decodeRequestBody(Request $request): string
  92.     {
  93.         $decodedRequestBody = '{}';
  95.         switch (true) {
  96.             case (strpos($request->getRequestUri(), 'hyperpay') !== false):
  97.                 /**
  98.                  * @var HyperPayClient $client
  99.                  */
  100.                 $client = $this->paymentFactory->get(
  101.                     $this->paymentProviderService->getPaymentProviderServiceIdentifier('hyperpay')
  102.                 );
  104.                 $decodedRequestBody = json_encode($client->encodeRequest($request));
  105.                 break;
  106.         }
  108.         return $decodedRequestBody;
  109.     }
  110. }