Sonata\NotificationBundle\Tests\Backend\AMQPBackendTest

Complexity

Total Complexity

6

Size/Duplication

Total Lines	165
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	6	2
B	testInitializeWithNoDeadLetterExchangeAndNoDeadLetterRoutingKey()	0	31	1
B	testInitializeWithDeadLetterExchangeAndNoDeadLetterRoutingKey()	0	44	1
B	testInitializeWithDeadLetterExchangeAndDeadLetterRoutingKey()	0	34	1
B	getBackendAndChannelMock()	0	37	1

<?php

/*
 * This file is part of the Sonata Project package.
 *
 * (c) Thomas Rabaix <thomas.rabaix@sonata-project.org>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Sonata\NotificationBundle\Tests\Backend;

class AMQPBackendTest extends \PHPUnit_Framework_TestCase
{
    const EXCHANGE = 'exchange';
    const QUEUE = 'foo';
    const KEY = 'message.type.foo';
    const DEAD_LETTER_EXCHANGE = 'dlx';
    const DEAD_LETTER_ROUTING_KEY = 'message.type.dl';

    public function setUp()
    {
        if (!class_exists('PhpAmqpLib\Channel\AMQPChannel')) {
            $this->markTestSkipped('AMQP Lib not installed');
        }
    }

    public function testInitializeWithNoDeadLetterExchangeAndNoDeadLetterRoutingKey()
    {
        list($backend, $channelMock) = $this->getBackendAndChannelMock();

        $channelMock->expects($this->once())
            ->method('exchange_declare')
            ->with($this->equalTo(self::EXCHANGE),
                   $this->equalTo('direct'),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->isType('boolean')
             );
        $channelMock->expects($this->once())
            ->method('queue_declare')
            ->with($this->equalTo(self::QUEUE),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->equalTo(array())
             );
        $channelMock->expects($this->once())
            ->method('queue_bind')
            ->with($this->equalTo(self::QUEUE),
                   $this->equalTo(self::EXCHANGE),
                   $this->equalTo(self::KEY)
             );

        $backend->initialize();
    }

    public function testInitializeWithDeadLetterExchangeAndNoDeadLetterRoutingKey()
    {
        list($backend, $channelMock) = $this->getBackendAndChannelMock(false, self::DEAD_LETTER_EXCHANGE);

        $channelMock->expects($this->exactly(2))
            ->method('exchange_declare')
            ->withConsecutive(
                array(
                    $this->equalTo(self::EXCHANGE),
                    $this->equalTo('direct'),
                    $this->isType('boolean'),
                    $this->isType('boolean'),
                    $this->isType('boolean'),
                )
             );
        $channelMock->expects($this->once())
            ->method('queue_declare')
            ->with($this->equalTo(self::QUEUE),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->equalTo(array(
                       'x-dead-letter-exchange' => array('S', self::DEAD_LETTER_EXCHANGE),
                   ))
             );
        $channelMock->expects($this->exactly(2))
            ->method('queue_bind')
            ->withConsecutive(
                array(
                   $this->equalTo(self::QUEUE),
                   $this->equalTo(self::EXCHANGE),
                   $this->equalTo(self::KEY),
                ),
                array(
                   $this->equalTo(self::QUEUE),
                   $this->equalTo(self::DEAD_LETTER_EXCHANGE),
                   $this->equalTo(self::KEY),
                )
             );

        $backend->initialize();
    }

    public function testInitializeWithDeadLetterExchangeAndDeadLetterRoutingKey()
    {
        list($backend, $channelMock) = $this->getBackendAndChannelMock(false, self::DEAD_LETTER_EXCHANGE, self::DEAD_LETTER_ROUTING_KEY);

        $channelMock->expects($this->once())
            ->method('exchange_declare')
            ->with($this->equalTo(self::EXCHANGE),
                   $this->equalTo('direct'),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->isType('boolean')
             );
        $channelMock->expects($this->once())
            ->method('queue_declare')
            ->with($this->equalTo(self::QUEUE),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->isType('boolean'),
                   $this->equalTo(array(
                       'x-dead-letter-exchange' => array('S', self::DEAD_LETTER_EXCHANGE),
                       'x-dead-letter-routing-key' => array('S', self::DEAD_LETTER_ROUTING_KEY),
                   ))
             );
        $channelMock->expects($this->once())
            ->method('queue_bind')
            ->with($this->equalTo(self::QUEUE),
                   $this->equalTo(self::EXCHANGE),
                   $this->equalTo(self::KEY)
             );

        $backend->initialize();
    }

    protected function getBackendAndChannelMock($recover = false, $deadLetterExchange = null, $deadLetterRoutingKey = null)
    {
        $mock = $this->getMockBuilder('\Sonata\NotificationBundle\Backend\AMQPBackend')
            ->setConstructorArgs(array(self::EXCHANGE, self::QUEUE, $recover, self::KEY, $deadLetterExchange, $deadLetterRoutingKey))
            ->setMethods(array('getIterator'))
            ->getMock();

        $settings = array(
            'host' => 'foo',
            'port' => 'port',
            'user' => 'user',
            'pass' => 'pass',
            'vhost' => '/',
        );

        $queues = array(
            array('queue' => self::QUEUE, 'routing_key' => self::KEY),
        );

        $channelMock = $this->getMockBuilder('\PhpAmqpLib\Channel\AMQPChannel')
            ->disableOriginalConstructor()
            ->setMethods(array('queue_declare', 'exchange_declare', 'queue_bind'))
            ->getMock()
        ;

        $dispatcherMock = $this->getMockBuilder('\Sonata\NotificationBundle\Backend\AMQPBackendDispatcher')
            ->setConstructorArgs(array($settings, $queues, 'default', array(array('type' => self::KEY, 'backend' => $mock))))
            ->setMethods(array('getChannel'))
            ->getMock();

        $dispatcherMock->method('getChannel')
            ->willReturn($channelMock);

        $mock->setDispatcher($dispatcherMock);

        return array($mock, $channelMock);
    }
}