vendor/shopware/core/Content/Flow/Dispatching/CachedFlowLoader.php line 84

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Flow\Dispatching;
  5. use Psr\Log\LoggerInterface;
  6. use Shopware\Core\Content\Flow\FlowEvents;
  7. use Shopware\Core\Framework\Adapter\Cache\CacheCompressor;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  9. use Symfony\Component\Cache\Adapter\TagAwareAdapterInterface;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Contracts\Service\ResetInterface;
  13. /**
  14.  * @internal not intended for decoration or replacement
  15.  */
  16. class CachedFlowLoader extends AbstractFlowLoader implements EventSubscriberInterface, ResetInterface
  17. {
  18.     public const KEY = 'flow-loader';
  20.     private array $flows = [];
  22.     private AbstractFlowLoader $decorated;
  24.     private TagAwareAdapterInterface $cache;
  26.     private LoggerInterface $logger;
  28.     public function __construct(
  29.         AbstractFlowLoader $decorated,
  30.         TagAwareAdapterInterface $cache,
  31.         LoggerInterface $logger
  32.     ) {
  33.         $this->decorated = $decorated;
  34.         $this->cache = $cache;
  35.         $this->logger = $logger;
  36.     }
  38.     /**
  39.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  40.      */
  41.     public static function getSubscribedEvents()
  42.     {
  43.         return [
  44.             FlowEvents::FLOW_WRITTEN_EVENT => 'invalidate',
  45.         ];
  46.     }
  48.     public function getDecorated(): AbstractFlowLoader
  49.     {
  50.         return $this->decorated;
  51.     }
  53.     public function load(): array
  54.     {
  55.         if (!empty($this->flows)) {
  56.             return $this->flows;
  57.         }
  59.         $item = $this->cache->getItem(self::KEY);
  61.         try {
  62.             if ($item->isHit() && $item->get()) {
  63.                 $this->logger->info('cache-hit: ' . self::KEY);
  65.                 return $this->flows = CacheCompressor::uncompress($item);
  66.             }
  67.         } catch (\Throwable $e) {
  68.             $this->logger->error($e->getMessage());
  69.         }
  71.         $this->logger->info('cache-miss: ' . self::KEY);
  73.         $flows = $this->getDecorated()->load();
  75.         $item = CacheCompressor::compress($item, $flows);
  77.         $item->tag([self::KEY]);
  79.         $this->cache->save($item);
  81.         return $this->flows = $flows;
  82.     }
  84.     public function invalidate(EntityWrittenEvent $event): void
  85.     {
  86.         $this->reset();
  87.         $this->cache->deleteItem(self::KEY);
  88.     }
  90.     public function reset(): void
  91.     {
  92.         $this->flows = [];
  93.     }
  94. }