Equip\Queue\WorkerTest

Complexity

Total Complexity

10

Size/Duplication

Total Lines	204
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes	4
Bugs	0	Features	4

10 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	7	1
A	testGetHandler()	0	12	1
A	testGetHandlerNotCallable()	0	15	1
A	testGetHandlerNoHandler()	0	5	1
A	testTickPacketNull()	0	12	1
A	testTickInvalidHandler()	0	17	1
B	testTickHandlerException()	0	26	1
B	testTickHandlerReturnFalse()	0	25	1
B	testTick()	0	29	1
B	testConsume()	0	24	1

<?php

namespace Equip\Queue;

use Equip\Queue\Driver\DriverInterface;
use Equip\Queue\Exception\HandlerException;
use Equip\Queue\Serializer\JsonSerializer;
use Equip\Queue\Serializer\MessageSerializerInterface;
use Exception;

class WorkerTest extends TestCase
{
    /**
     * @var DriverInterface
     */
    private $driver;

    /**
     * @var Event
     */
    private $event;

    /**
     * @var MessageSerializerInterface
     */
    private $serializer;

    /**
     * @var Worker
     */
    private $worker;

    protected function setUp()
    {
        $this->driver = $this->createMock(DriverInterface::class);

It seems like $this->createMock(\Equip\Queue\Driver\DriverInterface::class) of type object<PHPUnit_Framework_MockObject_MockObject> is incompatible with the declared type object<Equip\Queue\Driver\DriverInterface> of property $driver.

        $this->event = $this->createMock(Event::class);

It seems like $this->createMock(\Equip\Queue\Event::class) of type object<PHPUnit_Framework_MockObject_MockObject> is incompatible with the declared type object<Equip\Queue\Event> of property $event.

        $this->serializer = new JsonSerializer;
        $this->worker = new Worker($this->driver, $this->event);
    }

    public function testGetHandler()
    {
        $name = 'test';
        $routes = [
            $name => function () {},
        ];

        $method = static::getProtectedMethod($this->worker, 'getHandler');
        $result = $method->invoke($this->worker, $name, $routes);

        $this->assertSame($routes[$name], $result);
    }

    public function testGetHandlerNotCallable()
    {
        $this->setExpectedExceptionRegExp(
            HandlerException::class,
            '/The handler for `test` is invalid./'
        );

        $name = 'test';
        $routes = [
            $name => 'test',
        ];

        $method = static::getProtectedMethod($this->worker, 'getHandler');
        $method->invoke($this->worker, $name, $routes);
    }

    public function testGetHandlerNoHandler()
    {
        $method = static::getProtectedMethod($this->worker, 'getHandler');
        $this->assertNull($method->invoke($this->worker, 'test', []));
    }

    public function testTickPacketNull()
    {
        $queue = 'test-queue';
        $this->driver

The method expects() does not seem to exist on object<Equip\Queue\Driver\DriverInterface>.

            ->expects($this->once())
            ->method('pop')
            ->with($queue)
            ->willReturn(null);

        $method = static::getProtectedMethod($this->worker, 'tick');
        $this->assertTrue($method->invoke($this->worker, $queue));
    }

    public function testTickInvalidHandler()
    {
        $message = [
            'queue' => 'test-queue',
            'handler' => 'foo',
            'data' => ['foo' => 'bar'],
        ];

        $this->driver

The method expects() does not seem to exist on object<Equip\Queue\Driver\DriverInterface>.

            ->expects($this->once())
            ->method('pop')
            ->with($message['queue'])
            ->willReturn(json_encode($message));

        $method = static::getProtectedMethod($this->worker, 'tick');
        $this->assertTrue($method->invoke($this->worker, $message['queue']));
    }

    public function testTickHandlerException()
    {
        $message = new Message('queue', 'foo', ['foo' => 'bar']);
        $exception = new Exception;

        $this->driver

The method expects() does not seem to exist on object<Equip\Queue\Driver\DriverInterface>.

            ->expects($this->once())
            ->method('pop')
            ->with($message->queue())
            ->willReturn($this->serializer->serialize($message));

        $this->event

The method expects() does not seem to exist on object<Equip\Queue\Event>.

            ->expects($this->once())
            ->method('reject')
            ->with($message, $exception);

        $worker = new Worker(
            $this->driver,
            $this->event,
            $this->serializer,
            ['foo' => function () use ($exception) { throw $exception; }]
        );

        $method = static::getProtectedMethod($worker, 'tick');
        $this->assertTrue($method->invoke($worker, $message->queue()));
    }

    public function testTickHandlerReturnFalse()
    {
        $message = new Message('queue', 'foo', ['foo' => 'bar']);

        $this->driver

The method expects() does not seem to exist on object<Equip\Queue\Driver\DriverInterface>.

            ->expects($this->once())
            ->method('pop')
            ->with($message->queue())
            ->willReturn($this->serializer->serialize($message));

        $this->event

The method expects() does not seem to exist on object<Equip\Queue\Event>.

            ->expects($this->once())
            ->method('acknowledge')
            ->with($message);

        $worker = new Worker(
            $this->driver,
            $this->event,
            $this->serializer,
            ['foo' => function () { return false; }]
        );

        $method = static::getProtectedMethod($worker, 'tick');
        $this->assertFalse($method->invoke($worker, $message->queue()));
    }

    public function testTick()
    {
        $message = new Message('queue', 'foo', ['name' => 'foo']);

        $this->driver

The method expects() does not seem to exist on object<Equip\Queue\Driver\DriverInterface>.

            ->expects($this->once())
            ->method('pop')
            ->with($message->queue())
            ->willReturn($this->serializer->serialize($message));

        $this->event

The method expects() does not seem to exist on object<Equip\Queue\Event>.

            ->expects($this->once())
            ->method('acknowledge')
            ->with($message);

        $worker = new Worker(
            $this->driver,
            $this->event,
            $this->serializer,
            [
                'foo' => function ($data) use ($message) {
                    $this->assertSame($message->handler(), $data->handler());
                }
            ]
        );

        $method = static::getProtectedMethod($worker, 'tick');
        $this->assertTrue($method->invoke($worker, $message->queue()));
    }

    public function testConsume()
    {
        $message = new Message('queue', 'foo', ['name' => 'foo']);

        $this->driver

The method expects() does not seem to exist on object<Equip\Queue\Driver\DriverInterface>.

            ->expects($this->once())
            ->method('pop')
            ->with($message->queue())
            ->willReturn($this->serializer->serialize($message));

        $this->event

The method expects() does not seem to exist on object<Equip\Queue\Event>.

            ->expects($this->once())
            ->method('acknowledge')
            ->with($message);

        $worker = new Worker(
            $this->driver,
            $this->event,
            $this->serializer,
            ['foo' => function () { return false; }]
        );

        $worker->consume($message->queue());
    }
}