arthurkushman / php-wss

src/Components/Connection.php

Spacing +1 added lines, -1 removed lines

@@ -139,7 +139,7 @@
      */
     public function getUniqueSocketId(): int
     {
-        return (int)$this->socketConnection;
+        return (int) $this->socketConnection;
     }
 
     /**

src/Components/WSClientTrait.php

Doc Comments +4 added lines, -4 removed lines

@@ -184,10 +184,10 @@
     }
 
     /**
-     * @param $final
-     * @param $payload
-     * @param $opcode
-     * @param $masked
+     * @param boolean $final
+     * @param string $payload
+     * @param string $opcode
+     * @param boolean $masked
      * @throws ConnectionException
      * @throws \Exception
      */

Spacing +4 added lines, -4 removed lines

@@ -63,7 +63,7 @@ 
      */
     private function getPayloadLength(string $data)
     {
-        $payloadLength = (int)ord($data[1]) & self::MASK_127; // Bits 1-7 in byte 1
+        $payloadLength = (int) ord($data[1]) & self::MASK_127; // Bits 1-7 in byte 1
         if ($payloadLength > self::MASK_125) {
             if ($payloadLength === self::MASK_126) {
                 $data = $this->read(2); // 126: Payload is a 16-bit unsigned int
@@ -85,7 +85,7 @@ 
     private function getPayloadData(string $data, int $payloadLength): string
     {
         // Masking?
-        $mask = (bool)(ord($data[1]) >> 7);  // Bit 0 in byte 1
+        $mask = (bool) (ord($data[1]) >> 7); // Bit 0 in byte 1
         $payload = '';
         $maskingKey = '';
 
@@ -127,7 +127,7 @@ 
 
         // Is this the final fragment?  // Bit 0 in byte 0
         /// @todo Handle huge payloads with multiple fragments.
-        $final = (bool)(ord($data[0]) & 1 << 7);
+        $final = (bool) (ord($data[0]) & 1 << 7);
 
         // Parse opcode
         $opcode_int = ord($data[0]) & 31; // Bits 4-7
@@ -196,7 +196,7 @@ 
         // Binary string for header.
         $frameHeadBin = '';
         // Write FIN, final fragment bit.
-        $frameHeadBin .= (bool)$final ? '1' : '0';
+        $frameHeadBin .= (bool) $final ? '1' : '0';
         // RSV 1, 2, & 3 false and unused.
         $frameHeadBin .= '000';
         // Opcode rest of the byte.

src/Components/WscMain.php

Doc Comments +3 added lines, -3 removed lines

@@ -108,7 +108,7 @@ 
     }
 
     /**
-     * @return mixed|resource
+     * @return resource|null
      * @throws \InvalidArgumentException
      */
     private function getStreamContext()
@@ -207,7 +207,7 @@ 
     /**
      * Sends message to opened socket connection client->server
      *
-     * @param $payload
+     * @param string $payload
      * @param string $opcode
      * @throws \InvalidArgumentException
      * @throws BadOpcodeException
@@ -277,7 +277,7 @@ 
      *
      * @param integer $status http://tools.ietf.org/html/rfc6455#section-7.4
      * @param string $message A closing message, max 125 bytes.
-     * @return bool|null|string
+     * @return null|string
      * @throws \InvalidArgumentException
      * @throws BadOpcodeException
      * @throws BadUriException

Spacing +1 added lines, -1 removed lines

@@ -157,7 +157,7 @@
         return 'GET ' . $pathWithQuery . " HTTP/1.1\r\n"
             . implode(
                 "\r\n", array_map(
-                    function ($key, $value) {
+                    function($key, $value) {
                         return "$key: $value";
                     }, array_keys($headers), $headers
                 )

src/WebSocketServer.php

Indentation +1 added lines, -1 removed lines

@@ -69,7 +69,7 @@
         $server = stream_socket_server("tcp://{$this->config->getHost()}:{$this->config->getPort()}", $errno, $errorMessage);
 
         if ($server === false) {
-           throw new WebSocketException('Could not bind to socket: ' . $errno . ' - ' . $errorMessage . PHP_EOL, CommonsContract::SERVER_COULD_NOT_BIND_TO_SOCKET);
+            throw new WebSocketException('Could not bind to socket: ' . $errno . ' - ' . $errorMessage . PHP_EOL, CommonsContract::SERVER_COULD_NOT_BIND_TO_SOCKET);
         }
 
         @cli_set_process_title($this->config->getProcessName());

Spacing +2 added lines, -2 removed lines

@@ -37,7 +37,7 @@ 
     private const HEADER_BYTES_READ = 1024;
 
     // stream non-blocking
-    public const NON_BLOCK  = 0;
+    public const NON_BLOCK = 0;
 
     /**
      * WebSocketServer constructor.
@@ -334,7 +334,7 @@ 
         }
 
         $key = $match[1];
-        $this->handshakes[(int)$client] = $key;
+        $this->handshakes[(int) $client] = $key;
 
         // sending header according to WebSocket Protocol
         $secWebSocketAccept = base64_encode(sha1(trim($key) . self::HEADER_WEBSOCKET_ACCEPT_HASH, true));

src/Contracts/WebSocketServerContract.php

Indentation +3 added lines, -3 removed lines

@@ -22,10 +22,10 @@
     public const HEADER_HTTP1_1                   = 'HTTP/1.1 101 Web Socket Protocol Handshake';
     public const HEADER_WEBSOCKET_ACCEPT_HASH     = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11';
     public const HEADERS_UPGRADE_KEY              = 'Upgrade',
-                 HEADERS_CONNECTION_KEY           = 'Connection',
-                 HEADERS_SEC_WEBSOCKET_ACCEPT_KEY = 'Sec-WebSocket-Accept';
+                    HEADERS_CONNECTION_KEY           = 'Connection',
+                    HEADERS_SEC_WEBSOCKET_ACCEPT_KEY = 'Sec-WebSocket-Accept';
     public const HEADERS_UPGRADE_VALUE            = 'websocket',
-                 HEADERS_CONNECTION_VALUE         = 'Upgrade';
+                    HEADERS_CONNECTION_VALUE         = 'Upgrade';
     public const HEADERS_EOL                      = "\r\n";
     public const SEC_WEBSOCKET_KEY_PTRN           = '/Sec-WebSocket-Key:\s(.*)\n/';