VhostManager::processVhost() - Code Metrics - metfan/rabbit-setup - Measure and Improve Code Quality continuously with Scrutinizer

VhostManager::processVhost() C
last analyzed 2016-03-08 14:13 UTC

↳ Parent: VhostManager

Complexity

Conditions	11
Paths	16

Size

Total Lines	40
Code Lines	20

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
c	2
b	0
f	0
dl	0
loc	40
rs	5.2653
cc	11
eloc	20
nc	16
nop	2

How to fix Complexity

<?php
namespace Metfan\RabbitSetup\Manager\RabbitMq;

use Metfan\RabbitSetup\Http\ClientInterface;
use Metfan\RabbitSetup\Http\ClientPool;
use Psr\Log\LoggerInterface;

/**
 * Manager in charge of create Exchange and manage exchange, queue under this  vhost
 *
 * @author Ulrich
 * @package Metfan\RabbitSetup\Manager
 */
class VhostManager
{
    /**
     * @var ParameterManager
     */
    private $parameterManager;

    /**
     * @var ExchangeManager
     */
    private $exchangeManager;

    /**
     * @var QueueManager
     */
    private $queueManager;

    /**
     * @var ClientPool
     */
    private $clientPool;

    /**
     * @var LoggerInterface
     */
    private $logger;

    /**
     * @var PolicyManager
     */
    private $policyManager;

    /**
     * @param ClientPool $clientPool
     * @param ParameterManager $parameterManager
     * @param ExchangeManager $exchangeManager
     * @param QueueManager $queueManager
     * @param PolicyManager $policyManager
     * @param LoggerInterface $logger
     */
    public function __construct(
        ClientPool $clientPool,
        ParameterManager $parameterManager,
        ExchangeManager $exchangeManager,
        QueueManager $queueManager,
        PolicyManager $policyManager,
        LoggerInterface $logger)
    {

        $this->parameterManager = $parameterManager;
        $this->exchangeManager = $exchangeManager;
        $this->queueManager = $queueManager;
        $this->clientPool = $clientPool;
        $this->logger = $logger;
        $this->policyManager = $policyManager;
    }

    /**
     * check $configuration, get client related to connection config, create vhost, then process exchange and queue
     * @param $vhostName
     * @param array $configuration
     */
    public function processVhost($vhostName, array $configuration)
    {
        $client = $this->clientPool->getClientByName($configuration['connection']);

        $vhostName = urlencode($vhostName);

        $client->query(
            ClientInterface::METHOD_PUT,
            sprintf('/api/vhosts/%s', $vhostName),
            []);
        $this->logger->info(sprintf('Create vhost: <info>%s</info>', urldecode($vhostName)));

        //process parameters
        if (isset($configuration['parameters']) && count($configuration['parameters'])) {

            $this->parameterManager
                ->setClient($client)
                ->setVhost($vhostName);
            foreach ($configuration['parameters'] as $paramType => $parameters) {
                foreach ($parameters as $paramName => $paramOptions) {
                    $this->parameterManager->create($paramType, $paramName, $paramOptions);
                }
            }
        }

        //process exchanges
        if (isset($configuration['exchanges']) && count($configuration['exchanges'])) {
            $this->process($this->exchangeManager, $client, $vhostName, $configuration['exchanges']);
        }

        //process queues
        if (isset($configuration['queues']) && count($configuration['queues'])) {
            $this->process($this->queueManager, $client, $vhostName, $configuration['queues']);
        }

        //process policies
        if (isset($configuration['policies']) && count($configuration['policies'])) {
            $this->process($this->policyManager, $client, $vhostName, $configuration['policies']);
        }
    }

    private function process(RabbitMQManagerInterface $manager, ClientInterface $client, $vhostName, $elements)
    {
        $manager
            ->setClient($client)
            ->setVhost($vhostName);
        foreach ($elements as $name => $element) {
            $manager->create($name, $element);
        }
    }
}


1			<?php
2			namespace Metfan\RabbitSetup\Manager\RabbitMq;
3
4			use Metfan\RabbitSetup\Http\ClientInterface;
5			use Metfan\RabbitSetup\Http\ClientPool;
6			use Psr\Log\LoggerInterface;
7
8			/**
9			* Manager in charge of create Exchange and manage exchange, queue under this vhost
10			*
11			* @author Ulrich
12			* @package Metfan\RabbitSetup\Manager
13			*/
14			class VhostManager
15			{
16			/**
17			* @var ParameterManager
18			*/
19			private $parameterManager;
20
21			/**
22			* @var ExchangeManager
23			*/
24			private $exchangeManager;
25
26			/**
27			* @var QueueManager
28			*/
29			private $queueManager;
30
31			/**
32			* @var ClientPool
33			*/
34			private $clientPool;
35
36			/**
37			* @var LoggerInterface
38			*/
39			private $logger;
40
41			/**
42			* @var PolicyManager
43			*/
44			private $policyManager;
45
46			/**
47			* @param ClientPool $clientPool
48			* @param ParameterManager $parameterManager
49			* @param ExchangeManager $exchangeManager
50			* @param QueueManager $queueManager
51			* @param PolicyManager $policyManager
52			* @param LoggerInterface $logger
53			*/
54			public function __construct(
55			ClientPool $clientPool,
56			ParameterManager $parameterManager,
57			ExchangeManager $exchangeManager,
58			QueueManager $queueManager,
59			PolicyManager $policyManager,
60			LoggerInterface $logger)
61			{
62
63			$this->parameterManager = $parameterManager;
64			$this->exchangeManager = $exchangeManager;
65			$this->queueManager = $queueManager;
66			$this->clientPool = $clientPool;
67			$this->logger = $logger;
68			$this->policyManager = $policyManager;
69			}
70
71			/**
72			* check $configuration, get client related to connection config, create vhost, then process exchange and queue
73			* @param $vhostName
74			* @param array $configuration
75			*/
76			public function processVhost($vhostName, array $configuration)
77			{
78			$client = $this->clientPool->getClientByName($configuration['connection']);
79
80			$vhostName = urlencode($vhostName);
81
82			$client->query(
83			ClientInterface::METHOD_PUT,
84			sprintf('/api/vhosts/%s', $vhostName),
85			[]);
86			$this->logger->info(sprintf('Create vhost: <info>%s</info>', urldecode($vhostName)));
87
88			//process parameters
89			if (isset($configuration['parameters']) && count($configuration['parameters'])) {
90
91			$this->parameterManager
92			->setClient($client)
93			->setVhost($vhostName);
94			foreach ($configuration['parameters'] as $paramType => $parameters) {
95			foreach ($parameters as $paramName => $paramOptions) {
96			$this->parameterManager->create($paramType, $paramName, $paramOptions);
97			}
98			}
99			}
100
101			//process exchanges
102			if (isset($configuration['exchanges']) && count($configuration['exchanges'])) {
103			$this->process($this->exchangeManager, $client, $vhostName, $configuration['exchanges']);
104			}
105
106			//process queues
107			if (isset($configuration['queues']) && count($configuration['queues'])) {
108			$this->process($this->queueManager, $client, $vhostName, $configuration['queues']);
109			}
110
111			//process policies
112			if (isset($configuration['policies']) && count($configuration['policies'])) {
113			$this->process($this->policyManager, $client, $vhostName, $configuration['policies']);
114			}
115			}
116
117			private function process(RabbitMQManagerInterface $manager, ClientInterface $client, $vhostName, $elements)
118			{
119			$manager
120			->setClient($client)
121			->setVhost($vhostName);
122			foreach ($elements as $name => $element) {
123			$manager->create($name, $element);
124			}
125			}
126			}
127

metfan / rabbit-setup

VhostManager::processVhost() C last analyzed 2016-03-08 14:13 UTC

Complexity

Size

Duplication

Importance

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like

VhostManager::processVhost() C
last analyzed 2016-03-08 14:13 UTC