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

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;
  12. /**
  13.  * @internal not intended for decoration or replacement
  14.  */
  15. class CachedFlowLoader extends AbstractFlowLoader implements EventSubscriberInterface
  16. {
  17.     public const KEY = 'flow-loader';
  19.     private array $flows = [];
  21.     private AbstractFlowLoader $decorated;
  23.     private TagAwareAdapterInterface $cache;
  25.     private LoggerInterface $logger;
  27.     public function __construct(
  28.         AbstractFlowLoader $decorated,
  29.         TagAwareAdapterInterface $cache,
  30.         LoggerInterface $logger
  31.     ) {
  32.         $this->decorated = $decorated;
  33.         $this->cache = $cache;
  34.         $this->logger = $logger;
  35.     }
  37.     /**
  38.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  39.      */
  40.     public static function getSubscribedEvents()
  41.     {
  42.         return [
  43.             FlowEvents::FLOW_WRITTEN_EVENT => 'invalidate',
  44.         ];
  45.     }
  47.     public function getDecorated(): AbstractFlowLoader
  48.     {
  49.         return $this->decorated;
  50.     }
  52.     public function load(): array
  53.     {
  54.         if (!empty($this->flows)) {
  55.             return $this->flows;
  56.         }
  58.         $item = $this->cache->getItem(self::KEY);
  60.         try {
  61.             if ($item->isHit() && $item->get()) {
  62.                 $this->logger->info('cache-hit: ' . self::KEY);
  64.                 return $this->flows = CacheCompressor::uncompress($item);
  65.             }
  66.         } catch (\Throwable $e) {
  67.             $this->logger->error($e->getMessage());
  68.         }
  70.         $this->logger->info('cache-miss: ' . self::KEY);
  72.         $flows = $this->getDecorated()->load();
  74.         $item = CacheCompressor::compress($item, $flows);
  76.         $item->tag([self::KEY]);
  78.         $this->cache->save($item);
  80.         return $this->flows = $flows;
  81.     }
  83.     public function invalidate(EntityWrittenEvent $event): void
  84.     {
  85.         $this->flows = [];
  86.         $this->cache->deleteItem(self::KEY);
  87.     }
  88. }