PHP Dosya Yöneticisi

<?php

use Clue\React\Socks\Server;
use React\Promise\Promise;
use React\Promise\Timer\TimeoutException;

class ServerTest extends TestCase
{
    /** @var Server */
    private $server;
    private $connector;

public function setUp()
    {
        $socket = $this->getMockBuilder('React\Socket\ServerInterface')
            ->getMock();

$loop = $this->getMockBuilder('React\EventLoop\LoopInterface')
            ->getMock();

$this->connector = $this->getMockBuilder('React\Socket\ConnectorInterface')
            ->getMock();

$this->server = new Server($loop, $socket, $this->connector);
    }

public function testSetProtocolVersion()
    {
        $this->server->setProtocolVersion(4);
        $this->server->setProtocolVersion('4a');
        $this->server->setProtocolVersion(5);
        $this->server->setProtocolVersion(null);

$this->assertTrue(true);
    }

/**
     * @expectedException InvalidArgumentException
     */
    public function testSetInvalidProtocolVersion()
    {
        $this->server->setProtocolVersion(6);
    }

public function testSetAuthArray()
    {
        $this->server->setAuthArray(array());

$this->server->setAuthArray(array(
            'name1' => 'password1',
            'name2' => 'password2'
        ));

$this->assertTrue(true);
    }

/**
     * @expectedException InvalidArgumentException
     */
    public function testSetAuthInvalid()
    {
        $this->server->setAuth(true);
    }

/**
     * @expectedException UnexpectedValueException
     */
    public function testUnableToSetAuthIfProtocolDoesNotSupportAuth()
    {
        $this->server->setProtocolVersion(4);

$this->server->setAuthArray(array());
    }

/**
     * @expectedException UnexpectedValueException
     */
    public function testUnableToSetProtocolWhichDoesNotSupportAuth()
    {
        $this->server->setAuthArray(array());

// this is okay
        $this->server->setProtocolVersion(5);

$this->server->setProtocolVersion(4);
    }

public function testConnectWillCreateConnection()
    {
        $stream = $this->getMockBuilder('React\Socket\ConnectionInterface')->getMock();

$promise = new Promise(function () { });

$this->connector->expects($this->once())->method('connect')->with('google.com:80')->willReturn($promise);

$promise = $this->server->connectTarget($stream, array('google.com', 80));

$this->assertInstanceOf('React\Promise\PromiseInterface', $promise);
    }

public function testConnectWillCreateConnectionWithSourceUri()
    {
        $stream = $this->getMockBuilder('React\Socket\ConnectionInterface')->getMock();

$promise = new Promise(function () { });

$this->connector->expects($this->once())->method('connect')->with('google.com:80?source=socks5%3A%2F%2F10.20.30.40%3A5060')->willReturn($promise);

$promise = $this->server->connectTarget($stream, array('google.com', 80, 'socks5://10.20.30.40:5060'));

$this->assertInstanceOf('React\Promise\PromiseInterface', $promise);
    }

public function testConnectWillRejectIfConnectionFails()
    {
        $stream = $this->getMockBuilder('React\Socket\ConnectionInterface')->getMock();

$promise = new Promise(function ($_, $reject) { $reject(new \RuntimeException()); });

$this->connector->expects($this->once())->method('connect')->with('google.com:80')->willReturn($promise);

$promise = $this->server->connectTarget($stream, array('google.com', 80));

$promise->then(null, $this->expectCallableOnce());
    }

public function testConnectWillCancelConnectionIfStreamCloses()
    {
        $stream = $this->getMockBuilder('React\Socket\Connection')->disableOriginalConstructor()->setMethods(array('close'))->getMock();

$promise = new Promise(function () { }, function () {
            throw new \RuntimeException();
        });

$this->connector->expects($this->once())->method('connect')->with('google.com:80')->willReturn($promise);

$promise = $this->server->connectTarget($stream, array('google.com', 80));

$stream->emit('close');

$promise->then(null, $this->expectCallableOnce());
    }

public function testConnectWillAbortIfPromiseIsCanceled()
    {
        $stream = $this->getMockBuilder('React\Socket\ConnectionInterface')->getMock();

$promise = new Promise(function () { }, function () {
            throw new \RuntimeException();
        });

$this->connector->expects($this->once())->method('connect')->with('google.com:80')->willReturn($promise);

$promise = $this->server->connectTarget($stream, array('google.com', 80));

$promise->cancel();

$promise->then(null, $this->expectCallableOnce());
    }

public function provideConnectionErrors()
    {
        return array(
            array(
                new RuntimeException('', SOCKET_EACCES),
                Server::ERROR_NOT_ALLOWED_BY_RULESET
            ),
            array(
                new RuntimeException('', SOCKET_ENETUNREACH),
                Server::ERROR_NETWORK_UNREACHABLE
            ),
            array(
                new RuntimeException('', SOCKET_EHOSTUNREACH),
                Server::ERROR_HOST_UNREACHABLE,
            ),
            array(
                new RuntimeException('', SOCKET_ECONNREFUSED),
                Server::ERROR_CONNECTION_REFUSED
            ),
            array(
                new RuntimeException('Connection refused'),
                Server::ERROR_CONNECTION_REFUSED
            ),
            array(
                new RuntimeException('', SOCKET_ETIMEDOUT),
                Server::ERROR_TTL
            ),
            array(
                new TimeoutException(1.0),
                Server::ERROR_TTL
            ),
            array(
                new RuntimeException(),
                Server::ERROR_GENERAL
            )
        );
    }

/**
     * @dataProvider provideConnectionErrors
     * @param Exception $error
     * @param int       $expectedCode
     */
    public function testConnectWillReturnMappedSocks5ErrorCodeFromConnector($error, $expectedCode)
    {
        $stream = $this->getMockBuilder('React\Socket\ConnectionInterface')->getMock();

$promise = \React\Promise\reject($error);

$this->connector->expects($this->once())->method('connect')->willReturn($promise);

$promise = $this->server->connectTarget($stream, array('google.com', 80));

$code = null;
        $promise->then(null, function ($error) use (&$code) {
            $code = $error->getCode();
        });

$this->assertEquals($expectedCode, $code);
    }

public function testHandleSocksConnectionWillEndOnInvalidData()
    {
        $connection = $this->getMockBuilder('React\Socket\Connection')->disableOriginalConstructor()->setMethods(array('pause', 'end'))->getMock();
        $connection->expects($this->once())->method('pause');
        $connection->expects($this->once())->method('end');