eee

This reverts commit fdf58326

.phpstorm.meta.php

@@ -3,7 +3,7 @@
 namespace PHPSTORM_META {
 
     // Reflect
-	use Http\Context\Context;
+	use Kiri\Message\Context\Context;
 	use Kiri\Di\Container;
 
 	override(Container::get(0), map('@'));
@@ -12,6 +12,6 @@ namespace PHPSTORM_META {
 //    override(\make(0), map('@'));
     override(\di(0), map('@'));
     override(\duplicate(0), map('@'));
-    override(Context::getContext(0), map('@'));
+    override(Context::get(0), map('@'));
 
 }

EventDispatch.php

@@ -0,0 +1,55 @@
+<?php
+declare(strict_types=1);
+
+namespace Kiri\Events;
+
+use Kiri\Abstracts\Component;
+use Psr\EventDispatcher\EventDispatcherInterface;
+use Psr\EventDispatcher\StoppableEventInterface;
+use SplPriorityQueue;
+
+
+/**
+ *
+ */
+class EventDispatch extends Component implements EventDispatcherInterface
+{
+
+
+	/**
+	 * @param object $event
+	 * @return object
+     */
+	public function dispatch(object $event): object
+	{
+		$lists = make(EventProvider::class)->getListenersForEvent($event);
+
+		return $this->execute($lists, $event);
+	}
+
+
+    /**
+     * @param SplPriorityQueue $lists
+     * @param object $event
+     * @return object
+     */
+	public function execute(SplPriorityQueue $lists, object $event): object
+	{
+		if ($lists->isEmpty()) {
+			return $event;
+		}
+        foreach ($lists as $item)  {
+            try {
+                call_user_func($item, $event);
+            } catch (\Throwable $exception) {
+                error($exception);
+            }
+            if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
+                break;
+            }
+        }
+		return $event;
+	}
+
+
+}

EventInterface.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Kiri\Events;
+
+interface EventInterface
+{
+
+    /**
+     * @return void
+     */
+    public function process(): void;
+
+}

EventProvider.php

@@ -0,0 +1,67 @@
+<?php
+declare(strict_types=1);
+
+namespace Kiri\Events;
+
+
+use Closure;
+use Psr\EventDispatcher\ListenerProviderInterface;
+use SplPriorityQueue;
+
+/**
+ *
+ */
+class EventProvider implements ListenerProviderInterface
+{
+
+    /** @var Struct[] */
+    private array $_listeners = [];
+
+
+    /**
+     * @param object $event
+     * @return SplPriorityQueue
+     */
+    public function getListenersForEvent(object $event): SplPriorityQueue
+    {
+        $queue = new SplPriorityQueue();
+        $queue->setExtractFlags(SplPriorityQueue::EXTR_DATA);
+        // TODO: Implement getListenersForEvent() method.
+        foreach ($this->_listeners[get_class($event)] ?? [] as $listener) {
+            $queue->insert($listener->listener, $listener->priority);
+        }
+        return $queue;
+    }
+
+
+    /**
+     * @param string $event
+     * @param array|Closure|string $handler
+     * @param int $zOrder
+     * @throws
+     */
+    public function on(string $event, array|Closure|string $handler, int $zOrder = 1): void
+    {
+        if (is_string($handler) && !is_callable($handler, true)) {
+            throw new \Exception('Event handler must is execute function.');
+        }
+        $this->_listeners[$event][] = new Struct($event, $handler, $zOrder);
+    }
+
+
+    /**
+     * @param string $event
+     * @param callable $handler
+     * @return void
+     */
+    public function off(string $event, callable $handler): void
+    {
+        $events = $this->_listeners[$event] ?? [];
+
+        $this->_listeners[$event] = array_filter($events, function ($value) use ($handler) {
+            return $value->listener !== $handler;
+        });
+    }
+
+
+}

Struct.php

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

TestListener.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace Kiri\Events;
+
+class TestListener implements EventInterface
+{
+
+
+    /**
+     * @return void
+     */
+    public function process(): void
+    {
+        // TODO: Implement process() method.
+    }
+
+}

composer.json

@@ -10,15 +10,13 @@
   "license": "MIT",
   "require": {
     "php": ">=8.0",
-    "ext-json": "*",
     "psr/event-dispatcher": "^1.0"
   },
   "autoload": {
     "psr-4": {
-      "Kiri\\Events\\": "src/"
+      "Kiri\\Events\\": "./"
      }
   },
   "require-dev": {
-    "kwn/php-rdkafka-stubs": "^2.0"
   }
 }

src/EventDispatch.php

@@ -1,42 +0,0 @@
-<?php
-
-namespace Kiri\Events;
-
-use Kiri\Abstracts\Component;
-use Note\Inject;
-use Psr\EventDispatcher\EventDispatcherInterface;
-use Psr\EventDispatcher\StoppableEventInterface;
-
-
-/**
- *
- */
-class EventDispatch extends Component 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

@@ -1,44 +0,0 @@
-<?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

@@ -1,25 +0,0 @@
-<?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;
-	}
-}