变更

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('@'));

EventDispatch.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace Kiri\Events;
+
+use Kiri;
+use Kiri\Abstracts\Component;
+use Psr\Container\ContainerExceptionInterface;
+use Psr\Container\NotFoundExceptionInterface;
+use Psr\EventDispatcher\EventDispatcherInterface;
+use Psr\EventDispatcher\StoppableEventInterface;
+
+
+/**
+ *
+ */
+class EventDispatch extends Component implements EventDispatcherInterface
+{
+
+
+	/**
+	 * @param EventProvider $eventProvider
+	 * @param array $config
+	 * @throws \Exception
+	 */
+	public function __construct(public EventProvider $eventProvider, array $config = [])
+	{
+		parent::__construct($config);
+	}
+
+
+	/**
+	 * @param object $event
+	 * @return object
+	 * @throws ContainerExceptionInterface
+	 * @throws NotFoundExceptionInterface
+	 */
+	public function dispatch(object $event): object
+	{
+		$lists = $this->eventProvider->getListenersForEvent($event);
+		if (!$lists->valid()) {
+			return $event;
+		}
+		$lists->top();
+		while ($lists->valid()) {
+			try {
+				call_user_func($lists->current(), $event);
+			} catch (\Throwable $exception) {
+				$this->logger->error($exception->getMessage(), [$exception]);
+			}
+			if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
+				break;
+			}
+			$lists->next();
+		}
+		return $event;
+	}
+
+
+}

EventProvider.php

@@ -0,0 +1,65 @@
+<?php
+
+namespace Kiri\Events;
+
+
+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 \Exception
+	 */
+	public function on(string $event, array|\Closure|string $handler, int $zOrder = 1)
+	{
+		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

@@ -12,11 +12,11 @@ class Struct
 
 	public string $event;
 
-	public array|\Closure $listener;
+	public array|\Closure|string $listener;
 
 	public int $priority;
 
-	public function __construct(string $event, callable $listener, int $priority)
+	public function __construct(string $event, array|\Closure|string $listener, int $priority)
 	{
 		$this->event = $event;
 		$this->listener = $listener;

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 Note\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

@@ -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);
-	}
-
-
-}