Graze\Queue\Adapter\FirehoseAdapterTest

Complexity

Total Complexity

7

Size/Duplication

Total Lines	92
Duplicated Lines	11.96 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	11	11	1
A	testInterface()	0	4	1
A	testEnqueue()	0	21	1
A	testAcknowledge()	0	5	1
A	testDequeue()	0	5	1
A	testPurge()	0	5	1
A	testDelete()	0	5	1

<?php

/**
 * This file is part of graze/queue.
 *
 * Copyright (c) 2015 Nature Delivered Ltd. <https://www.graze.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 *
 * @license https://github.com/graze/queue/blob/master/LICENSE MIT
 *
 * @link    https://github.com/graze/queue
 */

namespace Graze\Queue\Adapter;

use Aws\ResultInterface;
use Aws\Firehose\FirehoseClient;
use Graze\Queue\Adapter\Exception\MethodNotSupportedException;
use Graze\Queue\Message\MessageFactoryInterface;
use Graze\Queue\Message\MessageInterface;
use Mockery as m;
use Mockery\MockInterface;
use PHPUnit_Framework_TestCase as TestCase;

class FirehoseAdapterTest extends TestCase
{
    /** @var MessageInterface|MockInterface */
    private $messageA;
    /** @var MessageInterface|MockInterface */
    private $messageB;
    /** @var MessageInterface|MockInterface */
    private $messageC;
    /** @var MessageInterface[]|MockInterface[] */
    private $messages;
    /** @var ResultInterface|MockInterface */
    private $model;
    /** @var MessageFactoryInterface|MockInterface */
    private $factory;
    /** @var FirehoseClient */
    private $client;

    public function setUp()

This method seems to be duplicated in your project.

    {
        $this->client = m::mock(FirehoseClient::class);
        $this->model = m::mock(ResultInterface::class);
        $this->factory = m::mock(MessageFactoryInterface::class);

        $this->messageA = $a = m::mock(MessageInterface::class);

Avoid variables with short names like $a. Configured minimum length is 2.

        $this->messageB = $b = m::mock(MessageInterface::class);

Avoid variables with short names like $b. Configured minimum length is 2.

        $this->messageC = $c = m::mock(MessageInterface::class);

Avoid variables with short names like $c. Configured minimum length is 2.

        $this->messages = [$a, $b, $c];
    }

    public function testInterface()
    {
        assertThat(new FirehoseAdapter($this->client, 'foo'), is(anInstanceOf('Graze\Queue\Adapter\AdapterInterface')));
    }

    public function testEnqueue()
    {
        $adapter = new FirehoseAdapter($this->client, 'foo');

        $this->messageA->shouldReceive('getBody')->once()->withNoArgs()->andReturn('foo');

The method shouldReceive does only exist in Mockery\MockInterface, but not in Graze\Queue\Message\MessageInterface.

        $this->messageB->shouldReceive('getBody')->once()->withNoArgs()->andReturn('bar');
        $this->messageC->shouldReceive('getBody')->once()->withNoArgs()->andReturn('baz');

        $this->model->shouldReceive('get')->once()->with('RequestResponses')->andReturn([]);

The method shouldReceive does only exist in Mockery\MockInterface, but not in Aws\ResultInterface.

        $this->client->shouldReceive('putRecordBatch')->once()->with([
            'DeliveryStreamName' => 'foo',
            'Records' => [
                ['Data' => 'foo'],
                ['Data' => 'bar'],
                ['Data' => 'baz'],
            ],
        ])->andReturn($this->model);

        $adapter->enqueue($this->messages);

$this->messages is of type array<integer,object<Mockery\MockInterface>>, but the function expects a array<integer,object<Graze\Queue\Message\MessageInterface>>.

    }

    /**
     * @expectedException \Graze\Queue\Adapter\Exception\MethodNotSupportedException
     */
    public function testAcknowledge()
    {
        $adapter = new FirehoseAdapter($this->client, 'foo');
        $adapter->acknowledge($this->messages);

$this->messages is of type array<integer,object<Mockery\MockInterface>>, but the function expects a array<integer,object<Graze\Queue\Message\MessageInterface>>.

    }

    /**
     * @expectedException \Graze\Queue\Adapter\Exception\MethodNotSupportedException
     */
    public function testDequeue()
    {
        $adapter = new FirehoseAdapter($this->client, 'foo');
        $adapter->dequeue($this->factory, 10);
    }

    /**
     * @expectedException \Graze\Queue\Adapter\Exception\MethodNotSupportedException
     */
    public function testPurge()
    {
        $adapter = new FirehoseAdapter($this->client, 'foo');
        $adapter->purge();
    }

    /**
     * @expectedException \Graze\Queue\Adapter\Exception\MethodNotSupportedException
     */
    public function testDelete()
    {
        $adapter = new FirehoseAdapter($this->client, 'foo');
        $adapter->delete();
    }
}