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

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\ScriptRule;
  11. use Shopware\Core\Framework\Script\Debugging\ScriptTraces;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class RulePayloadSubscriber implements EventSubscriberInterface
  15. {
  16.     private RulePayloadUpdater $updater;
  18.     private ScriptTraces $traces;
  20.     private string $cacheDir;
  22.     private bool $debug;
  24.     /**
  25.      * @internal
  26.      */
  27.     public function __construct(
  28.         RulePayloadUpdater $updater,
  29.         ScriptTraces $traces,
  30.         string $cacheDir,
  31.         bool $debug
  32.     ) {
  33.         $this->updater = $updater;
  34.         $this->traces = $traces;
  35.         $this->cacheDir = $cacheDir;
  36.         $this->debug = $debug;
  37.     }
  39.     public static function getSubscribedEvents(): array
  40.     {
  41.         return [
  42.             RuleEvents::RULE_LOADED_EVENT => 'unserialize',
  43.         ];
  44.     }
  46.     public function unserialize(EntityLoadedEvent $event): void
  47.     {
  48.         $this->indexIfNeeded($event);
  50.         /** @var RuleEntity $entity */
  51.         foreach ($event->getEntities() as $entity) {
  52.             $payload = $entity->getPayload();
  53.             if ($payload === null || !\is_string($payload)) {
  54.                 continue;
  55.             }
  57.             $payload = unserialize($payload);
  59.             $this->enrichConditions([$payload]);
  61.             $entity->setPayload($payload);
  62.         }
  63.     }
  65.     private function indexIfNeeded(EntityLoadedEvent $event): void
  66.     {
  67.         $rules = [];
  69.         /** @var RuleEntity $rule */
  70.         foreach ($event->getEntities() as $rule) {
  71.             if ($rule->getPayload() === null && !$rule->isInvalid()) {
  72.                 $rules[$rule->getId()] = $rule;
  73.             }
  74.         }
  76.         if (!\count($rules)) {
  77.             return;
  78.         }
  80.         $updated = $this->updater->update(array_keys($rules));
  82.         foreach ($updated as $id => $entity) {
  83.             $rules[$id]->assign($entity);
  84.         }
  85.     }
  87.     private function enrichConditions(array $conditions): void
  88.     {
  89.         foreach ($conditions as $condition) {
  90.             if ($condition instanceof ScriptRule) {
  91.                 $condition->assign([
  92.                     'traces' => $this->traces,
  93.                     'cacheDir' => $this->cacheDir,
  94.                     'debug' => $this->debug,
  95.                 ]);
  97.                 continue;
  98.             }
  100.             if ($condition instanceof Container || $condition instanceof FilterRule) {
  101.                 $this->enrichConditions($condition->getRules());
  102.             }
  103.         }
  104.     }
  105. }