Bluz\EventManager\EventManager

Complexity

Total Complexity

13

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	attach()	0	9	3
A	fire()	0	12	5
A	trigger()	0	19	5

<?php

/**
 * Bluz Framework Component
 *
 * @copyright Bluz PHP Team
 * @link      https://github.com/bluzphp/framework
 */

declare(strict_types=1);

namespace Bluz\EventManager;

/**
 * Event manager
 *
 * @package  Bluz\EventManager
 * @link     https://github.com/bluzphp/framework/wiki/EventManager
 */
class EventManager
{
    /**
     * @var array list of listeners
     */
    protected $listeners = [];

    /**
     * Attach callback to event
     *
     * @param string $eventName
     * @param callable $callback
     * @param integer $priority
     *
     * @return void
     */
    public function attach(string $eventName, callable $callback, int $priority = 1): void
    {
        if (!isset($this->listeners[$eventName])) {
            $this->listeners[$eventName] = [];
        }
        if (!isset($this->listeners[$eventName][$priority])) {
            $this->listeners[$eventName][$priority] = [];
        }
        $this->listeners[$eventName][$priority][] = $callback;
    }

    /**
     * Trigger event
     *
     * @param  string|Event  $event
     * @param  string|object $target
     * @param  array|object  $params
     *
     * @return string|object
     * @throws EventException
     */
    public function trigger($event, $target = null, $params = null)
    {
        if (!$event instanceof Event) {
            $event = new Event($event, $target, $params);
        }

        if (false !== strpos($event->getName(), ':')) {
            $namespace = substr($event->getName(), 0, strpos($event->getName(), ':'));

            if (isset($this->listeners[$namespace])) {
                $this->fire($this->listeners[$namespace], $event);
            }
        }

        if (isset($this->listeners[$event->getName()])) {
            $this->fire($this->listeners[$event->getName()], $event);
        }

        return $event->getTarget();
    }

    /**
     * Fire!
     *
     * @param array $listeners
     * @param Event $event
     *
     * @return void
     */
    protected function fire(array $listeners, Event $event): void
    {
        ksort($listeners);
        foreach ($listeners as $list) {
            foreach ($list as $listener) {
                $result = $listener($event);
                if (null === $result) {
                    // continue;
                } elseif (false === $result) {
                    break 2;
                } else {
                    $event->setTarget($result);
                }
            }
        }
    }
}