src/Core/System/SalesChannel/Context/CachedSalesChannelContextFactory.php line 44

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\System\SalesChannel\Context;
  5. use Shopware\Core\Framework\Adapter\Cache\AbstractCacheTracer;
  6. use Shopware\Core\Framework\Adapter\Cache\CacheValueCompressor;
  7. use Shopware\Core\Framework\Log\Package;
  8. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  9. use Symfony\Contracts\Cache\CacheInterface;
  10. use Symfony\Contracts\Cache\ItemInterface;
  12. #[Package('core')]
  13. class CachedSalesChannelContextFactory extends AbstractSalesChannelContextFactory
  14. {
  15.     final public const ALL_TAG = 'sales-channel-context';
  17.     /**
  18.      * @internal
  19.      *
  20.      * @param AbstractCacheTracer<SalesChannelContext> $tracer
  21.      */
  22.     public function __construct(private readonly AbstractSalesChannelContextFactory $decorated, private readonly CacheInterface $cache, private readonly AbstractCacheTracer $tracer)
  23.     {
  24.     }
  26.     public function getDecorated(): AbstractSalesChannelContextFactory
  27.     {
  28.         return $this->decorated;
  29.     }
  31.     public function create(string $token, string $salesChannelId, array $options = []): SalesChannelContext
  32.     {
  33.         $name = self::buildName($salesChannelId);
  35.         if (!$this->isCacheable($options)) {
  36.             return $this->getDecorated()->create($token, $salesChannelId, $options);
  37.         }
  39.         ksort($options);
  41.         $key = implode('-', [$name, md5(json_encode($options, \JSON_THROW_ON_ERROR))]);
  43.         $value = $this->cache->get($key, function (ItemInterface $item) use ($name, $token, $salesChannelId, $options) {
  44.             $context = $this->tracer->trace($name, fn () => $this->getDecorated()->create($token, $salesChannelId, $options));
  46.             $keys = array_unique(array_merge(
  47.                 $this->tracer->get($name),
  48.                 [$name, self::ALL_TAG]
  49.             ));
  51.             $item->tag($keys);
  53.             return CacheValueCompressor::compress($context);
  54.         });
  56.         $context = CacheValueCompressor::uncompress($value);
  58.         $context->assign(['token' => $token]);
  60.         return $context;
  61.     }
  63.     public static function buildName(string $salesChannelId): string
  64.     {
  65.         return 'context-factory-' . $salesChannelId;
  66.     }
  68.     /**
  69.      * @param array<string, mixed> $options
  70.      */
  71.     private function isCacheable(array $options): bool
  72.     {
  73.         return !isset($options[SalesChannelContextService::CUSTOMER_ID])
  74.             && !isset($options[SalesChannelContextService::BILLING_ADDRESS_ID])
  75.             && !isset($options[SalesChannelContextService::SHIPPING_ADDRESS_ID]);
  76.     }
  77. }