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

  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(
  24.         private readonly AbstractFlowLoader $decorated,
  25.         private readonly CacheInterface $cache
  26.     ) {
  27.     }
  29.     /**
  30.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  31.      */
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             FlowEvents::FLOW_WRITTEN_EVENT => 'invalidate',
  36.         ];
  37.     }
  39.     public function load(): array
  40.     {
  41.         if (!empty($this->flows)) {
  42.             return $this->flows;
  43.         }
  45.         $value = $this->cache->get(self::KEY, function (ItemInterface $item) {
  46.             $item->tag([self::KEY]);
  48.             return CacheValueCompressor::compress($this->decorated->load());
  49.         });
  51.         return $this->flows = CacheValueCompressor::uncompress($value);
  52.     }
  54.     public function invalidate(): void
  55.     {
  56.         $this->reset();
  57.         $this->cache->delete(self::KEY);
  58.     }
  60.     public function reset(): void
  61.     {
  62.         $this->flows = [];
  63.     }
  64. }