hfw / socket

src/WebSocket/FrameReader.php

Spacing +6 added lines, -6 removed lines

@@ -46,14 +46,14 @@ 
      */
     protected $maxLength = 10 * 1024 * 1024;
 
-    public function __construct (WebSocketClient $client) {
+    public function __construct(WebSocketClient $client) {
         $this->client = $client;
     }
 
     /**
      * @return Frame|null
      */
-    protected function getFrame () {
+    protected function getFrame() {
         if (!$this->head) {
             if (preg_match(self::REGEXP, $this->buffer, $head)) {
                 [, $op, $len] = unpack('C2', $head[0]);
@@ -95,7 +95,7 @@ 
      *
      * @return Generator|Frame[]
      */
-    public function getFrames () {
+    public function getFrames() {
         $this->buffer .= $this->client->recvAll();
         while ($frame = $this->getFrame()) {
             yield $frame;
@@ -105,7 +105,7 @@ 
     /**
      * @return int
      */
-    public function getMaxLength (): int {
+    public function getMaxLength(): int {
         return $this->maxLength;
     }
 
@@ -113,7 +113,7 @@ 
      * @param int $bytes
      * @return $this
      */
-    public function setMaxLength (int $bytes) {
+    public function setMaxLength(int $bytes) {
         if ($bytes < self::MAX_LENGTH_RANGE[0] or $bytes > self::MAX_LENGTH_RANGE[1]) {
             throw new InvalidArgumentException('Max length must be within range [125,2^63-1]');
         }
@@ -126,7 +126,7 @@ 
      *
      * @throws WebSocketError
      */
-    protected function validate (): void {
+    protected function validate(): void {
         if ($this->head['length'] > $this->maxLength) {
             throw new WebSocketError(Frame::CLOSE_TOO_LARGE, "Payload would exceed {$this->maxLength} bytes");
         }

Braces +3 added lines, -6 removed lines

@@ -67,11 +67,9 @@ 
                 ];
                 $this->buffer = substr($this->buffer, strlen($head[0]));
                 $this->validate();
-            }
-            elseif (strlen($this->buffer) >= 14) { // max head room
+            } elseif (strlen($this->buffer) >= 14) { // max head room
                 throw new WebSocketError(Frame::CLOSE_PROTOCOL_ERROR, 'Bad frame.');
-            }
-            else {
+            } else {
                 return null;
             }
         }
@@ -139,8 +137,7 @@ 
             if (!$this->head['final']) {
                 throw new WebSocketError(Frame::CLOSE_PROTOCOL_ERROR, "Received fragmented {$name}");
             }
-        }
-        elseif ($opCode > Frame::OP_BINARY) { // data
+        } elseif ($opCode > Frame::OP_BINARY) { // data
             throw new WebSocketError(Frame::CLOSE_PROTOCOL_ERROR, "Received {$name}");
         }
     }

src/WebSocket/Frame.php

Spacing +30 added lines, -30 removed lines

@@ -41,15 +41,15 @@ 
         0x0f => 'RESERVED CONTROL 0x0f',
     ];
 
-    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
@@ -79,7 +79,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;
@@ -91,7 +91,7 @@ 
      *
      * @return string
      */
-    public function __toString () {
+    public function __toString() {
         if ($this->isClose()) {
             return $this->getCloseReason();
         }
@@ -105,7 +105,7 @@ 
      *
      * @return int
      */
-    final public function getCloseCode (): int {
+    final public function getCloseCode(): int {
         $code = substr($this->payload, 0, 2);
         return isset($code[1]) ? unpack('n', $code)[1] : self::CLOSE_NORMAL;
     }
@@ -117,126 +117,126 @@ 
      *
      * @return string
      */
-    final public function getCloseReason (): string {
+    final 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 string
      */
-    public function getName (): string {
+    public function getName(): string {
         return self::NAMES[$this->opCode];
     }
 
     /**
      * @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 & self::RSV1);
     }
 
     /**
      * @return bool
      */
-    final public function hasRsv2 (): bool {
+    final public function hasRsv2(): bool {
         return (bool)($this->rsv & self::RSV2);
     }
 
     /**
      * @return bool
      */
-    final public function hasRsv3 (): bool {
+    final public function hasRsv3(): bool {
         return (bool)($this->rsv & self::RSV3);
     }
 
     /**
      * @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 $this->opCode >= self::OP_CLOSE;
     }
 
     /**
      * @return bool
      */
-    final public function isData (): bool {
+    final public function isData(): bool {
         return $this->opCode < self::OP_CLOSE;
     }
 
     /**
      * @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;
     }
 

src/AbstractServer.php

Spacing +2 added lines, -2 removed lines

@@ -18,7 +18,7 @@ 
      *
      * @return string
      */
-    public function __toString () {
+    public function __toString() {
         try {
             return implode(':', $this->getSockName());
         }
@@ -40,7 +40,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function bind (string $address, int $port = 0) {
+    public function bind(string $address, int $port = 0) {
         if (!@socket_bind($this->resource, $address, $port)) {
             throw new SocketError($this->resource, SOCKET_EOPNOTSUPP);
         }

Braces +1 added lines, -2 removed lines

@@ -21,8 +21,7 @@
     public function __toString () {
         try {
             return implode(':', $this->getSockName());
-        }
-        catch (Throwable $e) {
+        } catch (Throwable $e) {
             return "?{$this->resource}";
         }
     }

src/StreamServer.php

Spacing +4 added lines, -4 removed lines

@@ -12,7 +12,7 @@ 
      *
      * @return int
      */
-    final public static function getType (): int {
+    final public static function getType(): int {
         return SOCK_STREAM;
     }
 
@@ -25,7 +25,7 @@ 
      * @return StreamClient
      * @throws SocketError
      */
-    public function accept () {
+    public function accept() {
         if (!$resource = @socket_accept($this->resource)) {
             throw new SocketError($this->resource); // reliable errno
         }
@@ -45,7 +45,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function listen (int $backlog = 0) {
+    public function listen(int $backlog = 0) {
         if (!@socket_listen($this->resource, $backlog)) {
             throw new SocketError($this->resource); // reliable errno
         }
@@ -58,7 +58,7 @@ 
      * @param resource $resource The accepted connection.
      * @return StreamClient
      */
-    protected function newClient ($resource) {
+    protected function newClient($resource) {
         return new StreamClient($resource);
     }