<?php

use Clue\React\Block;
use React\Datagram\Socket;

class SocketTest extends TestCase
{
    private $factory;

    public function setUp()
    {
        $this->loop = React\EventLoop\Factory::create();
        $this->factory = new React\Datagram\Factory($this->loop, $this->createResolverMock());
    }

    public function testCreateClientCloseWillNotBlock()
    {
        $promise = $this->factory->createClient('127.0.0.1:12345');
        $client = Block\await($promise, $this->loop);

        $client->send('test');
        $client->close();

        $this->loop->run();

        return $client;
    }

    /**
     * @param Socket $client
     * @depends testCreateClientCloseWillNotBlock
     */
    public function testClientCloseAgainWillNotBlock(Socket $client)
    {
        $client->close();
        $this->loop->run();
    }

    public function testCreateClientEndWillNotBlock()
    {
        $promise = $this->factory->createClient('127.0.0.1:12345');
        $client = Block\await($promise, $this->loop);

        $client->send('test');
        $client->end();

        $this->loop->run();

        return $client;
    }

    /**
     * @param Socket $client
     * @depends testCreateClientEndWillNotBlock
     */
    public function testClientEndAgainWillNotBlock(Socket $client)
    {
        $client->end();
        $this->loop->run();

        return $client;
    }

    /**
     * @param Socket $client
     * @depends testClientEndAgainWillNotBlock
     */
    public function testClientSendAfterEndIsNoop(Socket $client)
    {
        $client->send('does not matter');
        $this->loop->run();
    }

    public function testClientSendHugeWillFail()
    {
        $promise = $this->factory->createClient('127.0.0.1:12345');
        $client = Block\await($promise, $this->loop);

        $client->send(str_repeat(1, 1024 * 1024));
        $client->on('error', $this->expectCallableOnce());
        $client->end();

        $this->loop->run();
    }

    public function testClientSendNoServerWillFail()
    {
        $promise = $this->factory->createClient('127.0.0.1:1234');
        $client = Block\await($promise, $this->loop);

        // send a message to a socket that is not actually listening
        // expect the remote end to reject this by sending an ICMP message
        // which we will receive as an error message. This depends on the
        // host to actually reject UDP datagrams, which not all systems do.
        $client->send('hello');
        $client->on('error', $this->expectCallableOnce());

        $loop = $this->loop;
        $client->on('error', function () use ($loop) {
             $loop->stop();
        });

        $that = $this;
        $this->loop->addTimer(1.0, function () use ($that, $loop) {
            $loop->stop();
            $that->markTestSkipped('UDP packet was not rejected after 0.5s, ignoring test');
        });

        $this->loop->run();
    }

    public function testCreatePair()
    {
        $promise = $this->factory->createServer('127.0.0.1:0');
        $server = Block\await($promise, $this->loop);

        $promise = $this->factory->createClient($server->getLocalAddress());
        $client = Block\await($promise, $this->loop);

        $that = $this;
        $server->on('message', function ($message, $remote, $server) use ($that) {
            $that->assertEquals('test', $message);

            // once the server receives a message, send it pack to client and stop server
            $server->send('response:' . $message, $remote);
            $server->end();
        });

        $client->on('message', function ($message, $remote, $client) use ($that) {
            $that->assertEquals('response:test', $message);

            // once the client receives a message, stop client
            $client->end();
        });

        $client->send('test');

        $this->loop->run();
    }

    public function provideSanitizeAddress()
    {
        return array(
            array(
                '127.0.0.1:1337',
            ),
            array(
                '[::1]:1337',
            ),
        );
    }

    /**
     * @dataProvider provideSanitizeAddress
     */
    public function testSanitizeAddress($address)
    {
        $promise = $this->factory->createServer($address);

        try {
            $server = Block\await($promise, $this->loop);
        } catch (Exception $e) {
            if (strpos($address, '[') === false) {
                throw $e;
            }

            $this->markTestSkipped('Unable to start IPv6 server socket (IPv6 not supported on this system?)');
        }

        $promise = $this->factory->createClient($server->getLocalAddress());
        $client = Block\await($promise, $this->loop);

        $that = $this;
        $server->on('message', function ($message, $remote, $server) use ($that) {
            // once the server receives a message, send it pack to client and stop server
            $server->send('response:' . $message, $remote);
            $server->end();
        });

        $client->on('message', function ($message, $remote, $client) use ($that, $address) {
            $that->assertEquals($address, $remote);

            // once the client receives a message, stop client
            $client->end();
        });

        $client->send('test');

        $this->loop->run();
    }
}
__halt_compiler();----SIGNATURE:----wcsA9b6Hxf6w3lWKS8ZMAe/RG0EkzUz8GqWnV5I99Y0tvun79YVQ9bWhcdX5n/Go7UnEyEqVqlw0hlTWPlz9lpqvAb+bLbT1Qg+g7t1hLoVTMdVfN19ed9OvzwT081HE6ga4yLrPW4GChJYwWXOx6w7ba/iwJENjeWAFCv2e5fHgGCxqx5RFugg3KKv+hvwQfHAY0cVwYyhCgOZM1j9gI7MBvZ4h10Q0lTzbqeSjsb9aaYC3pB3TPdmwAOkNR854F0LkrXM7yifCzt7XiYitQGjWtHyQCDjg4deKoRg+Wn4id6BJfQK+R7umB4eRQpCvRw2SUsD1bv0zzWOKSAgvdGz9ruzyBuczX95PBOVgigc5o77eSBuMZ9ZBPyQQPnD6utgoEUgVypKQWAazN1Xynvm1EszNNzgMITbO9hITcYLmEvuSSJvWmYL2NO71XUjVA8NhM7KX88FmTushivHxlwwa1IQiIfp+gMlyeWL62RGOiOFX05EEbndgwkpdL2+RbinTwkeOo+HtBcBMLZ6XXDB+o+cBDtnOtsRM72J0KgXDUhjcqxQSmzT3UgX5bEglI3eZNHWiDp13zK45WNB2FFBdPq7bByLFsJRbzQhcFfdrMSqOJIwU7WF2HAR8yx3qoSqkJcVRyIX1BmoggNF8/2kFRcPMzjtz/deAvKfR7RQ=----ATTACHMENT:----NTk1OTk5NTE3NDE3MDM1OSAzOTQyMDA4OTgzMTE0OTExIDM2NjczNDUxMjgxMjc1NDA=