modify plugin name

This reverts commit fdf58326

.gitignore

@@ -1,34 +1,34 @@
-# Created by .ignore support plugin (hsz.mobi)
+# Created by .ignore support plugin (hsz.mobi)
-### Yii template
+### Yii template
-assets/*
+assets/*
-!assets/.gitignore
+!assets/.gitignore
-protected/runtime/*
+protected/runtime/*
-!protected/runtime/.gitignore
+!protected/runtime/.gitignore
-protected/data/*.db
+protected/data/*.db
-themes/classic/views/
+themes/classic/views/
-
+
-### Example user template template
+### Example user template template
-### Example user template
+### Example user template
-
+
-# IntelliJ project files
+# IntelliJ project files
-.idea
+.idea
-*.iml
+*.iml
-out
+out
-gen
+gen
-
+
-composer.lock
+composer.lock
-
+
-*.log
+*.log
-commands/result
+commands/result
-config/setting.php
+config/setting.php
-tests/
+tests/
-vendor/
+vendor/
-runtime/
+runtime/
-
+
-*.xml
+*.xml
-*.lock
+*.lock
-
+
-oot
+oot
-d
+d
-
+
-composer.lock
+composer.lock

.phpstorm.meta.php

@@ -1,17 +1,17 @@
-<?php
+<?php
-
+
-namespace PHPSTORM_META {
+namespace PHPSTORM_META {
-
+
-    // Reflect
+    // Reflect
-	use Http\Context\Context;
+	use Kiri\Message\Context\Context;
-	use Kiri\Di\Container;
+	use Kiri\Di\Container;
-
+
-	override(Container::get(0), map('@'));
+	override(Container::get(0), map('@'));
-	override(Container::newObject(0), map('@'));
+	override(Container::newObject(0), map('@'));
-//    override(\Hyperf\Utils\Context::get(0), map('@'));
+//    override(\Hyperf\Utils\Context::get(0), map('@'));
-//    override(\make(0), map('@'));
+//    override(\make(0), map('@'));
-    override(\di(0), map('@'));
+    override(\di(0), map('@'));
-    override(\duplicate(0), map('@'));
+    override(\duplicate(0), map('@'));
-    override(Context::getContext(0), map('@'));
+    override(Context::getContext(0), map('@'));
-
+
-}
+}

EventDispatch.php

@@ -0,0 +1,51 @@
+<?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);
+		foreach ($lists as $listener) {
+			/** @var Struct $list */
+			$listener($event);
+			if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
+				break;
+			}
+		}
+		return $event;
+	}
+
+
+}

EventProvider.php

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

Struct.php

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

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