graze / queue

tests/unit/Handler/ResultAcknowledgementHandlerTest.php

<?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\Handler;

use ArrayIterator;
use Closure;
use Graze\Queue\Adapter\AdapterInterface;
use Graze\Queue\Message\MessageInterface;
use Mockery as m;
use Mockery\MockInterface;
use Graze\Queue\Test\TestCase;

class ResultAcknowledgementHandlerTest extends TestCase
{
    /** @var AdapterInterface|MockInterface */
    private $adapter;
    /** @var ResultAcknowledgementHandler */
    private $handler;
    /** @var MessageInterface|MockInterface */
    private $message;
    /** @var ArrayIterator */
    private $messages;

    public function setUp()
    {
        $this->adapter = m::mock('Graze\Queue\Adapter\AdapterInterface');

        $this->message = m::mock('Graze\Queue\Message\MessageInterface');
        $this->messages = new ArrayIterator([$this->message]);

        $this->handler = new EagerAcknowledgementHandler();

It seems like new Graze\Queue\Handler\EagerAcknowledgementHandler() of type Graze\Queue\Handler\EagerAcknowledgementHandler is incompatible with the declared type Graze\Queue\Handler\ResultAcknowledgementHandler of property $handler.

    }

    public function testHandleTrueResult()
    {
        $handler = new ResultAcknowledgementHandler(function ($result) {
            return $result === true;
        }, $this->handler);

        $this->message->shouldReceive('isValid')->once()->withNoArgs()->andReturn(true);

The method shouldReceive() does not exist on Graze\Queue\Message\MessageInterface.

        $this->adapter->shouldReceive('acknowledge')->once()->with(m::mustBe([$this->message]));

The method shouldReceive() does not exist on Graze\Queue\Adapter\AdapterInterface.

        $msgs = [];
        $handler($this->messages, $this->adapter, function ($msg, Closure $done) use (&$msgs) {

The parameter $done is not used and could be removed.

            $msgs[] = $msg;
            return true;
        });

        assertThat($msgs, is(identicalTo(iterator_to_array($this->messages))));
    }

    public function testHandleNonTrueResponse()
    {
        $handler = new ResultAcknowledgementHandler(function ($result) {
            return $result === true;
        }, $this->handler);

        $this->message->shouldReceive('isValid')->once()->withNoArgs()->andReturn(true);
        $this->adapter->shouldReceive('reject')->once()->with(m::mustBe([$this->message]));

        $handler($this->messages, $this->adapter, function ($msg, Closure $done) use (&$msgs) {

The parameter $msg is not used and could be removed.

The parameter $done is not used and could be removed.

            return false;
        });
    }

    public function testCustomResultAcknowledgementHandler()
    {
        $handler = new ResultAcknowledgementHandler(function ($result) {
            return $result === false;
        }, $this->handler);

        $this->message->shouldReceive('isValid')->once()->withNoArgs()->andReturn(true);
        $this->adapter->shouldReceive('acknowledge')->once()->with(m::mustBe([$this->message]));

        $handler($this->messages, $this->adapter, function ($msg) {

The parameter $msg is not used and could be removed.

            return false;
        });
    }
}