src/Core/Content/Rule/DataAbstractionLayer/RulePayloadSubscriber.php line 40

  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.  * @internal
  18.  */
  19. #[Package('business-ops')]
  20. class RulePayloadSubscriber implements EventSubscriberInterface
  21. {
  22.     /**
  23.      * @internal
  24.      */
  25.     public function __construct(
  26.         private readonly RulePayloadUpdater $updater,
  27.         private readonly ScriptTraces $traces,
  28.         private readonly string $cacheDir,
  29.         private readonly bool $debug
  30.     ) {
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             RuleEvents::RULE_LOADED_EVENT => 'unserialize',
  37.         ];
  38.     }
  40.     public function unserialize(EntityLoadedEvent $event): void
  41.     {
  42.         $this->indexIfNeeded($event);
  44.         /** @var RuleEntity $entity */
  45.         foreach ($event->getEntities() as $entity) {
  46.             $payload = $entity->getPayload();
  47.             if ($payload === null || !\is_string($payload)) {
  48.                 continue;
  49.             }
  51.             $payload = unserialize($payload);
  53.             $this->enrichConditions([$payload]);
  55.             $entity->setPayload($payload);
  56.         }
  57.     }
  59.     private function indexIfNeeded(EntityLoadedEvent $event): void
  60.     {
  61.         $rules = [];
  63.         /** @var RuleEntity $rule */
  64.         foreach ($event->getEntities() as $rule) {
  65.             if ($rule->getPayload() === null && !$rule->isInvalid()) {
  66.                 $rules[$rule->getId()] = $rule;
  67.             }
  68.         }
  70.         if (!\count($rules)) {
  71.             return;
  72.         }
  74.         $updated = $this->updater->update(array_keys($rules));
  76.         foreach ($updated as $id => $entity) {
  77.             $rules[$id]->assign($entity);
  78.         }
  79.     }
  81.     /**
  82.      * @param list<Rule> $conditions
  83.      */
  84.     private function enrichConditions(array $conditions): void
  85.     {
  86.         foreach ($conditions as $condition) {
  87.             if ($condition instanceof ScriptRule) {
  88.                 $condition->assign([
  89.                     'traces' => $this->traces,
  90.                     'cacheDir' => $this->cacheDir,
  91.                     'debug' => $this->debug,
  92.                 ]);
  94.                 continue;
  95.             }
  97.             if ($condition instanceof Container || $condition instanceof FilterRule) {
  98.                 $this->enrichConditions($condition->getRules());
  99.             }
  100.         }
  101.     }
  102. }