@@ -184,10 +184,10 @@ |
||
184 | 184 | } |
185 | 185 | |
186 | 186 | /** |
187 | - * @param $final |
|
188 | - * @param $payload |
|
189 | - * @param $opcode |
|
190 | - * @param $masked |
|
187 | + * @param boolean $final |
|
188 | + * @param string $payload |
|
189 | + * @param string $opcode |
|
190 | + * @param boolean $masked |
|
191 | 191 | * @throws ConnectionException |
192 | 192 | * @throws \Exception |
193 | 193 | */ |
@@ -69,7 +69,7 @@ |
||
69 | 69 | $server = stream_socket_server("tcp://{$this->config->getHost()}:{$this->config->getPort()}", $errno, $errorMessage); |
70 | 70 | |
71 | 71 | if ($server === false) { |
72 | - throw new WebSocketException('Could not bind to socket: ' . $errno . ' - ' . $errorMessage . PHP_EOL, CommonsContract::SERVER_COULD_NOT_BIND_TO_SOCKET); |
|
72 | + throw new WebSocketException('Could not bind to socket: ' . $errno . ' - ' . $errorMessage . PHP_EOL, CommonsContract::SERVER_COULD_NOT_BIND_TO_SOCKET); |
|
73 | 73 | } |
74 | 74 | |
75 | 75 | @cli_set_process_title($this->config->getProcessName()); |
@@ -22,10 +22,10 @@ |
||
22 | 22 | public const HEADER_HTTP1_1 = 'HTTP/1.1 101 Web Socket Protocol Handshake'; |
23 | 23 | public const HEADER_WEBSOCKET_ACCEPT_HASH = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'; |
24 | 24 | public const HEADERS_UPGRADE_KEY = 'Upgrade', |
25 | - HEADERS_CONNECTION_KEY = 'Connection', |
|
26 | - HEADERS_SEC_WEBSOCKET_ACCEPT_KEY = 'Sec-WebSocket-Accept'; |
|
25 | + HEADERS_CONNECTION_KEY = 'Connection', |
|
26 | + HEADERS_SEC_WEBSOCKET_ACCEPT_KEY = 'Sec-WebSocket-Accept'; |
|
27 | 27 | public const HEADERS_UPGRADE_VALUE = 'websocket', |
28 | - HEADERS_CONNECTION_VALUE = 'Upgrade'; |
|
28 | + HEADERS_CONNECTION_VALUE = 'Upgrade'; |
|
29 | 29 | public const HEADERS_EOL = "\r\n"; |
30 | 30 | public const SEC_WEBSOCKET_KEY_PTRN = '/Sec-WebSocket-Key:\s(.*)\n/'; |
31 | 31 |
@@ -124,6 +124,9 @@ discard block |
||
124 | 124 | } |
125 | 125 | |
126 | 126 | |
127 | + /** |
|
128 | + * @param string $host |
|
129 | + */ |
|
127 | 130 | private function proxy($host, $ip, $port, $auth) |
128 | 131 | { |
129 | 132 | // Set the stream context options if they're already set in the config |
@@ -154,7 +157,7 @@ discard block |
||
154 | 157 | |
155 | 158 | |
156 | 159 | /** |
157 | - * @return mixed|resource |
|
160 | + * @return resource|null |
|
158 | 161 | * @throws \InvalidArgumentException |
159 | 162 | */ |
160 | 163 | private function getStreamContext() |
@@ -257,7 +260,7 @@ discard block |
||
257 | 260 | /** |
258 | 261 | * Sends message to opened socket connection client->server |
259 | 262 | * |
260 | - * @param $payload |
|
263 | + * @param string $payload |
|
261 | 264 | * @param string $opcode |
262 | 265 | * @throws \InvalidArgumentException |
263 | 266 | * @throws BadOpcodeException |
@@ -329,7 +332,7 @@ discard block |
||
329 | 332 | * |
330 | 333 | * @param integer $status http://tools.ietf.org/html/rfc6455#section-7.4 |
331 | 334 | * @param string $message A closing message, max 125 bytes. |
332 | - * @return bool|null|string |
|
335 | + * @return null|string |
|
333 | 336 | * @throws \InvalidArgumentException |
334 | 337 | * @throws BadOpcodeException |
335 | 338 | * @throws BadUriException |