vendor/shopware/platform/src/Core/Content/Flow/Dispatching/CachedFlowLoader.php line 63

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Flow\Dispatching;
  5. use Shopware\Core\Content\Flow\FlowEvents;
  6. use Shopware\Core\Framework\Adapter\Cache\CacheValueCompressor;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Contracts\Cache\CacheInterface;
  9. use Symfony\Contracts\Cache\ItemInterface;
  10. use Symfony\Contracts\Service\ResetInterface;
  12. /**
  13.  * @internal not intended for decoration or replacement
  14.  */
  15. class CachedFlowLoader extends AbstractFlowLoader implements EventSubscriberInterface, ResetInterface
  16. {
  17.     public const KEY = 'flow-loader';
  19.     private array $flows = [];
  21.     private AbstractFlowLoader $decorated;
  23.     private CacheInterface $cache;
  25.     public function __construct(
  26.         AbstractFlowLoader $decorated,
  27.         CacheInterface $cache
  28.     ) {
  29.         $this->decorated = $decorated;
  30.         $this->cache = $cache;
  31.     }
  33.     /**
  34.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  35.      */
  36.     public static function getSubscribedEvents()
  37.     {
  38.         return [
  39.             FlowEvents::FLOW_WRITTEN_EVENT => 'invalidate',
  40.         ];
  41.     }
  43.     public function getDecorated(): AbstractFlowLoader
  44.     {
  45.         return $this->decorated;
  46.     }
  48.     public function load(): array
  49.     {
  50.         if (!empty($this->flows)) {
  51.             return $this->flows;
  52.         }
  54.         $value = $this->cache->get(self::KEY, function (ItemInterface $item) {
  55.             $item->tag([self::KEY]);
  57.             return CacheValueCompressor::compress($this->getDecorated()->load());
  58.         });
  60.         return $this->flows = CacheValueCompressor::uncompress($value);
  61.     }
  63.     public function invalidate(): void
  64.     {
  65.         $this->reset();
  66.         $this->cache->delete(self::KEY);
  67.     }
  69.     public function reset(): void
  70.     {
  71.         $this->flows = [];
  72.     }
  73. }