-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
10 changed files
with
153 additions
and
131 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,117 @@ | ||
| <?php | ||
|
|
||
| /* | ||
| * event-symfony-event-dispatcher (https://github.com/phpgears/event-symfony-event-dispatcher). | ||
| * Event bus with Symfony Event Dispatcher. | ||
| * | ||
| * @license MIT | ||
| * @link https://github.com/phpgears/event-symfony-event-dispatcher | ||
| * @author Julián Gutiérrez <juliangut@gmail.com> | ||
| */ | ||
|
|
||
| declare(strict_types=1); | ||
|
|
||
| namespace Gears\Event\Symfony; | ||
|
|
||
| use Gears\Event\EventHandler; | ||
| use Symfony\Component\EventDispatcher\Event as SymfonyEvent; | ||
| use Symfony\Component\EventDispatcher\EventDispatcher as SymfonyEventDispatcher; | ||
| use Symfony\Component\EventDispatcher\EventSubscriberInterface; | ||
|
|
||
| class Dispatcher extends SymfonyEventDispatcher implements EventDispatcher | ||
| { | ||
| /** | ||
| * ContainerAwareEventDispatcher constructor. | ||
| * | ||
| * @param array<string, mixed> $listenersMap | ||
| */ | ||
| public function __construct(array $listenersMap = []) | ||
| { | ||
| foreach ($listenersMap as $eventName => $listeners) { | ||
| if (!\is_array($listeners)) { | ||
| $listeners = [$listeners]; | ||
| } | ||
|
|
||
| foreach ($listeners as $listener) { | ||
| $this->addListener($eventName, $listener); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * {@inheritdoc} | ||
| */ | ||
| public function addSubscriber(EventSubscriberInterface $subscriber): void | ||
| { | ||
| foreach ($subscriber::getSubscribedEvents() as $eventName => $params) { | ||
| if (!\is_array($params)) { | ||
| $params = [$params]; | ||
| } | ||
|
|
||
| foreach ($params as $listener) { | ||
| if (!\is_array($listener)) { | ||
| $this->addListener($eventName, $listener); | ||
| } else { | ||
| $this->addListener($eventName, $listener[0], $listener[1] ?? 0); | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Adds an event listener that listens on the specified events. | ||
| * | ||
| * @param string $eventName | ||
| * @param mixed $listener | ||
| * @param mixed $priority | ||
| */ | ||
| public function addListener($eventName, $listener, $priority = 0): void | ||
| { | ||
| if (!$listener instanceof EventHandler) { | ||
| throw new \InvalidArgumentException(\sprintf( | ||
| 'Event handler must be an instance of %s, %s given', | ||
| EventHandler::class, | ||
| \is_object($listener) ? \get_class($listener) : \gettype($listener) | ||
| )); | ||
| } | ||
|
|
||
| parent::addListener($eventName, $listener, (int) $priority); | ||
| } | ||
|
|
||
| /** | ||
| * {@inheritdoc} | ||
| */ | ||
| public function dispatch($eventName, SymfonyEvent $event = null): SymfonyEvent | ||
| { | ||
| if ($event === null) { | ||
| throw new \InvalidArgumentException('Dispatched event cannot be empty'); | ||
| } | ||
|
|
||
| if (!$event instanceof EventEnvelope) { | ||
| throw new \InvalidArgumentException(\sprintf( | ||
| 'Dispatched event must implement %s, %s given', | ||
| EventEnvelope::class, | ||
| \get_class($event) | ||
| )); | ||
| } | ||
|
|
||
| $this->dispatchEvent($this->getListeners($eventName), $event); | ||
|
|
||
| return $event; | ||
| } | ||
|
|
||
| /** | ||
| * Dispatch event to registered listeners. | ||
| * | ||
| * @param EventHandler[] $listeners | ||
| * @param EventEnvelope $event | ||
| */ | ||
| private function dispatchEvent(array $listeners, EventEnvelope $event): void | ||
| { | ||
| $dispatchEvent = $event->getWrappedEvent(); | ||
|
|
||
| foreach ($listeners as $handler) { | ||
| $handler->handle($dispatchEvent); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.