vendor/dvdw/cache/src/Framework/Adapter/Cache/CacheHelper.php line 58

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Dvdw\Cache\Framework\Adapter\Cache;
  5. use Dvdw\Cache\System\SalesChannel\AbstractStoreApiResponseTagBuilder;
  6. use Psr\Cache\CacheException;
  7. use Psr\Cache\InvalidArgumentException;
  8. use Shopware\Core\Framework\Adapter\Cache\AbstractCacheTracer;
  9. use Shopware\Core\Framework\Adapter\Cache\CacheValueCompressor;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Cache\EntityCacheKeyGenerator;
  11. use Shopware\Core\Framework\DataAbstractionLayer\FieldSerializer\JsonFieldSerializer;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  14. use Shopware\Core\System\SalesChannel\StoreApiResponse;
  15. use Symfony\Contracts\Cache\CacheInterface;
  16. use Symfony\Contracts\Cache\ItemInterface;
  18. class CacheHelper
  19. {
  20.     private CacheInterface $cache;
  22.     private EntityCacheKeyGenerator $generator;
  24.     private AbstractCacheTracer $tracer;
  26.     private AbstractStoreApiResponseTagBuilder $tagBuilder;
  28.     public function __construct(
  29.         CacheInterface $cache,
  30.         EntityCacheKeyGenerator $generator,
  31.         AbstractCacheTracer $tracer,
  32.         AbstractStoreApiResponseTagBuilder $tagBuilder
  33.     )
  34.     {
  35.         $this->cache = $cache;
  36.         $this->generator = $generator;
  37.         $this->tracer = $tracer;
  38.         $this->tagBuilder = $tagBuilder;
  39.     }
  41.     /**
  42.      * @throws CacheException
  43.      * @throws InvalidArgumentException
  44.      */
  45.     public function get(CacheItemInfo $itemInfo): StoreApiResponse
  46.     {
  47.         $key = $itemInfo->getKey();
  49.         if ($key === null) {
  50.             $key = $this->generateKey($itemInfo->buildName(), $itemInfo->getCriteria(), $itemInfo->getContext());
  51.         }
  53.         $value = $this->cache->get($key, function (ItemInterface $item) use ($itemInfo) {
  54.             $name = $itemInfo->buildName();
  56.             $response = $this->tracer->trace($name, function () use ($itemInfo) {
  57.                 return $itemInfo->getRoute()->load($itemInfo->getRequest(), $itemInfo->getCriteria(), $itemInfo->getContext());
  58.             });
  60.             $tags = $itemInfo->getTags();
  62.             if ($tags === null) {
  63.                 $tags = [];
  64.             }
  66.             $tags = array_unique(array_filter(array_merge($tags, $this->generateTags($response, $itemInfo))));
  68.             $item->tag($tags);
  70.             return CacheValueCompressor::compress($response);
  71.         });
  73.         return CacheValueCompressor::uncompress($value);
  74.     }
  76.     private function generateKey(string $name, Criteria $criteria, SalesChannelContext $context): string
  77.     {
  78.         $parts = [
  79.             $this->generator->getCriteriaHash($criteria),
  80.             $this->generator->getSalesChannelContextHash($context)
  81.         ];
  83.         return $name . '-' . md5(JsonFieldSerializer::encodeJson($parts));
  84.     }
  86.     private function generateTags(StoreApiResponse $response, CacheItemInfo $itemInfo): array
  87.     {
  88.         $name = $itemInfo->buildName();
  90.         $tags = array_merge(
  91.             $this->tracer->get($name),
  92.             [$name, $itemInfo->getAllTag()],
  93.             $this->tagBuilder->build($response, $itemInfo)
  94.         );
  96.         return array_unique(array_filter($tags));
  97.     }
  98. }