Metabor\Event\Dispatcher

Complexity

Total Complexity

13

Size/Duplication

Total Lines	100
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

78.38%

Importance

Changes	7
Bugs	5	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	addCommand()	0	4	1
A	getCommands()	0	4	1
A	removeCommand()	0	7	2
A	addEvent()	0	4	1
A	dispatch()	0	14	3
A	__invoke()	0	15	4
A	isReady()	0	4	1

<?php

namespace Metabor\Event;

use MetaborStd\CallbackInterface;
use MetaborStd\Event\DispatcherInterface;
use MetaborStd\Event\EventInterface;

/**
 * @author Oliver Tischlinger
 */
class Dispatcher implements DispatcherInterface
{
    /**
     * @var array
     */
    private $commands = array();

    /**
     * @var array
     */
    private $onReadyCallbacks = array();

    /**
     * @var bool
     */
    private $isReady = false;

    /**
     * @param callable $command
     * @param array    $arguments
     */
    protected function addCommand($command, array $arguments)
    {
        $this->commands[] = array($command, $arguments);
    }

    /**
     * @return array
     */
    protected function getCommands()
    {
        return $this->commands;
    }

    /**
     * @param callable $command
     * @param array    $arguments
     */
    protected function removeCommand($command, array $arguments)
    {
        $key = array_search(array($command, $arguments), $this->commands);
        if ($key !== false) {
            unset($this->commands[$key]);
        }
    }

    /**
     * @param EventInterface $event
     * @param array          $arguments
     */
    protected function addEvent(EventInterface $event, array $arguments)
    {
        $this->addCommand($event, $arguments);
    }

    /**
     * @see \MetaborStd\Event\DispatcherInterface::dispatch()
     */
    public function dispatch(
        EventInterface $event,
        array $arguments = array(),
        CallbackInterface $onReadyCallback = null
    ) {
        if (!$this->isReady) {
            $this->addEvent($event, $arguments);
            if ($onReadyCallback) {
                $this->onReadyCallbacks[] = $onReadyCallback;
            }
        } else {
            throw new \RuntimeException('Was already invoked!');
        }
    }

    /**
     * @see \MetaborStd\CallbackInterface::__invoke()
     */
    public function __invoke()
    {
        if ($this->isReady) {
            throw new \RuntimeException('Was already invoked!');
        } else {
            foreach ($this->getCommands() as $list) {
                list($command, $arguments) = $list;
                call_user_func_array($command, $arguments);
            }
            $this->isReady = true;
            foreach ($this->onReadyCallbacks as $onReadyCallback) {
                $onReadyCallback();
            }
        }
    }

    /**
     * @return bool
     */
    public function isReady()
    {
        return $this->isReady;
    }
}