Application - Code Metrics - kakserpom/phpdaemon - Measure and Improve Code Quality continuously with Scrutinizer

Application C
last analyzed 2021-06-02 17:17 UTC

↳ Parent: Project

Complexity

Total Complexity

Size/Duplication

Total Lines	403
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	11

Importance

Changes

Metric	Value
dl	0
loc	403
rs	5.04
c	0
b	0
f	0
wmc	57
lcom	1
cbo	11

21 Methods

Rating	Name	Size	Complexity
A	setRedis()	5	1
A	getLocalSubscribersCount()	4	1
A	subscribe()	4	1
A	setnx()	4	1
A	setkey()	4	1
A	getkey()	4	1
A	expire()	4	1
A	unsubscribe()	4	1
A	unsubscribeReal()	4	1
A	publish()	4	1
A	onReady()	9	2
A	attachWss()	9	2
A	onFinish()	7	2
A	detachWss()	9	2
B	wsHandler()	25	6
A	beginSession()	15	4
A	getRouteOptions()	17	4
A	endSession()	4	1
F	beginRequest()	61	20
A	callMethod()	12	3
A	getConfigDefaults()	31	1

How to fix Complexity

<?php
namespace PHPDaemon\SockJS;

use PHPDaemon\Servers\WebSocket\Pool as WebSocketPool;
use PHPDaemon\Structures\ObjectStorage;

/**
 * @package    Libraries
 * @subpackage SockJS
 * @author     Vasily Zorin <[email protected]>
 */
class Application extends \PHPDaemon\Core\AppInstance
{
    public $wss;
    protected $redis;
    protected $sessions;

    /**
     * Set Redis instance
     * @param \PHPDaemon\Clients\Redis\Pool $redis
     * @return $this
     */
    public function setRedis(\PHPDaemon\Clients\Redis\Pool $redis)
    {
        $this->redis = $redis;
        return $this;
    }

    /**
     * getLocalSubscribersCount
     * @param  string $chan
     * @return integer
     */
    public function getLocalSubscribersCount($chan)
    {
        return $this->redis->getLocalSubscribersCount($this->config->redisprefix->value . $chan);
    }

    /**
     * subscribe
     * @param  string $chan [@todo description]
     * @param  callable $cb [@todo description]
     * @param  callable $opcb [@todo description]

     * @callback $cb ( )
     * @callback $opcb ( )
     * @return void
     */
    public function subscribe($chan, $cb, $opcb = null)
    {
        $this->redis->subscribe($this->config->redisprefix->value . $chan, $cb, $opcb);

    }

    /**
     * setnx
     * @param  string $key [@todo description]
     * @param  mixed $value [@todo description]
     * @param  callable $cb [@todo description]

     * @callback $cb ( )
     * @return void
     */
    public function setnx($key, $value, $cb = null)
    {
        $this->redis->setnx($this->config->redisprefix->value . $key, $value, $cb);
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }
    }

    /**
     * setkey
     * @param  string $key [@todo description]
     * @param  mixed $value [@todo description]
     * @param  callable $cb [@todo description]

     * @callback $cb ( )
     * @return void
     */
    public function setkey($key, $value, $cb = null)
    {
        $this->redis->set($this->config->redisprefix->value . $key, $value, $cb);
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }
    }

    /**
     * getkey
     * @param  string $key [@todo description]
     * @param  callable $cb [@todo description]

     * @callback $cb ( )
     * @return void
     */
    public function getkey($key, $cb = null)
    {
        $this->redis->get($this->config->redisprefix->value . $key, $cb);
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }
    }

    /**
     * expire
     * @param  string $key [@todo description]
     * @param  integer $seconds [@todo description]
     * @param  callable $cb [@todo description]

     * @callback $cb ( )
     * @return void
     */
    public function expire($key, $seconds, $cb = null)
    {
        $this->redis->expire($this->config->redisprefix->value . $key, $seconds, $cb);
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }
    }

    /**
     * unsubscribe
     * @param  string $chan [@todo description]
     * @param  callable $cb [@todo description]
     * @param  callable $opcb [@todo description]

     * @callback $cb ( )
     * @callback $opcb ( )
     * @return void
     */
    public function unsubscribe($chan, $cb, $opcb = null)
    {
        $this->redis->unsubscribe($this->config->redisprefix->value . $chan, $cb, $opcb);
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }
    }

    /**
     * unsubscribeReal
     * @param  string $chan [@todo description]
     * @param  callable $opcb [@todo description]

     * @callback $opcb ( )
     * @return void
     */
    public function unsubscribeReal($chan, $opcb = null)
    {
        $this->redis->unsubscribeReal($this->config->redisprefix->value . $chan, $opcb);
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }
    }

    /**
     * publish
     * @param  string $chan [@todo description]
     * @param  callable $cb [@todo description]
     * @param  callable $opcb [@todo description]

     * @callback $cb ( )
     * @callback $opcb ( )
     * @return void
     */
    public function publish($chan, $cb, $opcb = null)
    {
        $this->redis->publish($this->config->redisprefix->value . $chan, $cb, $opcb);
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }
    }

    /**
     * Called when the worker is ready to go
     * @return void
     */
    public function onReady()
    {
        $this->redis = \PHPDaemon\Clients\Redis\Pool::getInstance($this->config->redisname->value);
        $this->sessions = new ObjectStorage;
        $this->wss = new ObjectStorage;
        foreach (preg_split('~\s*;\s*~', $this->config->wssname->value) as $wssname) {
            $this->attachWss(WebSocketPool::getInstance(trim($wssname)));
        }
    }

    /**
     * attachWss
     * @param \PHPDaemon\Network\Pool $wss
     * @return boolean
     */
    public function attachWss($wss)
    {
        if ($this->wss->contains($wss)) {
            return false;
        }
        $this->wss->attach($wss);
        $wss->bind('customTransport', [$this, 'wsHandler']);
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }
        return true;
    }

    /**
     * onFinish
     * @return void
     */
    public function onFinish()
    {
        foreach ($this->attachedTo as $wss) {
class MyClass { }

$x = new MyClass();
$x->foo = true;
            $this->detachWss($wss);
        }
        parent::onFinish();
    }

    /**
     * detachWss
     * @param  object $wss [@todo description]
     * @return boolean
     */
    public function detachWss($wss)
    {
        if (!$this->wss->contains($wss)) {
            return false;
        }
        $this->wss->detach($wss);
        $wss->unbind('transport', [$this, 'wsHandler']);
        return true;
    }

    /**
     * wsHandler
     * @param  object $ws [@todo description]
     * @param  string $path [@todo description]
     * @param  object $client [@todo description]
     * @param  callable $state [@todo description]
     * @callback $state ( object $route )
     * @return boolean
     */
    public function wsHandler($ws, $path, $client, $state)
    {
        $e = explode('/', $path);
        $method = array_pop($e);
        $serverId = null;
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
        $sessId = null;
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
        if ($method !== 'websocket') {
            return false;
        }
        if (sizeof($e) < 3 || !isset($e[sizeof($e) - 2]) || !ctype_digit($e[sizeof($e) - 2])) {
            return false;
        }
        $sessId = array_pop($e);
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
        $serverId = array_pop($e);
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
        $path = implode('/', $e);
        $client = new WebSocketConnectionProxy($this, $client);
        $route = $ws->getRoute($path, $client, true);
        if (!$route) {
            $state($route);
            return false;
        }
        $route = new WebSocketRouteProxy($this, $route);
        $state($route);
        return true;
    }

    /**
     * beginSession
     * @param  string $path [@todo description]
     * @param  string $sessId [@todo description]
     * @param  string $server [@todo description]
     * @return object

     */
    public function beginSession($path, $sessId, $server)
    {
        $session = new Session($this, $sessId, $server);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        foreach ($this->wss as $wss) {
            if ($session->route = $wss->getRoute($path, $session)) {
                break;
            }
        }
        if (!$session->route) {
            return false;
        }
        $this->sessions->attach($session);
        $session->onHandshake();
        return $session;
    }

    /**
     * getRouteOptions
     * @param  string $path [@todo description]
     * @return array
     */
    public function getRouteOptions($path)
    {
        $opts = [
            'websocket' => true,
            'origins' => ['*:*'],
            'cookie_needed' => false,
        ];
        foreach ($this->wss as $wss) {
            if ($wss->routeExists($path)) {
                foreach ($wss->getRouteOptions($path) as $k => $v) {
                    $opts[$k] = $v;
                }
                break;
            }
        }
        return $opts;
    }

    /**
     * endSession
     * @param Session $session
     * @return void
     */
    public function endSession($session)
    {
        $this->sessions->detach($session);
    }

    /**
     * Creates Request.
     * @param  object $req Request.
     * @param  object $upstream Upstream application instance.
     * @return object           Request.
     */
    public function beginRequest($req, $upstream)
    {
        $e = array_map('rawurldecode', explode('/', $req->attrs->server['DOCUMENT_URI']));

        $serverId = null;
        $sessId = null;

        /* Route discovery */
        $path = null;
        $extra = [];
        do {
            foreach ($this->wss as $wss) {
                $try = implode('/', $e);
                if ($try === '') {
                    $try = '/';
                }
                if ($wss->routeExists($try)) {
                    $path = $try;
                    break 2;
                }
            }
            array_unshift($extra, array_pop($e));
        } while (sizeof($e) > 0);

        if ($path === null) {
            return $this->callMethod('NotFound', $req, $upstream);
        }

        if (sizeof($extra) > 0 && end($extra) === '') {
            array_pop($extra);
        }

        $method = sizeof($extra) ? array_pop($extra) : null;

        if ($method === null) {
            $method = 'Welcome';
        } elseif ($method === 'info') {
        } elseif (preg_match('~^iframe(?:-([^/]*))?\.html$~', $method, $m)) {
            $method = 'Iframe';
            $version = isset($m[1]) ? $m[1] : null;
        } else {
            if (sizeof($extra) < 2) {
                return $this->callMethod('NotFound', $req, $upstream);
            }
            $sessId = array_pop($extra);
            $serverId = array_pop($extra);
            if ($sessId === '' || $serverId === '' || mb_orig_strpos($sessId,
                    '.') !== false || mb_orig_strpos($serverId, '.') !== false
            ) {
                return $this->callMethod('NotFound', $req, $upstream);
            }
        }
        $req->attrs->sessId = $sessId;
        $req->attrs->serverId = $serverId;
        $req->attrs->path = $path;
        $req = $this->callMethod($method, $req, $upstream);
        if ($req instanceof Methods\Iframe && mb_orig_strlen($version)) {
            $req->attrs->version = $version;
function myFunction($a) {
    switch ($a) {
        case 'foo':
            $x = 1;
            break;

        case 'bar':
            $x = 2;
            break;
    }

    // $x is potentially undefined here.
    echo $x;
}
        }
        return $req;
    }

    /**
     * callMethod
     * @param  string $method [@todo description]
     * @param  object $req [@todo description]
     * @param  object $upstream [@todo description]
     * @return object
     */
    public function callMethod($method, $req, $upstream)
    {
        $method = strtr(ucwords(strtr($method, ['_' => ' '])), [' ' => '']);
        if (strtolower($method) === 'generic') {
            $method = 'NotFound';
        }
        $class = __NAMESPACE__ . '\\Methods\\' . $method;
        if (!class_exists($class)) {
            $class = __NAMESPACE__ . '\\Methods\\NotFound';
        }
        return new $class($this, $upstream, $req);
    }

    /**
     * Setting default config options
     * @return array|bool
     */
    protected function getConfigDefaults()
    {
        return [
            /* [string] @todo redis-name */
            'redis-name' => '',

            /* [string] @todo redis-prefix */
            'redis-prefix' => 'sockjs:',

            /* [string] @todo wss-name */
            'wss-name' => '',

            /* [Double] @todo batch-delay */
            'batch-delay' => new \PHPDaemon\Config\Entry\Double('0.05'),

            /* [Double] @todo heartbeat-interval */
            'heartbeat-interval' => new \PHPDaemon\Config\Entry\Double('25'),

            /* [Time] @todo dead-session-timeout */
            'dead-session-timeout' => new \PHPDaemon\Config\Entry\Time('1h'),

            /* [Size] @todo gc-max-response-size */
            'gc-max-response-size' => new \PHPDaemon\Config\Entry\Size('128k'),

            /* [Time] @todo network-timeout-read */
            'network-timeout-read' => new \PHPDaemon\Config\Entry\Time('2h'),

            /* [Time] @todo network-timeout-write */
            'network-timeout-write' => new \PHPDaemon\Config\Entry\Time('120s'),
        ];
    }
}


Application C
last analyzed 2021-06-02 17:17 UTC

Complexity

Size/Duplication

Coupling/Cohesion

Importance

21 Methods

How to fix Complexity

Complex Class

Available Fixes

1			<?php
2			namespace PHPDaemon\SockJS;
3
4			use PHPDaemon\Servers\WebSocket\Pool as WebSocketPool;
5			use PHPDaemon\Structures\ObjectStorage;
6
7			/**
8			* @package Libraries
9			* @subpackage SockJS
10			* @author Vasily Zorin <[email protected]>
11			*/
12			class Application extends \PHPDaemon\Core\AppInstance
13			{
14			public $wss;
15			protected $redis;
16			protected $sessions;
17
18			/**
19			* Set Redis instance
20			* @param \PHPDaemon\Clients\Redis\Pool $redis
21			* @return $this
22			*/
23			public function setRedis(\PHPDaemon\Clients\Redis\Pool $redis)
24			{
25			$this->redis = $redis;
26			return $this;
27			}
28
29			/**
30			* getLocalSubscribersCount
31			* @param string $chan
32			* @return integer
33			*/
34			public function getLocalSubscribersCount($chan)
35			{
36			return $this->redis->getLocalSubscribersCount($this->config->redisprefix->value . $chan);
37			}
38
39			/**
40			* subscribe

kakserpom / phpdaemon

Application C last analyzed 2021-06-02 17:17 UTC

Complexity

Size/Duplication

Coupling/Cohesion

Importance

21 Methods

How to fix Complexity

Complex Class

Available Fixes

Duplication Side-by-Side

Filter issues like

Application C
last analyzed 2021-06-02 17:17 UTC