TBolier\RethinkQL\UnitTest\Connection\Socket\HandshakeTest

Complexity

Total Complexity

6

Size/Duplication

Total Lines	94
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	3	1
A	testExceptionThrownOnInvalidProtocolVersion()	0	10	1
A	testExceptionThrownOnError()	0	9	1
A	testExceptionThrownOnVerifyProtocolWithError()	0	9	1
A	testExceptionThrownOnProtocolError()	0	10	1
A	testExceptionThrownOnStreamNotWritable()	0	7	1

<?php
declare(strict_types = 1);

namespace TBolier\RethinkQL\UnitTest\Connection\Socket;

use Mockery\MockInterface;
use TBolier\RethinkQL\Connection\Socket\Handshake;
use TBolier\RethinkQL\UnitTest\BaseUnitTestCase;
use Psr\Http\Message\StreamInterface;

class HandshakeTest extends BaseUnitTestCase
{
    /**
     * @var Handshake
     */
    private $handshake;

    /**
     * @return void
     */
    public function setUp(): void
    {
        $this->handshake = new Handshake('foo', 'bar', 42);
    }

    /**
     * @expectedException \TBolier\RethinkQL\Connection\Socket\Exception
     * @expectedExceptionMessage Not connected
     * @return void
     */
    public function testExceptionThrownOnStreamNotWritable(): void
    {
        $stream = \Mockery::mock(StreamInterface::class);
        $stream->shouldReceive('isWritable')->atLeast()->andReturn(false);
        $stream->shouldReceive('close');

        $this->handshake->hello($stream);

$stream of type Mockery\LegacyMockInterface|Mockery\MockInterface is incompatible with the type Psr\Http\Message\StreamInterface expected by parameter $stream of TBolier\RethinkQL\Connection\Socket\Handshake::hello().

    }

    /**
     * @expectedException \TBolier\RethinkQL\Connection\Socket\Exception
     * @expectedExceptionMessage Foobar
     * @return void
     */
    public function testExceptionThrownOnError(): void
    {
        $stream = \Mockery::mock(StreamInterface::class);
        $stream->shouldReceive('isWritable')->atLeast()->andReturn(true);
        $stream->shouldReceive('close');
        $stream->shouldReceive('write');
        $stream->shouldReceive('getContents')->atLeast()->andReturn('ERROR: Foobar');

        $this->handshake->hello($stream);

$stream of type Mockery\LegacyMockInterface|Mockery\MockInterface is incompatible with the type Psr\Http\Message\StreamInterface expected by parameter $stream of TBolier\RethinkQL\Connection\Socket\Handshake::hello().

    }

    /**
     * @expectedException \TBolier\RethinkQL\Connection\Socket\Exception
     * @expectedExceptionMessage Foobar
     * @return void
     */
    public function testExceptionThrownOnVerifyProtocolWithError(): void
    {
        $stream = \Mockery::mock(StreamInterface::class);
        $stream->shouldReceive('isWritable')->atLeast()->andReturn(true);
        $stream->shouldReceive('close');
        $stream->shouldReceive('write');
        $stream->shouldReceive('getContents')->atLeast()->andReturn('{"success":false, "error": "Foobar"}');

        $this->handshake->hello($stream);

$stream of type Mockery\LegacyMockInterface|Mockery\MockInterface is incompatible with the type Psr\Http\Message\StreamInterface expected by parameter $stream of TBolier\RethinkQL\Connection\Socket\Handshake::hello().

    }

    /**
     * @expectedException \TBolier\RethinkQL\Connection\Socket\Exception
     * @expectedExceptionMessage Unsupported protocol version.
     * @return void
     */
    public function testExceptionThrownOnInvalidProtocolVersion(): void
    {
        $stream = \Mockery::mock(StreamInterface::class);
        $stream->shouldReceive('isWritable')->atLeast()->andReturn(true);
        $stream->shouldReceive('close');
        $stream->shouldReceive('write');
        $stream->shouldReceive('getContents')->atLeast()
            ->andReturn('{"success":true, "max_protocol_version": 1, "min_protocol_version": 1}');

        $this->handshake->hello($stream);

$stream of type Mockery\LegacyMockInterface|Mockery\MockInterface is incompatible with the type Psr\Http\Message\StreamInterface expected by parameter $stream of TBolier\RethinkQL\Connection\Socket\Handshake::hello().

    }


    /**
     * @expectedException \TBolier\RethinkQL\Connection\Socket\Exception
     * @expectedExceptionMessage Woops!
     * @return void
     */
    public function testExceptionThrownOnProtocolError(): void
    {
        /** @var MockInterface $stream */
        $stream = \Mockery::mock(StreamInterface::class);
        $stream->shouldReceive('isWritable')->atLeast()->andReturn(true);
        $stream->shouldReceive('close');
        $stream->shouldReceive('write');
        $stream->shouldReceive('getContents')->atLeast()->andReturn('ERROR: Woops!');

        $this->handshake->hello($stream);
    }
}