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

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\EqualsFilter;
  10. use Shopware\Core\Framework\Event\EventAction\EventActionCollection;
  11. use Shopware\Core\Framework\Event\EventAction\EventActionDefinition;
  12. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class BusinessEventDispatcher implements EventDispatcherInterface
  16. {
  17.     /**
  18.      * @var EventDispatcherInterface
  19.      */
  20.     private $dispatcher;
  22.     /**
  23.      * @var EventActionDefinition
  24.      */
  25.     private $eventActionDefinition;
  27.     /**
  28.      * @var DefinitionInstanceRegistry
  29.      */
  30.     private $definitionRegistry;
  32.     public function __construct(
  33.         EventDispatcherInterface $dispatcher,
  34.         DefinitionInstanceRegistry $definitionRegistry,
  35.         EventActionDefinition $eventActionDefinition
  36.     ) {
  37.         $this->dispatcher = $dispatcher;
  38.         $this->eventActionDefinition = $eventActionDefinition;
  39.         $this->definitionRegistry = $definitionRegistry;
  40.     }
  42.     public function dispatch($event, ?string $eventName = null): object
  43.     {
  44.         $event = $this->dispatcher->dispatch($event, $eventName);
  46.         if (!$event instanceof BusinessEventInterface) {
  47.             return $event;
  48.         }
  50.         if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
  51.             return $event;
  52.         }
  54.         $this->callActions($event);
  56.         return $event;
  57.     }
  59.     public function addListener($eventName, $listener, $priority = 0): void
  60.     {
  61.         $this->dispatcher->addListener($eventName, $listener, $priority);
  62.     }
  64.     public function addSubscriber(EventSubscriberInterface $subscriber): void
  65.     {
  66.         $this->dispatcher->addSubscriber($subscriber);
  67.     }
  69.     public function removeListener($eventName, $listener): void
  70.     {
  71.         $this->dispatcher->removeListener($eventName, $listener);
  72.     }
  74.     public function removeSubscriber(EventSubscriberInterface $subscriber): void
  75.     {
  76.         $this->dispatcher->removeSubscriber($subscriber);
  77.     }
  79.     public function getListeners($eventName = null): array
  80.     {
  81.         return $this->dispatcher->getListeners($eventName);
  82.     }
  84.     public function getListenerPriority($eventName, $listener): ?int
  85.     {
  86.         return $this->dispatcher->getListenerPriority($eventName, $listener);
  87.     }
  89.     public function hasListeners($eventName = null): bool
  90.     {
  91.         return $this->dispatcher->hasListeners($eventName);
  92.     }
  94.     private function getActions(string $eventName, Context $context): EventActionCollection
  95.     {
  96.         $criteria = new Criteria();
  97.         $criteria->addFilter(new EqualsFilter('event_action.eventName', $eventName));
  99.         /** @var EventActionCollection $events */
  100.         $events = $this->definitionRegistry
  101.             ->getRepository($this->eventActionDefinition->getEntityName())
  102.             ->search($criteria, $context)
  103.             ->getEntities();
  105.         return $events;
  106.     }
  108.     private function callActions(BusinessEventInterface $event): void
  109.     {
  110.         $actions = $this->getActions($event->getName(), $event->getContext());
  112.         foreach ($actions as $action) {
  113.             $actionEvent = new BusinessEvent($action->getActionName(), $event, $action->getConfig());
  114.             $this->dispatcher->dispatch($actionEvent, $actionEvent->getActionName());
  115.         }
  117.         $globalEvent = new BusinessEvent(BusinessEvents::GLOBAL_EVENT, $event);
  118.         $this->dispatcher->dispatch($globalEvent, $globalEvent->getActionName());
  119.     }
  120. }