<?php

namespace Sabre\Event\Loop;

class FunctionsTest extends \PHPUnit_Framework_TestCase {

    function setUp() {

        // Always creating a fresh loop object.
        instance(new Loop());

    }

    function tearDown() {

        // Removing the global loop object.
        instance(null);

    }

    function testNextTick() {

        $check  = 0;
        nextTick(function() use (&$check) {

            $check++;

        });

        run();

        $this->assertEquals(1, $check);

    }

    function testTimeout() {

        $check  = 0;
        setTimeout(function() use (&$check) {

            $check++;

        }, 0.02);

        run();

        $this->assertEquals(1, $check);

    }

    function testTimeoutOrder() {

        $check  = [];
        setTimeout(function() use (&$check) {

            $check[] = 'a';

        }, 0.2);
        setTimeout(function() use (&$check) {

            $check[] = 'b';

        }, 0.1);
        setTimeout(function() use (&$check) {

            $check[] = 'c';

        }, 0.3);

        run();

        $this->assertEquals(['b', 'a', 'c'], $check);

    }

    function testSetInterval() {

        $check = 0;
        $intervalId = null;
        $intervalId = setInterval(function() use (&$check, &$intervalId) {

            $check++;
            if ($check > 5) {
                clearInterval($intervalId);
            }

        }, 0.02);

        run();
        $this->assertEquals(6, $check);

    }

    function testAddWriteStream() {

        $h = fopen('php://temp', 'r+');
        addWriteStream($h, function() use ($h) {

            fwrite($h, 'hello world');
            removeWriteStream($h);

        });
        run();
        rewind($h);
        $this->assertEquals('hello world', stream_get_contents($h));

    }

    function testAddReadStream() {

        $h = fopen('php://temp', 'r+');
        fwrite($h, 'hello world');
        rewind($h);

        $result = null;

        addReadStream($h, function() use ($h, &$result) {

            $result = fgets($h);
            removeReadStream($h);

        });
        run();
        $this->assertEquals('hello world', $result);

    }

    function testStop() {

        $check = 0;
        setTimeout(function() use (&$check) {
            $check++;
        }, 200);

        nextTick(function() {
            stop();
        });
        run();

        $this->assertEquals(0, $check);

    }

    function testTick() {

        $check = 0;
        setTimeout(function() use (&$check) {
            $check++;
        }, 1);

        nextTick(function() use (&$check) {
            $check++;
        });
        tick();

        $this->assertEquals(1, $check);

    }

}