Pass all the autobahn tests

Author: mbonneau

.gitignore

@@ -1,2 +1,3 @@
 /composer.lock
 /vendor
+/tests/ab/reports

src/WebSocketConnection.php

@@ -37,6 +37,8 @@ function (Frame $frame) {
                             list($closeCode) = array_merge(unpack('n*', substr($frame->getPayload(), 0, 2)));
                         }
 
+                        $this->stream->end($frame->getContents());
+
                         if ($closeCode >= 2000) {
                             // emit close code as error
                             $exception = new \Exception('WebSocket closed with code ' . $closeCode);
@@ -46,7 +48,6 @@ function (Frame $frame) {
 
                         $this->emit('close', [$closeCode, $this]);
 
-                        $this->stream->close();
                         return;
                 }
             },

tests/ab/fuzzingclient.json

@@ -0,0 +1,12 @@
+{
+    "options": {"failByDrop": false}
+  , "outdir": "reports"
+
+  , "servers": [
+        {"agent": "WebSocketMiddleware", "url": "ws://localhost:4321", "options": {"version": 18}}
+    ]
+
+  , "cases": ["*"]
+  , "exclude-cases": ["10.*", "11.*", "12.*", "13.*"]
+  , "exclude-agent-cases": {}
+}

tests/ab/testServer.php

@@ -0,0 +1,25 @@
+<?php
+
+use Ratchet\RFC6455\Messaging\Message;
+use React\EventLoop\Factory;
+use React\Http\MiddlewareRunner;
+use React\Http\Server;
+use Voryx\WebSocketMiddleware\WebSocketConnection;
+use Voryx\WebSocketMiddleware\WebSocketMiddleware;
+
+require __DIR__ . '/../../vendor/autoload.php';
+
+$loop = Factory::create();
+
+$ws = new WebSocketMiddleware([], function (WebSocketConnection $conn) {
+    $conn->on('message', function (Message $message) use ($conn) {
+        $conn->send($message);
+    });
+});
+
+$server = new Server(new MiddlewareRunner([$ws]));
+
+$server->listen(new \React\Socket\Server('127.0.0.1:4321', $loop));
+
+$loop->run();
+