Cmobi\RabbitmqBundle\Tests\Transport\Worker\TaskTest

Complexity

Total Complexity

8

Size/Duplication

Total Lines	101
Duplicated Lines	52.48 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	testGetQueueName()	0	6	1
A	testRefreshChannel()	0	6	1
A	testGetChannel()	0	6	1
A	testGetFromName()	0	6	1
A	getConnectionManagerMock()	10	10	1
A	getConnectionMock()	14	14	1
A	getCmobiAMQPMessage()	13	13	1
A	getChannelMock()	15	15	1

<?php

namespace Cmobi\RabbitmqBundle\Tests\Transport\Worker;

use Cmobi\RabbitmqBundle\Connection\CmobiAMQPChannel;
use Cmobi\RabbitmqBundle\Connection\CmobiAMQPConnection;
use Cmobi\RabbitmqBundle\Connection\ConnectionManager;
use Cmobi\RabbitmqBundle\Queue\CmobiAMQPMessage;
use Cmobi\RabbitmqBundle\Tests\BaseTestCase;
use Cmobi\RabbitmqBundle\Transport\Worker\Task;

class TaskTest extends BaseTestCase
{
    public function testGetQueueName()
    {
        $taskClient = new Task('test', $this->getConnectionManagerMock());

        $this->assertEquals('test', $taskClient->getQueueName());
    }

    public function testRefreshChannel()
    {
        $taskClient = new Task('test', $this->getConnectionManagerMock());

        $this->assertInstanceOf(CmobiAMQPChannel::class, $taskClient->refreshChannel());
    }

    public function testGetChannel()
    {
        $taskClient = new Task('test', $this->getConnectionManagerMock());

        $this->assertInstanceOf(CmobiAMQPChannel::class, $taskClient->refreshChannel());
    }

    public function testGetFromName()
    {
        $taskClient = new Task('test', $this->getConnectionManagerMock(), 'caller_test');

        $this->assertEquals('caller_test', $taskClient->getFromName());
    }

    /**
     * @return ConnectionManager
     */
    protected function getConnectionManagerMock()

This method seems to be duplicated in your project.

    {
        $connectionManagerMock = $this->getMockBuilder(ConnectionManager::class)
            ->disableOriginalConstructor()
            ->getMock();
        $connectionManagerMock->method('getConnection')
            ->willReturn($this->getConnectionMock());

        return $connectionManagerMock;
    }

    /**
     * @return CmobiAMQPConnection
     */
    protected function getConnectionMock()

This method seems to be duplicated in your project.

    {
        $connectionMock = $this->getMockBuilder(CmobiAMQPConnection::class)
            ->disableOriginalConstructor()
            ->getMock();
        $connectionMock->method('isConnected')
            ->willReturn(true);
        $connectionMock->method('reconnect')
            ->willReturn(true);
        $connectionMock->method('channel')
            ->willReturn($this->getChannelMock());

        return $connectionMock;
    }

    /**
     * @return CmobiAMQPChannel
     */
    protected function getChannelMock()

This method seems to be duplicated in your project.

    {
        $channelMock = $this->getMockBuilder(CmobiAMQPChannel::class)
            ->disableOriginalConstructor()
            ->getMock();
        $channelMock
            ->expects($this->any())
            ->method('basic_publish')
            ->willReturn(true);
        $channelMock
            ->method('basicConsume')
            ->willReturn(true);

        return $channelMock;
    }

    /**
     * @param string $msg
     * @param null   $correlationId
     *
     * @return CmobiAMQPMessage
     */
    protected function getCmobiAMQPMessage($msg = '', $correlationId = null)

This method seems to be duplicated in your project.

    {
        $msgMock = $this->getMockBuilder(CmobiAMQPMessage::class)
            ->disableOriginalConstructor()
            ->getMock();
        $msgMock->method('get')
            ->willReturn('correlation_id')
            ->willReturn($correlationId);
        $msgMock->method('getBody')
            ->willReturn($msg);

        return $msgMock;
    }
}