PHPDaemon\Servers\WebSocket\Pool

Complexity

Total Complexity

22

Size/Duplication

Total Lines	182
Duplicated Lines	9.89 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	getConfigDefaults()	0	19	1
A	setRouteOptions()	9	10	2
A	getRouteOptions()	0	8	2
A	addRoute()	9	10	2
B	getRoute()	0	40	11
A	setRoute()	0	6	1
A	removeRoute()	0	9	2
A	routeExists()	0	5	1

<?php
namespace PHPDaemon\Servers\WebSocket;

use PHPDaemon\Core\Daemon;
use PHPDaemon\Network\Server;
use PHPDaemon\WebSocket\Route;

class Pool extends Server
{
    use \PHPDaemon\Traits\EventHandlers;

    /**
     * @var array
     */
    public $routes = [];

    /**
     * Binary packet type
     */
    const BINARY = 'BINARY';

    /**
     * String packet type
     */
    const STRING = 'STRING';

    /**
     * Setting default config options
     * Overriden from ConnectionPool::getConfigDefaults
     * @return array|bool
     */
    protected function getConfigDefaults()
    {
        return [
            /* [boolean] Expose PHPDaemon version by X-Powered-By Header */
            'expose' => 1,

            /* [string|array] Listen addresses */
            'listen' => '0.0.0.0',

            /* [integer] Listen port */
            'port' => 8047,

            /* [Size] Maximum allowed size of packet */
            'max-allowed-packet' => new \PHPDaemon\Config\Entry\Size('1M'),

            /* [string] Related FlashPolicyServer instance name */
            'fps-name' => '',
        ];
    }

    /**
     * Sets an array of options associated to the route
     * @param  string $path Route name.
     * @param  array $opts Options
     * @return boolean       Success.
     */
    public function setRouteOptions($path, $opts)

This method seems to be duplicated in your project.

    {
        $routeName = ltrim($path, '/');
        if (!isset($this->routes[$routeName])) {
            Daemon::log(__METHOD__ . ': Route \'' . $path . '\' is not found.');
            return false;
        }
        $this->routeOptions[$routeName] = $opts;

The property routeOptions does not exist. Did you maybe forget to declare it?

        return true;
    }


    /**
     * Return options by route
     * @param  string $path Route name
     * @return array        Options
     */
    public function getRouteOptions($path)
    {
        $routeName = ltrim($path, '/');
        if (!isset($this->routeOptions[$routeName])) {
            return [];
        }
        return $this->routeOptions[$routeName];
    }

    /**
     * Adds a route if it doesn't exist already.
     * @param  string $path Route name.
     * @param  callable $cb Route's callback.
     * @callback $cb ( )
     * @return boolean        Success.
     */
    public function addRoute($path, $cb)

This method seems to be duplicated in your project.

    {
        $routeName = ltrim($path, '/');
        if (isset($this->routes[$routeName])) {
            Daemon::log(__METHOD__ . ': Route \'' . $path . '\' is already defined.');
            return false;
        }
        $this->routes[$routeName] = $cb;
        return true;
    }

    /**
     * @TODO
     * @param  string $path
     * @param  object $client
     * @param  boolean $withoutCustomTransport
     * @return mixed
     */
    public function getRoute($path, $client, $withoutCustomTransport = false)
    {
        if (!$withoutCustomTransport) {
            $this->trigger('customTransport', $path, $client, function ($set) use (&$result) {
                $result = $set;
            });
            if ($result !== null) {
                return $result;
            }
        }
        $routeName = ltrim($path, '/');
        if (!isset($this->routes[$routeName])) {
            if (Daemon::$config->logerrors->value) {
                Daemon::$process->log(get_class($this) . '::' . __METHOD__ . ' : undefined path "' . $path . '" for client "' . $client->addr . '"');
            }
            return false;
        }
        $route = $this->routes[$routeName];
        if (is_string($route)) { // if we have a class name
            if (class_exists($route)) {
                $this->onWakeup();

The method onWakeup does not exist on object<PHPDaemon\Servers\WebSocket\Pool>? Since you implemented __call, maybe consider adding a @method annotation.

                $ret = new $route($client);
                $this->onSleep();

The method onSleep does not exist on object<PHPDaemon\Servers\WebSocket\Pool>? Since you implemented __call, maybe consider adding a @method annotation.

                return $ret;
            } else {
                return false;
            }
        } elseif (is_array($route) || is_object($route)) { // if we have a lambda object or callback reference
            if (!is_callable($route)) {
                return false;
            }
            $ret = $route($client); // calling the route callback
            if (!$ret instanceof Route) {
                return false;
            }
            return $ret;
        } else {
            return false;
        }
    }

    /**
     * Force add/replace a route.
     * @param  string $path Path
     * @param  callable $cb Callback
     * @callback $cb ( )
     * @return boolean        Success
     */
    public function setRoute($path, $cb)
    {
        $routeName = ltrim($path, '/');
        $this->routes[$routeName] = $cb;
        return true;
    }

    /**
     * Removes a route.
     * @param  string $path Route name
     * @return boolean       Success
     */
    public function removeRoute($path)
    {
        $routeName = ltrim($path, '/');
        if (!isset($this->routes[$routeName])) {
            return false;
        }
        unset($this->routes[$routeName]);
        return true;
    }

    /**
     * Checks if route exists
     * @param  string $path Route name
     * @return boolean       Exists?
     */
    public function routeExists($path)
    {
        $routeName = ltrim($path, '/');
        return isset($this->routes[$routeName]);
    }
}