Test creation of appropriate server types

reactphp · Nov 9, 2017 · ea2b0c7 · ea2b0c7
1 parent b672499
commit ea2b0c7
Show file tree

Hide file tree

Showing 2 changed files with 42 additions and 1 deletion.
diff --git a/src/Server.php b/src/Server.php
@@ -20,7 +20,7 @@ public function __construct($uri, LoopInterface $loop, array $context = array())
         $context += array(
             'tcp' => array(),
             'tls' => array(),
-            'unix' => array(),
+            'unix' => array()
         );
 
         $scheme = 'tcp';

diff --git a/tests/ServerTest.php b/tests/ServerTest.php
@@ -4,11 +4,15 @@
 
 use React\EventLoop\Factory;
 use React\Socket\Server;
+use React\Socket\TcpConnector;
+use React\Socket\UnixConnector;
 use Clue\React\Block;
 use React\Socket\ConnectionInterface;
 
 class ServerTest extends TestCase
 {
+    const TIMEOUT = 0.1;
+
     public function testCreateServer()
     {
         $loop = Factory::create();
@@ -26,6 +30,38 @@ public function testConstructorThrowsForInvalidUri()
         $server = new Server('invalid URI', $loop);
     }
 
+    public function testConstructorCreatesExpectedTcpServer()
+    {
+        $loop = Factory::create();
+
+        $server = new Server(0, $loop);
+
+        $connector = new TcpConnector($loop);
+        $connector->connect($server->getAddress())
+            ->then($this->expectCallableOnce(), $this->expectCallableNever());
+
+        $connection = Block\await($connector->connect($server->getAddress()), $loop, self::TIMEOUT);
+
+        $connection->close();
+        $server->close();
+    }
+
+    public function testConstructorCreatesExpectedUnixServer()
+    {
+        $loop = Factory::create();
+
+        $server = new Server($this->getRandomSocketUri(), $loop);
+
+        $connector = new UnixConnector($loop);
+        $connector->connect($server->getAddress())
+            ->then($this->expectCallableOnce(), $this->expectCallableNever());
+
+        $connection = Block\await($connector->connect($server->getAddress()), $loop, self::TIMEOUT);
+
+        $connection->close();
+        $server->close();
+    }
+
     public function testEmitsConnectionForNewConnection()
     {
         $loop = Factory::create();
@@ -127,4 +163,9 @@ public function testDoesNotEmitSecureConnectionForNewPlainConnection()
 
         Block\sleep(0.1, $loop);
     }
+
+    private function getRandomSocketUri()
+    {
+        return "unix://" . sys_get_temp_dir() . DIRECTORY_SEPARATOR . uniqid(rand(), true) . '.sock';
+    }
 }