src/Subscriber/HttpClientSubscriber.php line 82

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Subscriber;
  7. use App\Event\HttpClient\Events;
  8. use App\Event\HttpClient\HttpClientRequestEvent;
  9. use App\Event\HttpClient\HttpClientResponseEvent;
  10. use App\Payment\Provider\Basys\BasysClient;
  11. use App\Service\Graph\ContainerTraversablePathAccess;
  12. use Psr\Log\LoggerInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class HttpClientSubscriber implements EventSubscriberInterface
  16. {
  17.     const HTTP_ERROR_CODES_REGEX = '/(^5\\d{2}$)|(^4\\d{2}$)/';
  19.     private LoggerInterface $logger;
  21.     public function __construct(LoggerInterface $restLogger)
  22.     {
  23.         $this->logger = $restLogger;
  24.     }
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             Events::HTTP_CALL_OUTGOING => 'onRequest',
  30.             Events::HTTP_CALL_INCOMING => 'onResponse',
  31.         ];
  32.     }
  34.     public function onRequest(HttpClientRequestEvent $requestEvent)
  35.     {
  36.         $request = $requestEvent->getRequest();
  38.         $data = $this->getMaskedBody($requestEvent);
  40.         $this->logger->info(\sprintf('[HTTP: REQUEST] [%s] %s %s with query parameters %s and body %s and headers %s',
  41.             $requestEvent->getRequestIdentifier(),
  42.             $requestEvent->getMethod(),
  43.             $request->getUrl(),
  44.             \http_build_query($request->getParameters() ?? []),
  45.             \is_array($data) ? \json_encode($data) : $data,
  46.             \json_encode($request->getHeaders())
  47.         ));
  48.     }
  50.     private function getMaskedBody(HttpClientRequestEvent $requestEvent)
  51.     {
  52.         if ($requestEvent->getContext() == BasysClient::PROVIDER_NAME) {
  53.             $data = $requestEvent->getRequest()->getBody();
  55.             if (empty($data)) {
  56.                 return $data;
  57.             }
  59.             $containerTraversablePathAccess = new ContainerTraversablePathAccess(
  60.                 is_array($data) ? $data : json_decode($data, true)
  61.                 , false);
  63.             if (
  64.                 $containerTraversablePathAccess->getByPath('payment_method.card.cvc', false) !== false
  65.                 || $containerTraversablePathAccess->getByPath('payment_method.card.expiration_date', false) !== false
  66.                 || $containerTraversablePathAccess->getByPath('payment_method.card.number', false) !== false
  67.             ) {
  68.                 $data = is_array($data) ? $data : json_decode($data, true);
  70.                 $data['payment_method']['card']['number'] = '***HIDE*FOR*LOGS***';
  71.                 $data['payment_method']['card']['cvc'] = '***HIDE*FOR*LOGS***';
  72.                 $data['payment_method']['card']['expiration_date'] = '***HIDE*FOR*LOGS***';
  73.             }
  75.             return $data;
  76.         }
  78.         return $requestEvent->getRequest()->getBody();
  79.     }
  82.     public function onResponse(HttpClientResponseEvent $responseEvent)
  83.     {
  84.         $response = $responseEvent->getResponse();
  86.         if (preg_match(self::HTTP_ERROR_CODES_REGEX, (string)$response->getStatusCode())) {
  87.             $this->logger->error(\sprintf('[HTTP: RESPONSE] [%s] Response with status code \'%s\' and body \'%s\'',
  88.                 $responseEvent->getRequestIdentifier(),
  89.                 $response->getStatusCode(),
  90.                 $response->getRawBody()
  91.             ));
  92.         } else {
  93.             $this->logger->info(\sprintf('[HTTP: RESPONSE] [%s] Response with status code \'%s\' and body \'%s\'',
  94.                 $responseEvent->getRequestIdentifier(),
  95.                 $response->getStatusCode(),
  96.                 $response->getRawBody()
  97.             ));
  98.         }
  99.     }
  100. }