custom/plugins/AcrisDiscountGroupCS/src/Storefront/Subscriber/ResponseCacheSubscriber.php line 56

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\DiscountGroup\Storefront\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_VALUE = 'acris-discount-group-scale-discounts';
  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(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(self::CACHE_HASH_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.     private function getCacheHashExtension($value, ?ArrayStruct $cacheHashExtension = null): ArrayStruct
  89.     {
  90.         if($cacheHashExtension === null) {
  91.             $cacheHashExtension = new ArrayStruct();
  92.         }
  93.         $encodedValue = md5(json_encode($value));
  94.         $cacheHashExtension->set($encodedValue, $encodedValue);
  95.         return $cacheHashExtension;
  96.     }
  98.     private function generateCacheHashFromExtension(ArrayStruct $cacheHashExtension): string
  99.     {
  100.         return md5(json_encode($cacheHashExtension->all()));
  101.     }
  103.     private function buildCacheHash(SalesChannelContext $context, $acrisCacheHash, ?string $currencyId): string
  104.     {
  105.         if(empty($currencyId) == true) {
  106.             $currencyId = $context->getCurrency()->getId();
  107.         }
  108.         return md5(json_encode([
  109.             $context->getRuleIds(),
  110.             $context->getContext()->getVersionId(),
  111.             $currencyId,
  112.             $context->getCustomer() ? 'logged-in' : 'not-logged-in',
  113.             $acrisCacheHash
  114.         ]));
  115.     }
  117.     private function getCurrencyIdChanging(Request $request): ?string
  118.     {
  119.         $route = $request->attributes->get('_route');
  120.         if ($route === 'frontend.checkout.configure') {
  121.             $currencyId = $request->get(SalesChannelContextService::CURRENCY_ID);
  123.             if (!$currencyId) {
  124.                 return null;
  125.             }
  126.             return $currencyId;
  127.         }
  128.         return null;
  129.     }
  130. }