ContainerBuilderTest::testPublisher() - Code Metrics - sofwar/laravel-rabbitmq - Measure and Improve Code Quality continuously with Scrutinizer

ContainerBuilderTest::testPublisher() A
last analyzed 2025-05-22 16:33 UTC

↳ Parent: ContainerBuilderTest
Complexity

Conditions	1
Paths	1
Size

Total Lines	28
Code Lines	18
Duplication

Lines	0
Ratio	0 %
Importance

Changes	1
Bugs	0	Features	0
Metric	Value
cc	1
eloc	18
nc	1
nop	0
dl	0
loc	28
rs	9.6666
c	1
b	0
f	0
<?php
namespace NeedleProject\LaravelRabbitMq\Builder;

use PHPUnit\Framework\TestCase;

class ContainerBuilderTest extends TestCase
{
    public function testPublisher()
    {
        $containerBuilder = new ContainerBuilder();
        $container = $containerBuilder->createContainer([
            'connections' => [
                'foo' => []
            ],
            'queues' => [],
            'consumers' => [],
            'exchanges' => [
                'my.exchange' => [
                    // used connection for the producer
                    'connection' => 'foo',
                    'name'       => 'the.exchange.name',
                    'attributes' => [
                        'exchange_type' => 'topic'
                    ]
                ]
            ],
            'publishers' => [
                'fooPublisher' => 'my.exchange'
            ]
        ]);

        $this->assertEquals(1, count($container->getPublishers()));
        $this->assertEquals(
            'my.exchange',
            $container->getPublisher('fooPublisher')->getAliasName()
            $container->getPublisher('fooPublisher')->/** @scrutinizer ignore-call */ getAliasName()
        );
    }

    public function testBadConnectionReferenceForExchange()
    {
        $containerBuilder = new ContainerBuilder();

        $this->expectException(\RuntimeException::class);

        $containerBuilder->createContainer([
            'connections' => [
                'foo' => []
            ],
            'queues' => [],
            'consumers' => [],
            'exchanges' => [
                'my.exchange' => [
                    'connection' => 'un-existent',
                    'name'       => 'the.exchange.name',
                    'attributes' => [
                        'exchange_type' => 'topic'
                    ]
                ]
            ],
            'publishers' => [
                'fooPublisher' => 'my.exchange'
            ]
        ]);
    }

    public function testConsumer()
    {
        $containerBuilder = new ContainerBuilder();
        $container = $containerBuilder->createContainer([
            'connections' => [
                'foo' => []
            ],
            'exchanges' => [],
            'consumers' => [
                'my-consumer' => [
                    'queue' => 'my.queue',
                    'prefetch_count' => 1,
                    'global_prefetch' => true,
                    'message_processor' => \NeedleProject\LaravelRabbitMq\Processor\CliOutputProcessor::class
                ]
            ],
            'queues' => [
                'my.queue' => [
                    // used connection for the producer
                    'connection' => 'foo',
                    'name'       => 'my.queue',
                    'attributes' => []
                ]
            ],
            'publishers' => []
        ]);

        $this->assertEquals(1, count($container->getConsumers()));
        $this->assertEquals(
            'my.queue',
            $container->getConsumer('my-consumer')->getAliasName()
        );
    }

    public function testQueueBadConnection()
    {
        $containerBuilder = new ContainerBuilder();

        $this->expectException(\RuntimeException::class);

        $containerBuilder->createContainer([
            'connections' => [
                'foo' => []
            ],
            'exchanges' => [],
            'consumers' => [
                'my-consumer' => [
                    'queue' => 'my.queue',
                    'prefetch_count' => 1,
                    'message_processor' => \NeedleProject\LaravelRabbitMq\Processor\CliOutputProcessor::class
                ]
            ],
            'queues' => [
                'my.queue' => [
                    // used connection for the producer
                    'connection' => 'bar',
                    'name'       => 'my.queue',
                    'attributes' => []
                ]
            ],
            'publishers' => []
        ]);
    }

    public function testBadConsumerReference()
    {
        $containerBuilder = new ContainerBuilder();

        $this->expectException(\RuntimeException::class);

        $containerBuilder->createContainer([
            'connections' => [
                'foo' => []
            ],
            'exchanges' => [],
            'consumers' => [
                'my-consumer' => [
                    'queue' => 'my.queue',
                    'prefetch_count' => 1,
                    'global_prefetch' => true,
                    'message_processor' => \NeedleProject\LaravelRabbitMq\Processor\CliOutputProcessor::class
                ]
            ],
            'queues' => [
                'my.queue.typo' => [
                    // used connection for the producer
                    'connection' => 'foo',
                    'name'       => 'my.queue',
                    'attributes' => []
                ]
            ],
            'publishers' => []
        ]);
    }

    public function testBadPublisherReference()
    {
        $containerBuilder = new ContainerBuilder();

        $this->expectException(\RuntimeException::class);

        $containerBuilder->createContainer([
            'connections' => [
                'foo' => []
            ],
            'queues' => [],
            'consumers' => [],
            'exchanges' => [
                'my.exchange' => [
                    // used connection for the producer
                    'connection' => 'foo',
                    'name'       => 'the.exchange.name',
                    'attributes' => [
                        'exchange_type' => 'topic'
                    ]
                ]
            ],
            'publishers' => [
                'fooPublisher' => 'my.exchange.typo'
            ]
        ]);
    }

    public function testQueuePublisherReference()
    {
        $containerBuilder = new ContainerBuilder();
        $container = $containerBuilder->createContainer([
            'connections' => [
                'foo' => []
            ],
            'queues' => [
                'a.queue' => [
                    // used connection for the producer
                    'connection' => 'foo',
                    'name'       => 'a.queue.name',
                    'attributes' => [
                    ]
                ]
            ],
            'consumers' => [],
            'exchanges' => [],
            'publishers' => [
                'fooPublisher' => 'a.queue'
            ]
        ]);


        $this->assertEquals(1, count($container->getPublishers()));
        $this->assertEquals(
            'a.queue',
            $container->getPublisher('fooPublisher')->getAliasName()
        );
    }
}

sofwar / laravel-rabbitmq

ContainerBuilderTest::testPublisher() A last analyzed 2025-05-22 16:33 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

ContainerBuilderTest::testPublisher() A
last analyzed 2025-05-22 16:33 UTC
