platform/src/Core/Content/Rule/DataAbstractionLayer/RulePayloadSubscriber.php line 29

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 Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. class RulePayloadSubscriber implements EventSubscriberInterface
  11. {
  12.     /**
  13.      * @var RulePayloadUpdater
  14.      */
  15.     private $updater;
  17.     public function __construct(RulePayloadUpdater $updater)
  18.     {
  19.         $this->updater = $updater;
  20.     }
  22.     public static function getSubscribedEvents(): array
  23.     {
  24.         return [
  25.             RuleEvents::RULE_LOADED_EVENT => 'unserialize',
  26.         ];
  27.     }
  29.     public function unserialize(EntityLoadedEvent $event): void
  30.     {
  31.         $this->indexIfNeeded($event);
  33.         /** @var RuleEntity $entity */
  34.         foreach ($event->getEntities() as $entity) {
  35.             $payload = $entity->getPayload();
  36.             if ($payload === null || !\is_string($payload)) {
  37.                 continue;
  38.             }
  40.             $entity->setPayload(unserialize($payload));
  41.         }
  42.     }
  44.     private function indexIfNeeded(EntityLoadedEvent $event): void
  45.     {
  46.         $rules = [];
  48.         /** @var RuleEntity $rule */
  49.         foreach ($event->getEntities() as $rule) {
  50.             if ($rule->getPayload() === null && !$rule->isInvalid()) {
  51.                 $rules[$rule->getId()] = $rule;
  52.             }
  53.         }
  55.         if (!\count($rules)) {
  56.             return;
  57.         }
  59.         $updated = $this->updater->update(array_keys($rules));
  61.         foreach ($updated as $id => $entity) {
  62.             $rules[$id]->assign($entity);
  63.         }
  64.     }
  65. }