GendoriaCommandQueueRabbitMqDriverExtension::prepend() - Code Metrics - Inspection of "Added Isobar logo." - Gendoria/command-queue-rabbitmq-bundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 59049f...fab486 )

by Tomasz

created 2016-10-04 12:14 UTC

prepend() A

↳ Parent: GendoriaCommandQueueRabbitMqDriverExtension

Complexity

Conditions	2
Paths	2

Size

Total Lines	64
Code Lines	43

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	64
rs	9.3956
c	0
b	0
f	0
cc	2
eloc	43
nc	2
nop	1

How to fix Long Method

<?php

namespace Gendoria\CommandQueueRabbitMqDriverBundle\DependencyInjection;

use Symfony\Component\Config\FileLocator;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Extension\PrependExtensionInterface;
use Symfony\Component\DependencyInjection\Loader;
use Symfony\Component\DependencyInjection\Reference;
use Symfony\Component\HttpKernel\DependencyInjection\Extension;

/**
 * This is the class that loads and manages your bundle configuration.
 *
 * To learn more see {@link http://symfony.com/doc/current/cookbook/bundles/extension.html}
 */
class GendoriaCommandQueueRabbitMqDriverExtension extends Extension implements PrependExtensionInterface
{
    /**
     * Get extension alias.
     *
     * @return string
     */
    public function getAlias()
    {
        return 'gendoria_command_queue_rabbit_mq_driver';
    }

    /**
     * Load extension.
     *
     * @param array            $configs
     * @param ContainerBuilder $container
     */
    public function load(array $configs, ContainerBuilder $container)
    {
        $configuration = new Configuration($this->getAlias());
        $config = $this->processConfiguration($configuration, $configs);

        $loader = new Loader\YamlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));
        $loader->load('services.yml');

        foreach ($config['drivers'] as $driverId => $driver) {
            $newDriver = clone $container->getDefinition('gendoria_command_queue_rabbit_mq_driver.send_driver');
            $newDriver->replaceArgument(
                1,
                new Reference(sprintf('old_sound_rabbit_mq.%s_producer', $driver['producer_name']))
            );
            $container->setDefinition('gendoria_command_queue_rabbit_mq_driver.driver.'.$driverId, $newDriver);

            $newWorker = clone $container->getDefinition('gendoria_command_queue_rabbit_mq_driver.external_data_worker');
            $newWorker->replaceArgument(
                3,
                new Reference(sprintf('old_sound_rabbit_mq.%s_producer', $driver['producer_name'].'_reschedule_delayed'))
            );
            $container->setDefinition('gendoria_command_queue_rabbit_mq_driver.worker.'.$driverId, $newWorker);
        }
        $container->removeDefinition('gendoria_command_queue_rabbit_mq_driver.send_driver');
        $container->removeDefinition('gendoria_command_queue_rabbit_mq_driver.external_data_worker');
    }

    /**
     * Prepend configuration to OldSoundRabbitMQBundle.
     *
     * @param ContainerBuilder $container
     */
    public function prepend(ContainerBuilder $container)
    {
        $configs = $container->getExtensionConfig($this->getAlias());
        $currentConfig = $this->processConfiguration(new Configuration($this->getAlias()), $configs);

        $rabbitMQConfig = array(
            'consumers' => array(),
            'producers' => array(),
        );

        foreach ($currentConfig['drivers'] as $driverId => $driver) {
            $exchangeOptions = array(
                'name' => $driver['exchange_name'],
                'type' => 'topic',
            );

            $rabbitMQConfig['producers'][$driver['producer_name']] = array(
                'connection' => $driver['rabbitmq_connection'],
                'exchange_options' => $exchangeOptions,
            );

            $rabbitMQConfig['consumers'][$driver['consumer_name']] = array(
                'connection' => $driver['rabbitmq_connection'],
                'exchange_options' => $exchangeOptions,
                'queue_options' => array(
                    'name' => $driver['consumer_queue_name'],
                    'durable' => true,
                    'auto_delete' => false,
                    'routing_keys' => array('*'),
                ),
                'qos_options' => array(
                    'prefetch_size' => 0,
                    'prefetch_count' => 1,
                    'global' => false,
                ),
                'callback' => 'gendoria_command_queue_rabbit_mq_driver.worker.'.$driverId,
            );

            $rabbitMQConfig['producers'][$driver['producer_name'].'_reschedule_delayed'] = array(
                'connection' => $driver['rabbitmq_connection'],
                'exchange_options' => array_merge($exchangeOptions, array(
                    'name' => $driver['exchange_name'].'-reschedule-delayed',
                )),
            );

            $rabbitMQConfig['consumers'][$driver['consumer_name'].'_reschedule_delayed'] = array(
                'connection' => $driver['rabbitmq_connection'],
                'exchange_options' => $rabbitMQConfig['producers'][$driver['producer_name'].'_reschedule_delayed']['exchange_options'],
                'queue_options' => array(
                    'name' => $driver['consumer_queue_name'].'-reschedule-delayed',
                    'durable' => true,
                    'auto_delete' => false,
                    'routing_keys' => array('*'),
                    'arguments' => array(
                        'x-dead-letter-exchange' => array('S', $exchangeOptions['name']),
                        'x-message-ttl' => array('I', 600000), //10 minutes
                    ),
                ),
                'callback' => 'gendoria_command_queue_rabbit_mq_driver.services_reschedule_worker',
            );
        }

        $container->prependExtensionConfig('old_sound_rabbit_mq', $rabbitMQConfig);
    }
}


1			<?php
2
3			namespace Gendoria\CommandQueueRabbitMqDriverBundle\DependencyInjection;
4
5			use Symfony\Component\Config\FileLocator;
6			use Symfony\Component\DependencyInjection\ContainerBuilder;
7			use Symfony\Component\DependencyInjection\Extension\PrependExtensionInterface;
8			use Symfony\Component\DependencyInjection\Loader;
9			use Symfony\Component\DependencyInjection\Reference;
10			use Symfony\Component\HttpKernel\DependencyInjection\Extension;
11
12			/**
13			* This is the class that loads and manages your bundle configuration.
14			*
15			* To learn more see {@link http://symfony.com/doc/current/cookbook/bundles/extension.html}
16			*/
17			class GendoriaCommandQueueRabbitMqDriverExtension extends Extension implements PrependExtensionInterface
18			{
19			/**
20			* Get extension alias.
21			*
22			* @return string
23			*/
24			public function getAlias()
25			{
26			return 'gendoria_command_queue_rabbit_mq_driver';
27			}
28
29			/**
30			* Load extension.
31			*
32			* @param array $configs
33			* @param ContainerBuilder $container
34			*/
35			public function load(array $configs, ContainerBuilder $container)
36			{
37			$configuration = new Configuration($this->getAlias());
38			$config = $this->processConfiguration($configuration, $configs);
39
40			$loader = new Loader\YamlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));
41			$loader->load('services.yml');
42
43			foreach ($config['drivers'] as $driverId => $driver) {
44			$newDriver = clone $container->getDefinition('gendoria_command_queue_rabbit_mq_driver.send_driver');
45			$newDriver->replaceArgument(
46			1,
47			new Reference(sprintf('old_sound_rabbit_mq.%s_producer', $driver['producer_name']))
48			);
49			$container->setDefinition('gendoria_command_queue_rabbit_mq_driver.driver.'.$driverId, $newDriver);
50
51			$newWorker = clone $container->getDefinition('gendoria_command_queue_rabbit_mq_driver.external_data_worker');
52			$newWorker->replaceArgument(
53			3,
54			new Reference(sprintf('old_sound_rabbit_mq.%s_producer', $driver['producer_name'].'_reschedule_delayed'))
55			);
56			$container->setDefinition('gendoria_command_queue_rabbit_mq_driver.worker.'.$driverId, $newWorker);
57			}
58			$container->removeDefinition('gendoria_command_queue_rabbit_mq_driver.send_driver');
59			$container->removeDefinition('gendoria_command_queue_rabbit_mq_driver.external_data_worker');
60			}
61
62			/**
63			* Prepend configuration to OldSoundRabbitMQBundle.
64			*
65			* @param ContainerBuilder $container
66			*/
67			public function prepend(ContainerBuilder $container)
68			{
69			$configs = $container->getExtensionConfig($this->getAlias());
70			$currentConfig = $this->processConfiguration(new Configuration($this->getAlias()), $configs);
71
72			$rabbitMQConfig = array(
73			'consumers' => array(),
74			'producers' => array(),
75			);
76
77			foreach ($currentConfig['drivers'] as $driverId => $driver) {
78			$exchangeOptions = array(
79			'name' => $driver['exchange_name'],
80			'type' => 'topic',
81			);
82
83			$rabbitMQConfig['producers'][$driver['producer_name']] = array(
84			'connection' => $driver['rabbitmq_connection'],
85			'exchange_options' => $exchangeOptions,
86			);
87
88			$rabbitMQConfig['consumers'][$driver['consumer_name']] = array(
89			'connection' => $driver['rabbitmq_connection'],
90			'exchange_options' => $exchangeOptions,
91			'queue_options' => array(
92			'name' => $driver['consumer_queue_name'],
93			'durable' => true,
94			'auto_delete' => false,
95			'routing_keys' => array('*'),
96			),
97			'qos_options' => array(
98			'prefetch_size' => 0,
99			'prefetch_count' => 1,
100			'global' => false,
101			),
102			'callback' => 'gendoria_command_queue_rabbit_mq_driver.worker.'.$driverId,
103			);
104
105			$rabbitMQConfig['producers'][$driver['producer_name'].'_reschedule_delayed'] = array(
106			'connection' => $driver['rabbitmq_connection'],
107			'exchange_options' => array_merge($exchangeOptions, array(
108			'name' => $driver['exchange_name'].'-reschedule-delayed',
109			)),
110			);
111
112			$rabbitMQConfig['consumers'][$driver['consumer_name'].'_reschedule_delayed'] = array(
113			'connection' => $driver['rabbitmq_connection'],
114			'exchange_options' => $rabbitMQConfig['producers'][$driver['producer_name'].'_reschedule_delayed']['exchange_options'],
115			'queue_options' => array(
116			'name' => $driver['consumer_queue_name'].'-reschedule-delayed',
117			'durable' => true,
118			'auto_delete' => false,
119			'routing_keys' => array('*'),
120			'arguments' => array(
121			'x-dead-letter-exchange' => array('S', $exchangeOptions['name']),
122			'x-message-ttl' => array('I', 600000), //10 minutes
123			),
124			),
125			'callback' => 'gendoria_command_queue_rabbit_mq_driver.services_reschedule_worker',
126			);
127			}
128
129			$container->prependExtensionConfig('old_sound_rabbit_mq', $rabbitMQConfig);
130			}
131			}
132

Gendoria / command-queue-rabbitmq-bundle

Push — master ( 59049f...fab486 )

prepend() A

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like