<?php

namespace Tests\Clue\React\HttpProxy;

use React\EventLoop\Factory;
use Clue\React\HttpProxy\ProxyConnector;
use React\Socket\TcpConnector;
use React\Socket\DnsConnector;
use Clue\React\Block;
use React\Socket\SecureConnector;

/** @group internet */
class FunctionalTest extends AbstractTestCase
{
    private $loop;
    private $tcpConnector;
    private $dnsConnector;

    public function setUp()
    {
        $this->loop = Factory::create();

        $this->tcpConnector = new TcpConnector($this->loop);

        $f = new \React\Dns\Resolver\Factory();
        $resolver = $f->create('8.8.8.8', $this->loop);

        $this->dnsConnector = new DnsConnector($this->tcpConnector, $resolver);
    }

    public function testNonListeningSocketRejectsConnection()
    {
        $proxy = new ProxyConnector('127.0.0.1:9999', $this->dnsConnector);

        $promise = $proxy->connect('google.com:80');

        $this->setExpectedException('RuntimeException', 'Unable to connect to proxy', SOCKET_ECONNREFUSED);
        Block\await($promise, $this->loop, 3.0);
    }

    public function testPlainGoogleDoesNotAcceptConnectMethod()
    {
        $proxy = new ProxyConnector('google.com', $this->dnsConnector);

        $promise = $proxy->connect('google.com:80');

        $this->setExpectedException('RuntimeException', '405 (Method Not Allowed)', SOCKET_ECONNREFUSED);
        Block\await($promise, $this->loop, 3.0);
    }

    public function testSecureGoogleDoesNotAcceptConnectMethod()
    {
        if (!function_exists('stream_socket_enable_crypto')) {
            $this->markTestSkipped('TLS not supported on really old platforms (HHVM < 3.8)');
        }

        $secure = new SecureConnector($this->dnsConnector, $this->loop);
        $proxy = new ProxyConnector('https://google.com:443', $secure);

        $promise = $proxy->connect('google.com:80');

        $this->setExpectedException('RuntimeException', '405 (Method Not Allowed)', SOCKET_ECONNREFUSED);
        Block\await($promise, $this->loop, 3.0);
    }

    public function testSecureGoogleDoesNotAcceptPlainStream()
    {
        $proxy = new ProxyConnector('google.com:443', $this->dnsConnector);

        $promise = $proxy->connect('google.com:80');

        $this->setExpectedException('RuntimeException', 'Connection to proxy lost', SOCKET_ECONNRESET);
        Block\await($promise, $this->loop, 3.0);
    }
}