Dazzle\Channel\Router\RouterComposite

Complexity

Total Complexity

19

Size/Duplication

Total Lines	148
Duplicated Lines	20.95 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	2
A	__destruct()	0	4	1
A	existsBus()	0	4	1
A	getBus()	9	9	2
A	setBus()	0	6	1
A	removeBus()	0	9	2
A	getBuses()	0	4	1
A	erase()	0	7	2
A	addRule()	11	11	2
A	addDefault()	11	11	2
A	handle()	0	14	3

<?php

namespace Dazzle\Channel\Router;

use Dazzle\Channel\Protocol\ProtocolInterface;
use Dazzle\Throwable\Exception\Logic\ResourceUndefinedException;

class RouterComposite implements RouterCompositeInterface
{
    /**
     * @var RouterInterface[]|RouterCompositeInterface[]
     */
    protected $bus;

    /**
     * @param RouterInterface[]|RouterCompositeInterface[] $bus
     */
    public function __construct($bus = [])
    {
        $this->bus = [];

        foreach ($bus as $name=>$router)
        {
            $this->setBus($name, $router);
        }
    }

    /**
     *
     */
    public function __destruct()
    {
        unset($this->bus);
    }

    /**
     * @override
     * @inheritDoc
     */
    public function existsBus($name)
    {
        return isset($this->bus[$name]);
    }

    /**
     * @override
     * @inheritDoc
     */
    public function getBus($name)

This method seems to be duplicated in your project.

    {
        if (!isset($this->bus[$name]))
        {
            throw new ResourceUndefinedException(__CLASS__ . " has no registered bus $name.");
        }

        return $this->bus[$name];
    }

    /**
     * @override
     * @inheritDoc
     */
    public function setBus($name, $router)
    {
        $this->bus[$name] = $router;

        return $this;
    }

    /**
     * @override
     * @inheritDoc
     */
    public function removeBus($name)
    {
        if (isset($this->bus[$name]))
        {
            unset($this->bus[$name]);
        }

        return $this;
    }

    /**
     * @override
     * @inheritDoc
     */
    public function getBuses()
    {
        return $this->bus;
    }

    /**
     * @override
     * @inheritDoc
     */
    public function handle($name, ProtocolInterface $protocol, $flags = 0, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0)
    {
        $handled = false;

        foreach ($this->bus as $name=>$router)
        {
            if ($router->handle($name, $protocol, $flags, $success, $failure, $cancel, $timeout))
            {
                $handled = true;
            }
        }

        return $handled;
    }

    /**
     * @override
     * @inheritDoc
     */
    public function erase()
    {
        foreach ($this->bus as $name=>$router)
        {
            $router->erase();
        }
    }

    /**
     * @override
     * @inheritDoc
     */
    public function addRule(callable $matcher, callable $handler, $propagate = false, $limit = 0)

This method seems to be duplicated in your project.

    {
        $handlers = [];

        foreach ($this->bus as $bus=>$router)
        {
            $handlers[] = $router->addRule($matcher, $handler, $propagate, $limit);
        }

        return $handlers;
    }

    /**
     * @override
     * @inheritDoc
     */
    public function addDefault(callable $handler, $propagate = false, $limit = 0)

This method seems to be duplicated in your project.

    {
        $handlers = [];

        foreach ($this->bus as $bus=>$router)
        {
            $handlers[] = $router->addDefault($handler, $propagate, $limit);
        }

        return $handlers;
    }
}