Cmobi\RabbitmqBundle\DependencyInjection\CmobiRabbitmqExtension

Complexity

Total Complexity

11

Size/Duplication

Total Lines	97
Duplicated Lines	29.9 %

Coupling/Cohesion

Components	1
Dependencies	9

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	load()	0	16	1
A	loadConnections()	0	23	3
A	loadRpcServers()	15	15	2
A	loadWorkers()	0	12	2
A	loadSubscribers()	14	14	2
A	registerLogger()	0	5	1

<?php

namespace Cmobi\RabbitmqBundle\DependencyInjection;

use Cmobi\RabbitmqBundle\DependencyInjection\Compiler\LogDispatcherPass;
use Cmobi\RabbitmqBundle\DependencyInjection\Compiler\RpcServerPass;
use Cmobi\RabbitmqBundle\DependencyInjection\Compiler\SubscriberPass;
use Cmobi\RabbitmqBundle\DependencyInjection\Compiler\WorkerPass;
use Symfony\Component\Config\FileLocator;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Definition;
use Symfony\Component\DependencyInjection\Loader\YamlFileLoader;
use Symfony\Component\HttpKernel\DependencyInjection\Extension;

class CmobiRabbitmqExtension extends Extension
{
    public function load(array $configs, ContainerBuilder $container)
    {
        $fileLocator = new FileLocator(__DIR__ . '/../Resources/config');
        $loader = new YamlFileLoader($container, $fileLocator);
        $loader->load('rabbitmq.yml');

        $configuration = $this->getConfiguration($configs, $container);
        $config = $this->processConfiguration($configuration, $configs);

$configuration is of type object|null, but the function expects a object<Symfony\Component\Config\Definition\ConfigurationInterface>.

        $this->registerLogger($container, $configs[0]['log_path']);
        $this->loadConnections($container, $configs[0]);
        $this->loadRpcServers($container, $config);
        $this->loadWorkers($container, $config);

        /* Compile and lock container */
        $container->compile();
    }

    protected function loadConnections(ContainerBuilder $container, array $configs)
    {
        $factories = [];

        foreach ($configs['connections'] as $name => $connection) {
            $connectionClass = '%cmobi_rabbitmq.connection.class%';

            if ($connection['lazy']) {
                $connectionClass = '%cmobi_rabbitmq.lazy.connection.class%';
            }
            $definition = new Definition(
                '%cmobi_rabbitmq.connection.factory.class%',
                [
                    $connectionClass,
                    $connection,
                ]
            );
            $factoryName = sprintf('cmobi_rabbitmq.connection.factory.%s', $name);
            $container->setDefinition($factoryName, $definition);
            $factories[$name] = $factoryName;
        }
        $container->setParameter('cmobi_rabbitmq.connection.factories', $factories);
    }

    public function loadRpcServers(ContainerBuilder $container, array $configs)

This method seems to be duplicated in your project.

    {
        foreach ($configs['rpc_servers'] as $server) {

            $container->addCompilerPass(new RpcServerPass(
                $server['queue']['name'],
                $server['queue']['connection'],
                $server['service'],
                $server['queue']['basic_qos'],
                $server['queue']['durable'],
                $server['queue']['auto_delete'],
                $server['queue']['arguments']
            ));
        }
    }

    public function loadWorkers(ContainerBuilder $container, array $configs)
    {
        foreach ($configs['workers'] as $worker) {
            $container->addCompilerPass(new WorkerPass(
                $worker['queue']['name'],
                $worker['queue']['connection'],
                $worker['service'],
                $worker['queue']['basic_qos'],
                $worker['queue']['arguments']
            ));
        }
    }

    public function loadSubscribers(ContainerBuilder $container, array $configs)

This method seems to be duplicated in your project.

    {
        foreach ($configs['subscribers'] as $subscriber) {
            $container->addCompilerPass(new SubscriberPass(
                $subscriber['queue']['exchange'],
                $subscriber['queue']['exchange_type'],
                $subscriber['queue']['name'],
                $subscriber['queue']['connection'],
                $subscriber['service'],
                $subscriber['queue']['basic_qos'],
                $subscriber['queue']['arguments']
            ));
        }
    }

    /**
     * @param ContainerBuilder $container
     * @param $path
     */
    public function registerLogger(ContainerBuilder $container, $path)
    {
        $logDispatcherPass = new LogDispatcherPass($path);
        $container->addCompilerPass($logDispatcherPass);
    }
}