@@ -12,7 +12,7 @@ |
||
| 12 | 12 | const MAX_BYTES_READ = 65535, |
| 13 | 13 | DEFAULT_TIMEOUT = 5, |
| 14 | 14 | DEFAULT_FRAGMENT_SIZE = 4096, |
| 15 | - DEFAULT_RESPONSE_HEADER = 1024; |
|
| 15 | + DEFAULT_RESPONSE_HEADER = 1024; |
|
| 16 | 16 | const SEC_WEBSOCKET_ACCEPT_PTTRN = '/Sec-WebSocket-Accept:\s(.*)$/mUi'; |
| 17 | 17 | const SERVER_KEY_ACCEPT = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'; |
| 18 | 18 | // MASKS |
@@ -21,10 +21,10 @@ |
||
| 21 | 21 | const HEADER_HTTP1_1 = 'HTTP/1.1 101 Web Socket Protocol Handshake'; |
| 22 | 22 | const HEADER_WEBSOCKET_ACCEPT_HASH = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'; |
| 23 | 23 | const HEADERS_UPGRADE_KEY = 'Upgrade', |
| 24 | - HEADERS_CONNECTION_KEY = 'Connection', |
|
| 25 | - HEADERS_SEC_WEBSOCKET_ACCEPT_KEY = 'Sec-WebSocket-Accept'; |
|
| 24 | + HEADERS_CONNECTION_KEY = 'Connection', |
|
| 25 | + HEADERS_SEC_WEBSOCKET_ACCEPT_KEY = 'Sec-WebSocket-Accept'; |
|
| 26 | 26 | const HEADERS_UPGRADE_VALUE = 'websocket', |
| 27 | - HEADERS_CONNECTION_VALUE = 'Upgrade'; |
|
| 27 | + HEADERS_CONNECTION_VALUE = 'Upgrade'; |
|
| 28 | 28 | const HEADERS_EOL = "\r\n"; |
| 29 | 29 | const SEC_WEBSOCKET_KEY_PTRN = '/Sec-WebSocket-Key:\s(.*)\n/'; |
| 30 | 30 | |
@@ -167,6 +167,9 @@ discard block |
||
| 167 | 167 | return $this->options['fragment_size']; |
| 168 | 168 | } |
| 169 | 169 | |
| 170 | + /** |
|
| 171 | + * @param string $payload |
|
| 172 | + */ |
|
| 170 | 173 | public function send($payload, $opcode = 'text', $masked = true) |
| 171 | 174 | { |
| 172 | 175 | if (!$this->is_connected) { |
@@ -199,6 +202,12 @@ discard block |
||
| 199 | 202 | } |
| 200 | 203 | } |
| 201 | 204 | |
| 205 | + /** |
|
| 206 | + * @param boolean $final |
|
| 207 | + * @param string $payload |
|
| 208 | + * @param string $opcode |
|
| 209 | + * @param boolean $masked |
|
| 210 | + */ |
|
| 202 | 211 | protected function send_fragment($final, $payload, $opcode, $masked) |
| 203 | 212 | { |
| 204 | 213 | // Binary string for header. |
@@ -375,6 +384,9 @@ discard block |
||
| 375 | 384 | return $this->receive(); // Receiving a close frame will close the socket now. |
| 376 | 385 | } |
| 377 | 386 | |
| 387 | + /** |
|
| 388 | + * @param string $data |
|
| 389 | + */ |
|
| 378 | 390 | protected function write($data) |
| 379 | 391 | { |
| 380 | 392 | $written = fwrite($this->socket, $data); |
@@ -412,6 +424,7 @@ discard block |
||
| 412 | 424 | |
| 413 | 425 | /** |
| 414 | 426 | * Helper to convert a binary to a string of '0' and '1'. |
| 427 | + * @param string $string |
|
| 415 | 428 | */ |
| 416 | 429 | protected static function sprintB($string) |
| 417 | 430 | { |