Innmind\AMQPBundle\DependencyInjection\InnmindAMQPExtension

Complexity

Total Complexity

14

Size/Duplication

Total Lines	141
Duplicated Lines	21.28 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

98.53%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	load()	0	21	1
A	configureConnection()	0	13	1
A	registerTranslators()	0	12	2
A	registerExchanges()	15	15	2
A	registerQueues()	0	20	2
A	registerBindings()	15	15	2
A	registerProducers()	0	19	2
A	registerSignalAwareClient()	0	13	2

<?php
declare(strict_types = 1);

namespace Innmind\AMQPBundle\DependencyInjection;

use Innmind\AMQPBundle\Producer\Producer;
use Symfony\Component\{
    HttpKernel\DependencyInjection\Extension,
    DependencyInjection\ContainerBuilder,
    DependencyInjection\Loader,
    DependencyInjection\Reference,
    DependencyInjection\Definition,
    Config\FileLocator
};

final class InnmindAMQPExtension extends Extension
{
    /**
     * {@inheritdoc}
     */
    public function load(array $configs, ContainerBuilder $container)
    {
        $loader = new Loader\YamlFileLoader(
            $container,
            new FileLocator(__DIR__.'/../Resources/config')
        );
        $loader->load('services.yml');
        $config = $this->processConfiguration(
            new Configuration,
            $configs
        );

        $this
            ->configureConnection($config, $container)
            ->registerTranslators($config, $container)
            ->registerExchanges($config, $container)
            ->registerQueues($config, $container)
            ->registerBindings($config, $container)
            ->registerProducers($config, $container)
            ->registerSignalAwareClient($config, $container);
    }

    private function configureConnection(
        array $config,
        ContainerBuilder $container
    ): self {
        $container
            ->getDefinition('innmind.amqp.connection.default')
            ->replaceArgument(0, $config['server']['transport']['name'])
            ->replaceArgument(1, $config['server'])
            ->replaceArgument(3, $config['server']['timeout'])
            ->replaceArgument(4, new Reference($config['clock']));

        return $this;
    }

    private function registerTranslators(
        array $config,
        ContainerBuilder $container
    ): self {
        $definition = $container->getDefinition('innmind.amqp.argument_translator');

        foreach ($config['argument_translators'] as $translator) {
            $definition->addArgument(new Reference($translator));
        }

        return $this;
    }

    private function registerExchanges(
        array $config,
        ContainerBuilder $container
    ): self {
        $autoDeclare = $container->getDefinition('innmind.amqp.client.auto_declare');

        foreach ($config['exchanges'] as $name => $exchange) {
            $autoDeclare->addMethodCall(
                'declareExchange',
                [$name, $exchange['type'], $exchange['durable'], $exchange['arguments']]
            );
        }

        return $this;
    }

    private function registerQueues(
        array $config,
        ContainerBuilder $container
    ): self {
        $autoDeclare = $container->getDefinition('innmind.amqp.client.auto_declare');
        $consumers = $container->getDefinition('innmind.amqp.consumers');

        foreach ($config['queues'] as $name => $queue) {
            $autoDeclare->addMethodCall(
                'declareQueue',
                [$name, $queue['durable'], $queue['exclusive'], $queue['arguments']]
            );
            $consumers->addMethodCall(
                'add',
                [$name, new Reference($queue['consumer'])]
            );
        }

        return $this;
    }

    private function registerBindings(
        array $config,
        ContainerBuilder $container
    ): self {
        $autoDeclare = $container->getDefinition('innmind.amqp.client.auto_declare');

        foreach ($config['bindings'] as $binding) {
            $autoDeclare->addMethodCall(
                'declareBinding',
                [$binding['exchange'], $binding['queue'], $binding['routingKey'], $binding['arguments']]
            );
        }

        return $this;
    }

    private function registerProducers(
        array $config,
        ContainerBuilder $container
    ): self {
        foreach ($config['exchanges'] as $name => $_) {
            $container->setDefinition(
                'innmind.amqp.producer.'.$name,
                new Definition(
                    Producer::class,
                    [
                        new Reference('innmind.amqp.client'),
                        $name
                    ]
                )
            );
        }

        return $this;
    }

    private function registerSignalAwareClient(
        array $config,
        ContainerBuilder $container
    ): self {
        if ($config['handle_posix_signals'] === true) {
            $container->setAlias(
                'innmind.amqp.client',
                'innmind.amqp.client.signal_aware'
            );
        }

        return $this;
    }
}