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

Connection F
last analyzed 2021-06-02 17:17 UTC

↳ Parent: Project

Complexity

Total Complexity

Size/Duplication

Total Lines	462
Duplicated Lines	2.38 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

Metric	Value
dl	11
loc	462
rs	2
c	0
b	0
f	0
wmc	89
lcom	1
cbo	5

12 Methods

Rating	Name	Duplication	Size	Complexity
A	init()	0	4	1
F	sendRequestHeaders()	0	55	21
A	head()	0	4	1
A	get()	0	4	1
A	customRequestHeaders()	0	14	5
B	post()	0	29	9
A	getBody()	0	4	1
A	getHeaders()	0	4	1
A	getHeader()	0	5	2
F	onRead()	11	146	40
A	onFinish()	0	17	5
A	requestFinished()	0	20	2

How to fix Duplicated Code Complexity

Duplicated Code

Duplicate code is one of the most pungent code smells. A rule that is often used is to re-structure code once it is duplicated in three or more places.

Common duplication problems, and corresponding solutions are:

If you have the same expression in different places: Extract expression to a method
If you have the same method in different sub-classes: Extract method, and pull up field to the parent class
If you have the same code in unrelated classes: Consider extracting the code to a new class, and injecting that class

Complex Class

Tip: Before tackling complexity, make sure that you eliminate any duplication first. This often can reduce the size of classes significantly.

Complex classes like Connection often do a lot of different things. To break such a class down, we need to identify a cohesive component within that class. A common approach to find such a component is to look for fields/methods that share the same prefixes, or suffixes. You can also have a look at the cohesion graph to spot any un-connected, or weakly-connected components.

Once you have determined the fields that belong together, you can apply the Extract Class refactoring. If the component makes sense as a sub-class, Extract Subclass is also a candidate, and is often faster.

While breaking up the class, it is a good idea to analyze how other classes use Connection, and based on these observations, apply Extract Interface, too.

<?php
namespace PHPDaemon\Clients\HTTP;

use PHPDaemon\Clients\HTTP\UploadFile;
use PHPDaemon\Core\Daemon;
use PHPDaemon\HTTPRequest\Generic;
use PHPDaemon\Network\ClientConnection;

/**
 * @package    NetworkClients
 * @subpackage HTTPClient
 * @author     Vasily Zorin <[email protected]>
 */
class Connection extends ClientConnection
{
    /**
     * State: headers
     */
    const STATE_HEADERS = 1;

    /**
     * State: body
     */
    const STATE_BODY = 2;

    /**
     * @var array Associative array of headers
     */
    public $headers = [];

    /**
     * @var integer Content length
     */
    public $contentLength = -1;

    /**
     * @var string Contains response body
     */
    public $body = '';

    /**
     * @var string End of line
     */
    protected $EOL = "\r\n";

    /**
     * @var array Associative array of Cookies
     */
    public $cookie = [];

    /**
     * @var integer Size of current chunk
     */
    protected $curChunkSize;

    /**
     * @var string
     */
    protected $curChunk;

    /**
     * @var boolean
     */
    public $chunked = false;

    /**
     * @var callback
     */
    public $chunkcb;

    /**
     * @var integer
     */
    public $protocolError;

    /**
     * @var integer
     */
    public $responseCode = 0;

    /**
     * @var string Last requested URL
     */
    public $lastURL;

    /**
     * @var array Raw headers array
     */
    public $rawHeaders = null;

    public $contentType;

    public $charset;

    public $eofTerminated = false;

    /**
     * @var \SplStack
     */
    protected $requests;

    /**
     * @var string
     */
    public $reqType;

    /**
     * Constructor
     */
    protected function init()
    {
        $this->requests = new \SplStack;
    }

    /**
     * Send request headers
     * @param $type
     * @param $url
     * @param &$params
     * @return void
     */
    protected function sendRequestHeaders($type, $url, &$params)
    {
        if (!is_array($params)) {
            $params = ['resultcb' => $params];
        }
        if (!isset($params['uri']) || !isset($params['host'])) {
            $prepared = Pool::parseUrl($url);
            if (!$prepared) {
                if (isset($params['resultcb'])) {
                    $params['resultcb'](false);
                }
                return;
            }
            list($params['host'], $params['uri']) = $prepared;
        }
        if ($params['uri'] === '') {
            $params['uri'] = '/';
        }
        $this->lastURL = 'http://' . $params['host'] . $params['uri'];
        if (!isset($params['version'])) {
            $params['version'] = '1.1';
        }
        $this->writeln($type . ' ' . $params['uri'] . ' HTTP/' . $params['version']);
        if (isset($params['proxy'])) {
            if (isset($params['proxy']['auth'])) {
                $this->writeln('Proxy-Authorization: basic ' . base64_encode($params['proxy']['auth']['username'] . ':' . $params['proxy']['auth']['password']));
            }
        }
        $this->writeln('Host: ' . $params['host']);
        if ($this->pool->config->expose->value && !isset($params['headers']['User-Agent'])) {
            $this->writeln('User-Agent: phpDaemon/' . Daemon::$version);
        }
        if (isset($params['cookie']) && sizeof($params['cookie'])) {
            $this->writeln('Cookie: ' . http_build_query($params['cookie'], '', '; '));
        }
        if (isset($params['contentType'])) {
            if (!isset($params['headers'])) {
                $params['headers'] = [];
            }
            $params['headers']['Content-Type'] = $params['contentType'];
        }
        if (isset($params['headers'])) {
            $this->customRequestHeaders($params['headers']);
        }
        if (isset($params['rawHeaders']) && $params['rawHeaders']) {
            $this->rawHeaders = [];
        }
        if (isset($params['chunkcb']) && is_callable($params['chunkcb'])) {
            $this->chunkcb = $params['chunkcb'];
        }
        $this->writeln('');
        $this->requests->push($type);
        $this->onResponse->push($params['resultcb']);
        $this->checkFree();
    }

    /**
     * Perform a HEAD request
     * @param string $url
     * @param array $params

     */
    public function head($url, $params = null)
    {
        $this->sendRequestHeaders('HEAD', $url, $params);
    }

    /**
     * Perform a GET request
     * @param string $url
     * @param array $params

     */
    public function get($url, $params = null)
    {
        $this->sendRequestHeaders('GET', $url, $params);
    }

    /**
     * @param array $headers
     */
    protected function customRequestHeaders($headers)
    {
        foreach ($headers as $key => $item) {
            if (is_numeric($key)) {
                if (is_string($item)) {
                    $this->writeln($item);
                } elseif (is_array($item)) {
                    $this->writeln($item[0] . ': ' . $item[1]); // @TODO: prevent injections?
                }
            } else {
                $this->writeln($key . ': ' . $item);
            }
        }
    }

    /**
     * Perform a POST request
     * @param string $url
     * @param array $data
     * @param array $params

     */
    public function post($url, $data = [], $params = null)
    {
        if (!is_string($data)) {
            foreach ($data as $val) {
                if ($val instanceof UploadFile) {
if ($x instanceof DoesNotExist) {
    // Do something.
}
                    $params['contentType'] = 'multipart/form-data';
                }
            }
        }
        if (!isset($params['contentType'])) {
            $params['contentType'] = 'application/x-www-form-urlencoded';
        }

        if ($params['contentType'] === 'application/x-www-form-urlencoded') {
            $body = http_build_query($data, '', '&', PHP_QUERY_RFC3986);
        } elseif ($params['contentType'] === 'application/x-json' || $params['contentType'] === 'application/json') {
            $body = json_encode($data);
        } else {
            $body = $data;
        }

        if (!isset($params['headers'])) {
            $params['headers'] = [];
        }
        $params['headers']['Content-Length'] = mb_orig_strlen($body);
/**
 * @return array|string
 */
function returnsDifferentValues($x) {
    if ($x) {
        return 'foo';
    }

    return array();
}

$x = returnsDifferentValues($y);
if (is_array($x)) {
    // $x is an array.
}
        $this->sendRequestHeaders('POST', $url, $params);
        $this->write($body);
/**
 * @return array|string
 */
function returnsDifferentValues($x) {
    if ($x) {
        return 'foo';
    }

    return array();
}

$x = returnsDifferentValues($y);
if (is_array($x)) {
    // $x is an array.
}
        $this->writeln('');
    }

    /**
     * Get body
     * @return string
     */
    public function getBody()
    {
        return $this->body;
    }

    /**
     * Get headers
     * @return array
     */
    public function getHeaders()
    {
        return $this->headers;
    }

    /**
     * Get header
     * @param  string $name Header name
     * @return string
     */
    public function getHeader($name)
    {
        $k = 'HTTP_' . strtoupper(strtr($name, Generic::$htr));
        return isset($this->headers[$k]) ? $this->headers[$k] : null;
    }

    /**
     * Called when new data received
     */
    public function onRead()
    {
        if ($this->state === self::STATE_BODY) {
            goto body;
        }
        if ($this->reqType === null) {
            if ($this->requests->isEmpty()) {
                $this->finish();
                return;
            }
            $this->reqType = $this->requests->shift();
        }
        while (($line = $this->readLine()) !== null) {
            if ($line !== '') {
                if ($this->rawHeaders !== null) {
                    $this->rawHeaders[] = $line;
                }
            } else {
                if (isset($this->headers['HTTP_CONTENT_LENGTH'])) {
                    $this->contentLength = (int)$this->headers['HTTP_CONTENT_LENGTH'];
                } else {
                    $this->contentLength = -1;
                }
                if (isset($this->headers['HTTP_TRANSFER_ENCODING'])) {

                    $e = explode(', ', strtolower($this->headers['HTTP_TRANSFER_ENCODING']));
                    $this->chunked = in_array('chunked', $e, true);
                } else {
                    $this->chunked = false;
                }
                if (isset($this->headers['HTTP_CONNECTION'])) {

                    $e = explode(', ', strtolower($this->headers['HTTP_CONNECTION']));
                    $this->keepalive = in_array('keep-alive', $e, true);
                }
                if (isset($this->headers['HTTP_CONTENT_TYPE'])) {
                    parse_str('type=' . strtr($this->headers['HTTP_CONTENT_TYPE'], [';' => '&', ' ' => '']), $p);
                    $this->contentType = $p['type'];
                    if (isset($p['charset'])) {
                        $this->charset = strtolower($p['charset']);
                    }
                }
                if ($this->contentLength === -1 && !$this->chunked && !$this->keepalive) {
                    $this->eofTerminated = true;
                }
                if ($this->reqType === 'HEAD') {
                    $this->requestFinished();
                } else {
                    $this->state = self::STATE_BODY;
                }
                break;
            }
            if ($this->state === self::STATE_ROOT) {
                $this->headers['STATUS'] = $line;
                $e = explode(' ', $this->headers['STATUS']);
                $this->responseCode = isset($e[1]) ? (int)$e[1] : 0;
                $this->state = self::STATE_HEADERS;
            } elseif ($this->state === self::STATE_HEADERS) {
                $e = explode(': ', $line);

                if (isset($e[1])) {
                    $k = 'HTTP_' . strtoupper(strtr($e[0], Generic::$htr));
                    if ($k === 'HTTP_SET_COOKIE') {
                        parse_str(strtr($e[1], [';' => '&', ' ' => '']), $p);
                        if (sizeof($p)) {
                            $this->cookie[$k = key($p)] =& $p;
                            $p['value'] = $p[$k];
                            unset($p[$k], $p);
                        }
                    }
                    if (isset($this->headers[$k])) {
                        if (is_array($this->headers[$k])) {
                            $this->headers[$k][] = $e[1];
                        } else {
                            $this->headers[$k] = [$this->headers[$k], $e[1]];
                        }
                    } else {
                        $this->headers[$k] = $e[1];
                    }
                }
            }
        }
        if ($this->state !== self::STATE_BODY) {
            return; // not enough data yet
        }
        body:
        if ($this->eofTerminated) {
            $body = $this->readUnlimited();
            if ($this->chunkcb) {
                $func = $this->chunkcb;
                $func($body);
            }
            $this->body .= $body;
            return;
        }
        if ($this->chunked) {
            chunk:
            if ($this->curChunkSize === null) { // outside of chunk
                $l = $this->readLine();
                if ($l === '') { // skip empty line
                    goto chunk;
                }
                if ($l === null) {
                    return; // not enough data yet
                }
                if (!ctype_xdigit($l)) {
                    $this->protocolError = __LINE__;
                    $this->finish(); // protocol error
                    return;
                }
                $this->curChunkSize = hexdec($l);
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
            }
            if ($this->curChunkSize !== null) {
                if ($this->curChunkSize === 0) {
                    if ($this->readLine() === '') {
                        $this->requestFinished();
                        return;
                    } else { // protocol error
                        $this->protocolError = __LINE__;
                        $this->finish();
                        return;
                    }
                }
                $n = $this->curChunkSize - mb_orig_strlen($this->curChunk);
                $this->curChunk .= $this->read($n);
                if ($this->curChunkSize <= mb_orig_strlen($this->curChunk)) {
                    if ($this->chunkcb) {
                        $func = $this->chunkcb;
                        $func($this->curChunk);
                    }
                    $this->body .= $this->curChunk;
                    $this->curChunkSize = null;
                    $this->curChunk = '';
                    goto chunk;
                }
            }
        } else {
            $body = $this->read($this->contentLength - mb_orig_strlen($this->body));
            if ($this->chunkcb) {
                $func = $this->chunkcb;
                $func($body);
            }
            $this->body .= $body;
            if (($this->contentLength !== -1) && (mb_orig_strlen($this->body) >= $this->contentLength)) {
                $this->requestFinished();
            }
        }
    }

    /**
     * Called when connection finishes
     */
    public function onFinish()
    {
        if ($this->eofTerminated) {
            $this->requestFinished();
            $this->onResponse->executeAll($this, false);
            parent::onFinish();
            return;
        }
        if ($this->protocolError) {
            $this->onResponse->executeAll($this, false);
        } else {
            if (($this->state !== self::STATE_ROOT) && !$this->onResponse->isEmpty()) {
                $this->requestFinished();
            }
        }
        parent::onFinish();
    }

    /**
     * Called when request is finished
     */
    protected function requestFinished()
    {
        $this->onResponse->executeOne($this, true);
        $this->state = self::STATE_ROOT;
        $this->contentLength = -1;
        $this->curChunkSize = null;
        $this->chunked = false;
        $this->eofTerminated = false;
        $this->headers = [];
        $this->rawHeaders = null;

        $this->contentType = null;
        $this->charset = null;
        $this->body = '';
        $this->responseCode = 0;
        $this->reqType = null;
        if (!$this->keepalive) {
            $this->finish();
        }
        $this->checkFree();
    }
}


Connection F
last analyzed 2021-06-02 17:17 UTC

Complexity

Size/Duplication

Coupling/Cohesion

Importance

12 Methods

How to fix Duplicated Code Complexity

Duplicated Code

Complex Class

1. Missing dependencies

2. Missing use statement

1		<?php
2		namespace PHPDaemon\Clients\HTTP;
3
4		use PHPDaemon\Clients\HTTP\UploadFile;
5		use PHPDaemon\Core\Daemon;
6		use PHPDaemon\HTTPRequest\Generic;
7		use PHPDaemon\Network\ClientConnection;
8
9		/**
10		* @package NetworkClients
11		* @subpackage HTTPClient
12		* @author Vasily Zorin <[email protected]>
13		*/
14		class Connection extends ClientConnection
15		{
16		/**
17		* State: headers
18		*/
19		const STATE_HEADERS = 1;
20
21		/**
22		* State: body
23		*/
24		const STATE_BODY = 2;
25
26		/**
27		* @var array Associative array of headers
28		*/
29		public $headers = [];
30
31		/**
32		* @var integer Content length
33		*/
34		public $contentLength = -1;
35
36		/**
37		* @var string Contains response body
38		*/
39		public $body = '';
40
41		/**
42		* @var string End of line
43		*/
44		protected $EOL = "\r\n";
45
46		/**
47		* @var array Associative array of Cookies
48		*/
49		public $cookie = [];
50
51		/**
52		* @var integer Size of current chunk
53		*/
54		protected $curChunkSize;
55
56		/**
57		* @var string
58		*/
59		protected $curChunk;
60
61		/**
62		* @var boolean
63		*/
64		public $chunked = false;
65
66		/**
67		* @var callback
68		*/
69		public $chunkcb;
70
71		/**
72		* @var integer
73		*/
74		public $protocolError;
75
76		/**
77		* @var integer
78		*/
79		public $responseCode = 0;
80
81		/**
82		* @var string Last requested URL
83		*/
84		public $lastURL;
85
86		/**
87		* @var array Raw headers array
88		*/
89		public $rawHeaders = null;
90
91		public $contentType;
92
93		public $charset;
94
95		public $eofTerminated = false;
96
97		/**
98		* @var \SplStack
99		*/
100		protected $requests;
101
102		/**
103		* @var string
104		*/
105		public $reqType;
106
107		/**
108		* Constructor
109		*/
110		protected function init()
111		{
112		$this->requests = new \SplStack;
113		}
114
115		/**
116		* Send request headers
117		* @param $type
118		* @param $url
119		* @param &$params
120		* @return void
121		*/
122		protected function sendRequestHeaders($type, $url, &$params)
123		{
124		if (!is_array($params)) {
125		$params = ['resultcb' => $params];
126		}
127		if (!isset($params['uri']) \|\| !isset($params['host'])) {
128		$prepared = Pool::parseUrl($url);
129		if (!$prepared) {
130		if (isset($params['resultcb'])) {
131		$params['resultcb'](false);
132		}
133		return;
134		}
135		list($params['host'], $params['uri']) = $prepared;
136		}
137		if ($params['uri'] === '') {
138		$params['uri'] = '/';
139		}
140		$this->lastURL = 'http://' . $params['host'] . $params['uri'];
141		if (!isset($params['version'])) {
142		$params['version'] = '1.1';
143		}
144		$this->writeln($type . ' ' . $params['uri'] . ' HTTP/' . $params['version']);
145		if (isset($params['proxy'])) {
146		if (isset($params['proxy']['auth'])) {
147		$this->writeln('Proxy-Authorization: basic ' . base64_encode($params['proxy']['auth']['username'] . ':' . $params['proxy']['auth']['password']));
148		}
149		}
150		$this->writeln('Host: ' . $params['host']);
151		if ($this->pool->config->expose->value && !isset($params['headers']['User-Agent'])) {
152		$this->writeln('User-Agent: phpDaemon/' . Daemon::$version);
153		}
154		if (isset($params['cookie']) && sizeof($params['cookie'])) {
155		$this->writeln('Cookie: ' . http_build_query($params['cookie'], '', '; '));
156		}
157		if (isset($params['contentType'])) {
158		if (!isset($params['headers'])) {
159		$params['headers'] = [];
160		}
161		$params['headers']['Content-Type'] = $params['contentType'];
162		}
163		if (isset($params['headers'])) {
164		$this->customRequestHeaders($params['headers']);
165		}
166		if (isset($params['rawHeaders']) && $params['rawHeaders']) {
167		$this->rawHeaders = [];
168		}
169		if (isset($params['chunkcb']) && is_callable($params['chunkcb'])) {
170		$this->chunkcb = $params['chunkcb'];
171		}
172		$this->writeln('');
173		$this->requests->push($type);
174		$this->onResponse->push($params['resultcb']);
175		$this->checkFree();
176		}
177
178		/**
179		* Perform a HEAD request
180		* @param string $url
181		* @param array $params
		0 ignored issues – show Documentation introduced 2016-05-19 07:18 UTC by Report Bug Copy Issue Report Should the type for parameter `$params` not be `array\|null`? This check looks for `@param` annotations where the type inferred by our type inference engine differs from the declared type. It makes a suggestion as to what type it considers more descriptive. Most often this is a case of a parameter that can be null in addition to its declared types. Loading history...
182		*/
183		public function head($url, $params = null)
184		{
185		$this->sendRequestHeaders('HEAD', $url, $params);
186		}
187
188		/**
189		* Perform a GET request
190		* @param string $url
191		* @param array $params
		0 ignored issues – show Documentation introduced 2016-05-19 07:18 UTC by Report Bug Copy Issue Report Should the type for parameter `$params` not be `array\|null`? This check looks for `@param` annotations where the type inferred by our type inference engine differs from the declared type. It makes a suggestion as to what type it considers more descriptive. Most often this is a case of a parameter that can be null in addition to its declared types. Loading history...
192		*/
193		public function get($url, $params = null)
194		{
195		$this->sendRequestHeaders('GET', $url, $params);
196		}
197
198		/**
199		* @param array $headers
200		*/
201		protected function customRequestHeaders($headers)
202		{
203		foreach ($headers as $key => $item) {
204		if (is_numeric($key)) {
205		if (is_string($item)) {
206		$this->writeln($item);
207		} elseif (is_array($item)) {
208		$this->writeln($item[0] . ': ' . $item[1]); // @TODO: prevent injections?
209		}
210		} else {
211		$this->writeln($key . ': ' . $item);
212		}
213		}
214		}
215
216		/**
217		* Perform a POST request
218		* @param string $url
219		* @param array $data
220		* @param array $params
		0 ignored issues – show Documentation introduced 2016-05-19 07:18 UTC by Report Bug Copy Issue Report Should the type for parameter `$params` not be `array\|null`? This check looks for `@param` annotations where the type inferred by our type inference engine differs from the declared type. It makes a suggestion as to what type it considers more descriptive. Most often this is a case of a parameter that can be null in addition to its declared types. Loading history...
221		*/
222		public function post($url, $data = [], $params = null)
223		{
224		if (!is_string($data)) {
225		foreach ($data as $val) {
226		if ($val instanceof UploadFile) {
		0 ignored issues – show Bug introduced 2016-05-16 20:46 UTC by Report Bug Copy Issue Report The class `PHPDaemon\Clients\HTTP\UploadFile` does not exist. Did you forget a USE statement, or did you not list all dependencies? This error could be the result of: 1. Missing dependencies PHP Analyzer uses your `composer.json` file (if available) to determine the dependencies of your project and to determine all the available classes and functions. It expects the `composer.json` to be in the root folder of your repository. Are you sure this class is defined by one of your dependencies, or did you maybe not list a dependency in either the `require` or `require-dev` section? 2. Missing use statement PHP does not complain about undefined classes in `ìnstanceof` checks. For example, the following PHP code will work perfectly fine: if ($x instanceof DoesNotExist) { // Do something. } If you have not tested against this specific condition, such errors might go unnoticed. Loading history...
227		$params['contentType'] = 'multipart/form-data';
228		}
229		}
230		}
231		if (!isset($params['contentType'])) {
232		$params['contentType'] = 'application/x-www-form-urlencoded';
233		}
234
235		if ($params['contentType'] === 'application/x-www-form-urlencoded') {
236		$body = http_build_query($data, '', '&', PHP_QUERY_RFC3986);
237		} elseif ($params['contentType'] === 'application/x-json' \|\| $params['contentType'] === 'application/json') {
238		$body = json_encode($data);
239		} else {
240		$body = $data;
241		}
242
243		if (!isset($params['headers'])) {
244		$params['headers'] = [];
245		}
246		$params['headers']['Content-Length'] = mb_orig_strlen($body);
		0 ignored issues – show Bug introduced 2019-06-11 12:44 UTC by Report Bug Copy Issue Report It seems like `$body` defined by `$data` on line `240` can also be of type `array`; however, `mb_orig_strlen()` does only seem to accept `string`, maybe add an additional type check? If a method or function can return multiple different values and unless you are sure that you only can receive a single value in this context, we recommend to add an additional type check: /** * @return array\|string */ function returnsDifferentValues($x) { if ($x) { return 'foo'; } return array(); } $x = returnsDifferentValues($y); if (is_array($x)) { // $x is an array. } If this a common case that PHP Analyzer should handle natively, please let us know by opening an issue. Loading history...
247		$this->sendRequestHeaders('POST', $url, $params);
248		$this->write($body);
		0 ignored issues – show Bug introduced 2019-06-11 12:44 UTC by Report Bug Copy Issue Report It seems like `$body` defined by `$data` on line `240` can also be of type `array`; however, `PHPDaemon\Network\Connection::write()` does only seem to accept `string`, maybe add an additional type check? If a method or function can return multiple different values and unless you are sure that you only can receive a single value in this context, we recommend to add an additional type check: /** * @return array\|string */ function returnsDifferentValues($x) { if ($x) { return 'foo'; } return array(); } $x = returnsDifferentValues($y); if (is_array($x)) { // $x is an array. } If this a common case that PHP Analyzer should handle natively, please let us know by opening an issue. Loading history...
249		$this->writeln('');
250		}
251
252		/**
253		* Get body
254		* @return string
255		*/
256		public function getBody()
257		{
258		return $this->body;
259		}
260
261		/**
262		* Get headers
263		* @return array
264		*/
265		public function getHeaders()
266		{
267		return $this->headers;
268		}
269
270		/**
271		* Get header
272		* @param string $name Header name
273		* @return string
274		*/
275		public function getHeader($name)
276		{
277		$k = 'HTTP_' . strtoupper(strtr($name, Generic::$htr));
278		return isset($this->headers[$k]) ? $this->headers[$k] : null;
279		}
280
281		/**
282		* Called when new data received
283		*/
284		public function onRead()
285		{
286		if ($this->state === self::STATE_BODY) {
287		goto body;
288		}
289		if ($this->reqType === null) {
290		if ($this->requests->isEmpty()) {
291		$this->finish();
292		return;
293		}
294		$this->reqType = $this->requests->shift();
295		}
296		while (($line = $this->readLine()) !== null) {
297		if ($line !== '') {
298		if ($this->rawHeaders !== null) {
299		$this->rawHeaders[] = $line;
300		}
301		} else {
302		if (isset($this->headers['HTTP_CONTENT_LENGTH'])) {
303		$this->contentLength = (int)$this->headers['HTTP_CONTENT_LENGTH'];
304		} else {
305		$this->contentLength = -1;
306		}
307	View Code Duplication	if (isset($this->headers['HTTP_TRANSFER_ENCODING'])) {
		0 ignored issues – show Duplication introduced 2015-12-06 14:42 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
308		$e = explode(', ', strtolower($this->headers['HTTP_TRANSFER_ENCODING']));
309		$this->chunked = in_array('chunked', $e, true);
310		} else {
311		$this->chunked = false;
312		}
313	View Code Duplication	if (isset($this->headers['HTTP_CONNECTION'])) {
		0 ignored issues – show Duplication introduced 2015-12-06 14:42 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
314		$e = explode(', ', strtolower($this->headers['HTTP_CONNECTION']));
315		$this->keepalive = in_array('keep-alive', $e, true);
316		}
317		if (isset($this->headers['HTTP_CONTENT_TYPE'])) {
318		parse_str('type=' . strtr($this->headers['HTTP_CONTENT_TYPE'], [';' => '&', ' ' => '']), $p);
319		$this->contentType = $p['type'];
320		if (isset($p['charset'])) {
321		$this->charset = strtolower($p['charset']);
322		}
323		}
324		if ($this->contentLength === -1 && !$this->chunked && !$this->keepalive) {
325		$this->eofTerminated = true;
326		}
327		if ($this->reqType === 'HEAD') {
328		$this->requestFinished();
329		} else {
330		$this->state = self::STATE_BODY;
331		}
332		break;
333		}
334		if ($this->state === self::STATE_ROOT) {
335		$this->headers['STATUS'] = $line;
336		$e = explode(' ', $this->headers['STATUS']);
337		$this->responseCode = isset($e[1]) ? (int)$e[1] : 0;
338		$this->state = self::STATE_HEADERS;
339		} elseif ($this->state === self::STATE_HEADERS) {
340		$e = explode(': ', $line);
341
342		if (isset($e[1])) {
343		$k = 'HTTP_' . strtoupper(strtr($e[0], Generic::$htr));
344		if ($k === 'HTTP_SET_COOKIE') {
345		parse_str(strtr($e[1], [';' => '&', ' ' => '']), $p);
346		if (sizeof($p)) {
347		$this->cookie[$k = key($p)] =& $p;
348		$p['value'] = $p[$k];
349		unset($p[$k], $p);
350		}
351		}
352		if (isset($this->headers[$k])) {
353		if (is_array($this->headers[$k])) {
354		$this->headers[$k][] = $e[1];
355		} else {
356		$this->headers[$k] = [$this->headers[$k], $e[1]];
357		}
358		} else {
359		$this->headers[$k] = $e[1];
360		}
361		}
362		}
363		}
364		if ($this->state !== self::STATE_BODY) {
365		return; // not enough data yet
366		}
367		body:
368		if ($this->eofTerminated) {
369		$body = $this->readUnlimited();
370		if ($this->chunkcb) {
371		$func = $this->chunkcb;
372		$func($body);
373		}
374		$this->body .= $body;
375		return;
376		}
377		if ($this->chunked) {
378		chunk:
379		if ($this->curChunkSize === null) { // outside of chunk
380		$l = $this->readLine();
381		if ($l === '') { // skip empty line
382		goto chunk;
383		}
384		if ($l === null) {
385		return; // not enough data yet
386		}
387		if (!ctype_xdigit($l)) {
388		$this->protocolError = __LINE__;
389		$this->finish(); // protocol error
390		return;
391		}
392		$this->curChunkSize = hexdec($l);
		0 ignored issues – show Documentation Bug introduced 2015-12-06 14:42 UTC by Report Bug Copy Issue Report It seems like `hexdec($l)` can also be of type `double`. However, the property `$curChunkSize` is declared as type `integer`. Maybe add an additional type check? Our type inference engine has found a suspicous assignment of a value to a property. This check raises an issue when a value that can be of a mixed type is assigned to a property that is type hinted more strictly. For example, imagine you have a variable `$accountId` that can either hold an Id object or false (if there is no account id yet). Your code now assigns that value to the `id` property of an instance of the `Account` class. This class holds a proper account, so the id value must no longer be false. Either this assignment is in error or a type check should be added for that assignment. class Id { public $id; public function __construct($id) { $this->id = $id; } } class Account { /** @var Id $id */ public $id; } $account_id = false; if (starsAreRight()) { $account_id = new Id(42); } $account = new Account(); if ($account instanceof Id) { $account->id = $account_id; } Loading history...
393		}
394		if ($this->curChunkSize !== null) {
395		if ($this->curChunkSize === 0) {
396		if ($this->readLine() === '') {
397		$this->requestFinished();
398		return;
399		} else { // protocol error
400		$this->protocolError = __LINE__;
401		$this->finish();
402		return;
403		}
404		}
405		$n = $this->curChunkSize - mb_orig_strlen($this->curChunk);
406		$this->curChunk .= $this->read($n);
407		if ($this->curChunkSize <= mb_orig_strlen($this->curChunk)) {
408		if ($this->chunkcb) {
409		$func = $this->chunkcb;
410		$func($this->curChunk);
411		}
412		$this->body .= $this->curChunk;
413		$this->curChunkSize = null;
414		$this->curChunk = '';
415		goto chunk;
416		}
417		}
418		} else {
419		$body = $this->read($this->contentLength - mb_orig_strlen($this->body));
420		if ($this->chunkcb) {
421		$func = $this->chunkcb;
422		$func($body);
423		}
424		$this->body .= $body;
425		if (($this->contentLength !== -1) && (mb_orig_strlen($this->body) >= $this->contentLength)) {
426		$this->requestFinished();
427		}
428		}
429		}
430
431		/**
432		* Called when connection finishes
433		*/
434		public function onFinish()
435		{
436		if ($this->eofTerminated) {
437		$this->requestFinished();
438		$this->onResponse->executeAll($this, false);
439		parent::onFinish();
440		return;
441		}
442		if ($this->protocolError) {
443		$this->onResponse->executeAll($this, false);
444		} else {
445		if (($this->state !== self::STATE_ROOT) && !$this->onResponse->isEmpty()) {
446		$this->requestFinished();
447		}
448		}
449		parent::onFinish();
450		}
451
452		/**
453		* Called when request is finished
454		*/
455		protected function requestFinished()
456		{
457		$this->onResponse->executeOne($this, true);
458		$this->state = self::STATE_ROOT;
459		$this->contentLength = -1;
460		$this->curChunkSize = null;
461		$this->chunked = false;
462		$this->eofTerminated = false;
463		$this->headers = [];
464		$this->rawHeaders = null;
		0 ignored issues – show Documentation Bug introduced 2015-12-06 14:42 UTC by Report Bug Copy Issue Report It seems like `null` of type `null` is incompatible with the declared type `array` of property `$rawHeaders`. Our type inference engine has found an assignment to a property that is incompatible with the declared type of that property. Either this assignment is in error or the assigned type should be added to the documentation/type hint for that property.. Loading history...
465		$this->contentType = null;
466		$this->charset = null;
467		$this->body = '';
468		$this->responseCode = 0;
469		$this->reqType = null;
470		if (!$this->keepalive) {
471		$this->finish();
472		}
473		$this->checkFree();
474		}
475		}
476

kakserpom / phpdaemon

Connection F last analyzed 2021-06-02 17:17 UTC

Complexity

Size/Duplication

Coupling/Cohesion

Importance

12 Methods

How to fix Duplicated Code Complexity

Duplicated Code

Complex Class

1. Missing dependencies

2. Missing use statement

Duplication Side-by-Side

Filter issues like

Connection F
last analyzed 2021-06-02 17:17 UTC