vendor/shopware/platform/src/Core/System/SalesChannel/Context/CachedSalesChannelContextFactory.php line 82

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\System\SalesChannel\Context;
  5. use Psr\Log\LoggerInterface;
  6. use Shopware\Core\Framework\Adapter\Cache\AbstractCacheTracer;
  7. use Shopware\Core\Framework\Adapter\Cache\CacheCompressor;
  8. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  9. use Symfony\Component\Cache\Adapter\TagAwareAdapterInterface;
  11. class CachedSalesChannelContextFactory extends AbstractSalesChannelContextFactory
  12. {
  13.     public const ALL_TAG = 'sales-channel-context';
  15.     private AbstractSalesChannelContextFactory $decorated;
  17.     private TagAwareAdapterInterface $cache;
  19.     /**
  20.      * @var AbstractCacheTracer<SalesChannelContext>
  21.      */
  22.     private AbstractCacheTracer $tracer;
  24.     private LoggerInterface $logger;
  26.     /**
  27.      * @param AbstractCacheTracer<SalesChannelContext> $tracer
  28.      */
  29.     public function __construct(
  30.         AbstractSalesChannelContextFactory $decorated,
  31.         TagAwareAdapterInterface $cache,
  32.         AbstractCacheTracer $tracer,
  33.         LoggerInterface $logger
  34.     ) {
  35.         $this->decorated = $decorated;
  36.         $this->cache = $cache;
  37.         $this->tracer = $tracer;
  38.         $this->logger = $logger;
  39.     }
  41.     public function getDecorated(): AbstractSalesChannelContextFactory
  42.     {
  43.         return $this->decorated;
  44.     }
  46.     public function create(string $token, string $salesChannelId, array $options = []): SalesChannelContext
  47.     {
  48.         $name = self::buildName($salesChannelId);
  50.         if (!$this->isCacheable($options)) {
  51.             $this->logger->info('cache-miss: ' . $name);
  53.             return $this->getDecorated()->create($token, $salesChannelId, $options);
  54.         }
  56.         ksort($options);
  58.         $key = md5(implode('-', [
  59.             $name,
  60.             json_encode($options),
  61.         ]));
  63.         $item = $this->cache->getItem($key);
  65.         try {
  66.             if ($item->isHit() && $item->get()) {
  67.                 $this->logger->info('cache-hit: ' . $name);
  69.                 /** @var SalesChannelContext $context */
  70.                 $context = CacheCompressor::uncompress($item);
  71.                 $context->assign(['token' => $token]);
  73.                 return $context;
  74.             }
  75.         } catch (\Throwable $e) {
  76.             $this->logger->error($e->getMessage());
  77.         }
  79.         $this->logger->info('cache-miss: ' . $name);
  81.         $context = $this->tracer->trace($name, function () use ($token, $salesChannelId, $options) {
  82.             return $this->getDecorated()->create($token, $salesChannelId, $options);
  83.         });
  85.         $keys = array_unique(array_merge(
  86.             $this->tracer->get($name),
  87.             [$name, self::ALL_TAG]
  88.         ));
  90.         $item = CacheCompressor::compress($item, $context);
  91.         $item->tag($keys);
  93.         $this->cache->save($item);
  95.         return $context;
  96.     }
  98.     public static function buildName(string $salesChannelId): string
  99.     {
  100.         return 'context-factory-' . $salesChannelId;
  101.     }
  103.     private function isCacheable(array $options): bool
  104.     {
  105.         return !isset($options[SalesChannelContextService::CUSTOMER_ID])
  106.             && !isset($options[SalesChannelContextService::BILLING_ADDRESS_ID])
  107.             && !isset($options[SalesChannelContextService::SHIPPING_ADDRESS_ID]);
  108.     }
  109. }