Add tests for Datagram\Socket

Author: clue

tests/SocketTest.php

@@ -0,0 +1,93 @@
+<?php
+
+use Datagram\Socket;
+use React\Promise\When;
+use React\Promise\PromiseInterface;
+
+class SocketTest extends TestCase
+{
+    private $factory;
+
+    public function setUp()
+    {
+        $this->loop = React\EventLoop\Factory::create();
+        $this->factory = new Datagram\Factory($this->loop, $this->createResolverMock());
+    }
+
+    public function testCreateClientCloseWillNotBlock()
+    {
+        $promise = $this->factory->createClient('127.0.0.1', 12345);
+        $client = $this->getValueFromResolvedPromise($promise);
+
+        $client->send('test');
+        $client->close();
+
+        $this->loop->run();
+
+        return $client;
+    }
+
+    /**
+     *
+     * @param Socket $client
+     * @depends testCreateClientCloseWillNotBlock
+     */
+    public function testClientCloseAgainWillNotBlock(Socket $client)
+    {
+        $client->close();
+        $this->loop->run();
+    }
+
+    public function testCreateClientEndWillNotBlock()
+    {
+        $promise = $this->factory->createClient('127.0.0.1', 12345);
+        $client = $this->getValueFromResolvedPromise($promise);
+
+        $client->send('test');
+        $client->end();
+
+        $this->loop->run();
+
+        return $client;
+    }
+
+    /**
+     *
+     * @param Socket $client
+     * @depends testCreateClientEndWillNotBlock
+     */
+    public function testClientEndAgainWillNotBlock(Socket $client)
+    {
+        $client->end();
+        $this->loop->run();
+    }
+
+    public function testCreatePair()
+    {
+        $promise = $this->factory->createServer(0, '127.0.0.1');
+        $server = $this->getValueFromResolvedPromise($promise);
+
+        $promise = $this->factory->createClient('127.0.0.1', $server->getPort());
+        $client = $this->getValueFromResolvedPromise($promise);
+
+        $that = $this;
+        $server->on('message', function ($message, $remote, $server) use ($that) {
+            $that->assertEquals('test', $message);
+
+            // once the server receives a message, send it pack to client and stop server
+            $server->send('response:' . $message, $remote);
+            $server->end();
+        });
+
+        $client->on('message', function ($message, $remote, $client) use ($that) {
+            $that->assertEquals('response:test', $message);
+
+            // once the client receives a message, stop client
+            $client->end();
+        });
+
+        $client->send('test');
+
+        $this->loop->run();
+    }
+}