Mleko\Event\SimpleEmitter

Complexity

Total Complexity

14

Size/Duplication

Total Lines	92
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

84.21%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	4
A	emit()	0	9	2
A	addListener()	0	8	2
A	removeListener()	0	11	3
A	extractEventName()	0	4	1
A	getEventListeners()	0	5	2

<?php
/**
 * @package event
 */


namespace Mleko\Event;


class SimpleEmitter implements MutableEmitter
{

    /** @var array */
    private $listeners = [];

    /** @var EventNameExtractor */
    private $eventNameExtractor;

    /**
     * SimpleEventBus constructor.
     * @param EventNameExtractor $eventNameExtractor
     * @param Listener[]|Listener[][] $listeners
     */
    public function __construct(EventNameExtractor $eventNameExtractor, array $listeners = [])
    {
        $this->eventNameExtractor = $eventNameExtractor;
        foreach ($listeners as $eventName => $listenerDef) {
            if (is_array($listenerDef)) {
                foreach ($listenerDef as $listener) {
                    $this->addListener($eventName, $listener);
                }
            } else {
                $this->addListener($eventName, $listenerDef);
            }
        }
    }

    /**
     * @param object $event
     * @return void
     */
    public function emit($event)
    {
        $eventName = $this->extractEventName($event);
        $eventListeners = $this->getEventListeners($eventName);
        $eventMeta = new Meta($event, $eventName, $eventName, $this);
        foreach ($eventListeners as $listener) {
            $listener->handle($event, $eventMeta);
        }
    }

    /**
     * @param string $eventName
     * @param Listener $listener
     * @return Subscription
     */
    public function addListener($eventName, Listener $listener)
    {
        if (!isset($this->listeners[$eventName])) {
            $this->listeners[$eventName] = [];
        }
        $this->listeners[$eventName][] = $listener;
        return new Subscription($eventName, $listener, $this);
    }

    /**
     * @param string $eventName
     * @param Listener $listener
     * @return bool
     */
    public function removeListener($eventName, Listener $listener)
    {
        $eventListeners = $this->getEventListeners($eventName);
        foreach ($eventListeners as $key => $eventListener) {
            if ($listener === $eventListener) {
                unset($this->listeners[$eventName][$key]);
                return true;
            }
        }
        return false;
    }

    /**
     * @param $event
     * @return string
     */
    private function extractEventName($event)
    {
        return $this->eventNameExtractor->extract($event);
    }

    /**
     * @param string $eventName
     * @return Listener[]
     */
    private function getEventListeners($eventName)
    {
        $eventListeners = array_key_exists($eventName, $this->listeners) ? $this->listeners[$eventName] : [];
        return $eventListeners;
    }
}