Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
Stub	[ DIR ]	drwxr-xr-x	2018-10-01 09:00
ConnectionTest.php	1.49 KB	-rw-r--r--	2018-10-01 09:00
ConnectorTest.php	4.42 KB	-rw-r--r--	2018-10-01 09:00
DnsConnectorTest.php	12.58 KB	-rw-r--r--	2018-10-01 09:00
FixedUriConnectorTest.php	525 B	-rw-r--r--	2018-10-01 09:00
FunctionalConnectorTest.php	809 B	-rw-r--r--	2018-10-01 09:00
FunctionalSecureServerTest.php	19.72 KB	-rw-r--r--	2018-10-01 09:00
FunctionalTcpServerTest.php	8.95 KB	-rw-r--r--	2018-10-01 09:00
IntegrationTest.php	11.36 KB	-rw-r--r--	2018-10-01 09:00
LimitingServerTest.php	6.03 KB	-rw-r--r--	2018-10-01 09:00
SecureConnectorTest.php	8.72 KB	-rw-r--r--	2018-10-01 09:00
SecureIntegrationTest.php	6.67 KB	-rw-r--r--	2018-10-01 09:00
SecureServerTest.php	3.24 KB	-rw-r--r--	2018-10-01 09:00
ServerTest.php	5.74 KB	-rw-r--r--	2018-10-01 09:00
TcpConnectorTest.php	8.74 KB	-rw-r--r--	2018-10-01 09:00
TcpServerTest.php	7.72 KB	-rw-r--r--	2018-10-01 09:00
TestCase.php	2.66 KB	-rw-r--r--	2018-10-01 09:00
TimeoutConnectorTest.php	4.99 KB	-rw-r--r--	2018-10-01 09:00
UnixConnectorTest.php	1.91 KB	-rw-r--r--	2018-10-01 09:00
UnixServerTest.php	7.86 KB	-rw-r--r--	2018-10-01 09:00

Rename

<?php

namespace React\Tests\Socket;

use React\EventLoop\Factory as LoopFactory;
use React\Socket\TcpServer;
use React\Socket\SecureServer;
use React\Socket\TcpConnector;
use React\Socket\SecureConnector;
use Clue\React\Block;
use React\Promise\Promise;
use Evenement\EventEmitterInterface;
use React\Promise\Deferred;
use React\Socket\ConnectionInterface;

class SecureIntegrationTest extends TestCase
{
    const TIMEOUT = 0.5;

private $loop;
    private $server;
    private $connector;
    private $address;

public function setUp()
    {
        if (!function_exists('stream_socket_enable_crypto')) {
            $this->markTestSkipped('Not supported on your platform (outdated HHVM?)');
        }

$this->loop = LoopFactory::create();
        $this->server = new TcpServer(0, $this->loop);
        $this->server = new SecureServer($this->server, $this->loop, array(
            'local_cert' => __DIR__ . '/../examples/localhost.pem'
        ));
        $this->address = $this->server->getAddress();
        $this->connector = new SecureConnector(new TcpConnector($this->loop), $this->loop, array('verify_peer' => false));
    }

public function tearDown()
    {
        if ($this->server !== null) {
            $this->server->close();
            $this->server = null;
        }
    }

public function testConnectToServer()
    {
        $client = Block\await($this->connector->connect($this->address), $this->loop, self::TIMEOUT);
        /* @var $client ConnectionInterface */

$client->close();

// if we reach this, then everything is good
        $this->assertNull(null);
    }

public function testConnectToServerEmitsConnection()
    {
        $promiseServer = $this->createPromiseForEvent($this->server, 'connection', $this->expectCallableOnce());

$promiseClient = $this->connector->connect($this->address);

list($_, $client) = Block\awaitAll(array($promiseServer, $promiseClient), $this->loop, self::TIMEOUT);
        /* @var $client ConnectionInterface */

$client->close();
    }

public function testSendSmallDataToServerReceivesOneChunk()
    {
        // server expects one connection which emits one data event
        $received = new Deferred();
        $this->server->on('connection', function (ConnectionInterface $peer) use ($received) {
            $peer->on('data', function ($chunk) use ($received) {
                $received->resolve($chunk);
            });
        });