e

composer.json

@@ -11,11 +11,11 @@
   "require": {
     "php": ">=8.0",
     "ext-json": "*",
-    "psr/http-message": "^1.0"
+    "psr/event-dispatcher": "^1.0"
   },
   "autoload": {
     "psr-4": {
-      "HttpMessage\\": "src/"
+      "Kiri\\Events\\": "src/"
      }
   },
   "require-dev": {

src/EventDispatch.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace Kiri\Events;
+
+use Annotation\Inject;
+use Kiri\Abstracts\BaseObject;
+use Psr\EventDispatcher\EventDispatcherInterface;
+use Psr\EventDispatcher\StoppableEventInterface;
+
+
+/**
+ *
+ */
+class EventDispatch extends BaseObject implements EventDispatcherInterface
+{
+
+	/**
+	 * @var EventProvider
+	 */
+	#[Inject(EventProvider::class)]
+	public EventProvider $eventProvider;
+
+
+	/**
+	 * @param object $event
+	 * @return object
+	 */
+	public function dispatch(object $event): object
+	{
+		$lists = $this->eventProvider->getListenersForEvent($event);
+		foreach ($lists as $listener) {
+			/** @var Struct $list */
+			$listener($event);
+			if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
+				break;
+			}
+		}
+		return $event;
+	}
+
+
+}

src/EventProvider.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace Kiri\Events;
+
+
+use Psr\EventDispatcher\ListenerProviderInterface;
+
+/**
+ *
+ */
+class EventProvider implements ListenerProviderInterface
+{
+
+	/** @var Struct[] */
+	private array $_listeners = [];
+
+
+	/**
+	 * @param object $event
+	 * @return iterable
+	 */
+	public function getListenersForEvent(object $event): iterable
+	{
+		$queue = new \SplPriorityQueue();
+		// TODO: Implement getListenersForEvent() method.
+		foreach ($this->_listeners[get_class($event)] ?? [] as $listener) {
+			$queue->insert($listener->listener, $listener->priority);
+		}
+		return $queue;
+	}
+
+
+	/**
+	 * @param string $event
+	 * @param callable $handler
+	 * @param int $zOrder
+	 */
+	public function on(string $event, callable $handler, int $zOrder = 1)
+	{
+		$this->_listeners[$event][] = new Struct($event, $handler, $zOrder);
+	}
+
+
+}

src/Struct.php

@@ -0,0 +1,25 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Kiri\Events;
+
+/**
+ *
+ */
+class Struct
+{
+
+	public string $event;
+
+	public array|\Closure $listener;
+
+	public int $priority;
+
+	public function __construct(string $event, callable $listener, int $priority)
+	{
+		$this->event = $event;
+		$this->listener = $listener;
+		$this->priority = $priority;
+	}
+}