Cmobi\RabbitmqBundle\Tests\Rpc\RpcServerBuilderTest

Complexity

Total Complexity

6

Size/Duplication

Total Lines	73
Duplicated Lines	54.79 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	testGetConnectionManager()	7	7	1
A	testBuildQueue()	7	7	1
A	testGetCallbackAfterBuildQueue()	8	8	1
A	getAMQPStreamConnectionMock()	18	18	1
A	getConnectionManagerMock()	0	8	1
A	getQueueServiceMock()	0	8	1

<?php

namespace Cmobi\RabbitmqBundle\Tests\Rpc;

use Cmobi\RabbitmqBundle\Connection\CmobiAMQPChannel;
use Cmobi\RabbitmqBundle\Connection\CmobiAMQPConnection;
use Cmobi\RabbitmqBundle\Connection\CmobiAMQPConnectionInterface;
use Cmobi\RabbitmqBundle\Connection\ConnectionManager;
use Cmobi\RabbitmqBundle\Queue\QueueCallbackInterface;
use Cmobi\RabbitmqBundle\Queue\QueueInterface;
use Cmobi\RabbitmqBundle\Queue\QueueServiceInterface;
use Cmobi\RabbitmqBundle\Transport\Rpc\RpcServerBuilder;
use Cmobi\RabbitmqBundle\Tests\BaseTestCase;

class RpcServerBuilderTest extends BaseTestCase
{
    public function testGetConnectionManager()

This method seems to be duplicated in your project.

    {
        $rpcServer = new RpcServerBuilder($this->getConnectionManagerMock(), $this->getLoggerMock(), []);
        $connectionManager = $rpcServer->getConnectionManager();

        $this->assertInstanceOf(ConnectionManager::class, $connectionManager);
    }

    public function testBuildQueue()

This method seems to be duplicated in your project.

    {
        $rpcServer = new RpcServerBuilder($this->getConnectionManagerMock(), $this->getLoggerMock(), []);
        $queue = $rpcServer->buildQueue('test', $this->getQueueServiceMock());

        $this->assertInstanceOf(QueueInterface::class, $queue);
    }

    public function testGetCallbackAfterBuildQueue()

This method seems to be duplicated in your project.

    {
        $rpcServer = new RpcServerBuilder($this->getConnectionManagerMock(), $this->getLoggerMock(), []);
        $queue = $rpcServer->buildQueue('test', $this->getQueueServiceMock());
        $callback = $queue->getCallback();

        $this->assertInstanceOf(QueueCallbackInterface::class, $callback);
    }

    /**
     * @return CmobiAMQPConnectionInterface
     */
    protected function getAMQPStreamConnectionMock()

This method seems to be duplicated in your project.

    {
        $class = $this->getMockBuilder(CmobiAMQPConnection::class)
            ->disableOriginalConstructor()
            ->getMock();

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

        $class->method('channel')
            ->willReturn($channelMock);

        return $class;
    }

    /**
     * @return ConnectionManager
     */
    protected function getConnectionManagerMock()
    {
        $connectionManagerMock = $this->getMockBuilder(ConnectionManager::class)
            ->disableOriginalConstructor()
            ->getMock();

        return $connectionManagerMock;
    }

    /**
     * @return QueueServiceInterface
     */
    protected function getQueueServiceMock()
    {
        $queueCallback = $this->getMockBuilder(QueueServiceInterface::class)
            ->disableOriginalConstructor()
            ->getMock();

        return $queueCallback;
    }
}