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

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\Event;
  5. use Shopware\Core\Framework\Context;
  6. use Shopware\Core\Framework\DataAbstractionLayer\DefinitionInstanceRegistry;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  9. use Shopware\Core\Framework\Event\EventAction\EventActionCollection;
  10. use Shopware\Core\Framework\Event\EventAction\EventActionDefinition;
  11. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class BusinessEventDispatcher implements EventDispatcherInterface
  15. {
  16.     /**
  17.      * @var EventDispatcherInterface
  18.      */
  19.     private $dispatcher;
  21.     /**
  22.      * @var EventActionDefinition
  23.      */
  24.     private $eventActionDefinition;
  26.     /**
  27.      * @var DefinitionInstanceRegistry
  28.      */
  29.     private $definitionRegistry;
  31.     public function __construct(
  32.         EventDispatcherInterface $dispatcher,
  33.         DefinitionInstanceRegistry $definitionRegistry,
  34.         EventActionDefinition $eventActionDefinition
  35.     ) {
  36.         $this->dispatcher = $dispatcher;
  37.         $this->eventActionDefinition = $eventActionDefinition;
  38.         $this->definitionRegistry = $definitionRegistry;
  39.     }
  41.     public function dispatch($event, ?string $eventName = null): object
  42.     {
  43.         $event = $this->dispatcher->dispatch($event, $eventName);
  45.         if ($event instanceof BusinessEventInterface) {
  46.             $this->callActions($event);
  47.         }
  49.         return $event;
  50.     }
  52.     public function addListener($eventName, $listener, $priority = 0): void
  53.     {
  54.         $this->dispatcher->addListener($eventName, $listener, $priority);
  55.     }
  57.     public function addSubscriber(EventSubscriberInterface $subscriber): void
  58.     {
  59.         $this->dispatcher->addSubscriber($subscriber);
  60.     }
  62.     public function removeListener($eventName, $listener): void
  63.     {
  64.         $this->dispatcher->removeListener($eventName, $listener);
  65.     }
  67.     public function removeSubscriber(EventSubscriberInterface $subscriber): void
  68.     {
  69.         $this->dispatcher->removeSubscriber($subscriber);
  70.     }
  72.     public function getListeners($eventName = null): array
  73.     {
  74.         return $this->dispatcher->getListeners($eventName);
  75.     }
  77.     public function getListenerPriority($eventName, $listener): ?int
  78.     {
  79.         return $this->dispatcher->getListenerPriority($eventName, $listener);
  80.     }
  82.     public function hasListeners($eventName = null): bool
  83.     {
  84.         return $this->dispatcher->hasListeners($eventName);
  85.     }
  87.     private function getActions(string $eventName, Context $context): EventActionCollection
  88.     {
  89.         $criteria = new Criteria();
  90.         $criteria->addFilter(new EqualsFilter('event_action.eventName', $eventName));
  92.         /** @var EventActionCollection $events */
  93.         $events = $this->definitionRegistry
  94.             ->getRepository($this->eventActionDefinition->getEntityName())
  95.             ->search($criteria, $context)
  96.             ->getEntities();
  98.         return $events;
  99.     }
  101.     private function callActions(BusinessEventInterface $event): void
  102.     {
  103.         $actions = $this->getActions($event->getName(), $event->getContext());
  105.         foreach ($actions as $action) {
  106.             $actionEvent = new BusinessEvent($action->getActionName(), $event, $action->getConfig());
  107.             $this->dispatcher->dispatch($actionEvent, $actionEvent->getActionName());
  108.         }
  110.         $globalEvent = new BusinessEvent(BusinessEvents::GLOBAL_EVENT, $event);
  111.         $this->dispatcher->dispatch($globalEvent, $globalEvent->getActionName());
  112.     }
  113. }