custom/plugins/AcrisCookieConsentCS/src/Subscriber/ResponseCacheSubscriber.php line 39

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\CookieConsent\Subscriber;
  5. use Shopware\Core\Framework\Struct\ArrayStruct;
  6. use Shopware\Core\PlatformRequest;
  7. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  8. use Shopware\Storefront\Framework\Cache\CacheResponseSubscriber;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\HttpFoundation\Cookie;
  11. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  12. use Symfony\Component\HttpKernel\KernelEvents;
  14. class ResponseCacheSubscriber implements EventSubscriberInterface
  15. {
  16.     public const CACHE_HASH_EXTENSION = 'acris_cache_hash';
  18.     public static function getSubscribedEvents()
  19.     {
  20.         return [
  21.             KernelEvents::RESPONSE => [
  22.                 ['setResponseCache', -2000]
  23.             ]
  24.         ];
  25.     }
  27.     public function addToCacheHash($value, SalesChannelContext $context)
  28.     {
  29.         if($context->hasExtension(self::CACHE_HASH_EXTENSION) === true) {
  30.             /** @var ArrayStruct $cacheHashExtension */
  31.             $cacheHashExtension = $context->getExtension(self::CACHE_HASH_EXTENSION);
  32.         } else {
  33.             $cacheHashExtension = new ArrayStruct();
  34.         }
  36.         $context->addExtension(self::CACHE_HASH_EXTENSION, $this->getCacheHashExtension($value, $cacheHashExtension));
  37.     }
  39.     public function setResponseCache(ResponseEvent $event)
  40.     {
  41.         $response = $event->getResponse();
  43.         $context = $event->getRequest()->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_CONTEXT_OBJECT);
  45.         if (!$context instanceof SalesChannelContext) {
  46.             return;
  47.         }
  49.         if($context->hasExtension(self::CACHE_HASH_EXTENSION) !== true) {
  50.             return;
  51.         }
  53.         /** @var ArrayStruct $acrisCacheHashExtension */
  54.         $acrisCacheHashExtension = $context->getExtension(self::CACHE_HASH_EXTENSION);
  55.         $acrisCacheHash = $this->generateCacheHashFromExtension($acrisCacheHashExtension);
  57.         if ($context->getCustomer()) {
  58.             $cacheHash = $this->buildCacheHash($context, $acrisCacheHash);
  59.         } else {
  60.             $cacheHash = $acrisCacheHash;
  61.         }
  62.         $response->headers->setCookie(new Cookie(CacheResponseSubscriber::CONTEXT_CACHE_COOKIE, $cacheHash));
  63.     }
  65.     public function generateCacheHash($value)
  66.     {
  67.         return $this->generateCacheHashFromExtension($this->getCacheHashExtension($value));
  68.     }
  70.     private function getCacheHashExtension($value, ?ArrayStruct $cacheHashExtension = null): ArrayStruct
  71.     {
  72.         if($cacheHashExtension === null) {
  73.             $cacheHashExtension = new ArrayStruct();
  74.         }
  75.         $encodedValue = md5(json_encode($value));
  76.         $cacheHashExtension->set($encodedValue, $encodedValue);
  77.         return $cacheHashExtension;
  78.     }
  80.     private function generateCacheHashFromExtension(ArrayStruct $cacheHashExtension): string
  81.     {
  82.         return md5(json_encode($cacheHashExtension->all()));
  83.     }
  85.     private function buildCacheHash(SalesChannelContext $context, $acrisCacheHash): string
  86.     {
  87.         return md5(json_encode([
  88.             $context->getRuleIds(),
  89.             $context->getContext()->getVersionId(),
  90.             $context->getCurrency()->getId(),
  91.             $acrisCacheHash
  92.         ]));
  93.     }
  94. }