vendor/store.shopware.com/netzpblog6/src/Controller/StoreApi/BlogPost/CachedBlogPostRoute.php line 103

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace NetzpBlog6\Controller\StoreApi\BlogPost;
  5. use OpenApi\Annotations as OA;
  6. use Shopware\Core\Framework\Routing\Annotation\Entity;
  7. use Symfony\Component\Routing\Annotation\Route;
  8. use Psr\Log\LoggerInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  11. use Shopware\Core\Framework\Adapter\Cache\AbstractCacheTracer;
  12. use Shopware\Core\Framework\Adapter\Cache\CacheCompressor;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Cache\EntityCacheKeyGenerator;
  14. use Shopware\Core\Framework\DataAbstractionLayer\FieldSerializer\JsonFieldSerializer;
  15. use Symfony\Component\Cache\Adapter\TagAwareAdapterInterface;
  17. class CachedBlogPostRoute extends AbstractBlogPostRoute
  18. {
  19.     private AbstractBlogPostRoute $decorated;
  21.     private TagAwareAdapterInterface $cache;
  23.     private EntityCacheKeyGenerator $generator;
  25.     private AbstractCacheTracer $tracer;
  27.     private array $states;
  29.     private LoggerInterface $logger;
  31.     public function __construct(
  32.         AbstractBlogPostRoute $decorated,
  33.         TagAwareAdapterInterface $cache,
  34.         EntityCacheKeyGenerator $generator,
  35.         AbstractCacheTracer $tracer,
  36.         LoggerInterface $logger
  37.     ) {
  38.         $this->decorated = $decorated;
  39.         $this->cache = $cache;
  40.         $this->generator = $generator;
  41.         $this->tracer = $tracer;
  42.         $this->states = [];
  43.         $this->logger = $logger;
  44.     }
  46.     public function getDecorated(): AbstractBlogPostRoute
  47.     {
  48.         return $this->decorated;
  49.     }
  51.     /**
  52.      * @Entity("s_plugin_netzp_blog")
  53.      * @OA\Post(
  54.      *      path="/blogpost/{postId}",
  55.      *      summary="This route can be used to load the s_plugin_netzp_blog",
  56.      *      operationId="readNetzpBlog",
  57.      *      tags={"Store API", "NetzpBlog"},
  58.      *      @OA\Parameter(name="Api-Basic-Parameters"),
  59.      *      @OA\Response(
  60.      *          response="200",
  61.      *          description="",
  62.      *          @OA\JsonContent(type="object",
  63.      *              @OA\Property(
  64.      *                  property="total",
  65.      *                  type="integer",
  66.      *                  description="Total amount"
  67.      *              ),
  68.      *              @OA\Property(
  69.      *                  property="aggregations",
  70.      *                  type="object",
  71.      *                  description="aggregation result"
  72.      *              )
  73.      *          )
  74.      *     )
  75.      * )
  76.      * @Route("/store-api/blogpost/{postId}", name="store-api.s_plugin_netzp_blog.load", methods={"GET", "POST"}, defaults={"_routeScope"={"store-api"}})
  77.      */
  78.     public function load(string $postId, Criteria $criteria, SalesChannelContext $context): BlogPostRouteResponse
  79.     {
  80.         // The context is provided with a state where the route cannot be cached
  81.         if ($context->hasState(...$this->states)) {
  82.             return $this->getDecorated()->load($postId, $criteria, $context);
  83.         }
  85.         // Fetch item from the cache pool
  86.         $item = $this->cache->getItem(
  87.             $this->generateKey($postId, $context, $criteria)
  88.         );
  90.         try {
  91.             if ($item->isHit() && $item->get()) {
  92.                 // Use cache compressor to uncompress the cache value
  93.                 return CacheCompressor::uncompress($item);
  94.             }
  95.         } catch (\Throwable $e) {
  96.             // Something went wrong when uncompress the cache item - we log the error and continue to overwrite the invalid cache item
  97.             $this->logger->error($e->getMessage());
  98.         }
  100.         $name = self::buildName($postId);
  101.         // start tracing of nested cache tags and system config keys
  102.         $response = $this->tracer->trace($name, function () use ($criteria, $context, $postId) {
  103.             return $this->getDecorated()->load($postId, $criteria, $context);
  104.         });
  106.         // compress cache content to reduce cache size
  107.         $item = CacheCompressor::compress($item, $response);
  109.         $item->tag(array_merge(
  110.         // get traced tags and configs
  111.             $this->tracer->get(self::buildName($postId)),
  112.             [self::buildName($postId)]
  113.         ));
  115.         $this->cache->save($item);
  117.         return $response;
  118.     }
  120.     public static function buildName(string $postId): string
  121.     {
  122.         return 'blog-post-route-' . $postId;
  123.     }
  125.     private function generateKey(string $postId, SalesChannelContext $context, Criteria $criteria): string
  126.     {
  127.         $parts = [
  128.             self::buildName($postId),
  129.             $this->generator->getCriteriaHash($criteria),
  130.             $this->generator->getSalesChannelContextHash($context),
  131.         ];
  133.         return md5(JsonFieldSerializer::encodeJson($parts));
  134.     }
  135. }