Merge pull request #3 from clue/tests

Add Tests

Author: clue

.travis.yml

@@ -0,0 +1,8 @@
+language: php
+php:
+  - 5.4
+  - 5.3
+before_script:
+  - composer install --dev --prefer-source --no-interaction
+script:
+  - phpunit --coverage-text

Datagram/Socket.php

@@ -92,9 +92,9 @@ public function close()
         $this->emit('close', array($this));
         $this->pause();
 
+        fclose($this->socket);
         $this->socket = false;
         $this->buffer->close();
-        fclose($this->socket);
 
         $this->removeAllListeners();
     }

phpunit.xml.dist

@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<phpunit colors="true">
+    <testsuites>
+        <testsuite name="Datagram Test Suite">
+            <directory>./tests/</directory>
+        </testsuite>
+    </testsuites>
+    <filter>
+        <whitelist>
+            <directory>./Datagram</directory>
+        </whitelist>
+    </filter>
+</phpunit>

tests/FactoryTest.php

@@ -0,0 +1,111 @@
+<?php
+
+use Datagram\Socket;
+
+use React\Promise\When;
+
+use React\Promise\PromiseInterface;
+
+require __DIR__.'/../vendor/autoload.php';
+
+class FactoryTest extends PHPUnit_Framework_TestCase
+{
+    private $factory;
+
+    public function setUp()
+    {
+        $this->loop = React\EventLoop\Factory::create();
+        $this->factory = new Datagram\Factory($this->loop, $this->createResolverMock());
+    }
+
+    public function testCreateClient()
+    {
+        $promise = $this->factory->createClient('127.0.0.1', 12345);
+
+        $capturedClient = $this->getValueFromResolvedPromise($promise);
+        $this->assertInstanceOf('Datagram\Socket', $capturedClient);
+
+        $capturedClient->close();
+    }
+
+    public function testCreateClientLocalhost()
+    {
+        $promise = $this->factory->createClient('localhost', 12345);
+
+        $capturedClient = $this->getValueFromResolvedPromise($promise);
+        $this->assertInstanceOf('Datagram\Socket', $capturedClient);
+
+        $capturedClient->close();
+    }
+
+    public function testCreateClientIpv6()
+    {
+        $promise = $this->factory->createClient('::1', 12345);
+
+        $capturedClient = $this->getValueFromResolvedPromise($promise);
+        $this->assertInstanceOf('Datagram\Socket', $capturedClient);
+
+        $capturedClient->close();
+    }
+
+    public function testCreateServer()
+    {
+        $promise = $this->factory->createServer(12345, '127.0.0.1');
+
+        $capturedServer = $this->getValueFromResolvedPromise($promise);
+        $this->assertInstanceOf('Datagram\Socket', $capturedServer);
+
+        $capturedServer->close();
+    }
+
+    protected function getValueFromResolvedPromise($promise)
+    {
+        $this->assertInstanceOf('React\Promise\PromiseInterface', $promise);
+
+        $loop = $this->loop;
+        $capturedValue = null;
+        $promise->then(function ($value) use (&$capturedValue, $loop) {
+            $capturedValue = $value;
+            $loop->stop();
+        }, $this->expectCallableNever());
+
+        // future-turn resolutions are not enforced, so the value MAY be known here already
+        if ($capturedValue === null) {
+            $loop->run();
+        }
+
+        return $capturedValue;
+    }
+
+    protected function expectCallableOnce()
+    {
+        $mock = $this->createCallableMock();
+        $mock
+            ->expects($this->once())
+            ->method('__invoke');
+
+        return $mock;
+    }
+
+    protected function expectCallableNever()
+    {
+        $mock = $this->createCallableMock();
+        $mock
+            ->expects($this->never())
+            ->method('__invoke');
+
+        return $mock;
+    }
+
+    protected function createCallableMock()
+    {
+        return $this->getMock('React\Tests\Socket\Stub\CallableStub');
+    }
+
+    private function createResolverMock()
+    {
+        return $this->getMockBuilder('React\Dns\Resolver\Resolver')
+        ->disableOriginalConstructor()
+        ->getMock();
+    }
+}