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

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 Shopware\Core\Framework\Log\Package;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Contracts\Cache\CacheInterface;
  10. use Symfony\Contracts\Cache\ItemInterface;
  11. use Symfony\Contracts\Service\ResetInterface;
  13. /**
  14.  * @internal not intended for decoration or replacement
  15.  */
  16. #[Package('business-ops')]
  17. class CachedFlowLoader extends AbstractFlowLoader implements EventSubscriberInterface, ResetInterface
  18. {
  19.     public const KEY = 'flow-loader';
  21.     private array $flows = [];
  23.     private AbstractFlowLoader $decorated;
  25.     private CacheInterface $cache;
  27.     public function __construct(
  28.         AbstractFlowLoader $decorated,
  29.         CacheInterface $cache
  30.     ) {
  31.         $this->decorated = $decorated;
  32.         $this->cache = $cache;
  33.     }
  35.     /**
  36.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  37.      */
  38.     public static function getSubscribedEvents()
  39.     {
  40.         return [
  41.             FlowEvents::FLOW_WRITTEN_EVENT => 'invalidate',
  42.         ];
  43.     }
  45.     public function getDecorated(): AbstractFlowLoader
  46.     {
  47.         return $this->decorated;
  48.     }
  50.     public function load(): array
  51.     {
  52.         if (!empty($this->flows)) {
  53.             return $this->flows;
  54.         }
  56.         $value = $this->cache->get(self::KEY, function (ItemInterface $item) {
  57.             $item->tag([self::KEY]);
  59.             return CacheValueCompressor::compress($this->getDecorated()->load());
  60.         });
  62.         return $this->flows = CacheValueCompressor::uncompress($value);
  63.     }
  65.     public function invalidate(): void
  66.     {
  67.         $this->reset();
  68.         $this->cache->delete(self::KEY);
  69.     }
  71.     public function reset(): void
  72.     {
  73.         $this->flows = [];
  74.     }
  75. }