vendor/suez/webservice-collection-bundle/src/WebServiceCollectionBundle/Subscriber/ParseResponseSubscriber.php line 68

Open in your IDE?
  1. <?php
  3. namespace WebServiceCollectionBundle\Subscriber;
  5. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  6. use WebServiceCollectionBundle\Event\WebserviceRequestEvent;
  7. use WebServiceCollectionBundle\Logger\WebServiceLogger;
  8. use WebServiceCollectionBundle\Manager\ResponseParser;
  9. use WebServiceCollectionBundle\Request\SoapRequest;
  10. use WebServiceCollectionBundle\WebserviceEvents;
  12. /**
  13.  * Class ParserSubscriber.
  14.  *
  15.  * @author Christophe Pyree <chpyr@smile.fr>
  16.  */
  17. class ParseResponseSubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var WebServiceLogger
  21.      */
  22.     private $webServiceLogger;
  23.     /**
  24.      * @var ResponseParser
  25.      */
  26.     private $parserManager;
  28.     /**
  29.      * ParseResponseSubscriber constructor.
  30.      *
  31.      * @param ResponseParser   $parserManager
  32.      * @param WebServiceLogger $webServiceLogger
  33.      */
  34.     public function __construct(ResponseParser $parserManager, WebServiceLogger $webServiceLogger)
  35.     {
  36.         $this->parserManager = $parserManager;
  37.         $this->webServiceLogger = $webServiceLogger;
  38.     }
  40.     /**
  41.      * @return array
  42.      */
  43.     public static function getSubscribedEvents()
  44.     {
  45.         return [
  46.             WebserviceEvents::REQUEST_NORMALIZE => ['normalizeOnPostSend', 1024],
  47.         ];
  48.     }
  50.     private $webServiceResponseClassMap = [];
  52.     /**
  53.      * @param $serviceClass
  54.      * @param $info
  55.      *
  56.      * @return $this
  57.      */
  58.     public function addMappingInfo($serviceClass, $info)
  59.     {
  60.         $this->webServiceResponseClassMap[$serviceClass] = $info;
  62.         return $this;
  63.     }
  65.     /**
  66.      * @param WebserviceRequestEvent $webserviceEvent
  67.      */
  68.     public function normalizeOnPostSend(WebserviceRequestEvent $webserviceEvent)
  69.     {
  70.         $context = [];
  71.         $context['request'] = $webserviceEvent->getRequest();
  72.         $context['operation'] = $webserviceEvent->getRequest()->getUrl();
  73. //        $this->webServiceLogger->info(sprintf('%s postsend', $webserviceEvent->getRequest()->getRequesterClass()));
  75.         $targetClass = $this->classMap(
  76.             $webserviceEvent->getRequest()->getRequesterClass(),
  77.             $webserviceEvent->getRequest()->getUrl()
  78.         );
  80.         if (!$targetClass) {
  81.             $this->webServiceLogger->info(
  82.                 sprintf('Target class for parsing \'%s\' is not specified from Request object', $webserviceEvent->getRequest()->getRequesterClass()),
  83.                 [$webserviceEvent->getRequest()]
  84.             );
  86.             return;
  87.         }
  89.         $format = $this->getFormat($webserviceEvent);
  91.         $responseInterfaceObject = $this->parserManager->parse($webserviceEvent->getRawResponse(), $targetClass, $format, $context);
  92.         $webserviceEvent->setParsedResponse($responseInterfaceObject);
  93.     }
  95.     /**
  96.      * @param WebserviceRequestEvent $webserviceEvent
  97.      *
  98.      * @return string
  99.      */
  100.     protected function getFormat(WebserviceRequestEvent $webserviceEvent)
  101.     {
  102.         $format = 'json';
  104.         if ($webserviceEvent->getRequest() instanceof SoapRequest) {
  105.             $format = 'soap';
  106.         }
  108.         return $format;
  109.     }
  111.     /**
  112.      * @param $requesterClass
  113.      * @param null $urlOrOperation
  114.      *
  115.      * @return mixed|string
  116.      */
  117.     private function classMap($requesterClass, $urlOrOperation = null)
  118.     {
  119.         if (!isset($this->webServiceResponseClassMap[$requesterClass])) {
  120.             return '';
  121.         }
  123.         $responseClass = (array) $this->webServiceResponseClassMap[$requesterClass];
  125.         if ($urlOrOperation && \is_array($responseClass) && isset($responseClass[$urlOrOperation])) {
  126.             return $responseClass[$urlOrOperation];
  127.         }
  129.         return array_shift($responseClass);
  130.     }
  132.     /**
  133.      * @param $object
  134.      *
  135.      * @return string
  136.      */
  137.     public function getBuildType($object)
  138.     {
  139.         if (\is_array($object)) {
  140.             return 'array';
  141.         }
  143.         if (\is_object($object)) {
  144.             return \get_class($object);
  145.         }
  146.     }
  147. }