Run autobahn tests on Travis

Author: kelunik

.travis.yml

@@ -1,7 +1,10 @@
-sudo: false
+sudo: required
 
 language: php
 
+services:
+  - docker
+
 php:
   - 7.0
   - 7.1
@@ -18,6 +21,8 @@ env:
 
 before_install:
   - phpenv config-rm xdebug.ini || echo "No xdebug config."
+  - docker pull crossbario/autobahn-testsuite
+  - docker run -d -v ${PWD}/test-autobahn/config:/config -v ${PWD}/test-autobahn/reports:/reports -p 9001:9001 --name fuzzingserver crossbario/autobahn-testsuite
 
 install:
   - composer update -n --prefer-dist
@@ -30,6 +35,7 @@ install:
 
 script:
   - phpdbg -qrr vendor/bin/phpunit --verbose --coverage-php coverage/cov/main.cov
+  - php test-autobahn/runner.php
   - PHP_CS_FIXER_IGNORE_ENV=1 php vendor/bin/php-cs-fixer --diff --dry-run -v fix
 
 after_script:

test-autobahn/config/fuzzingserver.json

@@ -0,0 +1,7 @@
+{
+    "url": "ws://127.0.0.1:9001",
+    "outdir": "./reports/clients",
+    "cases": ["*"],
+    "exclude-cases": ["7.*", "12.*", "13.*"],
+    "exclude-agent-cases": {}
+}

test-autobahn/runner.php

@@ -0,0 +1,79 @@
+<?php
+
+use Amp\ByteStream\StreamException;
+use Amp\Loop;
+use Amp\Websocket;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+const AGENT = 'amphp/websocket';
+
+Loop::run(function () {
+    $errors = 0;
+
+    $options = (new Websocket\Options)
+        ->withMaximumMessageSize(32 * 1024 * 1024)
+        ->withMaximumFrameSize(32 * 1024 * 1024)
+        ->withValidateUtf8(true);
+
+    /** @var Websocket\Connection $connection */
+    $connection = yield Websocket\connect('ws://127.0.0.1:9001/getCaseCount');
+    /** @var Websocket\Message $message */
+    $message = yield $connection->receive();
+    $cases = (int) yield $message->buffer();
+
+    echo "Going to run {$cases} test cases." . PHP_EOL;
+
+    for ($i = 1; $i < $cases; $i++) {
+        $connection = yield Websocket\connect('ws://127.0.0.1:9001/getCaseInfo?case=' . $i . '&agent=' . AGENT);
+        $message = yield $connection->receive();
+        $info = \json_decode(yield $message->buffer(), true);
+
+        print $info['id'] . ' ' . str_repeat('-', 80 - strlen($info['id']) - 1) . PHP_EOL;
+        print wordwrap($info['description'], 80, PHP_EOL) . ' ';
+
+        $connection = yield Websocket\connect('ws://127.0.0.1:9001/runCase?case=' . $i . '&agent=' . AGENT, null, null, $options);
+
+        try {
+            while ($message = yield $connection->receive()) {
+                $content = yield $message->buffer();
+
+                if ($message->isBinary()) {
+                    yield $connection->sendBinary($content);
+                } else {
+                    yield $connection->send($content);
+                }
+            }
+        } catch (Websocket\ClosedException $e) {
+            // ignore
+        } catch (AssertionError $e) {
+            print 'Assertion error: ' . $e->getMessage() . PHP_EOL;
+            $connection->close();
+        } catch (Error $e) {
+            print 'Error: ' . $e->getMessage() . PHP_EOL;
+            $connection->close();
+        } catch (StreamException $e) {
+            print 'Stream exception: ' . $e->getMessage() . PHP_EOL;
+            $connection->close();
+        }
+
+        $connection = yield Websocket\connect('ws://127.0.0.1:9001/getCaseStatus?case=' . $i . '&agent=' . AGENT);
+        $message = yield $connection->receive();
+        print ($result = \json_decode(yield $message->buffer(), true)['behavior']);
+
+        if ($result === 'FAILED') {
+            $errors++;
+        }
+
+        print PHP_EOL . PHP_EOL;
+    }
+
+    $connection = yield Websocket\connect('ws://127.0.0.1:9001/updateReports?agent=' . AGENT);
+    $connection->close();
+
+    Loop::stop();
+
+    if ($errors) {
+        exit(1);
+    }
+});