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. }