eee

.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,13 +1,12 @@
 <?php
+declare(strict_types=1);
 
 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;
+use SplPriorityQueue;
 
 
 /**
@@ -18,40 +17,37 @@ class EventDispatch extends Component implements EventDispatcherInterface
 
 
 	/**
-	 * @param EventProvider $eventProvider
+	 * @param object $event
-	 * @param array $config
+	 * @return object
-	 * @throws \Exception
+     */
-	 */
+	public function dispatch(object $event): object
-	public function __construct(public EventProvider $eventProvider, array $config = [])
 	{
-		parent::__construct($config);
+		$lists = make(EventProvider::class)->getListenersForEvent($event);
+
+		return $this->execute($lists, $event);
 	}
 
 
-	/**
+    /**
-	 * @param object $event
+     * @param SplPriorityQueue $lists
-	 * @return object
+     * @param object $event
-	 * @throws ContainerExceptionInterface
+     * @return object
-	 * @throws NotFoundExceptionInterface
+     */
-	 */
+	public function execute(SplPriorityQueue $lists, object $event): object
-	public function dispatch(object $event): object
 	{
-		$lists = $this->eventProvider->getListenersForEvent($event);
+		if ($lists->isEmpty()) {
-		if (!$lists->valid()) {
 			return $event;
 		}
-		$lists->top();
+        foreach ($lists as $item)  {
-		while ($lists->valid()) {
+            try {
-			try {
+                call_user_func($item, $event);
-				call_user_func($lists->current(), $event);
+            } catch (\Throwable $exception) {
-			} catch (\Throwable $exception) {
+                error($exception);
-				$this->logger->error($exception->getMessage(), [$exception]);
+            }
-			}
+            if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
-			if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
+                break;
-				break;
+            }
-			}
+        }
-			$lists->next();
-		}
 		return $event;
 	}
 

EventInterface.php

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

EventProvider.php

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

Struct.php

@@ -16,6 +16,12 @@ class Struct
 
 	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;

TestListener.php

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