Mleko\Event\SimpleEmitter

Complexity

Total Complexity

10

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

83.33%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

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

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


namespace Mleko\Event;


class SimpleEmitter implements MutableEmitter
{

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

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

    /**
     * SimpleEventBus constructor.
     * @param EventNameExtractor $eventNameExtractor
     */
    public function __construct(EventNameExtractor $eventNameExtractor)
    {
        $this->eventNameExtractor = $eventNameExtractor;
    }

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

The call to handle() misses a required argument $meta.

        }
    }

    /**
     * @param string $eventName
     * @param Listener $listener
     * @return Subscription
     */
    public function addListener($eventName, Listener $listener)
    {
        $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 $eventName
     * @return Listener[]
     */
    private function getEventListeners($eventName)
    {
        $eventListeners = array_key_exists($eventName, $this->listeners) ? $this->listeners[$eventName] : [];
        return $eventListeners;
    }
}