custom/plugins/AcrisShopSwitchCS/src/Subscriber/ResponseCacheSubscriber.php line 56

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\ShopSwitch\Subscriber;
  5. use Shopware\Core\Framework\Struct\ArrayStruct;
  6. use Shopware\Core\PlatformRequest;
  7. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextService;
  8. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  9. use Shopware\Storefront\Framework\Cache\CacheResponseSubscriber;
  10. use Shopware\Storefront\Framework\Routing\MaintenanceModeResolver;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpFoundation\Cookie;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  17. class ResponseCacheSubscriber implements EventSubscriberInterface
  18. {
  19.     public const CACHE_HASH_EXTENSION = 'acris_cache_hash';
  21.     public const CACHE_HASH_STAY_ON_PAGE = '90605113f9cb402284c6afbb3d408731';
  23.     private bool $httpCacheEnabled;
  25.     private MaintenanceModeResolver $maintenanceModeResolver;
  27.     public function __construct(
  28.         bool $httpCacheEnabled,
  29.         MaintenanceModeResolver $maintenanceModeResolver)
  30.     {
  31.         $this->httpCacheEnabled = $httpCacheEnabled;
  32.         $this->maintenanceModeResolver = $maintenanceModeResolver;
  33.     }
  35.     public static function getSubscribedEvents()
  36.     {
  37.         return [
  38.             KernelEvents::RESPONSE => [
  39.                 ['setResponseCache', -2000]
  40.             ]
  41.         ];
  42.     }
  44.     public function addToCacheHash($value, SalesChannelContext $context)
  45.     {
  46.         if($context->hasExtension(self::CACHE_HASH_EXTENSION) === true) {
  47.             /** @var ArrayStruct $cacheHashExtension */
  48.             $cacheHashExtension = $context->getExtension(self::CACHE_HASH_EXTENSION);
  49.         } else {
  50.             $cacheHashExtension = new ArrayStruct();
  51.         }
  53.         $context->addExtension(self::CACHE_HASH_EXTENSION, $this->getCacheHashExtension($value, $cacheHashExtension));
  54.     }
  56.     public function setResponseCache(ResponseEvent $event)
  57.     {
  58.         if (!$this->httpCacheEnabled) {
  59.             return;
  60.         }
  62.         $response = $event->getResponse();
  64.         $request = $event->getRequest();
  66.         if ($this->maintenanceModeResolver->isMaintenanceRequest($request)) {
  67.             return;
  68.         }
  70.         $context = $request->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_CONTEXT_OBJECT);
  72.         if (!$context instanceof SalesChannelContext) {
  73.             return;
  74.         }
  76.         if($context->hasExtension(self::CACHE_HASH_EXTENSION) !== true) {
  77.             return;
  78.         }
  80.         /** @var ArrayStruct $acrisCacheHashExtension */
  81.         $acrisCacheHashExtension = $context->getExtension(self::CACHE_HASH_EXTENSION);
  82.         $acrisCacheHash = $this->generateCacheHashFromExtension($acrisCacheHashExtension);
  83.         $cacheHash = $this->buildCacheHash($context, $acrisCacheHash, $this->getCurrencyIdChanging($request));
  85.         $response->headers->setCookie(new Cookie(CacheResponseSubscriber::CONTEXT_CACHE_COOKIE, $cacheHash));
  86.     }
  88.     public function generateCacheHash($value)
  89.     {
  90.         return $this->generateCacheHashFromExtension($this->getCacheHashExtension($value));
  91.     }
  93.     private function getCacheHashExtension($value, ?ArrayStruct $cacheHashExtension = null): ArrayStruct
  94.     {
  95.         if($cacheHashExtension === null) {
  96.             $cacheHashExtension = new ArrayStruct();
  97.         }
  98.         $encodedValue = md5(json_encode($value));
  99.         $cacheHashExtension->set($encodedValue, $encodedValue);
  100.         return $cacheHashExtension;
  101.     }
  103.     private function generateCacheHashFromExtension(ArrayStruct $cacheHashExtension): string
  104.     {
  105.         return md5(json_encode($cacheHashExtension->all()));
  106.     }
  108.     private function buildCacheHash(SalesChannelContext $context, $acrisCacheHash, ?string $currencyId): string
  109.     {
  110.         if(empty($currencyId) == true) {
  111.             $currencyId = $context->getCurrency()->getId();
  112.         }
  113.         return md5(json_encode([
  114.             $context->getRuleIds(),
  115.             $context->getContext()->getVersionId(),
  116.             $currencyId,
  117.             $context->getCustomer() ? 'logged-in' : 'not-logged-in',
  118.             $acrisCacheHash
  119.         ]));
  120.     }
  122.     private function getCurrencyIdChanging(Request $request): ?string
  123.     {
  124.         $route = $request->attributes->get('_route');
  125.         if ($route === 'frontend.checkout.configure') {
  126.             $currencyId = $request->get(SalesChannelContextService::CURRENCY_ID);
  128.             if (!$currencyId) {
  129.                 return null;
  130.             }
  131.             return $currencyId;
  132.         }
  133.         return null;
  134.     }
  135. }