icedream
/
php-language-server
1
0
Fork 0
Code Releases Activity

Inline ParsingMode enum as class constants

pull/107/head
Felix Becker 2016-10-24 19:15:47 +02:00
parent 5285aea1f4
commit 228951b4c0
1 changed files with 8 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/ProtocolStreamReader.php
View File

@ -8,16 +8,13 @@ use AdvancedJsonRpc\Message as MessageBody;
use Sabre\Event\Loop; use Sabre\Event\Loop;
use RuntimeException; use RuntimeException;
abstract class ParsingMode
{
const HEADERS = 1;
const BODY = 2;
}
class ProtocolStreamReader implements ProtocolReader class ProtocolStreamReader implements ProtocolReader
{ {
const PARSE_HEADERS = 1;
const PARSE_BODY = 2;
private $input; private $input;
private $parsingMode = ParsingMode::HEADERS; private $parsingMode = self::PARSE_HEADERS;
private $buffer = ''; private $buffer = '';
private $headers = []; private $headers = [];
private $contentLength; private $contentLength;
@ -37,9 +34,9 @@ class ProtocolStreamReader implements ProtocolReader
while (($c = fgetc($this->input)) !== false && $c !== '') { while (($c = fgetc($this->input)) !== false && $c !== '') {
$this->buffer .= $c; $this->buffer .= $c;
switch ($this->parsingMode) { switch ($this->parsingMode) {
case ParsingMode::HEADERS: case self::PARSE_HEADERS:
if ($this->buffer === "\r\n") { if ($this->buffer === "\r\n") {
$this->parsingMode = ParsingMode::BODY; $this->parsingMode = self::PARSE_BODY;
$this->contentLength = (int)$this->headers['Content-Length']; $this->contentLength = (int)$this->headers['Content-Length'];
$this->buffer = ''; $this->buffer = '';
} else if (substr($this->buffer, -2) === "\r\n") { } else if (substr($this->buffer, -2) === "\r\n") {
@ -48,14 +45,14 @@ class ProtocolStreamReader implements ProtocolReader
$this->buffer = ''; $this->buffer = '';
} }
break; break;
case ParsingMode::BODY: case self::PARSE_BODY:
if (strlen($this->buffer) === $this->contentLength) { if (strlen($this->buffer) === $this->contentLength) {
if (isset($this->listener)) { if (isset($this->listener)) {
$msg = new Message(MessageBody::parse($this->buffer), $this->headers); $msg = new Message(MessageBody::parse($this->buffer), $this->headers);
$listener = $this->listener; $listener = $this->listener;
$listener($msg); $listener($msg);
} }
$this->parsingMode = ParsingMode::HEADERS; $this->parsingMode = self::PARSE_HEADERS;
$this->headers = []; $this->headers = [];
$this->buffer = ''; $this->buffer = '';
} }