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

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Rule\DataAbstractionLayer;
  5. use Shopware\Core\Content\Rule\RuleDefinition;
  6. use Shopware\Core\Content\Rule\RuleEntity;
  7. use Shopware\Core\Content\Rule\RuleEvents;
  8. use Shopware\Core\Framework\Adapter\Cache\CacheClearer;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class RulePayloadSubscriber implements EventSubscriberInterface
  13. {
  14.     /**
  15.      * @var CacheClearer
  16.      */
  17.     private $cacheClearer;
  19.     /**
  20.      * @var RulePayloadUpdater
  21.      */
  22.     private $updater;
  24.     public function __construct(RulePayloadUpdater $updater, CacheClearer $cacheClearer)
  25.     {
  26.         $this->updater = $updater;
  27.         $this->cacheClearer = $cacheClearer;
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             RuleEvents::RULE_LOADED_EVENT => 'unserialize',
  34.         ];
  35.     }
  37.     public function unserialize(EntityLoadedEvent $event): void
  38.     {
  39.         $this->indexIfNeeded($event);
  41.         /** @var RuleEntity $entity */
  42.         foreach ($event->getEntities() as $entity) {
  43.             if (!$entity->getPayload() || !\is_string($entity->getPayload())) {
  44.                 continue;
  45.             }
  47.             $unserialized = unserialize($entity->getPayload());
  49.             $entity->setPayload($unserialized);
  50.         }
  51.     }
  53.     private function indexIfNeeded(EntityLoadedEvent $event): void
  54.     {
  55.         $rules = [];
  57.         /** @var RuleEntity $rule */
  58.         foreach ($event->getEntities() as $rule) {
  59.             if ($rule->getPayload() === null && !$rule->isInvalid()) {
  60.                 $rules[$rule->getId()] = $rule;
  61.             }
  62.         }
  64.         if (!\count($rules)) {
  65.             return;
  66.         }
  68.         $updated = $this->updater->update(array_keys($rules));
  70.         foreach ($updated as $id => $entity) {
  71.             $rules[$id]->assign($entity);
  72.         }
  74.         $this->cacheClearer->invalidateIds(array_keys($updated), RuleDefinition::ENTITY_NAME);
  75.     }
  76. }