vendor/shopware/core/Framework/Event/BusinessEventDispatcher.php line 46

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\Event;
  5. use Psr\EventDispatcher\StoppableEventInterface;
  6. use Shopware\Core\Framework\Context;
  7. use Shopware\Core\Framework\DataAbstractionLayer\DefinitionInstanceRegistry;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\OrFilter;
  12. use Shopware\Core\Framework\Event\EventAction\EventActionCollection;
  13. use Shopware\Core\Framework\Event\EventAction\EventActionDefinition;
  14. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class BusinessEventDispatcher implements EventDispatcherInterface
  18. {
  19.     /**
  20.      * @var EventDispatcherInterface
  21.      */
  22.     private $dispatcher;
  24.     /**
  25.      * @var EventActionDefinition
  26.      */
  27.     private $eventActionDefinition;
  29.     /**
  30.      * @var DefinitionInstanceRegistry
  31.      */
  32.     private $definitionRegistry;
  34.     public function __construct(
  35.         EventDispatcherInterface $dispatcher,
  36.         DefinitionInstanceRegistry $definitionRegistry,
  37.         EventActionDefinition $eventActionDefinition
  38.     ) {
  39.         $this->dispatcher = $dispatcher;
  40.         $this->eventActionDefinition = $eventActionDefinition;
  41.         $this->definitionRegistry = $definitionRegistry;
  42.     }
  44.     public function dispatch($event, ?string $eventName = null): object
  45.     {
  46.         $event = $this->dispatcher->dispatch($event, $eventName);
  48.         if (!$event instanceof BusinessEventInterface) {
  49.             return $event;
  50.         }
  52.         if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
  53.             return $event;
  54.         }
  56.         $this->callActions($event);
  58.         return $event;
  59.     }
  61.     /**
  62.      * @param callable $listener can not use native type declaration @see https://github.com/symfony/symfony/issues/42283
  63.      */
  64.     public function addListener(string $eventName, $listener, int $priority = 0): void
  65.     {
  66.         $this->dispatcher->addListener($eventName, $listener, $priority);
  67.     }
  69.     public function addSubscriber(EventSubscriberInterface $subscriber): void
  70.     {
  71.         $this->dispatcher->addSubscriber($subscriber);
  72.     }
  74.     /**
  75.      * @param callable $listener can not use native type hint as it is incompatible with symfony <5.3.4
  76.      */
  77.     public function removeListener(string $eventName, $listener): void
  78.     {
  79.         $this->dispatcher->removeListener($eventName, $listener);
  80.     }
  82.     public function removeSubscriber(EventSubscriberInterface $subscriber): void
  83.     {
  84.         $this->dispatcher->removeSubscriber($subscriber);
  85.     }
  87.     public function getListeners(?string $eventName = null): array
  88.     {
  89.         return $this->dispatcher->getListeners($eventName);
  90.     }
  92.     /**
  93.      * @param callable $listener can not use native type hint as it is incompatible with symfony <5.3.4
  94.      */
  95.     public function getListenerPriority(string $eventName, $listener): ?int
  96.     {
  97.         return $this->dispatcher->getListenerPriority($eventName, $listener);
  98.     }
  100.     public function hasListeners(?string $eventName = null): bool
  101.     {
  102.         return $this->dispatcher->hasListeners($eventName);
  103.     }
  105.     private function getActions(BusinessEventInterface $event, Context $context): EventActionCollection
  106.     {
  107.         $name = $event->getName();
  109.         $criteria = new Criteria();
  110.         $criteria->addFilter(new EqualsFilter('event_action.eventName', $name));
  111.         $criteria->addFilter(new EqualsFilter('event_action.active', true));
  113.         $criteria->addFilter(new OrFilter([
  114.             new EqualsFilter('event_action.rules.id', null),
  115.             new EqualsAnyFilter('event_action.rules.id', $context->getRuleIds()),
  116.         ]));
  118.         if ($event instanceof SalesChannelAware) {
  119.             $criteria->addFilter(new OrFilter([
  120.                 new EqualsFilter('salesChannels.id', $event->getSalesChannelId()),
  121.                 new EqualsFilter('salesChannels.id', null),
  122.             ]));
  123.         }
  125.         /** @var EventActionCollection $events */
  126.         $events = $this->definitionRegistry
  127.             ->getRepository($this->eventActionDefinition->getEntityName())
  128.             ->search($criteria, $context)
  129.             ->getEntities();
  131.         return $events;
  132.     }
  134.     private function callActions(BusinessEventInterface $event): void
  135.     {
  136.         $actions = $this->getActions($event, $event->getContext());
  138.         foreach ($actions as $action) {
  139.             $actionEvent = new BusinessEvent($action->getActionName(), $event, $action->getConfig());
  140.             $this->dispatcher->dispatch($actionEvent, $actionEvent->getActionName());
  141.         }
  143.         $globalEvent = new BusinessEvent(BusinessEvents::GLOBAL_EVENT, $event);
  144.         $this->dispatcher->dispatch($globalEvent, $globalEvent->getActionName());
  145.     }
  146. }