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 Clue\React\Block;
use React\Dns\Resolver\Factory as ResolverFactory;
use React\EventLoop\Factory;
use React\Socket\Connector;
use React\Socket\DnsConnector;
use React\Socket\SecureConnector;
use React\Socket\TcpConnector;

/** @group internet */
class IntegrationTest extends TestCase
{
    const TIMEOUT = 5.0;

/** @test */
    public function gettingStuffFromGoogleShouldWork()
    {
        $loop = Factory::create();
        $connector = new Connector($loop);

$conn = Block\await($connector->connect('google.com:80'), $loop);

$this->assertContains(':80', $conn->getRemoteAddress());
        $this->assertNotEquals('google.com:80', $conn->getRemoteAddress());

$conn->write("GET / HTTP/1.0\r\n\r\n");

$response = $this->buffer($conn, $loop, self::TIMEOUT);

$this->assertRegExp('#^HTTP/1\.0#', $response);
    }

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

$loop = Factory::create();
        $secureConnector = new Connector($loop);

$conn = Block\await($secureConnector->connect('tls://google.com:443'), $loop);

$conn->write("GET / HTTP/1.0\r\n\r\n");

$response = $this->buffer($conn, $loop, self::TIMEOUT);

$this->assertRegExp('#^HTTP/1\.0#', $response);
    }

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

$loop = Factory::create();

$factory = new ResolverFactory();
        $dns = $factory->create('8.8.8.8', $loop);

$connector = new DnsConnector(
            new SecureConnector(
                new TcpConnector($loop),
                $loop
            ),
            $dns
        );

$conn = Block\await($connector->connect('google.com:443'), $loop);

$conn->write("GET / HTTP/1.0\r\n\r\n");

$response = $this->buffer($conn, $loop, self::TIMEOUT);

$this->assertRegExp('#^HTTP/1\.0#', $response);
    }

/** @test */
    public function gettingPlaintextStuffFromEncryptedGoogleShouldNotWork()
    {
        $loop = Factory::create();
        $connector = new Connector($loop);

$conn = Block\await($connector->connect('google.com:443'), $loop);

$this->assertContains(':443', $conn->getRemoteAddress());
        $this->assertNotEquals('google.com:443', $conn->getRemoteAddress());

$conn->write("GET / HTTP/1.0\r\n\r\n");

$response = $this->buffer($conn, $loop, self::TIMEOUT);

$this->assertNotRegExp('#^HTTP/1\.0#', $response);
    }

public function testConnectingFailsIfDnsUsesInvalidResolver()
    {
        $loop = Factory::create();

$factory = new ResolverFactory();
        $dns = $factory->create('demo.invalid', $loop);

$connector = new Connector($loop, array(
            'dns' => $dns
        ));

$this->setExpectedException('RuntimeException');
        Block\await($connector->connect('google.com:80'), $loop, self::TIMEOUT);
    }

public function testCancellingPendingConnectionWithoutTimeoutShouldNotCreateAnyGarbageReferences()
    {
        if (class_exists('React\Promise\When')) {
            $this->markTestSkipped('Not supported on legacy Promise v1 API');
        }

$loop = Factory::create();
        $connector = new Connector($loop, array('timeout' => false));

gc_collect_cycles();
        $promise = $connector->connect('8.8.8.8:80');
        $promise->cancel();
        unset($promise);