src/Core/System/SalesChannel/Context/CachedBaseContextFactory.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\BaseContext;
  9. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  10. use Symfony\Contracts\Cache\CacheInterface;
  11. use Symfony\Contracts\Cache\ItemInterface;
  13. /**
  14.  * @internal
  15.  */
  16. #[Package('core')]
  17. class CachedBaseContextFactory extends AbstractBaseContextFactory
  18. {
  19.     /**
  20.      * @param AbstractCacheTracer<SalesChannelContext> $tracer
  21.      */
  22.     public function __construct(private readonly AbstractBaseContextFactory $decorated, private readonly CacheInterface $cache, private readonly AbstractCacheTracer $tracer)
  23.     {
  24.     }
  26.     public function getDecorated(): AbstractBaseContextFactory
  27.     {
  28.         return $this->decorated;
  29.     }
  31.     public function create(string $salesChannelId, array $options = []): BaseContext
  32.     {
  33.         if (isset($options[SalesChannelContextService::ORIGINAL_CONTEXT])) {
  34.             return $this->getDecorated()->create($salesChannelId, $options);
  35.         }
  36.         if (isset($options[SalesChannelContextService::PERMISSIONS])) {
  37.             return $this->getDecorated()->create($salesChannelId, $options);
  38.         }
  40.         $name = self::buildName($salesChannelId);
  42.         ksort($options);
  44.         $keys = \array_intersect_key($options, [
  45.             SalesChannelContextService::CURRENCY_ID => true,
  46.             SalesChannelContextService::LANGUAGE_ID => true,
  47.             SalesChannelContextService::DOMAIN_ID => true,
  48.             SalesChannelContextService::PAYMENT_METHOD_ID => true,
  49.             SalesChannelContextService::SHIPPING_METHOD_ID => true,
  50.             SalesChannelContextService::VERSION_ID => true,
  51.             SalesChannelContextService::COUNTRY_ID => true,
  52.             SalesChannelContextService::COUNTRY_STATE_ID => true,
  53.         ]);
  55.         $key = implode('-', [$name, md5(json_encode($keys, \JSON_THROW_ON_ERROR))]);
  57.         $value = $this->cache->get($key, function (ItemInterface $item) use ($name, $salesChannelId, $options) {
  58.             $context = $this->tracer->trace($name, fn () => $this->getDecorated()->create($salesChannelId, $options));
  60.             $keys = array_unique(array_merge(
  61.                 $this->tracer->get($name),
  62.                 [$name, CachedSalesChannelContextFactory::ALL_TAG]
  63.             ));
  65.             $item->tag($keys);
  67.             return CacheValueCompressor::compress($context);
  68.         });
  70.         return CacheValueCompressor::uncompress($value);
  71.     }
  73.     public static function buildName(string $salesChannelId): string
  74.     {
  75.         return 'base-context-factory-' . $salesChannelId;
  76.     }
  77. }