RequestParser::__construct() - Code Metrics - Inspection of "Initial commit" - ThrusterIO/http - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( bc5bb1...0df69c )

by Aurimas

created 2016-01-09 22:46 UTC

RequestParser::__construct() A

↳ Parent: RequestParser

Complexity

Conditions	2
Paths	2

Size

Total Lines	21
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	2.004

Metric	Value
dl	0
loc	21
ccs	9
cts	10
cp	0.9
rs	9.3143
cc	2
eloc	14
nc	2
nop	1
crap	2.004

<?php

namespace Thruster\Component\Http;

use Thruster\Component\EventEmitter\EventEmitterInterface;
use Thruster\Component\EventEmitter\EventEmitterTrait;
use Thruster\Component\Http\Exception\BadRequestException;
use Thruster\Component\Http\Exception\RequestEntityTooLargeException;
use Thruster\Component\Http\Exception\RequestHTTPVersionNotSupported;
use Thruster\Component\Http\Exception\RequestURITooLongException;
use Thruster\Component\Stream\StreamInterface;

/**
 * Class RequestParser
 *
 * @package Thruster\Component\Http
 * @author  Aurimas Niekis <[email protected]>
 */
class RequestParser implements EventEmitterInterface
{
    use EventEmitterTrait;

    const HEAD_SEPARATOR = "\r\n\r\n";

    /**
     * @var array
     */
    protected $options;

    /**
     * @var bool
     */
    protected $receivedHead;

    /**
     * @var resource
     */
    protected $head;

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

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

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

    /**
     * @var array
     */
    protected $headers;

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

    public function __construct(array $options = [])
    {
        $options += [
            'max_head_size' => 8190,
            'max_request_line' => 8190,
            'max_body_size' => 10 * 1024 * 1024,
            'memory_limit' => 1 * 1024 * 1024,
            'supported_protocol_versions' => ['1.0' => true, '1.1' => true]
        ];

        $this->options = $options;
        $this->receivedHead = false;
        $this->head = '';

        $this->headers = [];

        $this->body = fopen('php://temp/maxmemory:' . $options['memory_limit'], 'r+b');


        if (false === $this->body) {
            throw new \RuntimeException('Could not open buffer for body');
        }
    }

    /**
     * @param $data

     * @throws BadRequestException
     * @throws RequestEntityTooLargeException
     * @throws RequestURITooLongException
     */
    public function onData($data)
    {
        if ($this->receivedHead) {
            fwrite($this->body, $data);

            $this->checkBodySize();
        } else {
            $this->head .= $data;

            if (false !== strpos($this->head, self::HEAD_SEPARATOR)) {
                list($head, $body) = explode(self::HEAD_SEPARATOR, $this->head, 2);

                fwrite($this->body, $body);
                $this->head = $head;

                $this->checkHeadSize();

                $this->parseHead();

                $this->checkProtocolVersion();

                $this->parseUri();

                $this->checkBodySize();
                $this->receivedHead = true;

                $this->emit('received_head', [$this->headers, $this->httpMethod, $this->uri, $this->protocolVersion]);
            }
        }

        if ($this->isRequestFinished()) {
            $this->emit('request', [$this->buildRequest()]);
        }
    }

    /**
     * @throws BadRequestException
     * @throws RequestURITooLongException
     */
    protected function parseHead()
    {
        $parsedRequestLine = false;
        foreach (explode("\n", str_replace(["\r\n", "\n\r", "\r"], "\n", $this->head)) as $line) {
            if (false === $parsedRequestLine) {
                if (strlen($line) > $this->options['max_request_line']) {
                    throw new RequestURITooLongException();
                }

                if (false == preg_match('/^[a-zA-Z]+\s+([a-zA-Z]+:\/\/|\/).*/', $line, $matches)) {

                    throw new BadRequestException();
                }

                $parts = explode(' ', $line, 3);
                $this->httpMethod = $parts[0];
                $this->protocolVersion = explode('/', $parts[2] ?? 'HTTP/1.1')[1];
                $this->uri = $parts[1];

                $parsedRequestLine = true;
                continue;
            }

            if (false !== strpos($line, ':')) {
                $parts = explode(':', $line, 2);
                $key = trim($parts[0]);
                $value = trim($parts[1] ?? '');

                $this->headers[$key][] = $value;
            }
        }
    }

    protected function parseUri()
    {
        $hostKey = array_filter(
            array_keys($this->headers),
            function ($key) {
                return 'host' === strtolower($key);
            }
        );

        if (!$hostKey) {

            return;
        }

        $host = $this->headers[reset($hostKey)][0];
        $scheme = ':443' === substr($host, -4) ? 'https' : 'http';

        $this->uri = $scheme . '://' . $host . '/' . ltrim($this->uri, '/');
    }

    protected function buildRequest()
    {
        rewind($this->body);

        $request = new ServerRequest(
            [],
            [],
            $this->uri,
            $this->httpMethod,
            $this->body,
            $this->headers,
            [],
            [],
            null,
            $this->protocolVersion
        );

        return $request;
    }

    protected function isRequestFinished() : bool
    {
        if (false === $this->receivedHead) {
            return false;
        }

        if (false === isset($this->headers['Content-Length'])) {
            return true;
        }

        $contentLength = max($this->headers['Content-Length']);
        if ($contentLength <= $this->getBodySize()) {
            return true;
        }

        return false;
    }

    /**
     * @throws RequestEntityTooLargeException
     */
    protected function checkBodySize()
    {
        if ($this->getBodySize() > $this->options['max_body_size']) {
            throw new RequestEntityTooLargeException();
        }
    }

    /**
     * @throws RequestEntityTooLargeException
     */
    protected function checkHeadSize()
    {
        if (strlen($this->head) > $this->options['max_head_size']) {
            throw new RequestEntityTooLargeException();
        }
    }

    /**
     * @throws RequestHTTPVersionNotSupported
     */
    protected function checkProtocolVersion()
    {
        if (false === isset($this->options['supported_protocol_versions'][$this->protocolVersion])) {
            throw new RequestHTTPVersionNotSupported();
        }
    }

    protected function getBodySize() : int
    {
        return fstat($this->body)['size'];
    }
}


1		<?php
2
3		namespace Thruster\Component\Http;
4
5		use Thruster\Component\EventEmitter\EventEmitterInterface;
6		use Thruster\Component\EventEmitter\EventEmitterTrait;
7		use Thruster\Component\Http\Exception\BadRequestException;
8		use Thruster\Component\Http\Exception\RequestEntityTooLargeException;
9		use Thruster\Component\Http\Exception\RequestHTTPVersionNotSupported;
10		use Thruster\Component\Http\Exception\RequestURITooLongException;
11		use Thruster\Component\Stream\StreamInterface;
12
13		/**
14		* Class RequestParser
15		*
16		* @package Thruster\Component\Http
17		* @author Aurimas Niekis <[email protected]>
18		*/
19		class RequestParser implements EventEmitterInterface
20		{
21		use EventEmitterTrait;
22
23		const HEAD_SEPARATOR = "\r\n\r\n";
24
25		/**
26		* @var array
27		*/
28		protected $options;
29
30		/**
31		* @var bool
32		*/
33		protected $receivedHead;
34
35		/**
36		* @var resource
37		*/
38		protected $head;
39
40		/**
41		* @var string
42		*/
43		protected $body;
44
45		/**
46		* @var string
47		*/
48		protected $httpMethod;
49
50		/**
51		* @var string
52		*/
53		protected $protocolVersion;
54
55		/**
56		* @var array
57		*/
58		protected $headers;
59
60		/**
61		* @var string
62		*/
63		protected $uri;
64
65	9	public function __construct(array $options = [])
66		{
67		$options += [
68	9	'max_head_size' => 8190,
69		'max_request_line' => 8190,
70		'max_body_size' => 10 * 1024 * 1024,
71		'memory_limit' => 1 * 1024 * 1024,
72		'supported_protocol_versions' => ['1.0' => true, '1.1' => true]
73		];
74
75	9	$this->options = $options;
76	9	$this->receivedHead = false;
77	9	$this->head = '';
		0 ignored issues – show Documentation Bug introduced 2016-01-05 22:36 UTC by Report Bug Copy Issue Report It seems like `''` of type `string` is incompatible with the declared type `resource` of property `$head`. 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...
78	9	$this->headers = [];
79
80	9	$this->body = fopen('php://temp/maxmemory:' . $options['memory_limit'], 'r+b');
		0 ignored issues – show Documentation Bug introduced 2016-01-05 22:36 UTC by Report Bug Copy Issue Report It seems like `fopen('php://temp/maxmem...'memory_limit'], 'r+b')` of type `resource` is incompatible with the declared type `string` of property `$body`. 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...
81
82	9	if (false === $this->body) {
83		throw new \RuntimeException('Could not open buffer for body');
84		}
85	9	}
86
87		/**
88		* @param $data
89
90		* @throws BadRequestException
91		* @throws RequestEntityTooLargeException
92		* @throws RequestURITooLongException
93		*/
94	9	public function onData($data)
95		{
96	9	if ($this->receivedHead) {
97	1	fwrite($this->body, $data);
98
99	1	$this->checkBodySize();
100		} else {
101	9	$this->head .= $data;
102
103	9	if (false !== strpos($this->head, self::HEAD_SEPARATOR)) {
104	9	list($head, $body) = explode(self::HEAD_SEPARATOR, $this->head, 2);
105
106	9	fwrite($this->body, $body);
107	9	$this->head = $head;
108
109	9	$this->checkHeadSize();
110
111	8	$this->parseHead();
112
113	6	$this->checkProtocolVersion();
114
115	5	$this->parseUri();
116
117	5	$this->checkBodySize();
118	4	$this->receivedHead = true;
119
120	4	$this->emit('received_head', [$this->headers, $this->httpMethod, $this->uri, $this->protocolVersion]);
121		}
122		}
123
124	4	if ($this->isRequestFinished()) {
125	4	$this->emit('request', [$this->buildRequest()]);
126		}
127	4	}
128
129		/**
130		* @throws BadRequestException
131		* @throws RequestURITooLongException
132		*/
133	8	protected function parseHead()
134		{
135	8	$parsedRequestLine = false;
136	8	foreach (explode("\n", str_replace(["\r\n", "\n\r", "\r"], "\n", $this->head)) as $line) {
137	8	if (false === $parsedRequestLine) {
138	8	if (strlen($line) > $this->options['max_request_line']) {
139	1	throw new RequestURITooLongException();
140		}
141
142	7	if (false == preg_match('/^[a-zA-Z]+\s+([a-zA-Z]+:\/\/\|\/).*/', $line, $matches)) {
		0 ignored issues – show Bug Best Practice introduced 2016-01-05 22:36 UTC by Report Bug Copy Issue Report It seems like you are loosely comparing `preg_match('/^[a-zA-Z]+\...).*/', $line, $matches)` of type `integer` to the boolean `false`. If you are specifically checking for 0, consider using something more explicit like `=== 0` instead. Loading history...
143	1	throw new BadRequestException();
144		}
145
146	6	$parts = explode(' ', $line, 3);
147	6	$this->httpMethod = $parts[0];
148	6	$this->protocolVersion = explode('/', $parts[2] ?? 'HTTP/1.1')[1];
149	6	$this->uri = $parts[1];
150
151	6	$parsedRequestLine = true;
152	6	continue;
153		}
154
155	6	if (false !== strpos($line, ':')) {
156	6	$parts = explode(':', $line, 2);
157	6	$key = trim($parts[0]);
158	6	$value = trim($parts[1] ?? '');
159
160	6	$this->headers[$key][] = $value;
161		}
162		}
163	6	}
164
165	5	protected function parseUri()
166		{
167	5	$hostKey = array_filter(
168	5	array_keys($this->headers),
169	5	function ($key) {
170	5	return 'host' === strtolower($key);
171	5	}
172		);
173
174	5	if (!$hostKey) {
		0 ignored issues – show Bug Best Practice introduced 2016-01-05 22:36 UTC by Report Bug Copy Issue Report The expression `$hostKey` of type `array` is implicitly converted to a boolean; are you sure this is intended? If so, consider using `empty($expr)` instead to make it clear that you intend to check for an array without elements. This check marks implicit conversions of arrays to boolean values in a comparison. While in PHP an empty array is considered to be equal (but not identical) to false, this is not always apparent. Consider making the comparison explicit by using `empty(..)` or `! empty(...)` instead. Loading history...
175	1	return;
176		}
177
178	4	$host = $this->headers[reset($hostKey)][0];
179	4	$scheme = ':443' === substr($host, -4) ? 'https' : 'http';
180
181	4	$this->uri = $scheme . '://' . $host . '/' . ltrim($this->uri, '/');
182	4	}
183
184	4	protected function buildRequest()
185		{
186	4	rewind($this->body);
187
188	4	$request = new ServerRequest(
189	4	[],
190	4	[],
191	4	$this->uri,
192	4	$this->httpMethod,
193	4	$this->body,
194	4	$this->headers,
195	4	[],
196	4	[],
197	4	null,
198	4	$this->protocolVersion
199		);
200
201	4	return $request;
202		}
203
204	4	protected function isRequestFinished() : bool
205		{
206	4	if (false === $this->receivedHead) {
207	4	return false;
208		}
209
210	4	if (false === isset($this->headers['Content-Length'])) {
211	3	return true;
212		}
213
214	1	$contentLength = max($this->headers['Content-Length']);
215	1	if ($contentLength <= $this->getBodySize()) {
216	1	return true;
217		}
218
219	1	return false;
220		}
221
222		/**
223		* @throws RequestEntityTooLargeException
224		*/
225	5	protected function checkBodySize()
226		{
227	5	if ($this->getBodySize() > $this->options['max_body_size']) {
228	1	throw new RequestEntityTooLargeException();
229		}
230	4	}
231
232		/**
233		* @throws RequestEntityTooLargeException
234		*/
235	9	protected function checkHeadSize()
236		{
237	9	if (strlen($this->head) > $this->options['max_head_size']) {
238	1	throw new RequestEntityTooLargeException();
239		}
240	8	}
241
242		/**
243		* @throws RequestHTTPVersionNotSupported
244		*/
245	6	protected function checkProtocolVersion()
246		{
247	6	if (false === isset($this->options['supported_protocol_versions'][$this->protocolVersion])) {
248	1	throw new RequestHTTPVersionNotSupported();
249		}
250	5	}
251
252	5	protected function getBodySize() : int
253		{
254	5	return fstat($this->body)['size'];
255		}
256		}
257

ThrusterIO / http

Push — master ( bc5bb1...0df69c )

RequestParser::__construct() A

Complexity

Size

Duplication

Code Coverage

Duplication Side-by-Side

Filter issues like