NeedleProject\LaravelRabbitMq\Processor\AbstractMessageProcessorTest

Complexity

Total Complexity

2

Size/Duplication

Total Lines	124
Duplicated Lines	0 %

Importance

Changes	4
Bugs	0	Features	0

15 Methods

Rating	Name	Duplication	Size	Complexity
A	hp$1 ➔ processMessage()	0	3	1
	testSuccesfullyAck()	0	22	?
A	hp$4 ➔ processMessage()	0	4	1
A	hp$4 ➔ testErrorNack()	0	27	1
	testNackFromException()	0	22	?
A	hp$0 ➔ processMessage()	0	3	1
A	hp$3 ➔ processMessage()	0	3	1
A	hp$1 ➔ testNackFromException()	0	22	1
	testErrorNack()	0	27	?
	testControlledNack()	0	22	?
A	hp$0 ➔ testSuccesfullyAck()	0	22	1
A	hp$3 ➔ testMessageCounter()	0	21	1
	testMessageCounter()	0	21	?
A	hp$2 ➔ processMessage()	0	3	1
A	hp$2 ➔ testControlledNack()	0	22	1

<?php
namespace NeedleProject\LaravelRabbitMq\Processor;

use PhpAmqpLib\Channel\AMQPChannel;
use PhpAmqpLib\Message\AMQPMessage;
use PHPUnit\Framework\TestCase;
use Psr\Log\LoggerInterface;

class AbstractMessageProcessorTest extends TestCase
{
    public function testSuccesfullyAck()
    {
        $messageProcessor = new class extends AbstractMessageProcessor {
            public function processMessage(AMQPMessage $message): bool
            {
                return true;
            }
        };
        $loggerMock = $this->createMock(LoggerInterface::class);
        $messageProcessor->setLogger($loggerMock);

        $channelMock = $this->createMock(AMQPChannel::class);
        $channelMock->expects($this->once())
            ->method('basic_ack')
            ->with('foo')
            ->willReturn(null);

        $amqpMessage = $this->createMock(AMQPMessage::class);
        $amqpMessage->delivery_info['channel'] = $channelMock;

Accessing delivery_info on the interface PHPUnit\Framework\MockObject\MockObject suggest that you code against a concrete implementation. How about adding an instanceof check?

        $amqpMessage->delivery_info['delivery_tag'] = 'foo';

        $messageProcessor->consume($amqpMessage);
    }

    public function testNackFromException()
    {
        $messageProcessor = new class extends AbstractMessageProcessor {
            public function processMessage(AMQPMessage $message): bool
            {
                throw new \Exception('foo');
            }
        };
        $loggerMock = $this->createMock(LoggerInterface::class);
        $messageProcessor->setLogger($loggerMock);

        $channelMock = $this->createMock(AMQPChannel::class);
        $channelMock->expects($this->once())
            ->method('basic_nack')
            ->with('foo')
            ->willReturn(null);

        $amqpMessage = $this->createMock(AMQPMessage::class);
        $amqpMessage->delivery_info['channel'] = $channelMock;

Accessing delivery_info on the interface PHPUnit\Framework\MockObject\MockObject suggest that you code against a concrete implementation. How about adding an instanceof check?

        $amqpMessage->delivery_info['delivery_tag'] = 'foo';

        $messageProcessor->consume($amqpMessage);
    }

    public function testControlledNack()
    {
        $messageProcessor = new class extends AbstractMessageProcessor {
            public function processMessage(AMQPMessage $message): bool
            {
                return false;
            }
        };
        $loggerMock = $this->createMock(LoggerInterface::class);
        $messageProcessor->setLogger($loggerMock);

        $channelMock = $this->createMock(AMQPChannel::class);
        $channelMock->expects($this->once())
            ->method('basic_nack')
            ->with('foo')
            ->willReturn(null);

        $amqpMessage = $this->createMock(AMQPMessage::class);
        $amqpMessage->delivery_info['channel'] = $channelMock;

Accessing delivery_info on the interface PHPUnit\Framework\MockObject\MockObject suggest that you code against a concrete implementation. How about adding an instanceof check?

        $amqpMessage->delivery_info['delivery_tag'] = 'foo';

        $messageProcessor->consume($amqpMessage);
    }

    public function testMessageCounter()
    {
        $messageProcessor = new class extends AbstractMessageProcessor {
            public function processMessage(AMQPMessage $message): bool
            {
                return true;
            }
        };
        $loggerMock = $this->createMock(LoggerInterface::class);
        $messageProcessor->setLogger($loggerMock);

        $channelMock = $this->createMock(AMQPChannel::class);
        $amqpMessage = $this->createMock(AMQPMessage::class);
        $amqpMessage->delivery_info['channel'] = $channelMock;

Accessing delivery_info on the interface PHPUnit\Framework\MockObject\MockObject suggest that you code against a concrete implementation. How about adding an instanceof check?

        $amqpMessage->delivery_info['delivery_tag'] = 'foo';

        $messageProcessor->consume($amqpMessage);
        $messageProcessor->consume($amqpMessage);
        $messageProcessor->consume($amqpMessage);

        $this->assertEquals(3, $messageProcessor->getProcessedMessages());
    }

    public function testErrorNack()
    {
        $messageProcessor = new class extends AbstractMessageProcessor {
            public function processMessage(AMQPMessage $message): bool
            {
                // trigger nack
                return false;
            }
        };
        $loggerMock = $this->createMock(LoggerInterface::class);
        $messageProcessor->setLogger($loggerMock);
        $channelMock = $this->createMock(AMQPChannel::class);
        $channelMock->expects($this->atLeastOnce())
            ->method('basic_nack')
            ->will($this->throwException(new \RuntimeException('FooBar')));

        $amqpMessage = $this->createMock(AMQPMessage::class);
        $amqpMessage->delivery_info['channel'] = $channelMock;

Accessing delivery_info on the interface PHPUnit\Framework\MockObject\MockObject suggest that you code against a concrete implementation. How about adding an instanceof check?

        $amqpMessage->delivery_info['delivery_tag'] = 1;
        $amqpMessage->expects($this->atLeastOnce())
            ->method('getBody')
            ->willReturn('foo');

        $loggerMock->expects($this->atLeastOnce())
            ->method('debug')
            ->with('Did not processed with success message foo');
        $messageProcessor->consume($amqpMessage);
    }
}