OldSound\RabbitMqBundle\Tests\RabbitMq\BaseAmqpTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	71
Duplicated Lines	0 %

Importance

Changes	3
Bugs	1	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	testNotLazyConnection()	0	14	1
A	testDispatchEvent()	0	21	1
A	invokeMethod()	0	7	1
A	testLazyConnection()	0	14	1

<?php

namespace OldSound\RabbitMqBundle\Tests\RabbitMq;

use PHPUnit\Framework\MockObject\MockObject;
use Symfony\Contracts\EventDispatcher\EventDispatcherInterface as ContractsEventDispatcherInterface;
use OldSound\RabbitMqBundle\Event\AMQPEvent;
use OldSound\RabbitMqBundle\RabbitMq\BaseAmqp;
use OldSound\RabbitMqBundle\RabbitMq\Consumer;
use PHPUnit\Framework\TestCase;

class BaseAmqpTest extends TestCase
{
    public function testLazyConnection()
    {
        $connection = $this->getMockBuilder('PhpAmqpLib\Connection\AbstractConnection')
            ->disableOriginalConstructor()
            ->getMock();

        $connection
            ->method('connectOnConstruct')
            ->willReturn(false);
        $connection
            ->expects(static::never())
            ->method('channel');

        new Consumer($connection, null);
    }

    public function testNotLazyConnection()
    {
        $connection = $this->getMockBuilder('PhpAmqpLib\Connection\AbstractConnection')
            ->disableOriginalConstructor()
            ->getMock();

        $connection
            ->method('connectOnConstruct')
            ->willReturn(true);
        $connection
            ->expects(static::once())
            ->method('channel');

        new Consumer($connection, null);
    }

    public function testDispatchEvent()
    {
        /** @var BaseAmqp|MockObject $baseAmqpConsumer */
        $baseAmqpConsumer = $this->getMockBuilder('OldSound\RabbitMqBundle\RabbitMq\BaseAmqp')
            ->disableOriginalConstructor()
            ->getMock();

        $eventDispatcher = $this->getMockBuilder('Symfony\Contracts\EventDispatcher\EventDispatcherInterface')
            ->disableOriginalConstructor()
            ->getMock();

        $baseAmqpConsumer->expects($this->atLeastOnce())
            ->method('getEventDispatcher')
            ->willReturn($eventDispatcher);

        $eventDispatcher->expects($this->once())
            ->method('dispatch')
            ->with(new AMQPEvent(), AMQPEvent::ON_CONSUME)
            ->willReturn(new AMQPEvent());

        $this->invokeMethod('dispatchEvent', $baseAmqpConsumer, [AMQPEvent::ON_CONSUME, new AMQPEvent()]);
    }

    /**
     * @param string $name
     * @param MockObject $obj
     * @param array $params
     *
     * @return mixed
     */
    protected function invokeMethod($name, $obj, $params)
    {
        $class = new \ReflectionClass(get_class($obj));
        $method = $class->getMethod($name);
        $method->setAccessible(true);

        return $method->invokeArgs($obj, $params);
    }
}