Sebdesign\SM\Event\Dispatcher

Complexity

Total Complexity

25

Size/Duplication

Total Lines	128
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	dispatch()	0	10	2
A	addListener()	0	6	1
B	addSubscriber()	0	14	7
A	removeListener()	0	12	3
B	removeSubscriber()	0	12	6
A	getListeners()	0	14	3
A	getListenerPriority()	0	4	1
A	hasListeners()	0	4	1

<?php

namespace Sebdesign\SM\Event;

use Illuminate\Contracts\Events\Dispatcher as DispatcherContract;
use Symfony\Component\EventDispatcher\Event;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

class Dispatcher implements EventDispatcherInterface
{
    /**
     * @var \Illuminate\Contracts\Events\Dispatcher
     */
    protected $dispatcher;

    /**
     * @var array
     */
    protected $events = [];

    /**
     * @param \Illuminate\Contracts\Events\Dispatcher $dispatcher
     */
    public function __construct(DispatcherContract $dispatcher)
    {
        $this->dispatcher = $dispatcher;
    }

    /**
     * {@inheritDoc}
     */
    public function dispatch($eventName, Event $event = null)
    {
        if (is_null($event)) {
            $event = new Event();
        }

        $this->dispatcher->fire($eventName, $event);

        return $event;
    }

    /**
     * {@inheritDoc}
     */
    public function addListener($eventName, $listener, $priority = 0)
    {
        $this->events[] = $eventName;

        $this->dispatcher->listen($eventName, $listener, $priority);
    }

    /**
     * {@inheritDoc}
     */
    public function addSubscriber(EventSubscriberInterface $subscriber)
    {
        foreach ($subscriber->getSubscribedEvents() as $eventName => $params) {
            if (is_string($params)) {
                $this->addListener($eventName, [$subscriber, $params]);
            } elseif (is_string($params[0])) {
                $this->addListener($eventName, [$subscriber, $params[0]], isset($params[1]) ? $params[1] : 0);
            } else {
                foreach ($params as $listener) {
                    $this->addListener($eventName, [$subscriber, $listener[0]], isset($listener[1]) ? $listener[1] : 0);
                }
            }
        }
    }

    /**
     * {@inheritDoc}
     */
    public function removeListener($eventName, $listener)
    {
        $listeners = $this->getListeners($eventName);

        $this->dispatcher->forget($eventName);

        foreach ($listeners as $l) {
            if ($l !== $listener) {
                $this->addListener($eventName, $l);
            }
        }
    }

    /**
     * {@inheritDoc}
     */
    public function removeSubscriber(EventSubscriberInterface $subscriber)
    {
        foreach ($subscriber->getSubscribedEvents() as $eventName => $params) {
            if (is_array($params) && is_array($params[0])) {
                foreach ($params as $listener) {
                    $this->removeListener($eventName, [$subscriber, $listener[0]]);
                }
            } else {
                $this->removeListener($eventName, [$subscriber, is_string($params) ? $params : $params[0]]);
            }
        }
    }

    /**
     * {@inheritDoc}
     */
    public function getListeners($eventName = null)
    {
        if (! is_null($eventName)) {
            return $this->dispatcher->getListeners($eventName);

The method getListeners() does not exist on Illuminate\Contracts\Events\Dispatcher. Did you maybe mean listen()?

        }

        $sorted = [];

        foreach ($this->events as $eventName) {
            $sorted = array_merge($sorted, $this->dispatcher->getListeners($eventName));

The method getListeners() does not exist on Illuminate\Contracts\Events\Dispatcher. Did you maybe mean listen()?

        }

        return array_filter($sorted);
    }

    /**
     * {@inheritDoc}
     */
    public function getListenerPriority($eventName, $listener)
    {
        return array_search($listener, $this->getListeners($eventName), true);
    }

    /**
     * {@inheritDoc}
     */
    public function hasListeners($eventName = null)
    {
        return (bool) count($this->getListeners($eventName));
    }
}