src/WsProxy/Subscriber/SoapClientEventLogSubscriber.php line 76

Open in your IDE?
  1. <?php
  3. namespace App\WsProxy\Subscriber;
  5. use App\Ws\SoapClient\Transport;
  6. use Phpro\SoapClient\Event\FaultEvent;
  7. use Phpro\SoapClient\Event\RequestEvent;
  8. use Phpro\SoapClient\Event\ResponseEvent;
  9. use Psr\Log\LoggerInterface;
  10. use Soap\ExtSoapEngine\Transport\TraceableTransport;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Phpro\SoapClient\Event;
  14. class SoapClientEventLogSubscriber implements EventSubscriberInterface
  15. {
  16.     private LoggerInterface $soapLogger;
  18.     private array $methods = ['AddBillItem', 'AddItem','AddOrModifyTicket', 'AddTicket', 'BasketMarketingAgreements', 'BasketOnLinePayment', 'BatchVoucherLock',
  19.         'CalculateOrderByPromotion', 'CalculatePriceByVoucher', 'CancelBasket', 'CancelReservation', 'CancelReservationByToken',
  20.         'CloseBasket', 'CloseBill', 'DeleteBasketItem', 'LockPlaces', 'LockPlacesExt', 'LockSeatExt',
  21.         'LockSeatList', 'MarkAsFiscalized', 'ModifyTicket', 'OpenBasket', 'OpenBill', 'SavePaymentProcesStatus', 'SetBasketPayment', 'UpdateBasketClient',
  22.         'UpdateClientReservation', 'UpdateTicketInfo', 'UpdateTicketInfoRaw', 'UpdateTicketList', 'UseExternalPayment', 'UseInternalPaymentCard', 'UsePaymentProvider',
  23.         'RegisterAccount', 'RefundTransaction', 'CanBeRefunded'
  24.     ];
  26.     protected Transport $transport;
  28.     public function __construct(LoggerInterface $soapLogger)
  29.     {
  30.         $this->transport = new Transport();
  31.         $this->soapLogger = $soapLogger;
  32.     }
  34.     /**
  35.      * {@inheritdoc}
  36.      */
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             //RequestEvent::class => 'onClientRequest',
  41.             ResponseEvent::class => 'onClientResponse',
  42.             FaultEvent::class => 'onClientFault'
  43.         ];
  44.     }
  46.     public function onClientRequest(Event\RequestEvent $event)
  47.     {
  48.         if ($this->isMethodToLog($event->getMethod())) {
  49.             $debug = $event->getRequest();//$event->getClient()->debugLastSoapRequest();
  51.             $this->soapLogger->error(sprintf(
  52.                 '[phpro/soap-client] Request for method "%s" with data %s',
  53.                 $event->getMethod(),
  54.                 print_r($debug, true)
  55.             ));
  56.         }
  57.     }
  59.     public function onClientResponse(Event\ResponseEvent $event)
  60.     {
  61.         if ($this->isMethodToLog($event->getRequestEvent()->getMethod())) {
  63.             $debug = $this->createDebug($event);
  65.             $this->soapLogger->info(sprintf(
  66.                 'Method "%s" with [REQUEST HEADERS] : %s, [REQUEST BODY] : %s, [RESPONSE HEADERS] %s, [RESPONSE BODY] %s',
  67.                 $event->getRequestEvent()->getMethod(),
  68.                 print_r($debug['requestHeaders'],true),
  69.                 print_r($debug['requestBody'],true),
  70.                 print_r($debug['responseHeaders'],true),
  71.                 print_r($debug['responseBody'],true),
  72.             ));
  73.         }
  74.     }
  76.     public function onClientFault(Event\FaultEvent $event)
  77.     {
  78.         $debug = $this->createDebug($event);
  80.         $this->soapLogger->error(sprintf(
  81.             '[phpro/soap-client] fault "%s" for request "%s" with data %s',
  82.             $event->getSoapException()->getMessage(),
  83.             $event->getRequestEvent()->getMethod(),
  84.             print_r($debug, true)
  85.         ));
  86.     }
  88.     public function getSubscribedMethods(): array
  89.     {
  90.         return $this->methods;
  91.     }
  93.     private function isMethodToLog(string $method): bool
  94.     {
  95.         return in_array($method, $this->methods);
  96.     }
  98.     public function setTransport(string $factoryClass, TraceableTransport $transport): SoapClientEventLogSubscriber
  99.     {
  100.         $this->transport->setTransport($this->transport->getClient($factoryClass), $transport);
  101.         return $this;
  102.     }
  104.     public function createDebug($event): array
  105.     {
  106.         $transport = $this->transport->getTransport($this->transport->getClient(get_class($event->getRequestEvent()->getRequest())));
  107.         $debug = [];
  109.         if($transport instanceof TraceableTransport) {
  110.             $lastRequestCollection = $transport->collectLastRequestInfo();
  111.             $debug['requestBody'] = $lastRequestCollection->getLastRequest();
  112.             $debug['requestHeaders'] = $lastRequestCollection->getLastRequestHeaders();
  113.             $debug['responseBody'] = $lastRequestCollection->getLastResponse();
  114.             $debug['responseHeaders'] = $lastRequestCollection->getLastResponseHeaders();
  115.         }
  117.         return $debug;
  118.     }
  119. }