hfw / socket

src/Reactor.php

Braces +1 added lines, -2 removed lines

@@ -93,8 +93,7 @@
             foreach ($rwe[0] as $id => $socket) {
                 $socket->onReadable();
             }
-        }
-        finally {
+        } finally {
             array_walk_recursive($rwe, function(ReactiveInterface $each) {
                 if (!$each->isOpen()) {
                     $this->remove($each);

Spacing +7 added lines, -7 removed lines

@@ -28,12 +28,12 @@ 
      * @return int
      * @throws SocketError
      */
-    public static function select (array &$read, array &$write, array &$except, ?float $timeout = null): int {
+    public static function select(array &$read, array &$write, array &$except, ?float $timeout = null): int {
         $rwe = [$read, $write, $except];
         array_walk_recursive($rwe, function(SocketInterface &$each) {
             $each = $each->getResource();
         });
-        $uSec = (int)(fmod($timeout, 1) * 1000000); // ignored if timeout is null
+        $uSec = (int) (fmod($timeout, 1) * 1000000); // ignored if timeout is null
         $count = @socket_select($rwe[0], $rwe[1], $rwe[2], $timeout, $uSec); // keys are preserved
         if ($count === false) {
             $read = $write = $except = [];
@@ -51,7 +51,7 @@ 
      * @param ReactiveInterface $socket
      * @return $this
      */
-    public function add (ReactiveInterface $socket) {
+    public function add(ReactiveInterface $socket) {
         $this->sockets[$socket->getId()] = $socket;
         return $this;
     }
@@ -61,14 +61,14 @@ 
      *
      * @return int
      */
-    public function count () {
+    public function count() {
         return count($this->sockets);
     }
 
     /**
      * @return SocketInterface[]
      */
-    public function getSockets () {
+    public function getSockets() {
         return $this->sockets;
     }
 
@@ -82,7 +82,7 @@ 
      * @param float|null $timeout Maximum seconds to block. `NULL` blocks forever.
      * @return int Number of sockets selected.
      */
-    public function react (?float $timeout = null): int {
+    public function react(?float $timeout = null): int {
         /** @var ReactiveInterface[][] $rwe */
         $rwe = [$this->sockets, [], $this->sockets];
         $count = static::select($rwe[0], $rwe[1], $rwe[2], $timeout);
@@ -110,7 +110,7 @@ 
      * @param int|ReactiveInterface $id
      * @return $this
      */
-    public function remove ($id) {
+    public function remove($id) {
         unset($this->sockets[$id instanceof ReactiveInterface ? $id->getId() : $id]);
         return $this;
     }

src/DatagramClient.php

Spacing +1 added lines, -1 removed lines

@@ -12,7 +12,7 @@
      *
      * @return int
      */
-    final public static function getType (): int {
+    final public static function getType(): int {
         return SOCK_DGRAM;
     }
 

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

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;
             }
         }

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;
@@ -52,7 +52,7 @@ 
      * @param int $opCode
      * @param string $payload
      */
-    public function broadcast (int $opCode, string $payload) {
+    public function broadcast(int $opCode, string $payload) {
         foreach ($this->clients as $client) {
             if ($client->isOk()) {
                 $client->getFrameHandler()->write($opCode, $payload);
@@ -63,7 +63,7 @@ 
     /**
      * @param string $payload
      */
-    public function broadcastBinary (string $payload) {
+    public function broadcastBinary(string $payload) {
         $this->broadcast(Frame::OP_BINARY, $payload);
     }
 
@@ -72,7 +72,7 @@ 
      *
      * @param string $payload
      */
-    public function broadcastPing (string $payload = '') {
+    public function broadcastPing(string $payload = '') {
         $this->broadcast(Frame::OP_PING, $payload);
     }
 
@@ -81,7 +81,7 @@ 
      *
      * @param string $text
      */
-    public function broadcastText (string $text) {
+    public function broadcastText(string $text) {
         $this->broadcast(Frame::OP_TEXT, $text);
     }
 
@@ -92,7 +92,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);
@@ -110,14 +110,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;
     }
 
@@ -125,17 +125,17 @@ 
      * @param resource $resource
      * @return WebSocketClient
      */
-    protected function newClient ($resource) {
+    protected function newClient($resource) {
         return new WebSocketClient($resource, $this);
     }
 
     /**
      * Servers never get OOB data.
      */
-    final public function onOutOfBand (): void {
+    final public function onOutOfBand(): void {
     }
 
-    public function onReadable (): void {
+    public function onReadable(): void {
         $this->accept();
     }
 
@@ -144,7 +144,7 @@ 
      *
      * @param WebSocketClient $client
      */
-    public function remove (WebSocketClient $client) {
+    public function remove(WebSocketClient $client) {
         unset($this->clients[$client->getId()]);
         $this->reactor->remove($client);
     }

src/AbstractClient.php

Spacing +5 added lines, -5 removed lines

@@ -18,7 +18,7 @@ 
      *
      * @return string
      */
-    public function __toString () {
+    public function __toString() {
         try {
             return implode(':', $this->getPeerName());
         }
@@ -41,7 +41,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function connect (string $address, int $port = 0) {
+    public function connect(string $address, int $port = 0) {
         if (!@socket_connect($this->resource, $address, $port)) {
             // ignore expected errors for non-blocking connections
             $errno = SocketError::getLast($this->resource);
@@ -61,7 +61,7 @@ 
      * @return array `[ 0 => address, 1 => port ]`
      * @throws SocketError
      */
-    public function getPeerName (): array {
+    public function getPeerName(): array {
         if ($this->getDomain() === AF_UNIX) {
             return [$this->getOption(17), 0]; // SO_PEERCRED is not exposed by PHP
         }
@@ -81,7 +81,7 @@ 
      * @return int Total bytes sent.
      * @throws SocketError
      */
-    public function send (string $data, int $flags = 0): int {
+    public function send(string $data, int $flags = 0): int {
         $count = @socket_send($this->resource, $data, strlen($data), $flags);
         if ($count === false) {
             throw new SocketError($this->resource); // reliable errno
@@ -96,7 +96,7 @@ 
      * @return $this
      * @throws SocketError `int` total bytes sent is set as the extra data.
      */
-    public function write (string $data) {
+    public function write(string $data) {
         $length = strlen($data);
         $total = 0;
         while ($total < $length) {

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

Spacing +3 added lines, -3 removed lines

@@ -27,20 +27,20 @@
      *
      * @return int
      */
-    public function getId (): int;
+    public function getId(): int;
 
     /**
      * Returns the underlying socket resource.
      *
      * @return resource
      */
-    public function getResource ();
+    public function getResource();
 
     /**
      * Whether the underlying resource is usable.
      *
      * @return bool
      */
-    public function isOpen (): bool;
+    public function isOpen(): bool;
 
 }
\ No newline at end of file

src/SocketError.php

Spacing +4 added lines, -4 removed lines

@@ -29,7 +29,7 @@ 
      * @param resource $resource PHP socket resource, or `null` for the global error.
      * @return int If the resource is closed or not a socket, `SOCKET_EBADF` is returned.
      */
-    public static function getLast ($resource = null) {
+    public static function getLast($resource = null) {
         if (isset($resource)) {
             if (@get_resource_type($resource) !== 'Socket') {
                 return SOCKET_EBADF; // Bad file descriptor
@@ -62,7 +62,7 @@ 
      * @param int $fallback Code to assume if one can't be found via the subject.
      * @param SocketError|null $previous Slippage of a prior error.
      */
-    public function __construct ($subject = null, $fallback = 0, SocketError $previous = null) {
+    public function __construct($subject = null, $fallback = 0, SocketError $previous = null) {
         if ($errno = is_int($subject) ? $subject : static::getLast($subject)) {
             $message = socket_strerror($errno);
         }
@@ -77,7 +77,7 @@ 
     /**
      * @return mixed
      */
-    public function getExtra () {
+    public function getExtra() {
         return $this->extra;
     }
 
@@ -85,7 +85,7 @@ 
      * @param mixed $extra
      * @return $this
      */
-    public function setExtra ($extra) {
+    public function setExtra($extra) {
         $this->extra = $extra;
         return $this;
     }

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']}";