Borobudur\Bus\Gate

Complexity

Total Complexity

14

Size/Duplication

Total Lines	108
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	enableSystemBus()	0	6	2
A	disableSystemBus()	0	4	1
A	attach()	0	17	2
A	detach()	0	4	1
A	get()	0	8	2
A	has()	0	4	1
A	getSystemMessage()	0	4	1
A	assertNotRegisteredBus()	0	6	2
A	assertValidSystemBus()	0	6	2

<?php
/*
 * This file is part of the Borobudur-Bus package.
 *
 * (c) Hexacodelabs <http://hexacodelabs.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Borobudur\Bus;

use Borobudur\Bus\Exception\InvalidArgumentException;
use Borobudur\Bus\Message\SystemMessage;

/**
 * @author      Iqbal Maulana <iq.bluejack@gmail.com>
 * @created     8/17/15
 */
class Gate implements GateInterface
{
    /**
     * @var BusInterface[]
     */
    private $buses = array();

    /**
     * {@inheritdoc}
     */
    public function enableSystemBus()
    {
        if (!isset($this->buses[BusInterface::SYSTEM_BUS])) {
            $this->attach(new SystemBus());
        }
    }

    /**
     * {@inheritdoc}
     */
    public function disableSystemBus()
    {
        $this->detach(BusInterface::SYSTEM_BUS);
    }

    /**
     * {@inheritdoc}
     */
    public function attach(BusInterface $bus)
    {
        $name = $bus->getName();

        if (BusInterface::SYSTEM_BUS === $name) {
            $this->assertValidSystemBus($bus);
            $this->buses[$name] = $bus;

            return;
        }

        $this->assertNotRegisteredBus($name);

        $bus = new BusProxy($bus);
        $bus->setGate($this);
        $this->buses[$name] = $bus;
    }

    /**
     * {@inheritdoc}
     */
    public function detach($busName)
    {
        unset($this->buses[$busName]);
    }

    /**
     * {@inheritdoc}
     */
    public function get($busName)
    {
        if (!isset($this->buses[$busName])) {
            throw new InvalidArgumentException(sprintf('Bus "%s" is not registered.', $busName));
        }

        return $this->buses[$busName];
    }

    /**
     * {@inheritdoc}
     */
    public function has($busName)
    {
        return array_key_exists($busName, $this->buses);
    }

    /**
     * {@inheritdoc}
     */
    public function getSystemMessage()
    {
        return new SystemMessage();
    }

    /**
     * Assert that bus with specified name is not registered.
     *
     * @param string $name
     *
     * @throws InvalidArgumentException
     */
    private function assertNotRegisteredBus($name)
    {
        if (isset($this->buses[$name])) {
            throw new InvalidArgumentException(sprintf('Bus with name "%s" is already attached.', $name));
        }
    }

    /**
     * Assert valid system bus.
     *
     * @param BusInterface $bus
     */
    private function assertValidSystemBus(BusInterface $bus)
    {
        if (false === $bus instanceof SystemBus) {
            throw new InvalidArgumentException(sprintf('Bus with name "%s" reserved for system bus.', $bus->getName()));
        }
    }
}