hfw / socket

src/ReactiveInterface.php

Spacing +2 added lines, -2 removed lines

@@ -14,13 +14,13 @@
      *
      * @return void
      */
-    public function onOutOfBand (): void;
+    public function onOutOfBand(): void;
 
     /**
      * Called by the reactor when the socket has readable data.
      *
      * @return void
      */
-    public function onReadable (): void;
+    public function onReadable(): void;
 
 }
\ No newline at end of file

src/WebSocket/HandShake.php

Spacing +9 added lines, -9 removed lines

@@ -45,32 +45,32 @@ 
      */
     protected $sizeLimit = 4096;
 
-    public function __construct (WebSocketClient $client) {
+    public function __construct(WebSocketClient $client) {
         $this->client = $client;
     }
 
     /**
      * @return string[]
      */
-    public function getHeaders () {
+    public function getHeaders() {
         return $this->headers;
     }
 
     /**
      * @return string
      */
-    public function getMethod (): string {
+    public function getMethod(): string {
         return $this->method;
     }
 
     /**
      * @return int
      */
-    public function getRsv (): int {
+    public function getRsv(): int {
         return $this->rsv;
     }
 
-    public function negotiate (): bool {
+    public function negotiate(): bool {
         $this->buffer .= $this->client->recvAll();
         try {
             if (strlen($this->buffer) > $this->sizeLimit) {
@@ -90,7 +90,7 @@ 
                 $key = strtolower(trim($key));
                 $value = trim($value);
                 if (isset($this->headers[$key])) {
-                    $this->headers[$key] .= ', ' . $value;
+                    $this->headers[$key] .= ', '.$value;
                 }
                 else {
                     $this->headers[$key] = $value;
@@ -108,19 +108,19 @@ 
         }
     }
 
-    protected function upgrade (): void {
+    protected function upgrade(): void {
         $this->client->write(implode("\r\n", [
             "HTTP/1.1 101 Switching Protocols",
             "Connection: Upgrade",
             "Upgrade: websocket",
-            "Sec-WebSocket-Accept: " . base64_encode(sha1($this->headers['sec-websocket-key'] . self::RFC_GUID, true)),
+            "Sec-WebSocket-Accept: ".base64_encode(sha1($this->headers['sec-websocket-key'].self::RFC_GUID, true)),
         ]));
     }
 
     /**
      * Validates the received HTTP handshake headers, or throws.
      */
-    protected function validate (): void {
+    protected function validate(): void {
         if (!(
             $check = 'method = http 1.1'
             and preg_match('/HTTP\/1\.1$/i', $this->method)

Braces +2 added lines, -4 removed lines

@@ -91,8 +91,7 @@ 
                 $value = trim($value);
                 if (isset($this->headers[$key])) {
                     $this->headers[$key] .= ', ' . $value;
-                }
-                else {
+                } else {
                     $this->headers[$key] = $value;
                 }
             }
@@ -101,8 +100,7 @@ 
             $this->upgrade();
             $this->client->write("\r\n\r\n");
             return true;
-        }
-        catch (WebSocketError $e) {
+        } catch (WebSocketError $e) {
             $this->client->write("HTTP/1.1 {$e->getCode()}\r\n\r\n");
             throw $e;
         }

src/WebSocket/FrameReader.php

Spacing +10 added lines, -10 removed lines

@@ -31,21 +31,21 @@ 
      */
     protected $sizeLimit = 10 * 1024 * 1024; // 10 MiB
 
-    public function __construct (WebSocketClient $client) {
+    public function __construct(WebSocketClient $client) {
         $this->client = $client;
     }
 
     /**
      * @return int
      */
-    public function getSizeLimit (): int {
+    public function getSizeLimit(): int {
         return $this->sizeLimit;
     }
 
     /**
      * @return Frame|null
      */
-    protected function parse () {
+    protected function parse() {
         if (
             $this->parse_1_opCode()
             and $this->parse_2_length()
@@ -68,7 +68,7 @@ 
     /**
      * @return bool
      */
-    protected function parse_1_opCode (): bool {
+    protected function parse_1_opCode(): bool {
         if (!isset($this->current['opCode'])) {
             if (null === $char = $this->shift(1)) {
                 return false;
@@ -99,7 +99,7 @@ 
      *
      * @return bool
      */
-    protected function parse_2_length (): bool {
+    protected function parse_2_length(): bool {
         // first pass
         if (!isset($this->current['lengthSize'])) {
             if (null === $byte = $this->shift(1)) {
@@ -140,7 +140,7 @@ 
      *
      * @return bool
      */
-    protected function parse_3_mask (): bool {
+    protected function parse_3_mask(): bool {
         if (!isset($this->current['mask'])) {
             if (null === $mask = $this->shift(4)) {
                 return false;
@@ -153,7 +153,7 @@ 
     /**
      * @return bool
      */
-    protected function parse_4_payload (): bool {
+    protected function parse_4_payload(): bool {
         if (!isset($this->current['payload'])) {
             $length = $this->current['length'];
             if (null === $payload = $this->shift($length)) {
@@ -175,7 +175,7 @@ 
      *
      * @return Generator|Frame[]
      */
-    public function recvAll () {
+    public function recvAll() {
         $this->buffer .= $this->client->recvAll();
         while ($frame = $this->parse()) {
             yield $frame;
@@ -186,7 +186,7 @@ 
      * @param int $bytes
      * @return $this
      */
-    public function setSizeLimit (int $bytes) {
+    public function setSizeLimit(int $bytes) {
         $this->sizeLimit = $bytes;
         return $this;
     }
@@ -197,7 +197,7 @@ 
      * @param int $bytes
      * @return null|string
      */
-    protected function shift (int $bytes): ?string {
+    protected function shift(int $bytes): ?string {
         if (strlen($this->buffer) < $bytes) {
             return null;
         }

src/WebSocket/WebSocketError.php

Spacing +4 added lines, -4 removed lines

@@ -25,7 +25,7 @@ 
      */
     protected $frame;
 
-    public function __construct (int $code, string $message = '', Frame $frame = null, Throwable $previous = null) {
+    public function __construct(int $code, string $message = '', Frame $frame = null, Throwable $previous = null) {
         parent::__construct($message, $code, $previous);
         $this->frame = $frame;
     }
@@ -33,14 +33,14 @@ 
     /**
      * @return mixed
      */
-    public function getExtra () {
+    public function getExtra() {
         return $this->extra;
     }
 
     /**
      * @return Frame|null
      */
-    public function getFrame () {
+    public function getFrame() {
         return $this->frame;
     }
 
@@ -48,7 +48,7 @@ 
      * @param mixed $extra
      * @return $this
      */
-    public function setExtra ($extra) {
+    public function setExtra($extra) {
         $this->extra = $extra;
         return $this;
     }

src/WebSocket/MessageHandler.php

Spacing +10 added lines, -10 removed lines

@@ -33,35 +33,35 @@ 
     /**
      * @param WebSocketClient $client
      */
-    public function __construct (WebSocketClient $client) {
+    public function __construct(WebSocketClient $client) {
         $this->client = $client;
     }
 
     /**
      * @return int
      */
-    final public function getMaxLength (): int {
+    final public function getMaxLength(): int {
         return $this->maxLength;
     }
 
     /**
      * @return bool
      */
-    final public function isBinaryStream (): bool {
+    final public function isBinaryStream(): bool {
         return $this->binaryStream;
     }
 
     /**
      * @return bool
      */
-    final public function isTextStream (): bool {
+    final public function isTextStream(): bool {
         return $this->textStream;
     }
 
     /**
      * @param string $binary
      */
-    public function onBinary (string $binary): void {
+    public function onBinary(string $binary): void {
         unset($binary);
         throw new WebSocketError(Frame::CLOSE_UNHANDLED_DATA, "I don't handle binary data.");
     }
@@ -69,7 +69,7 @@ 
     /**
      * @param string $text
      */
-    public function onText (string $text): void {
+    public function onText(string $text): void {
         $this->onText_CheckUtf8($text);
         throw new WebSocketError(Frame::CLOSE_UNHANDLED_DATA, "I don't handle text.");
     }
@@ -79,7 +79,7 @@ 
      *
      * @param string $text
      */
-    protected function onText_CheckUtf8 (string $text): void {
+    protected function onText_CheckUtf8(string $text): void {
         if (!mb_detect_encoding($text, 'UTF-8', true)) {
             throw new WebSocketError(Frame::CLOSE_BAD_DATA, "Received TEXT is not UTF-8.");
         }
@@ -89,7 +89,7 @@ 
      * @param bool $flag
      * @return $this
      */
-    public function setBinaryStream (bool $flag) {
+    public function setBinaryStream(bool $flag) {
         $this->binaryStream = $flag;
         return $this;
     }
@@ -98,7 +98,7 @@ 
      * @param int $maxLength
      * @return $this
      */
-    public function setMaxLength (int $maxLength) {
+    public function setMaxLength(int $maxLength) {
         $this->maxLength = $maxLength;
         return $this;
     }
@@ -107,7 +107,7 @@ 
      * @param bool $flag
      * @return $this
      */
-    public function setTextStream (bool $flag) {
+    public function setTextStream(bool $flag) {
         $this->textStream = $flag;
         return $this;
     }

src/WebSocket/WebSocketServer.php

Spacing +13 added lines, -13 removed lines

@@ -29,7 +29,7 @@ 
      * @param $resource
      * @param Reactor $reactor
      */
-    public function __construct ($resource, Reactor $reactor) {
+    public function __construct($resource, Reactor $reactor) {
         parent::__construct($resource);
         $reactor->add($this);
         $this->reactor = $reactor;
@@ -38,7 +38,7 @@ 
     /**
      * @return WebSocketClient
      */
-    public function accept () {
+    public function accept() {
         /** @var WebSocketClient $client */
         $client = parent::accept();
         $this->clients[$client->getId()] = $client;
@@ -46,7 +46,7 @@ 
         return $client;
     }
 
-    public function broadcastBinary (string $payload) {
+    public function broadcastBinary(string $payload) {
         $this->broadcastFrame($payload, Frame::OP_BINARY);
     }
 
@@ -57,7 +57,7 @@ 
      * @param int $opCode
      * @param bool $final
      */
-    public function broadcastFrame (string $payload, int $opCode = Frame::OP_TEXT, bool $final = true) {
+    public function broadcastFrame(string $payload, int $opCode = Frame::OP_TEXT, bool $final = true) {
         foreach ($this->clients as $client) {
             if ($client->isOk()) {
                 $client->getFrameHandler()->write(...func_get_args());
@@ -70,7 +70,7 @@ 
      *
      * @param string $payload
      */
-    public function broadcastPing (string $payload = '') {
+    public function broadcastPing(string $payload = '') {
         $this->broadcastFrame($payload, Frame::OP_PING);
     }
 
@@ -79,7 +79,7 @@ 
      *
      * @param string $text
      */
-    public function broadcastText (string $text) {
+    public function broadcastText(string $text) {
         $this->broadcastFrame($text, Frame::OP_TEXT);
     }
 
@@ -90,7 +90,7 @@ 
      * @param string $reason
      * @return StreamServer
      */
-    public function close (int $code = Frame::CLOSE_INTERRUPT, $reason = '') {
+    public function close(int $code = Frame::CLOSE_INTERRUPT, $reason = '') {
         foreach ($this->clients as $client) {
             try {
                 $client->close($code, $reason);
@@ -108,14 +108,14 @@ 
      *
      * @return int
      */
-    public function count (): int {
+    public function count(): int {
         return count($this->clients);
     }
 
     /**
      * @return WebSocketClient[]
      */
-    public function getClients () {
+    public function getClients() {
         return $this->clients;
     }
 
@@ -123,7 +123,7 @@ 
      * @param resource $resource
      * @return WebSocketClient
      */
-    protected function newClient ($resource) {
+    protected function newClient($resource) {
         return new WebSocketClient($resource, $this);
     }
 
@@ -132,13 +132,13 @@ 
      *
      * @inheritDoc
      */
-    final public function onOutOfBand (): void {
+    final public function onOutOfBand(): void {
     }
 
     /**
      * @inheritDoc
      */
-    public function onReadable (): void {
+    public function onReadable(): void {
         $this->accept();
     }
 
@@ -147,7 +147,7 @@ 
      *
      * @param WebSocketClient $client
      */
-    public function remove (WebSocketClient $client) {
+    public function remove(WebSocketClient $client) {
         unset($this->clients[$client->getId()]);
         $this->reactor->remove($client);
     }

Braces +1 added lines, -2 removed lines

@@ -94,8 +94,7 @@
         foreach ($this->clients as $client) {
             try {
                 $client->close($code, $reason);
-            }
-            catch (Exception $e) {
+            } catch (Exception $e) {
                 continue;
             }
         }

src/WebSocket/WebSocketClient.php

Spacing +16 added lines, -16 removed lines

@@ -51,7 +51,7 @@ 
      * @param $resource
      * @param WebSocketServer $server
      */
-    public function __construct ($resource, WebSocketServer $server) {
+    public function __construct($resource, WebSocketServer $server) {
         parent::__construct($resource);
         $this->server = $server;
     }
@@ -74,10 +74,10 @@ 
      * @param string $reason
      * @return StreamClient|void
      */
-    public function close (int $code = null, string $reason = '') {
+    public function close(int $code = null, string $reason = '') {
         try {
             if ($code >= 1000 and $this->state === self::STATE_OK) {
-                $payload = pack('n', $code) . $reason;
+                $payload = pack('n', $code).$reason;
                 $this->getFrameHandler()->write($payload, Frame::OP_CLOSE);
                 $this->shutdown(self::CH_WRITE);
             }
@@ -92,49 +92,49 @@ 
     /**
      * @return FrameHandler
      */
-    public function getFrameHandler () {
+    public function getFrameHandler() {
         return $this->frameHandler ?? $this->frameHandler = new FrameHandler($this);
     }
 
     /**
      * @return FrameReader
      */
-    public function getFrameReader () {
+    public function getFrameReader() {
         return $this->frameReader ?? $this->frameReader = new FrameReader($this);
     }
 
     /**
      * @return HandShake
      */
-    public function getHandshake () {
+    public function getHandshake() {
         return $this->handshake ?? $this->handshake = new HandShake($this);
     }
 
     /**
      * @return MessageHandler
      */
-    public function getMessageHandler () {
+    public function getMessageHandler() {
         return $this->messageHandler ?? $this->messageHandler = new MessageHandler($this);
     }
 
     /**
      * @return WebSocketServer
      */
-    public function getServer () {
+    public function getServer() {
         return $this->server;
     }
 
     /**
      * @return int
      */
-    public function getState (): int {
+    public function getState(): int {
         return $this->state;
     }
 
     /**
      * @return bool
      */
-    final public function isOk (): bool {
+    final public function isOk(): bool {
         return $this->state === self::STATE_OK;
     }
 
@@ -143,7 +143,7 @@ 
      *
      * The RFC says the connection must be dropped if any unsupported activity occurs.
      */
-    final public function onOutOfBand (): void {
+    final public function onOutOfBand(): void {
         $this->close(Frame::CLOSE_PROTOCOL_ERROR, "Received out-of-band data.");
     }
 
@@ -152,7 +152,7 @@ 
      *
      * @throws Exception
      */
-    public function onReadable (): void {
+    public function onReadable(): void {
         if (!strlen($this->recv(1, MSG_PEEK))) { // peer has shut down writing, or closed.
             $this->close();
             return;
@@ -188,7 +188,7 @@ 
     /**
      * Stub.
      */
-    protected function onStateOk (): void {
+    protected function onStateOk(): void {
 
     }
 
@@ -196,7 +196,7 @@ 
      * @param FrameHandler $frameHandler
      * @return $this
      */
-    public function setFrameHandler (FrameHandler $frameHandler) {
+    public function setFrameHandler(FrameHandler $frameHandler) {
         $this->frameHandler = $frameHandler;
         return $this;
     }
@@ -205,7 +205,7 @@ 
      * @param FrameReader $frameReader
      * @return $this
      */
-    public function setFrameReader (FrameReader $frameReader) {
+    public function setFrameReader(FrameReader $frameReader) {
         $this->frameReader = $frameReader;
         return $this;
     }
@@ -214,7 +214,7 @@ 
      * @param MessageHandler $messageHandler
      * @return $this
      */
-    public function setMessageHandler (MessageHandler $messageHandler) {
+    public function setMessageHandler(MessageHandler $messageHandler) {
         $this->messageHandler = $messageHandler;
         return $this;
     }

Braces +3 added lines, -6 removed lines

@@ -81,8 +81,7 @@ 
                 $this->getFrameHandler()->write($payload, Frame::OP_CLOSE);
                 $this->shutdown(self::CH_WRITE);
             }
-        }
-        finally {
+        } finally {
             $this->state = self::STATE_CLOSE;
             $this->server->remove($this);
             parent::close();
@@ -174,12 +173,10 @@ 
                 case self::STATE_CLOSE:
                     return;
             }
-        }
-        catch (WebSocketError $e) {
+        } catch (WebSocketError $e) {
             $this->close($e->getCode(), $e->getMessage());
             throw $e;
-        }
-        catch (Exception $e) {
+        } catch (Exception $e) {
             $this->close(Frame::CLOSE_INTERNAL_ERROR);
             throw $e;
         }

src/WebSocket/FrameHandler.php

Spacing +17 added lines, -17 removed lines

@@ -33,7 +33,7 @@ 
      */
     protected $text = '';
 
-    public function __construct (WebSocketClient $client) {
+    public function __construct(WebSocketClient $client) {
         $this->client = $client;
     }
 
@@ -44,7 +44,7 @@ 
      *
      * @param Frame $binary
      */
-    protected function onBinary (Frame $binary): void {
+    protected function onBinary(Frame $binary): void {
         $handler = $this->client->getMessageHandler();
         if ($handler->isBinaryStream()) {
             $handler->onBinary($binary->getPayload());
@@ -73,7 +73,7 @@ 
      *
      * @param Frame $close
      */
-    protected function onClose (Frame $close): void {
+    protected function onClose(Frame $close): void {
         $this->client->close($close->getCloseCode());
     }
 
@@ -82,7 +82,7 @@ 
      *
      * @param Frame $frame
      */
-    protected function onContinue (Frame $frame): void {
+    protected function onContinue(Frame $frame): void {
         switch ($this->continue) {
             case Frame::OP_TEXT:
                 $this->onText($frame);
@@ -108,7 +108,7 @@ 
      *
      * @param Frame $control
      */
-    protected function onControl (Frame $control): void {
+    protected function onControl(Frame $control): void {
         if ($control->isClose()) {
             $this->onClose($control);
         }
@@ -125,7 +125,7 @@ 
      *
      * @param Frame $data
      */
-    protected function onData (Frame $data): void {
+    protected function onData(Frame $data): void {
         if ($data->isText()) {
             $this->onText($data);
         }
@@ -141,7 +141,7 @@ 
      *
      * @param Frame $frame
      */
-    public function onFrame (Frame $frame): void {
+    public function onFrame(Frame $frame): void {
         $this->onFrame_CheckRsv($frame);
         $frame->validate();
         if ($frame->isControl()) {
@@ -160,7 +160,7 @@ 
      *
      * @param Frame $frame
      */
-    protected function onFrame_CheckRsv (Frame $frame): void {
+    protected function onFrame_CheckRsv(Frame $frame): void {
         if ($badRsv = $frame->getRsv() & ~$this->client->getHandshake()->getRsv()) {
             $badRsv = str_pad(base_convert($badRsv, 10, 2), 3, 0, STR_PAD_LEFT);
             throw new WebSocketError(Frame::CLOSE_PROTOCOL_ERROR, "Received unknown RSV: 0b{$badRsv}");
@@ -174,7 +174,7 @@ 
      *
      * @param Frame $ping
      */
-    protected function onPing (Frame $ping): void {
+    protected function onPing(Frame $ping): void {
         $this->writePong($ping->getPayload());
     }
 
@@ -185,7 +185,7 @@ 
      *
      * @param Frame $pong
      */
-    protected function onPong (Frame $pong): void {
+    protected function onPong(Frame $pong): void {
         // stub
     }
 
@@ -196,7 +196,7 @@ 
      *
      * @param Frame $text
      */
-    protected function onText (Frame $text): void {
+    protected function onText(Frame $text): void {
         $handler = $this->client->getMessageHandler();
         if ($handler->isTextStream()) {
             $handler->onText($text->getPayload());
@@ -221,7 +221,7 @@ 
      * @param int $opCode
      * @param bool $final
      */
-    public function write (string $payload, int $opCode = Frame::OP_TEXT, bool $final = true): void {
+    public function write(string $payload, int $opCode = Frame::OP_TEXT, bool $final = true): void {
         $head = chr(($final ? 0x80 : 0) | $opCode);
         $length = strlen($payload);
         if ($length > 65535) {
@@ -235,22 +235,22 @@ 
         else {
             $head .= chr($length);
         }
-        $this->client->write($head . $payload);
+        $this->client->write($head.$payload);
     }
 
-    public function writeBinary (string $payload, bool $final = true): void {
+    public function writeBinary(string $payload, bool $final = true): void {
         $this->write($payload, Frame::OP_BINARY, $final);
     }
 
-    public function writePing (string $payload = ''): void {
+    public function writePing(string $payload = ''): void {
         $this->write($payload, Frame::OP_PING);
     }
 
-    public function writePong (string $payload = ''): void {
+    public function writePong(string $payload = ''): void {
         $this->write($payload, Frame::OP_PONG);
     }
 
-    public function writeText (string $payload, bool $final = true): void {
+    public function writeText(string $payload, bool $final = true): void {
         $this->write($payload, Frame::OP_TEXT, $final);
     }
 }
\ No newline at end of file

Braces +9 added lines, -18 removed lines

@@ -48,8 +48,7 @@ 
         $handler = $this->client->getMessageHandler();
         if ($handler->isBinaryStream()) {
             $handler->onBinary($binary->getPayload());
-        }
-        else {
+        } else {
             if (strlen($this->binary) + $binary->getLength() > $handler->getMaxLength()) {
                 throw new WebSocketError(Frame::CLOSE_TOO_LARGE, $handler->getMaxLength(), $binary);
             }
@@ -111,11 +110,9 @@ 
     protected function onControl (Frame $control): void {
         if ($control->isClose()) {
             $this->onClose($control);
-        }
-        elseif ($control->isPing()) {
+        } elseif ($control->isPing()) {
             $this->onPing($control);
-        }
-        elseif ($control->isPong()) {
+        } elseif ($control->isPong()) {
             $this->onPong($control);
         }
     }
@@ -128,8 +125,7 @@ 
     protected function onData (Frame $data): void {
         if ($data->isText()) {
             $this->onText($data);
-        }
-        elseif ($data->isBinary()) {
+        } elseif ($data->isBinary()) {
             $this->onBinary($data);
         }
     }
@@ -146,11 +142,9 @@ 
         $frame->validate();
         if ($frame->isControl()) {
             $this->onControl($frame);
-        }
-        elseif ($frame->isContinue()) {
+        } elseif ($frame->isContinue()) {
             $this->onContinue($frame);
-        }
-        else {
+        } else {
             $this->onData($frame);
         }
     }
@@ -200,8 +194,7 @@ 
         $handler = $this->client->getMessageHandler();
         if ($handler->isTextStream()) {
             $handler->onText($text->getPayload());
-        }
-        else {
+        } else {
             if (strlen($this->text) + $text->getLength() > $handler->getMaxLength()) {
                 throw new WebSocketError(Frame::CLOSE_TOO_LARGE, $handler->getMaxLength(), $text);
             }
@@ -227,12 +220,10 @@ 
         if ($length > 65535) {
             $head .= chr(127);
             $head .= pack('J', $length);
-        }
-        elseif ($length >= 126) {
+        } elseif ($length >= 126) {
             $head .= chr(126);
             $head .= pack('n', $length);
-        }
-        else {
+        } else {
             $head .= chr($length);
         }
         $this->client->write($head . $payload);

src/WebSocket/Frame.php

Spacing +29 added lines, -29 removed lines

@@ -17,15 +17,15 @@ 
     const OP_PING = 0x09;
     const OP_PONG = 0x0a;
 
-    const CLOSE_NORMAL = 1000;              // mutual closure
-    const CLOSE_INTERRUPT = 1001;           // abrupt closure due to hangups, reboots, "going away"
-    const CLOSE_PROTOCOL_ERROR = 1002;      // invalid behavior / framing
-    const CLOSE_UNHANDLED_DATA = 1003;      // message handler doesn't want the payload
-    const CLOSE_BAD_DATA = 1007;            // message handler can't understand the payload
-    const CLOSE_POLICY_VIOLATION = 1008;    // generic "access denied"
-    const CLOSE_TOO_LARGE = 1009;           // unacceptable payload size
-    const CLOSE_EXPECTATION = 1010;         // peer closed because it wants extensions (listed in the reason)
-    const CLOSE_INTERNAL_ERROR = 1011;      // like http 500
+    const CLOSE_NORMAL = 1000; // mutual closure
+    const CLOSE_INTERRUPT = 1001; // abrupt closure due to hangups, reboots, "going away"
+    const CLOSE_PROTOCOL_ERROR = 1002; // invalid behavior / framing
+    const CLOSE_UNHANDLED_DATA = 1003; // message handler doesn't want the payload
+    const CLOSE_BAD_DATA = 1007; // message handler can't understand the payload
+    const CLOSE_POLICY_VIOLATION = 1008; // generic "access denied"
+    const CLOSE_TOO_LARGE = 1009; // unacceptable payload size
+    const CLOSE_EXPECTATION = 1010; // peer closed because it wants extensions (listed in the reason)
+    const CLOSE_INTERNAL_ERROR = 1011; // like http 500
 
     /**
      * @var bool
@@ -53,7 +53,7 @@ 
      * @param int $opCode
      * @param string $payload
      */
-    public function __construct (bool $final, int $rsv, int $opCode, string $payload) {
+    public function __construct(bool $final, int $rsv, int $opCode, string $payload) {
         $this->final = $final;
         $this->rsv = $rsv;
         $this->opCode = $opCode;
@@ -65,7 +65,7 @@ 
      *
      * @return string
      */
-    final public function __toString () {
+    final public function __toString() {
         if ($this->isClose()) {
             return $this->getCloseReason();
         }
@@ -79,7 +79,7 @@ 
      *
      * @return int
      */
-    public function getCloseCode (): int {
+    public function getCloseCode(): int {
         if ($this->getLength() >= 2) {
             return unpack('n', substr($this->payload, 0, 2))[1];
         }
@@ -93,112 +93,112 @@ 
      *
      * @return string
      */
-    public function getCloseReason (): string {
+    public function getCloseReason(): string {
         return substr($this->payload, 2);
     }
 
     /**
      * @return int
      */
-    final public function getLength (): int {
+    final public function getLength(): int {
         return strlen($this->payload);
     }
 
     /**
      * @return int
      */
-    final public function getOpCode (): int {
+    final public function getOpCode(): int {
         return $this->opCode;
     }
 
     /**
      * @return string
      */
-    final public function getPayload (): string {
+    final public function getPayload(): string {
         return $this->payload;
     }
 
     /**
      * @return int
      */
-    final public function getRsv (): int {
+    final public function getRsv(): int {
         return $this->rsv;
     }
 
     /**
      * @return bool
      */
-    final public function hasRsv1 (): bool {
+    final public function hasRsv1(): bool {
         return (bool)($this->rsv & 0b100);
     }
 
     /**
      * @return bool
      */
-    final public function hasRsv2 (): bool {
+    final public function hasRsv2(): bool {
         return (bool)($this->rsv & 0b010);
     }
 
     /**
      * @return bool
      */
-    final public function hasRsv3 (): bool {
+    final public function hasRsv3(): bool {
         return (bool)($this->rsv & 0b001);
     }
 
     /**
      * @return bool
      */
-    final public function isBinary (): bool {
+    final public function isBinary(): bool {
         return $this->opCode === self::OP_BINARY;
     }
 
     /**
      * @return bool
      */
-    final public function isClose (): bool {
+    final public function isClose(): bool {
         return $this->opCode === self::OP_CLOSE;
     }
 
     /**
      * @return bool
      */
-    final public function isContinue (): bool {
+    final public function isContinue(): bool {
         return $this->opCode === self::OP_CONTINUE;
     }
 
     /**
      * @return bool
      */
-    final public function isControl (): bool {
+    final public function isControl(): bool {
         return (bool)($this->opCode & 0b1000);
     }
 
     /**
      * @return bool
      */
-    final public function isFinal (): bool {
+    final public function isFinal(): bool {
         return $this->final;
     }
 
     /**
      * @return bool
      */
-    final public function isPing (): bool {
+    final public function isPing(): bool {
         return $this->opCode === self::OP_PING;
     }
 
     /**
      * @return bool
      */
-    final public function isPong (): bool {
+    final public function isPong(): bool {
         return $this->opCode === self::OP_PONG;
     }
 
     /**
      * @return bool
      */
-    final public function isText (): bool {
+    final public function isText(): bool {
         return $this->opCode === self::OP_TEXT;
     }
 
@@ -207,7 +207,7 @@ 
      *
      * @throws WebSocketError
      */
-    public function validate (): void {
+    public function validate(): void {
         if ($this->isControl()) {
             if ($this->opCode > self::OP_PONG) {
                 throw new WebSocketError(self::CLOSE_PROTOCOL_ERROR, "Reserved control opcode ($this->opCode).");

Braces +1 added lines, -2 removed lines

@@ -217,8 +217,7 @@
             if (!$this->isFinal()) {
                 throw new WebSocketError(self::CLOSE_PROTOCOL_ERROR, "Fragmented control frame.");
             }
-        }
-        elseif ($this->opCode > self::OP_BINARY) {
+        } elseif ($this->opCode > self::OP_BINARY) {
             throw new WebSocketError(self::CLOSE_PROTOCOL_ERROR, "Reserved data opcode ($this->opCode).");
         }
     }