Merge pull request #18 from clue/functional

Add functional test

Author: clue

.travis.yml

@@ -3,7 +3,13 @@ php:
   - 5.3
   - 5.6
   - hhvm
-before_script:
+env:
+  - LOGIN='username:password@localhost'
+install:
+  - bash -c '[ "$(id -un)" == "root" ] && apt-get update && apt-get install -y sudo || true'
+  - sudo apt-get install -y asterisk
+  - sudo cp tests/username.conf /etc/asterisk/manager.d/username.conf
+  - sudo /etc/init.d/asterisk restart
   - composer install --prefer-source --no-interaction
 script:
   - phpunit --coverage-text

tests/FunctionalTest.php

@@ -0,0 +1,112 @@
+<?php
+
+use Clue\React\Ami\Factory;
+use React\Promise\PromiseInterface;
+use Clue\React\Ami\Client;
+use Clue\React\Ami\Api;
+use Clue\React\Ami\Protocol\Response;
+
+class FunctionalTest extends TestCase
+{
+    private static $address = false;
+    private static $loop;
+
+    public static function setUpBeforeClass()
+    {
+        self::$address = getenv('LOGIN');
+        self::$loop = React\EventLoop\Factory::create();
+    }
+
+    public function setUp()
+    {
+        if (self::$address === false) {
+            $this->markTestSkipped('No ENV named LOGIN found. Please use "export LOGIN=\'user:pass@host\'.');
+        }
+    }
+
+    public function testConnection()
+    {
+        $factory = new Factory(self::$loop);
+
+        $client = $this->waitFor($factory->createClient(self::$address));
+        /* @var $client Client */
+
+        $this->assertFalse($client->isBusy());
+
+        return $client;
+    }
+
+    /**
+     * @depends testConnection
+     * @param Client $client
+     */
+    public function testPing(Client $client)
+    {
+        $api = new Api($client);
+
+        $pong = $this->waitFor($api->ping());
+        /* @var $pong Response */
+    }
+
+    /**
+     * @depends testConnection
+     * @param Client $client
+     * @expectedException Exception
+     */
+    public function testInvalidCommandGetsRejected(Client $client)
+    {
+        $this->waitFor($client->request($client->createAction('Invalid')));
+    }
+
+    /**
+     * @depends testConnection
+     * @param Client $client
+     */
+    public function testApiLogoffDisconnects(Client $client)
+    {
+        $api = new Api($client);
+
+        $ret = $this->waitFor($api->logoff());
+        /* @var $ret Response */
+
+        $this->assertFalse($client->isBusy());
+
+        //$client->on('close', $this->expectCallableOnce());
+
+        self::$loop->run();
+
+        return $client;
+    }
+
+    /**
+     * @depends testApiLogoffDisconnects
+     * @param Client $client
+     * @expectedException Exception
+     */
+    public function testSendRejectedAfterClose(Client $client)
+    {
+        $this->waitFor($client->request($client->createAction('Ping')));
+    }
+
+    private function waitFor(PromiseInterface $promise)
+    {
+        $resolved = null;
+        $exception = null;
+
+        $promise->then(function ($c) use (&$resolved) {
+            $resolved = $c;
+        }, function($error) use (&$exception) {
+            $exception = $error;
+        });
+
+        while ($resolved === null && $exception === null) {
+            self::$loop->tick();
+        }
+
+        if ($exception !== null) {
+            throw $exception;
+        }
+
+        return $resolved;
+    }
+}

tests/username.conf

@@ -0,0 +1,6 @@
+; demo config for functional test
+; should be placed in: /etc/asterisk/manager.d/username.conf
+[username]
+secret = password
+read   = system,call,log,verbose,command,agent,user,originate
+write  = system,call,log,verbose,command,agent,user,originate