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. }