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

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\Rule\Container\Container;
  9. use Shopware\Core\Framework\Rule\Container\FilterRule;
  10. use Shopware\Core\Framework\Rule\Rule;
  11. use Shopware\Core\Framework\Rule\ScriptRule;
  12. use Shopware\Core\Framework\Script\Debugging\ScriptTraces;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. /**
  16.  * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  17.  */
  18. class RulePayloadSubscriber implements EventSubscriberInterface
  19. {
  20.     private RulePayloadUpdater $updater;
  22.     private ScriptTraces $traces;
  24.     private string $cacheDir;
  26.     private bool $debug;
  28.     /**
  29.      * @internal
  30.      */
  31.     public function __construct(
  32.         RulePayloadUpdater $updater,
  33.         ScriptTraces $traces,
  34.         string $cacheDir,
  35.         bool $debug
  36.     ) {
  37.         $this->updater = $updater;
  38.         $this->traces = $traces;
  39.         $this->cacheDir = $cacheDir;
  40.         $this->debug = $debug;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             RuleEvents::RULE_LOADED_EVENT => 'unserialize',
  47.         ];
  48.     }
  50.     public function unserialize(EntityLoadedEvent $event): void
  51.     {
  52.         $this->indexIfNeeded($event);
  54.         /** @var RuleEntity $entity */
  55.         foreach ($event->getEntities() as $entity) {
  56.             $payload = $entity->getPayload();
  57.             if ($payload === null || !\is_string($payload)) {
  58.                 continue;
  59.             }
  61.             $payload = unserialize($payload);
  63.             $this->enrichConditions([$payload]);
  65.             $entity->setPayload($payload);
  66.         }
  67.     }
  69.     private function indexIfNeeded(EntityLoadedEvent $event): void
  70.     {
  71.         $rules = [];
  73.         /** @var RuleEntity $rule */
  74.         foreach ($event->getEntities() as $rule) {
  75.             if ($rule->getPayload() === null && !$rule->isInvalid()) {
  76.                 $rules[$rule->getId()] = $rule;
  77.             }
  78.         }
  80.         if (!\count($rules)) {
  81.             return;
  82.         }
  84.         $updated = $this->updater->update(array_keys($rules));
  86.         foreach ($updated as $id => $entity) {
  87.             $rules[$id]->assign($entity);
  88.         }
  89.     }
  91.     /**
  92.      * @param list<Rule> $conditions
  93.      */
  94.     private function enrichConditions(array $conditions): void
  95.     {
  96.         foreach ($conditions as $condition) {
  97.             if ($condition instanceof ScriptRule) {
  98.                 $condition->assign([
  99.                     'traces' => $this->traces,
  100.                     'cacheDir' => $this->cacheDir,
  101.                     'debug' => $this->debug,
  102.                 ]);
  104.                 continue;
  105.             }
  107.             if ($condition instanceof Container || $condition instanceof FilterRule) {
  108.                 $this->enrichConditions($condition->getRules());
  109.             }
  110.         }
  111.     }
  112. }