eee

This reverts commit fdf58326

.phpstorm.meta.php

@@ -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

@@ -1,11 +1,12 @@
 <?php
+declare(strict_types=1);
 
 namespace Kiri\Events;
 
 use Kiri\Abstracts\Component;
-use Kiri\Kiri;
 use Psr\EventDispatcher\EventDispatcherInterface;
 use Psr\EventDispatcher\StoppableEventInterface;
+use SplPriorityQueue;
 
 
 /**
@@ -18,14 +19,31 @@ class EventDispatch extends Component implements EventDispatcherInterface
 	/**
 	 * @param object $event
 	 * @return object
-	 * @throws \ReflectionException
      */
 	public function dispatch(object $event): object
 	{
-		$lists = $this->eventProvider->getListenersForEvent($event);
+		$lists = make(EventProvider::class)->getListenersForEvent($event);
-		foreach ($lists as $listener) {
+
-			/** @var Struct $list */
+		return $this->execute($lists, $event);
-			$listener($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) {
+				\Kiri::getLogger()->json_log($exception);
+            }
             if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
                 break;
             }

EventInterface.php

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

EventListener.php

@@ -0,0 +1,39 @@
+<?php
+
+namespace Kiri\Events;
+
+
+use Exception;
+use Kiri\Di\Interface\InjectTargetInterface;
+
+#[\Attribute]
+readonly class EventListener implements InjectTargetInterface
+{
+
+
+    /**
+     * @param string $event
+     * @throws Exception
+     */
+    public function __construct(public string $event)
+    {
+    }
+
+
+    /**
+     * @param string $class
+     * @return void
+     * @throws Exception
+     */
+    public function dispatch(string $class): void
+    {
+        // TODO: Implement dispatch() method.
+        $target = \Kiri::getDi()->getReflectionClass($class)->newInstanceWithoutConstructor();
+		
+		if (!($target instanceof EventInterface)) {
+            throw new Exception("Event listen must implement " . EventInterface::class);
+        }
+        on($this->event, [$target, "process"]);
+    }
+
+}

EventProvider.php

@@ -1,9 +1,12 @@
 <?php
+declare(strict_types=1);
 
 namespace Kiri\Events;
 
 
+use Closure;
 use Psr\EventDispatcher\ListenerProviderInterface;
+use SplPriorityQueue;
 
 /**
  *
@@ -17,11 +20,12 @@ class EventProvider implements ListenerProviderInterface
 
     /**
      * @param object $event
-	 * @return iterable
+     * @return SplPriorityQueue
      */
-	public function getListenersForEvent(object $event): iterable
+    public function getListenersForEvent(object $event): SplPriorityQueue
     {
-		$queue = new \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);
@@ -32,13 +36,32 @@ class EventProvider implements ListenerProviderInterface
 
     /**
      * @param string $event
-	 * @param callable $handler
+     * @param array|Closure|string $handler
      * @param int $zOrder
+     * @throws
      */
-	public function on(string $event, callable $handler, int $zOrder = 1)
+    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

@@ -12,11 +12,17 @@ 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)
+
+    /**
+     * @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;

TestListener.php

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

composer.json

@@ -9,7 +9,7 @@
   ],
   "license": "MIT",
   "require": {
-    "php": ">=8.0",
+    "php": ">=8.5",
     "psr/event-dispatcher": "^1.0"
   },
   "autoload": {