OldSound\RabbitMqBundle\DependencyInjection\Compiler\RegisterPartsPass

Complexity

Total Complexity

4

Size/Duplication

Total Lines	27
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	process()	0	25	4

<?php

namespace OldSound\RabbitMqBundle\DependencyInjection\Compiler;

use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
use Symfony\Component\DependencyInjection\Reference;

class RegisterPartsPass implements CompilerPassInterface
{
    public function process(ContainerBuilder $container): void
    {
        $services = $container->findTaggedServiceIds('old_sound_rabbit_mq.base_amqp');
        $container->setParameter('old_sound_rabbit_mq.base_amqp', array_keys($services));
        if (!$container->hasDefinition('old_sound_rabbit_mq.parts_holder')) {
            return;
        }

        $definition = $container->getDefinition('old_sound_rabbit_mq.parts_holder');

        $tags = [
            'old_sound_rabbit_mq.base_amqp',
            'old_sound_rabbit_mq.binding',
            'old_sound_rabbit_mq.producer',
            'old_sound_rabbit_mq.consumer',
            'old_sound_rabbit_mq.multi_consumer',
            'old_sound_rabbit_mq.anon_consumer',
            'old_sound_rabbit_mq.batch_consumer',
            'old_sound_rabbit_mq.rpc_client',
            'old_sound_rabbit_mq.rpc_server',
        ];

        foreach ($tags as $tag) {
            foreach ($container->findTaggedServiceIds($tag) as $id => $attributes) {
                $definition->addMethodCall('addPart', [$tag, new Reference($id)]);
            }
        }
    }
}