Sonata\NotificationBundle\Tests\Backend\AMQPBackendDispatcherTest

Complexity

Total Complexity

11

Size/Duplication

Total Lines	102
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	6	2
A	testQueue()	0	10	1
A	testDefaultQueue()	0	7	1
A	testDefaultQueueNotFound()	0	7	1
A	testInvalidQueue()	0	9	1
A	testAllQueueInitializeOnce()	0	18	2
A	getMockQueue()	0	17	2
A	getDispatcher()	0	12	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;

use Sonata\NotificationBundle\Backend\AMQPBackendDispatcher;

class AMQPBackendDispatcherTest extends \PHPUnit_Framework_TestCase
{
    public function setUp()
    {
        if (!class_exists('PhpAmqpLib\Message\AMQPMessage')) {
            $this->markTestSkipped('AMQP Lib not installed');
        }
    }

    public function testQueue()
    {
        $mock = $this->getMockQueue('foo', 'message.type.foo', $this->once());
        $mock2 = $this->getMockQueue('bar', 'message.type.foo', $this->never());
        $fooBackend = array('type' => 'message.type.foo', 'backend' => $mock);
        $barBackend = array('type' => 'message.type.bar', 'backend' => $mock2);
        $backends = array($fooBackend, $barBackend);
        $dispatcher = $this->getDispatcher($backends);
        $dispatcher->createAndPublish('message.type.foo', array());
    }

    public function testDefaultQueue()
    {
        $mock = $this->getMockQueue('foo', 'message.type.foo', $this->once());
        $fooBackend = array('type' => 'default', 'backend' => $mock);
        $dispatcher = $this->getDispatcher(array($fooBackend));
        $dispatcher->createAndPublish('some.other.type', array());
    }

    /**
     * @expectedException \Sonata\NotificationBundle\Exception\BackendNotFoundException
     */
    public function testDefaultQueueNotFound()
    {
        $mock = $this->getMockQueue('foo', 'message.type.foo', $this->never());
        $fooBackend = array('type' => 'message.type.foo', 'backend' => $mock);
        $dispatcher = $this->getDispatcher(array($fooBackend));
        $dispatcher->createAndPublish('some.other.type', array());
    }

    /**
     * @expectedException \Sonata\NotificationBundle\Exception\BackendNotFoundException
     */
    public function testInvalidQueue()
    {
        $mock = $this->getMockQueue('foo', 'message.type.bar');
        $dispatcher = $this->getDispatcher(
            array(array('type' => 'bar', 'backend' => $mock)),
            array(array('queue' => 'foo', 'routing_key' => 'message.type.bar'))
        );
        $dispatcher->createAndPublish('message.type.bar', array());
    }

    public function testAllQueueInitializeOnce()
    {
        $queues = array(
            array('queue' => 'foo', 'routing_key' => 'message.type.foo'),
            array('queue' => 'bar', 'routing_key' => 'message.type.bar'),
            array('queue' => 'baz', 'routing_key' => 'message.type.baz'),
        );
        $backends = array();
        foreach ($queues as $queue) {
            $mock = $this->getMockQueue($queue['queue'], $queue['routing_key']);
            $mock->expects($this->once())
                ->method('initialize');
            $backends[] = array('type' => $queue['routing_key'], 'backend' => $mock);
        }
        $dispatcher = $this->getDispatcher($backends, $queues);
        $dispatcher->createAndPublish('message.type.foo', array());
        $dispatcher->createAndPublish('message.type.foo', array());
    }

    protected function getMockQueue($queue, $type, $called = null)

The parameter $queue is not used and could be removed.

The parameter $type is not used and could be removed.

    {
        $methods = array('createAndPublish', 'initialize');
        $args = array('', 'foo', false, 'message.type.foo');
        $mock = $this->getMockBuilder('Sonata\NotificationBundle\Backend\AMQPBackend')
                     ->setConstructorArgs($args)
                     ->setMethods($methods)
                     ->getMock();

        if ($called !== null) {
            $mock->expects($called)
                ->method('createAndPublish')
            ;
        }

        return $mock;
    }

    protected function getDispatcher(array $backends, array $queues = array(array('queue' => 'foo', 'routing_key' => 'message.type.foo')))
    {
        $settings = array(
                'host' => 'foo',
                'port' => 'port',
                'user' => 'user',
                'pass' => 'pass',
                'vhost' => '/',
        );

        return new AMQPBackendDispatcher($settings, $queues, 'default', $backends);
    }
}