hfw / socket

src/WebSocketFrame.php

Spacing +13 added lines, -13 removed lines

@@ -25,7 +25,7 @@ 
      * @param bool $final
      * @return string
      */
-    public static function pack (string $payload, int $opCode = self::OP_TEXT, bool $final = true): string {
+    public static function pack(string $payload, int $opCode = self::OP_TEXT, bool $final = true): string {
         $frame = chr(0x80 | $opCode);
         $len = strlen($payload);
         if ($len > 65535) {
@@ -39,14 +39,14 @@ 
         else {
             $frame .= chr($len);
         }
-        return $frame . $payload;
+        return $frame.$payload;
     }
 
-    public function __construct (string $data) {
+    public function __construct(string $data) {
         $this->data = $data;
     }
 
-    final public function getLength () {
+    final public function getLength() {
         switch ($char = ord($this->data[1]) & 0x7f) {
             case 127: // big-endian long-long
                 return unpack('J', substr($this->data, 2, 8));
@@ -60,7 +60,7 @@ 
     /**
      * @return int[]
      */
-    final public function getMask () {
+    final public function getMask() {
         if ($this->isMasked()) {
             switch (ord($this->data[1]) & 0x7f) {
                 case 127:
@@ -74,11 +74,11 @@ 
         return [0, 0, 0, 0];
     }
 
-    final public function getOpCode (): int {
+    final public function getOpCode(): int {
         return ord($this->data[0]) & 0x0f;
     }
 
-    final public function getPayload (): string {
+    final public function getPayload(): string {
         $length = $this->getLength();
         if ($length === 0) {
             return '';
@@ -102,27 +102,27 @@ 
         return $decoded;
     }
 
-    final public function isBinary (): bool {
+    final public function isBinary(): bool {
         return $this->getOpCode() === self::OP_BINARY;
     }
 
-    final public function isClose (): bool {
+    final public function isClose(): bool {
         return $this->getOpCode() === self::OP_CLOSE;
     }
 
-    final public function isFinal (): bool {
+    final public function isFinal(): bool {
         return (bool)(ord($this->data[0]) & 0x80);
     }
 
-    final public function isMasked (): bool {
+    final public function isMasked(): bool {
         return (bool)(ord($this->data[1]) & 0x80);
     }
 
-    final public function isPong (): bool {
+    final public function isPong(): bool {
         return $this->getOpCode() === self::OP_PONG;
     }
 
-    final public function isText (): bool {
+    final public function isText(): bool {
         return $this->getOpCode() === self::OP_TEXT;
     }
 

Braces +2 added lines, -4 removed lines

@@ -31,12 +31,10 @@
         if ($len > 65535) {
             $frame .= chr(127);
             $frame .= pack('J', $len);
-        }
-        elseif ($len >= 126) {
+        } elseif ($len >= 126) {
             $frame .= chr(126);
             $frame .= pack('n', $len);
-        }
-        else {
+        } else {
             $frame .= chr($len);
         }
         return $frame . $payload;

src/ReactiveInterface.php

Spacing +2 added lines, -2 removed lines

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

src/SocketInterface.php

Spacing +5 added lines, -5 removed lines

@@ -42,34 +42,34 @@
      *
      * @return int `SOCK_*`
      */
-    public static function getType ();
+    public static function getType();
 
     /**
      * Returns the address family constant of the socket.
      *
      * @return int `AF_*`
      */
-    public function getDomain ();
+    public function getDomain();
 
     /**
      * Returns the underlying socket resource as an integer.
      *
      * @return int
      */
-    public function getId ();
+    public function getId();
 
     /**
      * Returns the protocol constant used by the socket.
      *
      * @return int
      */
-    public function getProtocol ();
+    public function getProtocol();
 
     /**
      * Returns the underlying socket resource.
      *
      * @return resource
      */
-    public function getResource ();
+    public function getResource();
 
 }
\ No newline at end of file

src/AbstractServer.php

Spacing +2 added lines, -2 removed lines

@@ -14,7 +14,7 @@ 
      *
      * @return string
      */
-    public function __toString () {
+    public function __toString() {
         try {
             return implode(':', $this->getSockName());
         }
@@ -36,7 +36,7 @@ 
      * @throws Error
      * @return $this
      */
-    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 Error($this->resource, SOCKET_EOPNOTSUPP);
         }

src/WebSocketServer.php

Spacing +18 added lines, -18 removed lines

@@ -23,7 +23,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;
@@ -35,7 +35,7 @@ 
      * https://tools.ietf.org/html/rfc6455#section-4.2
      * @return WebSocketClient
      */
-    public function accept () {
+    public function accept() {
         if (!$resource = @socket_accept($this->resource)) {
             throw new Error($this->resource); // reliable errno
         }
@@ -50,7 +50,7 @@ 
     /**
      * @param WebSocketClient $client
      */
-    protected function acceptHandshake (WebSocketClient $client) {
+    protected function acceptHandshake(WebSocketClient $client) {
         $head = $client->await(self::CH_READ)->recv(4096); // todo client->readUntil(string,maxlength)
         $head = explode("\r\n", $head);
         $method = array_shift($head);
@@ -78,17 +78,17 @@ 
             "HTTP/1.1 101 Switching Protocols",
             "Upgrade: websocket",
             "Connection: Upgrade",
-            "Sec-WebSocket-Accept: " . base64_encode(sha1($base64Key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)),
+            "Sec-WebSocket-Accept: ".base64_encode(sha1($base64Key.'258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)),
         ];
 
-        $client->write(implode("\r\n", $response) . "\r\n\r\n");
+        $client->write(implode("\r\n", $response)."\r\n\r\n");
     }
 
     /**
      * @param WebSocketClient $client
      * @param string $connection
      */
-    protected function acceptHandshakeConnection (WebSocketClient $client, string $connection) {
+    protected function acceptHandshakeConnection(WebSocketClient $client, string $connection) {
         if (!preg_match('/^upgrade$/i', $connection)) {
             $this->reject($client, "Expected: Connection: Upgrade");
         }
@@ -100,7 +100,7 @@ 
      * @param WebSocketClient $client
      * @param string $host
      */
-    protected function acceptHandshakeHost (WebSocketClient $client, string $host) {
+    protected function acceptHandshakeHost(WebSocketClient $client, string $host) {
 
     }
 
@@ -108,7 +108,7 @@ 
      * @param WebSocketClient $client
      * @param string $base64Key
      */
-    protected function acceptHandshakeKey (WebSocketClient $client, string $base64Key) {
+    protected function acceptHandshakeKey(WebSocketClient $client, string $base64Key) {
         $key = base64_decode($base64Key);
         if ($key === false or strlen($key) !== 16) {
             $this->reject($client, "Expected Sec-WebSocket-Key");
@@ -119,7 +119,7 @@ 
      * @param WebSocketClient $client
      * @param string $method
      */
-    protected function acceptHandshakeMethod (WebSocketClient $client, string $method) {
+    protected function acceptHandshakeMethod(WebSocketClient $client, string $method) {
         if (!preg_match('/HTTP\/1\.1$/i', $method)) {
             $this->reject($client, "Expected: HTTP/1.1");
         }
@@ -131,7 +131,7 @@ 
      * @param WebSocketClient $client
      * @param string $origin
      */
-    protected function acceptHandshakeOrigin (WebSocketClient $client, string $origin) {
+    protected function acceptHandshakeOrigin(WebSocketClient $client, string $origin) {
 
     }
 
@@ -139,7 +139,7 @@ 
      * @param WebSocketClient $client
      * @param string $upgrade
      */
-    protected function acceptHandshakeUpgrade (WebSocketClient $client, string $upgrade) {
+    protected function acceptHandshakeUpgrade(WebSocketClient $client, string $upgrade) {
         if (!preg_match('/^websocket$/i', $upgrade)) {
             $this->reject($client, "Expected Upgrade: websocket");
         }
@@ -149,7 +149,7 @@ 
      * @param WebSocketClient $client
      * @param string $version
      */
-    protected function acceptHandshakeVersion (WebSocketClient $client, string $version) {
+    protected function acceptHandshakeVersion(WebSocketClient $client, string $version) {
         if ($version !== '13') {
             $this->reject($client, "Expected Sec-WebSocket-Version: 13");
         }
@@ -158,7 +158,7 @@ 
     /**
      * @return WebSocketClient[]
      */
-    public function getClients () {
+    public function getClients() {
         return $this->clients;
     }
 
@@ -166,7 +166,7 @@ 
      * @param resource $resource
      * @return WebSocketClient
      */
-    protected function newClient ($resource) {
+    protected function newClient($resource) {
         return new WebSocketClient($resource, $this);
     }
 
@@ -175,14 +175,14 @@ 
      *
      * @inheritDoc
      */
-    final public function onOutOfBand () {
+    final public function onOutOfBand() {
         // do nothing
     }
 
     /**
      * @inheritDoc
      */
-    public function onReadable () {
+    public function onReadable() {
         $this->accept();
     }
 
@@ -193,7 +193,7 @@ 
      * @param string $reason
      * @throws RuntimeException
      */
-    protected function reject (WebSocketClient $client, string $reason) {
+    protected function reject(WebSocketClient $client, string $reason) {
         throw new RuntimeException("Rejected {$client}: {$reason}");
     }
 
@@ -203,7 +203,7 @@ 
      * @param WebSocketClient $client
      * @return $this
      */
-    public function remove (WebSocketClient $client) {
+    public function remove(WebSocketClient $client) {
         unset($this->clients[$client->getId()]);
         $this->reactor->remove($client->getId());
         return $this;

src/StreamClient.php

Spacing +4 added lines, -4 removed lines

@@ -17,7 +17,7 @@ 
      * @return static[] Two instances at indices `0` and `1`.
      * @throws Error
      */
-    public static function newUnixPair (...$extra) {
+    public static function newUnixPair(...$extra) {
         if (!@socket_create_pair(AF_UNIX, SOCK_STREAM, 0, $fd)) {
             throw new Error; // reliable errno
         }
@@ -32,7 +32,7 @@ 
      *
      * @return int
      */
-    final public static function getType () {
+    final public static function getType() {
         return SOCK_STREAM;
     }
 
@@ -46,7 +46,7 @@ 
      * @return string
      * @throws Error The error's extra data is set to what was partially read.
      */
-    public function read ($length) {
+    public function read($length) {
         $data = '';
         while ($length > 0) {
             try {
@@ -76,7 +76,7 @@ 
      * @throws Error
      * @return string
      */
-    public function recv ($length, $flags = 0) {
+    public function recv($length, $flags = 0) {
         $count = @socket_recv($this->resource, $data, $length, $flags);
         if ($count === false) {
             $error = new Error($this->resource, SOCKET_EINVAL);

src/WebSocketClient.php

Spacing +9 added lines, -9 removed lines

@@ -18,7 +18,7 @@ 
      * @param $resource
      * @param WebSocketServer $server
      */
-    public function __construct ($resource, WebSocketServer $server) {
+    public function __construct($resource, WebSocketServer $server) {
         parent::__construct($resource);
         $this->server = $server;
     }
@@ -26,33 +26,33 @@ 
     /**
      * Removes the client from the server and reactor.
      */
-    protected function onClose () {
+    protected function onClose() {
         $this->server->remove($this);
     }
 
     /**
      * @param string $payload
      */
-    protected function onData (string $payload): void {
+    protected function onData(string $payload): void {
     }
 
     /**
      * WebSockets do not use the out-of-band channel.
      */
-    final public function onOutOfBand () {
+    final public function onOutOfBand() {
     }
 
     /**
      * When a browser responds to a ping.
      */
-    protected function onPong (): void {
+    protected function onPong(): void {
         // stub
     }
 
     /**
      * Reads framed messages.
      */
-    public function onReadable (): void {
+    public function onReadable(): void {
         $data = $this->recv(4096);
         $frame = new WebSocketFrame($data);
         if ($frame->isText()) {
@@ -74,17 +74,17 @@ 
      *
      * @param string $text
      */
-    protected function onText (string $text): void {
+    protected function onText(string $text): void {
     }
 
     /**
      * Pings the browser.
      */
-    public function ping () {
+    public function ping() {
         $this->write(WebSocketFrame::pack('', WebSocketFrame::OP_PING));
     }
 
-    public function writeText (string $message) {
+    public function writeText(string $message) {
         $packed = WebSocketFrame::pack($message);
         $this->write($packed);
     }

Braces +3 added lines, -6 removed lines

@@ -57,14 +57,11 @@
         $frame = new WebSocketFrame($data);
         if ($frame->isText()) {
             $this->onText($frame->getPayload());
-        }
-        elseif ($frame->isBinary()) {
+        } elseif ($frame->isBinary()) {
             $this->onData($frame->getPayload());
-        }
-        elseif ($frame->isPong()) {
+        } elseif ($frame->isPong()) {
             $this->onPong();
-        }
-        elseif ($frame->isClose()) {
+        } elseif ($frame->isClose()) {
             $this->close();
         }
     }

src/StreamServer.php

Spacing +5 added lines, -5 removed lines

@@ -12,7 +12,7 @@ 
      *
      * @return int
      */
-    final public static function getType () {
+    final public static function getType() {
         return SOCK_STREAM;
     }
 
@@ -27,7 +27,7 @@ 
      * @throws Error
      * @return StreamClient The accepted connection, as a client instance.
      */
-    public function accept () {
+    public function accept() {
         if (!$resource = @socket_accept($this->resource)) {
             throw new Error($this->resource); // reliable errno
         }
@@ -46,7 +46,7 @@ 
      * @throws Error
      * @return $this
      */
-    public function listen ($backlog = 0) {
+    public function listen($backlog = 0) {
         if (!@socket_listen($this->resource, $backlog)) {
             throw new Error($this->resource); // reliable errno
         }
@@ -60,7 +60,7 @@ 
      * @return StreamClient
      * @throws Error
      */
-    protected function newClient ($resource) {
+    protected function newClient($resource) {
         return new StreamClient($resource);
     }
 
@@ -70,7 +70,7 @@ 
      * @param StreamClient $client
      * @return void
      */
-    protected function onAccept (StreamClient $client) {
+    protected function onAccept(StreamClient $client) {
     }
 
 }

src/AbstractClient.php

Braces +2 added lines, -4 removed lines

@@ -19,8 +19,7 @@ 
     public function __toString () {
         try {
             return implode(':', $this->getPeerName());
-        }
-        catch (Exception $exception) {
+        } catch (Exception $exception) {
             return ':';
         }
     }
@@ -109,8 +108,7 @@ 
             try {
                 $total += $count = $this->await(self::CH_WRITE)->send($data);
                 $data = substr($data, $count); // 0 bytes sent = unaltered buffer
-            }
-            catch (Error $error) {
+            } catch (Error $error) {
                 $error->setExtra($total);
                 throw $error;
             }