Merge pull request #154 from Textalk/v1.5-master

Fix; allow header block larger than 1024 bytes

Author: Sören Jensen

lib/Client.php

@@ -177,7 +177,11 @@ function ($key, $value) {
             $this->write($header);
 
             // Get server response header (terminated with double CR+LF).
-            $response = stream_get_line($this->socket, 1024, "\r\n\r\n");
+            $response = '';
+            do {
+                $buffer = fgets($this->socket, 1024);
+                $response .= $buffer;
+            } while (substr_count($response, "\r\n\r\n") == 0);
 
             // Validate response.
             if (!preg_match('#Sec-WebSocket-Accept:\s(.*)$#mUi', $response, $matches)) {

tests/mock/mock-socket.php

@@ -56,6 +56,11 @@ function fread()
     $args = func_get_args();
     return MockSocket::handle('fread', $args);
 }
+function fgets()
+{
+    $args = func_get_args();
+    return MockSocket::handle('fgets', $args);
+}
 function stream_context_create()
 {
     $args = func_get_args();

tests/scripts/client.connect-authed.json

@@ -40,14 +40,13 @@
         "return": 248
     },
     {
-        "function": "stream_get_line",
+        "function": "fgets",
         "params": [
             "@mock-stream",
-            1024,
-            "\r\n\r\n"
+            1024
         ],
         "return-op": "key-respond",
-        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: {key}"
+        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: {key}\r\n\r\n"
     },
     {
         "function": "fwrite",

tests/scripts/client.connect-context.json

@@ -40,14 +40,13 @@
         "return": 199
     },
     {
-        "function": "stream_get_line",
+        "function": "fgets",
         "params": [
             "@mock-stream",
-            1024,
-            "\r\n\r\n"
+            1024
         ],
         "return-op": "key-respond",
-        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: {key}"
+        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: {key}\r\n\r\n"
     },
     {
         "function": "fwrite",

tests/scripts/client.connect-extended.json

@@ -40,14 +40,13 @@
         "return": 224
     },
     {
-        "function": "stream_get_line",
+        "function": "fgets",
         "params": [
             "@mock-stream",
-            1024,
-            "\r\n\r\n"
+            1024
         ],
         "return-op": "key-respond",
-        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: {key}"
+        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: {key}\r\n\r\n"
     },
     {
         "function": "fwrite",

tests/scripts/client.connect-headers.json

@@ -40,14 +40,22 @@
         "return": 255
     },
     {
-        "function": "stream_get_line",
+        "function": "fgets",
         "params": [
             "@mock-stream",
-            1024,
-            "\r\n\r\n"
+            1024
         ],
         "return-op": "key-respond",
-        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: {key}"
+        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: {key}\r\nX-Very-Long_Header: This is added to provoke split reads of headers in client 0123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456\r\n"
+    },
+    {
+        "function": "fgets",
+        "params": [
+            "@mock-stream",
+            1024
+        ],
+        "return-op": "key-respond",
+        "return": "Next234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789\r\n\r\n"
     },
     {
         "function": "fwrite",

tests/scripts/client.connect-invalid-key.json

@@ -39,12 +39,11 @@
         "return": 199
     },
     {
-        "function": "stream_get_line",
+        "function": "fgets",
         "params": [
             "@mock-stream",
-            1024,
-            "\r\n\r\n"
+            1024
         ],
-        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: BAD"
+        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: BAD\r\n\r\n"
     }
 ]

tests/scripts/client.connect-invalid-upgrade.json

@@ -39,12 +39,11 @@
         "return": 199
     },
     {
-        "function": "stream_get_line",
+        "function": "fgets",
         "params": [
             "@mock-stream",
-            1024,
-            "\r\n\r\n"
+            1024
         ],
-        "return": "Invalid upgrade response"
+        "return": "Invalid upgrade response\r\n\r\n"
     }
 ]

tests/scripts/client.connect-persistent.json

@@ -54,14 +54,13 @@
         "return": 248
     },
     {
-        "function": "stream_get_line",
+        "function": "fgets",
         "params": [
             "@mock-stream",
-            1024,
-            "\r\n\r\n"
+            1024
         ],
         "return-op": "key-respond",
-        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: {key}"
+        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: {key}\r\n\r\n"
     },
     {
         "function": "fwrite",

tests/scripts/client.connect-timeout.json

@@ -40,14 +40,13 @@
         "return": 199
     },
     {
-        "function": "stream_get_line",
+        "function": "fgets",
         "params": [
             "@mock-stream",
-            1024,
-            "\r\n\r\n"
+            1024
         ],
         "return-op": "key-respond",
-        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: {key}"
+        "return": "HTTP\/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: {key}\r\n\r\n"
     },
     {
         "function": "fwrite",