aboutsummaryrefslogtreecommitdiffhomepage
path: root/assets/php/vendor/react/socket/tests/ServerTest.php
diff options
context:
space:
mode:
Diffstat (limited to 'assets/php/vendor/react/socket/tests/ServerTest.php')
-rwxr-xr-xassets/php/vendor/react/socket/tests/ServerTest.php173
1 files changed, 0 insertions, 173 deletions
diff --git a/assets/php/vendor/react/socket/tests/ServerTest.php b/assets/php/vendor/react/socket/tests/ServerTest.php
deleted file mode 100755
index 14fdb2c..0000000
--- a/assets/php/vendor/react/socket/tests/ServerTest.php
+++ /dev/null
@@ -1,173 +0,0 @@
-<?php
-
-namespace React\Tests\Socket;
-
-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 testCreateServerWithZeroPortAssignsRandomPort()
- {
- $loop = Factory::create();
-
- $server = new Server(0, $loop);
- $this->assertNotEquals(0, $server->getAddress());
- $server->close();
- }
-
- /**
- * @expectedException InvalidArgumentException
- */
- public function testConstructorThrowsForInvalidUri()
- {
- $loop = $this->getMockBuilder('React\EventLoop\LoopInterface')->getMock();
-
- $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();
-
- $server = new Server(0, $loop);
- $server->on('connection', $this->expectCallableOnce());
-
- $client = stream_socket_client($server->getAddress());
-
- Block\sleep(0.1, $loop);
- }
-
- public function testDoesNotEmitConnectionForNewConnectionToPausedServer()
- {
- $loop = Factory::create();
-
- $server = new Server(0, $loop);
- $server->pause();
- $server->on('connection', $this->expectCallableNever());
-
- $client = stream_socket_client($server->getAddress());
-
- Block\sleep(0.1, $loop);
- }
-
- public function testDoesEmitConnectionForNewConnectionToResumedServer()
- {
- $loop = Factory::create();
-
- $server = new Server(0, $loop);
- $server->pause();
- $server->on('connection', $this->expectCallableOnce());
-
- $client = stream_socket_client($server->getAddress());
-
- Block\sleep(0.1, $loop);
-
- $server->resume();
- Block\sleep(0.1, $loop);
- }
-
- public function testDoesNotAllowConnectionToClosedServer()
- {
- $loop = Factory::create();
-
- $server = new Server(0, $loop);
- $server->on('connection', $this->expectCallableNever());
- $address = $server->getAddress();
- $server->close();
-
- $client = @stream_socket_client($address);
-
- Block\sleep(0.1, $loop);
-
- $this->assertFalse($client);
- }
-
- public function testEmitsConnectionWithInheritedContextOptions()
- {
- if (defined('HHVM_VERSION') && version_compare(HHVM_VERSION, '3.13', '<')) {
- // https://3v4l.org/hB4Tc
- $this->markTestSkipped('Not supported on legacy HHVM < 3.13');
- }
-
- $loop = Factory::create();
-
- $server = new Server(0, $loop, array(
- 'backlog' => 4
- ));
-
- $all = null;
- $server->on('connection', function (ConnectionInterface $conn) use (&$all) {
- $all = stream_context_get_options($conn->stream);
- });
-
- $client = stream_socket_client($server->getAddress());
-
- Block\sleep(0.1, $loop);
-
- $this->assertEquals(array('socket' => array('backlog' => 4)), $all);
- }
-
- public function testDoesNotEmitSecureConnectionForNewPlainConnection()
- {
- if (!function_exists('stream_socket_enable_crypto')) {
- $this->markTestSkipped('Not supported on your platform (outdated HHVM?)');
- }
-
- $loop = Factory::create();
-
- $server = new Server('tls://127.0.0.1:0', $loop, array(
- 'tls' => array(
- 'local_cert' => __DIR__ . '/../examples/localhost.pem'
- )
- ));
- $server->on('connection', $this->expectCallableNever());
-
- $client = stream_socket_client(str_replace('tls://', '', $server->getAddress()));
-
- Block\sleep(0.1, $loop);
- }
-
- private function getRandomSocketUri()
- {
- return "unix://" . sys_get_temp_dir() . DIRECTORY_SEPARATOR . uniqid(rand(), true) . '.sock';
- }
-}