hfw / socket

src/AbstractClient.php

Braces +2 added lines, -4 removed lines

@@ -21,8 +21,7 @@ 
     public function __toString () {
         try {
             return implode(':', $this->getPeerName());
-        }
-        catch (Throwable $e) {
+        } catch (Throwable $e) {
             return "?{$this->resource}";
         }
     }
@@ -102,8 +101,7 @@ 
         while ($total < $length) {
             try {
                 $total += $this->awaitWritable()->send(substr($data, $total));
-            }
-            catch (SocketError $e) {
+            } catch (SocketError $e) {
                 $e->setExtra($total);
                 throw $e;
             }

src/SocketError.php

Braces +1 added lines, -2 removed lines

@@ -65,8 +65,7 @@
     public function __construct ($subject = null, $fallback = 0, SocketError $previous = null) {
         if ($errno = is_int($subject) ? $subject : static::getLast($subject)) {
             $message = socket_strerror($errno);
-        }
-        else {
+        } else {
             $errno = $fallback;
             $last = error_get_last();
             $message = "{$last['message']} in {$last['file']}:{$last['line']}";

src/AbstractSocket.php

Braces +2 added lines, -4 removed lines

@@ -52,11 +52,9 @@
     public function __construct ($resource) {
         if (!is_resource($resource) or get_resource_type($resource) !== 'Socket') {
             throw new InvalidArgumentException('Expected an open socket resource.', SOCKET_EBADF);
-        }
-        elseif (socket_get_option($resource, SOL_SOCKET, SO_TYPE) !== static::getType()) {
+        } elseif (socket_get_option($resource, SOL_SOCKET, SO_TYPE) !== static::getType()) {
             throw new InvalidArgumentException('Invalid socket type for ' . static::class, SOCKET_ESOCKTNOSUPPORT);
-        }
-        elseif ($errno = SocketError::getLast($resource)) {
+        } elseif ($errno = SocketError::getLast($resource)) {
             // "File descriptor in bad state"
             throw new SocketError(SOCKET_EBADFD, 0, new SocketError($errno));
         }

src/AbstractServer.php

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/StreamClient.php

Braces +2 added lines, -4 removed lines

@@ -52,8 +52,7 @@ 
                 $length -= $chunkSize = strlen($chunk);
             } while ($chunkSize and $length);
             return $data;
-        }
-        catch (SocketError $e) {
+        } catch (SocketError $e) {
             $e->setExtra($data);
             throw $e;
         }
@@ -90,8 +89,7 @@ 
         $length = $this->getOption(SO_RCVBUF);
         try {
             return $this->recv($length, $flags);
-        }
-        catch (SocketError $e) {
+        } catch (SocketError $e) {
             if ($e->getCode() === SOCKET_EAGAIN) { // would block
                 return '';
             }

src/WebSocket/WebSocketServer.php

Braces +1 added lines, -2 removed lines

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

src/WebSocket/WebSocketClient.php

Braces +4 added lines, -8 removed lines

@@ -82,8 +82,7 @@ 
             if ($code >= 1000 and $this->isOk()) {
                 $this->frameHandler->writeClose($code, $reason);
             }
-        }
-        finally {
+        } finally {
             $this->server->remove($this);
             parent::close();
             $this->state = self::STATE_CLOSED;
@@ -200,16 +199,13 @@ 
                     $this->state = self::STATE_OK;
                     $this->onStateOk();
                 }
-            }
-            elseif ($this->isOk()) {
+            } elseif ($this->isOk()) {
                 $this->frameHandler->onReadable();
             }
-        }
-        catch (WebSocketError $e) {
+        } catch (WebSocketError $e) {
             $this->close($e->getCode(), $e->getMessage());
             throw $e;
-        }
-        catch (Throwable $e) {
+        } catch (Throwable $e) {
             $this->close(Frame::CLOSE_INTERNAL_ERROR);
             throw $e;
         }

src/WebSocket/FrameReader.php

Braces +4 added lines, -8 removed lines

@@ -141,19 +141,15 @@
         if ($badRsv = $rsv & ~$this->rsv) {
             $badRsv = str_pad(base_convert($badRsv >> 4, 10, 2), 3, '0', STR_PAD_LEFT);
             throw new WebSocketError(Frame::CLOSE_PROTOCOL_ERROR, "Received unknown RSV bits: 0b{$badRsv}");
-        }
-        elseif ($opCode >= Frame::OP_CLOSE) {
+        } elseif ($opCode >= Frame::OP_CLOSE) {
             if ($opCode > Frame::OP_PONG) {
                 throw new WebSocketError(Frame::CLOSE_PROTOCOL_ERROR, "Received unsupported control frame ({$opCode})");
-            }
-            elseif (!$final) {
+            } elseif (!$final) {
                 throw new WebSocketError(Frame::CLOSE_PROTOCOL_ERROR, "Received fragmented control frame ({$opCode})");
             }
-        }
-        elseif ($opCode > Frame::OP_BINARY) {
+        } elseif ($opCode > Frame::OP_BINARY) {
             throw new WebSocketError(Frame::CLOSE_PROTOCOL_ERROR, "Received unsupported data frame ({$opCode})");
-        }
-        elseif ($length > $this->maxLength) {
+        } elseif ($length > $this->maxLength) {
             throw new WebSocketError(Frame::CLOSE_TOO_LARGE, "Payload would exceed {$this->maxLength} bytes");
         }
 

src/WebSocket/FrameHandler.php

Braces +9 added lines, -18 removed lines

@@ -105,8 +105,7 @@ 
     protected function onBinary (Frame $frame): void {
         if ($this->stream) {
             $this->client->onBinary($frame->getPayload());
-        }
-        else {
+        } else {
             $this->onData_CheckLength($frame);
             $this->buffer .= $frame->getPayload();
             if ($frame->isFinal()) {
@@ -149,12 +148,10 @@ 
         try {
             if ($this->continue === Frame::OP_TEXT) {
                 $this->onText($frame);
-            }
-            else {
+            } else {
                 $this->onBinary($frame);
             }
-        }
-        finally {
+        } finally {
             if ($frame->isFinal()) {
                 $this->continue = null;
             }
@@ -173,14 +170,11 @@ 
     protected function onControl (Frame $frame): void {
         if ($frame->isClose()) {
             $this->onClose($frame);
-        }
-        elseif ($frame->isPing()) {
+        } elseif ($frame->isPing()) {
             $this->onPing($frame);
-        }
-        elseif ($frame->isPong()) {
+        } elseif ($frame->isPong()) {
             $this->onPong($frame);
-        }
-        else {
+        } else {
             throw new WebSocketError(Frame::CLOSE_PROTOCOL_ERROR, "Unsupported control frame.", $frame);
         }
     }
@@ -248,8 +242,7 @@ 
     public function onFrame (Frame $frame): void {
         if ($frame->isControl()) {
             $this->onControl($frame);
-        }
-        else {
+        } else {
             $this->onData($frame);
         }
     }
@@ -378,12 +371,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);