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