ConnectionManagerDelayTest.php

<?php

namespace ConnectionManager\Tests\Extra;

use ConnectionManager\Extra\ConnectionManagerDelay;
use React\EventLoop\Loop;

class ConnectionManagerDelayTest extends TestCase
{
    private $loop;

    /**
     * @before
     */
    public function setUpLoop()
    {
        $this->loop = Loop::get();
    }

    public function testConstructWithoutLoopAssignsLoopAutomatically()
    {
        $unused = $this->getMockBuilder('React\Socket\ConnectorInterface')->getMock();
        $cm = new ConnectionManagerDelay($unused, 0);

        $ref = new \ReflectionProperty($cm, 'loop');
        if (PHP_VERSION_ID < 80100) {
            $ref->setAccessible(true);
        }
        $loop = $ref->getValue($cm);

        $this->assertInstanceOf('React\EventLoop\LoopInterface', $loop);
    }

    public function testContructorThrowsExceptionForInvalidLoop()
    {
        $unused = $this->getMockBuilder('React\Socket\ConnectorInterface')->getMock();

        $this->setExpectedException('InvalidArgumentException', 'Argument #3 ($loop) expected null|React\EventLoop\LoopInterface');
        new ConnectionManagerDelay($unused, 0, 'loop');
    }

    public function testDelayTenth()
    {
        $will = $this->createConnectionManagerMock(true);
        $cm = new ConnectionManagerDelay($will, 0.1, $this->loop);

        $promise = $cm->connect('www.google.com:80');
        $this->assertInstanceOf('React\Promise\PromiseInterface', $promise);

        Loop::run();
        $promise->then($this->expectCallableOnce(), $this->expectCallableNever());
    }

    public function testCancellationOfPromiseBeforeDelayDoesNotStartConnection()
    {
        $unused = $this->getMockBuilder('React\Socket\ConnectorInterface')->getMock();
        $unused->expects($this->never())->method('connect');

        $cm = new ConnectionManagerDelay($unused, 1.0, $this->loop);

        $promise = $cm->connect('www.google.com:80');
        $promise->cancel();

        Loop::run();
    }
}