vendor/shopware/core/Content/Rule/DataAbstractionLayer/RulePayloadSubscriber.php line 52

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Rule\DataAbstractionLayer;
  5. use Shopware\Core\Content\Rule\RuleEntity;
  6. use Shopware\Core\Content\Rule\RuleEvents;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  8. use Shopware\Core\Framework\Log\Package;
  9. use Shopware\Core\Framework\Rule\Container\Container;
  10. use Shopware\Core\Framework\Rule\Container\FilterRule;
  11. use Shopware\Core\Framework\Rule\Rule;
  12. use Shopware\Core\Framework\Rule\ScriptRule;
  13. use Shopware\Core\Framework\Script\Debugging\ScriptTraces;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. /**
  17. * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  18. */
  19. #[Package('business-ops')]
  20. class RulePayloadSubscriber implements EventSubscriberInterface
  21. {
  22. private RulePayloadUpdater $updater;
  24. private ScriptTraces $traces;
  26. private string $cacheDir;
  28. private bool $debug;
  30. /**
  31. * @internal
  32. */
  33. public function __construct(
  34. RulePayloadUpdater $updater,
  35. ScriptTraces $traces,
  36. string $cacheDir,
  37. bool $debug
  38. ) {
  39. $this->updater = $updater;
  40. $this->traces = $traces;
  41. $this->cacheDir = $cacheDir;
  42. $this->debug = $debug;
  43. }
  45. public static function getSubscribedEvents(): array
  46. {
  47. return [
  48. RuleEvents::RULE_LOADED_EVENT => 'unserialize',
  49. ];
  50. }
  52. public function unserialize(EntityLoadedEvent $event): void
  53. {
  54. $this->indexIfNeeded($event);
  56. /** @var RuleEntity $entity */
  57. foreach ($event->getEntities() as $entity) {
  58. $payload = $entity->getPayload();
  59. if ($payload === null || !\is_string($payload)) {
  60. continue;
  61. }
  63. $payload = unserialize($payload);
  65. $this->enrichConditions([$payload]);
  67. $entity->setPayload($payload);
  68. }
  69. }
  71. private function indexIfNeeded(EntityLoadedEvent $event): void
  72. {
  73. $rules = [];
  75. /** @var RuleEntity $rule */
  76. foreach ($event->getEntities() as $rule) {
  77. if ($rule->getPayload() === null && !$rule->isInvalid()) {
  78. $rules[$rule->getId()] = $rule;
  79. }
  80. }
  82. if (!\count($rules)) {
  83. return;
  84. }
  86. $updated = $this->updater->update(array_keys($rules));
  88. foreach ($updated as $id => $entity) {
  89. $rules[$id]->assign($entity);
  90. }
  91. }
  93. /**
  94. * @param list<Rule> $conditions
  95. */
  96. private function enrichConditions(array $conditions): void
  97. {
  98. foreach ($conditions as $condition) {
  99. if ($condition instanceof ScriptRule) {
  100. $condition->assign([
  101. 'traces' => $this->traces,
  102. 'cacheDir' => $this->cacheDir,
  103. 'debug' => $this->debug,
  104. ]);
  106. continue;
  107. }
  109. if ($condition instanceof Container || $condition instanceof FilterRule) {
  110. $this->enrichConditions($condition->getRules());
  111. }
  112. }
  113. }
  114. }