vendor/shopware/core/System/SalesChannel/Context/CachedSalesChannelContextFactory.php line 57

  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(
  23.         private readonly AbstractSalesChannelContextFactory $decorated,
  24.         private readonly CacheInterface $cache,
  25.         private readonly AbstractCacheTracer $tracer
  26.     ) {
  27.     }
  29.     public function getDecorated(): AbstractSalesChannelContextFactory
  30.     {
  31.         return $this->decorated;
  32.     }
  34.     public function create(string $token, string $salesChannelId, array $options = []): SalesChannelContext
  35.     {
  36.         $name = self::buildName($salesChannelId);
  38.         if (!$this->isCacheable($options)) {
  39.             return $this->getDecorated()->create($token, $salesChannelId, $options);
  40.         }
  42.         ksort($options);
  44.         $key = implode('-', [$name, md5(json_encode($options, \JSON_THROW_ON_ERROR))]);
  46.         $value = $this->cache->get($key, function (ItemInterface $item) use ($name, $token, $salesChannelId, $options) {
  47.             $context = $this->tracer->trace($name, fn () => $this->getDecorated()->create($token, $salesChannelId, $options));
  49.             $keys = array_unique(array_merge(
  50.                 $this->tracer->get($name),
  51.                 [$name, self::ALL_TAG]
  52.             ));
  54.             $item->tag($keys);
  56.             return CacheValueCompressor::compress($context);
  57.         });
  59.         $context = CacheValueCompressor::uncompress($value);
  61.         $context->assign(['token' => $token]);
  63.         return $context;
  64.     }
  66.     public static function buildName(string $salesChannelId): string
  67.     {
  68.         return 'context-factory-' . $salesChannelId;
  69.     }
  71.     /**
  72.      * @param array<string, mixed> $options
  73.      */
  74.     private function isCacheable(array $options): bool
  75.     {
  76.         return !isset($options[SalesChannelContextService::CUSTOMER_ID])
  77.             && !isset($options[SalesChannelContextService::BILLING_ADDRESS_ID])
  78.             && !isset($options[SalesChannelContextService::SHIPPING_ADDRESS_ID]);
  79.     }
  80. }