sonrac\WAMP\Routers\Router

Complexity

Total Complexity

17

Size/Duplication

Total Lines	293
Duplicated Lines	0 %

Test Coverage

Coverage

85.11%

Importance

Changes

0

14 Methods

Rating	Name	Duplication	Size	Complexity
A	addSubscriber()	0	3	1
A	addRoute()	0	3	1
A	__construct()	0	10	1
A	onRouterStop()	0	3	1
A	getClient()	0	3	1
A	onConnectionOpen()	0	3	1
A	onConnectionClose()	0	3	1
A	removeEvent()	0	6	3
A	setClient()	0	3	1
A	getControllerNamespace()	0	3	1
A	onRouterStart()	0	3	1
A	addEvent()	0	11	2
A	setControllerNamespace()	0	3	1
A	parseGroups()	0	4	1

<?php
/**
 * Created by PhpStorm.
 *
 * @author Donii Sergii <doniysa@gmail.com>
 * Date: 10/25/17
 * Time: 11:56 AM
 */

namespace sonrac\WAMP\Routers;

use sonrac\WAMP\Contracts\WAMPRouterInterface;
use Thruway\Event\ConnectionOpenEvent;
use Thruway\Peer\ClientInterface;
use Thruway\Peer\Router as PeerRouter;

/**
 * Class Router
 * Router class.
 *
 * <h2>Events list</h2>
 * <table class="table table-bordered table-stripped table-hover table-responsive">
 * <thead>
 * <tr>
 * <td>Event name</td>
 * <td>Constant name</td>
 * <td>Description</td>
 * <td>Method for subscribe (is static for class <i>sonrac\WAMP\Routers\Router</i>)</td>
 * </tr>
 * </thead>
 * <tbody>
 * <tr>
 * <td>connection_open</td>
 * <td><i>sonrac\WAMP\Routers\Router::EVENT_CONNECTION_OPEN</i></td>
 * <td>Connection opened</td>
 * <td><i>sonrac\WAMP\Routers\Router::onOpen</i></td>
 * </tr>
 * </tbody>
 * </table>
 *
 * <h2>Example events adding</h2>
 *
 * <code>
 * $app->router->onOpen()
 * </code>
 */
class Router extends PeerRouter implements WAMPRouterInterface
{
    use RouterTrait;

    /**
     * Connection open event name.
     *
     * @var string
     * @const
     */
    const EVENT_CONNECTION_OPEN = 'connection_open';

    /**
     * Connection close event name.
     *
     * @var string
     * @const
     */
    const EVENT_CONNECTION_CLOSE = 'connection_close';

    /**
     * Router start event name.
     *
     * @var string
     * @const
     */
    const EVENT_ROUTER_START = 'router.start';

    /**
     * Router stop event name.
     *
     * @var string
     * @const
     */
    const EVENT_ROUTER_STOP = 'router.stop';

    /**
     * RPC router.
     *
     * @var \sonrac\WAMP\Contracts\RPCRouterInterface
     */
    protected $rpcRouter;

    /**
     * Publisher/subscription router.
     *
     * @var \sonrac\WAMP\Contracts\PubSubRouterInterface
     */
    protected $pubSubRouter;

    /**
     * Loop object.
     *
     * @var null|\React\EventLoop\LoopInterface
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    protected $loop;
    /**
     * Routes.
     *
     * @var array
     */
    protected $routes = [];

    /**
     * Peer client.
     *
     * @var \Thruway\Peer\ClientInterface|\sonrac\WAMP\Client
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    protected $client = null;

    /**
     * Default controller namespaces.
     *
     * @var null|string
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    protected $controllerNamespace = null;

    /**
     * Events.
     *
     * @var array
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    protected static $events = [
    ];

    /**
     * Router constructor.
     *
     * @param \sonrac\WAMP\Contracts\RPCRouterInterface|\sonrac\WAMP\Routers\RPCRouter       $RPCRouter    RPC router
     * @param \sonrac\WAMP\Contracts\PubSubRouterInterface|\sonrac\WAMP\Routers\PubSubRouter $pubSubRouter Publisher/subscription
     *                                                                                                     router
     * @param \React\EventLoop\LoopInterface|null                                            $loop         Loop object
     */
    public function __construct(
        \sonrac\WAMP\Contracts\RPCRouterInterface $RPCRouter,
        \sonrac\WAMP\Contracts\PubSubRouterInterface $pubSubRouter,
        \React\EventLoop\LoopInterface $loop = null
    ) {
        $this->rpcRouter = $RPCRouter;
        $this->pubSubRouter = $pubSubRouter;
        $this->loop = $loop;

        parent::__construct($loop);
    }

    /**
     * Add subscriber.
     *
     * @param string          $path     Route path
     * @param \Closure|string $callback Handler
     *
     * @return \React\Promise\Promise
     */
    public function addSubscriber($path, $callback)
    {
        return $this->pubSubRouter->addRoute($path, $callback);

The method addRoute() does not exist on sonrac\WAMP\Contracts\PubSubRouterInterface. Since it exists in all sub-types, consider adding an abstract or default implementation to sonrac\WAMP\Contracts\PubSubRouterInterface.

    }

    /**
     * Add procedure.
     *
     * @param string          $name      Name
     * @param string|\Closure $procedure Procedure
     *
     * @return \React\Promise\Promise
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    public function addRoute($name, $procedure)
    {
        return $this->rpcRouter->addRoute($name, $procedure);

The method addRoute() does not exist on sonrac\WAMP\Contracts\RPCRouterInterface. Since it exists in all sub-types, consider adding an abstract or default implementation to sonrac\WAMP\Contracts\RPCRouterInterface.

    }

    /**
     * Set default controller namespace.
     *
     * @param string $namespace
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    public function setControllerNamespace($namespace)
    {
        $this->controllerNamespace = $namespace;
    }

    /**
     * Get default controller namespace.
     *
     * @return null|string
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    public function getControllerNamespace()
    {
        return $this->controllerNamespace;
    }

    /**
     * Add open event listener.
     *
     * @param \Closure|string $callback Callback
     * @param int             $priority Callback priority
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    public function onConnectionOpen($callback, $priority = 0)
    {
        $this->addEvent($callback, static::EVENT_CONNECTION_OPEN, $priority);
    }

    /**
     * Add stop router event listener.
     *
     * @param \Closure|string $callback Callback
     * @param int             $priority Callback priority
     *
     * @throws \Exception
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    public function onRouterStop($callback, $priority = 0)
    {
        $this->addEvent($callback, static::EVENT_ROUTER_STOP, $priority);
    }

    /**
     * Add connection close event listener.
     *
     * @param \Closure|string $callback Callback
     * @param int             $priority Callback priority
     *
     * @throws \Exception
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    public function onConnectionClose($callback, $priority = 0)
    {
        $this->addEvent($callback, static::EVENT_CONNECTION_CLOSE, $priority);
    }

    /**
     * Remove event listener.
     *
     * @param string $eventName Event name
     * @param mixed  $callback  Callback
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    public function removeEvent($eventName, $callback)
    {
        $this->getEventDispatcher()->removeListener($eventName, $callback);

        if (isset(static::$events[$eventName]) && count(static::$events[$eventName]) === 0) {
            unset(static::$events[$eventName]);
        }
    }

    /**
     * Add open event listener.
     *
     * @param \Closure|string $callback Callback
     * @param int             $priority Callback priority
     *
     * @throws \Exception
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    public function onRouterStart($callback, $priority = 0)
    {
        $this->addEvent($callback, static::EVENT_ROUTER_START, $priority);
    }

    /**
     * Get client.
     *
     * @return \Thruway\Peer\ClientInterface|\sonrac\WAMP\Client
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    public function getClient()
    {
        return $this->client;
    }

    /**
     * Set client
     *
     * @param \Thruway\Peer\ClientInterface $client Client
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    public function setClient(ClientInterface $client)
    {
        $this->client = $client;
    }

    /**
     * {@inheritdoc}
     */
    public function parseGroups()
    {
        $this->rpcRouter->parseGroups();

The method parseGroups() does not exist on sonrac\WAMP\Contracts\RPCRouterInterface. Since it exists in all sub-types, consider adding an abstract or default implementation to sonrac\WAMP\Contracts\RPCRouterInterface.

        $this->pubSubRouter->parseGroups();

The method parseGroups() does not exist on sonrac\WAMP\Contracts\PubSubRouterInterface. Since it exists in all sub-types, consider adding an abstract or default implementation to sonrac\WAMP\Contracts\PubSubRouterInterface.

    }

    /**
     * Add event.
     *
     * @param \Closure|string $callback  Callback
     * @param string          $eventName Event name
     * @param int             $priority  Priority
     *
     * @author Donii Sergii <doniysa@gmail.com>
     */
    protected function addEvent($callback, $eventName, $priority)
    {
        if (is_string($callback)) {
            list($class, $method) = explode('&', $callback);

            $callback = function (ConnectionOpenEvent $event) use ($class, $method) {
                return $class::{$method}($event);
            };
        }

        $this->getEventDispatcher()->addListener($eventName, $callback, $priority);
    }
}