platform/src/Core/Content/Flow/Dispatching/CachedFlowLoader.php line 80

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.     public static function getSubscribedEvents()
  38.     {
  39.         return [
  40.             FlowEvents::FLOW_WRITTEN_EVENT => 'invalidate',
  41.         ];
  42.     }
  44.     public function getDecorated(): AbstractFlowLoader
  45.     {
  46.         return $this->decorated;
  47.     }
  49.     public function load(): array
  50.     {
  51.         if (!empty($this->flows)) {
  52.             return $this->flows;
  53.         }
  55.         $item = $this->cache->getItem(self::KEY);
  57.         try {
  58.             if ($item->isHit() && $item->get()) {
  59.                 $this->logger->info('cache-hit: ' . self::KEY);
  61.                 return $this->flows = CacheCompressor::uncompress($item);
  62.             }
  63.         } catch (\Throwable $e) {
  64.             $this->logger->error($e->getMessage());
  65.         }
  67.         $this->logger->info('cache-miss: ' . self::KEY);
  69.         $flows = $this->getDecorated()->load();
  71.         $item = CacheCompressor::compress($item, $flows);
  73.         $item->tag([self::KEY]);
  75.         $this->cache->save($item);
  77.         return $this->flows = $flows;
  78.     }
  80.     public function invalidate(EntityWrittenEvent $event): void
  81.     {
  82.         $this->flows = [];
  83.         $this->cache->deleteItem(self::KEY);
  84.     }
  85. }