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

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\CookieConsent\Subscriber;
  5. use Shopware\Core\Checkout\Customer\CustomerEntity;
  6. use Shopware\Core\Framework\Struct\ArrayStruct;
  7. use Shopware\Core\PlatformRequest;
  8. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextService;
  9. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  10. use Shopware\Storefront\Framework\Cache\CacheResponseSubscriber;
  11. use Shopware\Storefront\Framework\Routing\MaintenanceModeResolver;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\HttpFoundation\Cookie;
  14. use Symfony\Component\HttpFoundation\Request;
  15. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  16. use Symfony\Component\HttpKernel\KernelEvents;
  18. class ResponseCacheSubscriber implements EventSubscriberInterface
  19. {
  20.     public const CACHE_HASH_EXTENSION = 'acris_cache_hash';
  22.     public CONST CASH_HASH_COOKIE_LIFETIME = 86400 * 30;
  24.     private bool $httpCacheEnabled;
  26.     private MaintenanceModeResolver $maintenanceModeResolver;
  28.     public function __construct(
  29.         bool $httpCacheEnabled,
  30.         MaintenanceModeResolver $maintenanceModeResolver)
  31.     {
  32.         $this->httpCacheEnabled = $httpCacheEnabled;
  33.         $this->maintenanceModeResolver = $maintenanceModeResolver;
  34.     }
  36.     public static function getSubscribedEvents()
  37.     {
  38.         return [
  39.             KernelEvents::RESPONSE => [
  40.                 ['setResponseCache', -2000]
  41.             ]
  42.         ];
  43.     }
  45.     public function addToCacheHash($value, SalesChannelContext $context)
  46.     {
  47.         if($context->hasExtension(self::CACHE_HASH_EXTENSION) === true) {
  48.             /** @var ArrayStruct $cacheHashExtension */
  49.             $cacheHashExtension = $context->getExtension(self::CACHE_HASH_EXTENSION);
  50.         } else {
  51.             $cacheHashExtension = new ArrayStruct();
  52.         }
  54.         $context->addExtension(self::CACHE_HASH_EXTENSION, $this->getCacheHashExtension($value, $cacheHashExtension));
  55.     }
  57.     public function setResponseCache(ResponseEvent $event)
  58.     {
  59.         if (!$this->httpCacheEnabled) {
  60.             return;
  61.         }
  63.         $response = $event->getResponse();
  65.         $request = $event->getRequest();
  67.         if ($this->maintenanceModeResolver->isMaintenanceRequest($request)) {
  68.             return;
  69.         }
  71.         $context = $request->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_CONTEXT_OBJECT);
  73.         if (!$context instanceof SalesChannelContext) {
  74.             return;
  75.         }
  77.         if($context->hasExtension(self::CACHE_HASH_EXTENSION) !== true) {
  78.             return;
  79.         }
  81.         /** @var ArrayStruct $acrisCacheHashExtension */
  82.         $acrisCacheHashExtension = $context->getExtension(self::CACHE_HASH_EXTENSION);
  83.         $acrisCacheHash = $this->generateCacheHashFromExtension($acrisCacheHashExtension);
  84.         $cacheHash = $this->buildCacheHash($context, $acrisCacheHash, $this->getCurrencyIdChanging($request));
  86.         $response->headers->setCookie(new Cookie(CacheResponseSubscriber::CONTEXT_CACHE_COOKIE, $cacheHash, time() + self::CASH_HASH_COOKIE_LIFETIME));
  87.     }
  89.     public function generateCacheHash($value)
  90.     {
  91.         return $this->generateCacheHashFromExtension($this->getCacheHashExtension($value));
  92.     }
  94.     private function getCacheHashExtension($value, ?ArrayStruct $cacheHashExtension = null): ArrayStruct
  95.     {
  96.         if($cacheHashExtension === null) {
  97.             $cacheHashExtension = new ArrayStruct();
  98.         }
  99.         $encodedValue = md5(json_encode($value));
  100.         $cacheHashExtension->set($encodedValue, $encodedValue);
  101.         return $cacheHashExtension;
  102.     }
  104.     private function generateCacheHashFromExtension(ArrayStruct $cacheHashExtension): string
  105.     {
  106.         return md5(json_encode($cacheHashExtension->all()));
  107.     }
  109.     private function buildCacheHash(SalesChannelContext $context, $acrisCacheHash, ?string $currencyId): string
  110.     {
  111.         if(empty($currencyId) == true) {
  112.             $currencyId = $context->getCurrency()->getId();
  113.         }
  114.         return md5(json_encode([
  115.             $context->getRuleIds(),
  116.             $context->getContext()->getVersionId(),
  117.             $currencyId,
  118.             $context->getCustomer() ? 'logged-in' : 'not-logged-in',
  119.             $acrisCacheHash
  120.         ]));
  121.     }
  123.     private function getCurrencyIdChanging(Request $request): ?string
  124.     {
  125.         $route = $request->attributes->get('_route');
  126.         if ($route === 'frontend.checkout.configure') {
  127.             $currencyId = $request->get(SalesChannelContextService::CURRENCY_ID);
  129.             if (!$currencyId) {
  130.                 return null;
  131.             }
  132.             return $currencyId;
  133.         }
  134.         return null;
  135.     }
  136. }