custom/plugins/NetzpBlog6/src/Controller/StoreApi/BlogPost/CachedBlogPostRoute.php line 53

  1. <?php declare(strict_types=1);
  3. namespace NetzpBlog6\Controller\StoreApi\BlogPost;
  5. use Shopware\Core\Framework\Util\Json;
  6. use Symfony\Component\Routing\Annotation\Route;
  7. use Psr\Log\LoggerInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  10. use Shopware\Core\Framework\Adapter\Cache\AbstractCacheTracer;
  11. use Shopware\Core\Framework\Adapter\Cache\CacheCompressor;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Cache\EntityCacheKeyGenerator;
  13. use Symfony\Component\Cache\Adapter\TagAwareAdapterInterface;
  15. class CachedBlogPostRoute extends AbstractBlogPostRoute
  16. {
  17.     private array $states = [];
  19.     public function __construct(private readonly AbstractBlogPostRoute $decorated,
  20.                                 private readonly TagAwareAdapterInterface $cache,
  21.                                 private readonly EntityCacheKeyGenerator $generator,
  22.                                 private readonly AbstractCacheTracer $tracer,
  23.                                 private readonly LoggerInterface $logger)
  24.     {
  25.     }
  27.     public function getDecorated(): AbstractBlogPostRoute
  28.     {
  29.         return $this->decorated;
  30.     }
  32.     #[Route(path: '/store-api/blogpost/{postId}', name: 'store-api.s_plugin_netzp_blog.load', methods: ['GET', 'POST'], defaults: ['_routeScope' => ['store-api']])]
  33.     public function load(string $postId, Criteria $criteria, SalesChannelContext $context): BlogPostRouteResponse
  34.     {
  35.         if ($context->hasState(...$this->states)) {
  36.             return $this->getDecorated()->load($postId, $criteria, $context);
  37.         }
  39.         $item = $this->cache->getItem(
  40.             $this->generateKey($postId, $context, $criteria)
  41.         );
  43.         try {
  44.             if ($item->isHit() && $item->get()) {
  45.                 return CacheCompressor::uncompress($item);
  46.             }
  47.         }
  48.         catch (\Throwable $e) {
  49.             $this->logger->error($e->getMessage());
  50.         }
  52.         $name = self::buildName($postId);
  53.         $response = $this->tracer->trace($name, fn() => $this->getDecorated()->load($postId, $criteria, $context));
  55.         $item = CacheCompressor::compress($item, $response);
  57.         $item->tag(array_merge(
  58.             $this->tracer->get(self::buildName($postId)),
  59.             [self::buildName($postId)]
  60.         ));
  62.         $this->cache->save($item);
  64.         return $response;
  65.     }
  67.     public static function buildName(string $postId): string
  68.     {
  69.         return 'blog-post-route-' . $postId;
  70.     }
  72.     private function generateKey(string $postId,
  73.                                  SalesChannelContext $context,
  74.                                  Criteria $criteria): string
  75.     {
  76.         $customerId = $context->getCustomer()?->getId();
  78.         $parts = [
  79.             self::buildName($postId),
  80.             $this->generator->getCriteriaHash($criteria),
  81.             $this->generator->getSalesChannelContextHash($context)
  82.         ];
  84.         if($customerId != null) {
  85.             $parts[] = $customerId;
  86.         }
  88.         return md5(Json::encode($parts));
  89.     }
  90. }