Phossa2\Event\EventDispatcher

Complexity

Total Complexity

11

Size/Duplication

Total Lines	112
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	7

Importance

Changes	6
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	2
A	newEvent()	0	14	3
A	getMatchedQueue()	0	16	2
A	getEventNames()	0	4	1
A	matchEventQueues()	0	12	3

<?php
/**
 * Phossa Project
 *
 * PHP version 5.4
 *
 * @category  Library
 * @package   Phossa2\Event
 * @copyright Copyright (c) 2016 phossa.com
 * @license   http://mit-license.org/ MIT License
 * @link      http://www.phossa.com/
 */
/*# declare(strict_types=1); */

namespace Phossa2\Event;

use Phossa2\Event\Traits\CountableTrait;
use Phossa2\Event\Traits\NameGlobbingTrait;
use Phossa2\Event\Interfaces\EventInterface;
use Phossa2\Event\Traits\SharedManagerTrait;
use Phossa2\Event\Traits\ListenerAwareTrait;
use Phossa2\Event\Interfaces\CountableInterface;
use Phossa2\Event\Interfaces\SharedManagerInterface;
use Phossa2\Event\Interfaces\ListenerAwareInterface;

/**
 * EventDispatcher
 *
 * Advanced event manager with
 *
 * - event name globbing
 * - shared manager support
 * - attach/detach listener
 * - able to trigger an event with countable times
 *
 * @package Phossa2\Event
 * @author  Hong Zhang <phossa@126.com>
 * @version 2.0.0
 * @since   2.0.0 added
 */
class EventDispatcher extends EventManager implements SharedManagerInterface, ListenerAwareInterface, CountableInterface
{
    use CountableTrait,
        NameGlobbingTrait,
        SharedManagerTrait,
        ListenerAwareTrait;

    /**
     * event prototype
     *
     * @var    EventInterface|null
     * @access protected
     */
    protected $event_proto;

    /**
     * Create a event manager with defined scopes
     *
     * @param  string|array $scopes
     * @param  EventInterface $event_proto event prototype if any
     * @access public
     */
    public function __construct(
        $scopes = '',
        EventInterface $event_proto = null
    ) {
        // set scopes
        if ('' !== $scopes) {
            $this->scopes = (array) $scopes;
        }

        // set event prototype
        $this->event_proto = $event_proto;
    }

    /**
     * Override `newEvent()` in EventManager.
     *
     * Added event prototype support
     *
     * {@inheritDoc}
     */
    protected function newEvent(
        $eventName,
        $context,
        array $properties
    )/*# : EventInterface */ {
        if (is_object($eventName)) {
            return $eventName;
        } elseif ($this->event_proto) {
            $evt = clone $this->event_proto;
            return $evt($eventName, $context, $properties);
        } else {
            return new Event($eventName, $context, $properties);
        }
    }

    /**
     * Override `getMatchedQueue()` in EventManager.
     *
     * Support for shared manager & name globbing
     *
     * {@inheritDoc}
     */
    protected function getMatchedQueue(
        /*# : string */ $eventName
    )/*# : EventQueueInterface */ {
        // get all shared managers
        $managers = $this->getShareables();

        // add $this manager
        array_unshift($managers, $this);

        /* @var $mgr EventDispatcher */
        $nqueue = $this->newEventQueue();
        foreach ($managers as $mgr) {
            $nqueue = $nqueue->combine($mgr->matchEventQueues($eventName));
        }
        return $nqueue;
    }

    /**
     * Get all event names of $this manager
     *
     * @return array
     * @access protected
     */
    protected function getEventNames()/*# : array */
    {
        return array_keys($this->events);
    }

    /**
     * Get a merged queue in $this manager for the given event name
     *
     * @param  string $eventName
     * @return EventQueueInterface
     * @access protected
     */
    protected function matchEventQueues(
        /*# string */ $eventName
    )/*: EventQueueInterface */ {
        $nqueue = $this->newEventQueue();
        $names  = $this->globEventNames($eventName, $this->getEventNames());
        foreach ($names as $evtName) {
            if ($this->hasEvent($evtName)) {
                $nqueue = $nqueue->combine($this->events[$evtName]);
            }
        }
        return $nqueue;
    }
}