vendor/suez/webservice-collection-bundle/src/WebServiceCollectionBundle/Subscriber/CacheSubscriber.php line 87

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\CacheManager;
  9. use WebServiceCollectionBundle\Model\ResponseInterface;
  10. use WebServiceCollectionBundle\WebserviceEvents;
  12. /**
  13.  * Class CacheManager.
  14.  *
  15.  * @author Christophe Pyree <chpyr@smile.fr>
  16.  */
  17. class CacheSubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var WebServiceLogger
  21.      */
  22.     private $webServiceLogger;
  23.     /**
  24.      * @var CacheManager
  25.      */
  26.     private $cacheManager;
  28.     /**
  29.      * CacheSubscriber constructor.
  30.      *
  31.      * @param CacheManager     $cacheManager
  32.      * @param WebServiceLogger $webServiceLogger
  33.      */
  34.     public function __construct(CacheManager $cacheManager, WebServiceLogger $webServiceLogger)
  35.     {
  36.         $this->webServiceLogger = $webServiceLogger;
  37.         $this->cacheManager = $cacheManager;
  38.     }
  40.     /**
  41.      * {@inheritdoc}
  42.      *
  43.      * @return array
  44.      */
  45.     public static function getSubscribedEvents()
  46.     {
  47.         return [
  48.             WebserviceEvents::REQUEST_PRE_SEND => [
  49.                 ['getCacheIfExistOnPreSend', 1024],
  50.             ],
  51.             WebserviceEvents::REQUEST_POST_SEND => [
  52.                 ['setCacheOnPostSend', -1024],
  53.             ],
  54.         ];
  55.     }
  57.     /**
  58.      * @param WebserviceRequestEvent $webserviceEvent
  59.      *
  60.      * @throws \Psr\SimpleCache\InvalidArgumentException
  61.      */
  62.     public function getCacheIfExistOnPreSend(WebserviceRequestEvent $webserviceEvent)
  63.     {
  64.         $engine = $this->cacheManager->getEngine();
  66.         //Cache is not allowed
  67.         if (!$engine || !$this->cacheManager->isCachable($webserviceEvent->getRequest())) {
  68.             //            $this->webServiceLogger->debug(sprintf('%s can\'t be found in cache because it\'s not allowed by bundle config ', $webserviceEvent->getRequest()->getUrl()), [$webserviceEvent->getRequest()->getRequesterClass()]);
  69.             return;
  70.         }
  72.         $hashKey = $webserviceEvent->getRequest()->getHashKey();
  73.         if ($parsedCachedResult = $engine->get($hashKey)) {
  74.             $webserviceEvent->setParsedResponse($parsedCachedResult);
  75.             $webserviceEvent->setCachedResponse(true);
  76.             $this->webServiceLogger->info(sprintf('%s response has retrieved from CACHE', $webserviceEvent->getRequest()->getRequesterClass()));
  77.         }
  78.     }
  80.     /**
  81.      * Mise en cache de la réponse si la configuration du service l'autorise.
  82.      *
  83.      * @param WebserviceRequestEvent $webserviceEvent
  84.      *
  85.      * @throws \Psr\SimpleCache\InvalidArgumentException
  86.      */
  87.     public function setCacheOnPostSend(WebserviceRequestEvent $webserviceEvent)
  88.     {
  89.         if ($webserviceEvent->isCachedResponse()) {
  90.             return;
  91.         }
  93.         $engine = $this->cacheManager->getEngine();
  94.         //Cache is not allowed
  95.         if (!$engine || !$this->cacheManager->isCachable($webserviceEvent->getRequest())) {
  96.             return;
  97.         }
  99.         //Responnse has already cached
  100.         if ($webserviceEvent->isCachedResponse()) {
  101.             return;
  102.         }
  104.         //$this->webServiceLogger->info(sprintf('%s setCacheOnPostSend', $webserviceEvent->getRequest()->getRequesterClass()));
  105.         $parsedResponse = $webserviceEvent->getParsedResponse();
  106.         $serviceName = $webserviceEvent->getRequest()->getRequesterClass();
  107.         if (!$parsedResponse instanceof ResponseInterface) {
  108.             $this->webServiceLogger->info(sprintf('%s response result not implement ResponseInterface. Cache capibility not allowed', $serviceName), [$parsedResponse]);
  110.             return;
  111.         }
  113.         if ($parsedResponse->hasError() || $parsedResponse->getError()) {
  114.             $this->webServiceLogger->error(sprintf('%s Service has returned with error. We can not cache response.', $serviceName), [$parsedResponse]);
  116.             return;
  117.         }
  119.         $hashKey = $webserviceEvent->getRequest()->getHashKey();
  120.         $parsedResponse = $webserviceEvent->getParsedResponse();
  121.         $ttl = $this->cacheManager->getTTL($webserviceEvent->getRequest());
  123.         $return = $engine->set(
  124.             $hashKey,
  125.             $parsedResponse,
  126.             $ttl
  127.         );
  129.         $this->webServiceLogger->info(sprintf('Response  was set in cache for "%s" seconds with key %s', $ttl, $hashKey));
  130.     }
  131. }