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

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 Shopware\Core\Framework\Feature;
  15. use Shopware\Core\Framework\Log\Package;
  16. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. /**
  20.  * @deprecated tag:v6.5.0 - reason:remove-decorator - Will be removed in v6.5.0, use FlowDispatcher instead.
  21.  */
  22. #[Package('business-ops')]
  23. class BusinessEventDispatcher implements EventDispatcherInterface
  24. {
  25.     /**
  26.      * @var EventDispatcherInterface
  27.      */
  28.     private $dispatcher;
  30.     /**
  31.      * @var EventActionDefinition
  32.      */
  33.     private $eventActionDefinition;
  35.     /**
  36.      * @var DefinitionInstanceRegistry
  37.      */
  38.     private $definitionRegistry;
  40.     /**
  41.      * @internal
  42.      */
  43.     public function __construct(
  44.         EventDispatcherInterface $dispatcher,
  45.         DefinitionInstanceRegistry $definitionRegistry,
  46.         EventActionDefinition $eventActionDefinition
  47.     ) {
  48.         $this->dispatcher = $dispatcher;
  49.         $this->eventActionDefinition = $eventActionDefinition;
  50.         $this->definitionRegistry = $definitionRegistry;
  51.     }
  53.     public function dispatch($event, ?string $eventName = null): object
  54.     {
  55.         $event = $this->dispatcher->dispatch($event, $eventName);
  57.         if (Feature::isActive('FEATURE_NEXT_17858')) {
  58.             return $event;
  59.         }
  61.         if (!$event instanceof BusinessEventInterface || $event instanceof FlowEvent) {
  62.             return $event;
  63.         }
  65.         if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
  66.             return $event;
  67.         }
  69.         $this->callActions($event);
  71.         return $event;
  72.     }
  74.     /**
  75.      * @param callable $listener can not use native type declaration @see https://github.com/symfony/symfony/issues/42283
  76.      */
  77.     public function addListener(string $eventName, $listener, int $priority = 0): void
  78.     {
  79.         $this->dispatcher->addListener($eventName, $listener, $priority);
  80.     }
  82.     public function addSubscriber(EventSubscriberInterface $subscriber): void
  83.     {
  84.         $this->dispatcher->addSubscriber($subscriber);
  85.     }
  87.     /**
  88.      * @param callable $listener can not use native type hint as it is incompatible with symfony <5.3.4
  89.      */
  90.     public function removeListener(string $eventName, $listener): void
  91.     {
  92.         $this->dispatcher->removeListener($eventName, $listener);
  93.     }
  95.     public function removeSubscriber(EventSubscriberInterface $subscriber): void
  96.     {
  97.         $this->dispatcher->removeSubscriber($subscriber);
  98.     }
  100.     public function getListeners(?string $eventName = null): array
  101.     {
  102.         return $this->dispatcher->getListeners($eventName);
  103.     }
  105.     /**
  106.      * @param callable $listener can not use native type hint as it is incompatible with symfony <5.3.4
  107.      */
  108.     public function getListenerPriority(string $eventName, $listener): ?int
  109.     {
  110.         return $this->dispatcher->getListenerPriority($eventName, $listener);
  111.     }
  113.     public function hasListeners(?string $eventName = null): bool
  114.     {
  115.         return $this->dispatcher->hasListeners($eventName);
  116.     }
  118.     private function getActions(BusinessEventInterface $event, Context $context): EventActionCollection
  119.     {
  120.         $name = $event->getName();
  122.         $criteria = new Criteria();
  123.         $criteria->setTitle('business-events::' . $event->getName());
  124.         $criteria->addFilter(new EqualsFilter('event_action.eventName', $name));
  125.         $criteria->addFilter(new EqualsFilter('event_action.active', true));
  127.         $criteria->addFilter(new OrFilter([
  128.             new EqualsFilter('event_action.rules.id', null),
  129.             new EqualsAnyFilter('event_action.rules.id', $context->getRuleIds()),
  130.         ]));
  132.         if ($event instanceof SalesChannelAware) {
  133.             $criteria->addFilter(new OrFilter([
  134.                 new EqualsFilter('salesChannels.id', $event->getSalesChannelId()),
  135.                 new EqualsFilter('salesChannels.id', null),
  136.             ]));
  137.         }
  139.         /** @var EventActionCollection $events */
  140.         $events = $this->definitionRegistry
  141.             ->getRepository($this->eventActionDefinition->getEntityName())
  142.             ->search($criteria, $context)
  143.             ->getEntities();
  145.         return $events;
  146.     }
  148.     private function callActions(BusinessEventInterface $event): void
  149.     {
  150.         $actions = $this->getActions($event, $event->getContext());
  152.         foreach ($actions as $action) {
  153.             $actionEvent = new BusinessEvent($action->getActionName(), $event, $action->getConfig());
  154.             $this->dispatcher->dispatch($actionEvent, $actionEvent->getActionName());
  155.         }
  157.         $globalEvent = new BusinessEvent(BusinessEvents::GLOBAL_EVENT, $event);
  158.         $this->dispatcher->dispatch($globalEvent, $globalEvent->getActionName());
  159.     }
  160. }