src/Core/Content/Flow/Dispatching/CachedFlowLoader.php line 52

  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.     final public const KEY = 'flow-loader';
  21.     private array $flows = [];
  23.     public function __construct(private readonly AbstractFlowLoader $decorated, private readonly CacheInterface $cache)
  24.     {
  25.     }
  27.     /**
  28.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  29.      */
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             FlowEvents::FLOW_WRITTEN_EVENT => 'invalidate',
  34.         ];
  35.     }
  37.     public function load(): array
  38.     {
  39.         if (!empty($this->flows)) {
  40.             return $this->flows;
  41.         }
  43.         $value = $this->cache->get(self::KEY, function (ItemInterface $item) {
  44.             $item->tag([self::KEY]);
  46.             return CacheValueCompressor::compress($this->decorated->load());
  47.         });
  49.         return $this->flows = CacheValueCompressor::uncompress($value);
  50.     }
  52.     public function invalidate(): void
  53.     {
  54.         $this->reset();
  55.         $this->cache->delete(self::KEY);
  56.     }
  58.     public function reset(): void
  59.     {
  60.         $this->flows = [];
  61.     }
  62. }