Subversion Repositories php-qbpwcf

<?php

namespace React\Tests\Socket;

use React\Socket\Connection;

use React\Socket\Server;

use React\EventLoop\StreamSelectLoop;

class ConnectionTest extends TestCase

{

    /**

     * @covers React\Socket\Connection::getRemoteAddress

     */

    public function testGetRemoteAddress()

    {

        $loop   = new StreamSelectLoop();

        $server = new Server($loop);

        $server->listen(0);

        $class  = new \ReflectionClass('React\\Socket\\Server');

        $master = $class->getProperty('master');

        $master->setAccessible(true);

        $client = stream_socket_client('tcp://localhost:' . $server->getPort());

        $class  = new \ReflectionClass('React\\Socket\\Connection');

        $method = $class->getMethod('parseAddress');

        $method->setAccessible(true);

        $servConn = new Connection($server->master, $loop);

        $mock = $this->createCallableMock();

        $mock

            ->expects($this->once())

            ->method('__invoke')

            ->with($method->invokeArgs($servConn, array(stream_socket_get_name($master->getValue($server), false))))

        ;

        $server->on('connection', function ($conn) use ($mock) {

            $mock($conn->getRemoteAddress());

        });

        $loop->tick();

    }

    public function remoteAddressProvider()

    {

        return array(

            array('192.168.1.120', '192.168.1.120:12345')

          , array('9999:0000:aaaa:bbbb:cccc:dddd:eeee:ffff', '[9999:0000:aaaa:bbbb:cccc:dddd:eeee:ffff]:12345')

          , array('10.0.0.1', '10.0.0.1:80')

        );

    }

    /**

     * @dataProvider remoteAddressProvider

     * @covers React\Socket\Connection::parseAddress

     */

    public function testParseAddress($expected, $given)

    {

        $class  = new \ReflectionClass('React\\Socket\\Connection');

        $method = $class->getMethod('parseAddress');

        $method->setAccessible(true);

        $socket = fopen('php://temp', 'r');

        $loop   = $this->createLoopMock();

        $conn = new Connection($socket, $loop);

        $result = $method->invokeArgs($conn, array($given));

        $this->assertEquals($expected, $result);

    }

    private function createLoopMock()

    {

        return $this->getMock('React\EventLoop\LoopInterface');

    }

}