RabbitMqModule\Controller\SetupFabricController

Complexity

Total Complexity

9

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Test Coverage

Coverage

94.29%

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
B	indexAction()	0	24	4
A	getServiceParts()	0	18	3
A	getServiceKeys()	0	10	2

<?php

namespace RabbitMqModule\Controller;

use RabbitMqModule\Service\SetupFabricAwareInterface;
use Zend\Console\ColorInterface;

/**
 * Class SetupFabricController
 * @package RabbitMqModule\Controller
 */
class SetupFabricController extends AbstractConsoleController
{
    /**
     * Default action if none provided
     *
     * @return \Zend\Console\Response
     */
    public function indexAction()
    {
        /** @var \Zend\Console\Response $response */
        $response = $this->getResponse();
        $this->getConsole()->writeLine('Setting up the AMQP fabric');

        try {
            $services = $this->getServiceParts();

            foreach ($services as $service) {
                if (!$service instanceof SetupFabricAwareInterface) {
                    continue;
                }
                $service->setupFabric();
            }
        } catch (\Exception $e) {
            $response->setErrorLevel(1);
            $this->getConsole()->writeText(sprintf('Exception: %s', $e->getMessage()), ColorInterface::LIGHT_RED);

            return $response;
        } finally {
            return $response;
        }
    }

    /**
     * @return SetupFabricAwareInterface[]
     */
    protected function getServiceParts()
    {
        $serviceKeys = [
            'consumer',
            'producer',
            'rpc_client',
            'rpc_server',
        ];
        $parts = [];
        foreach ($serviceKeys as $serviceKey) {
            $keys = $this->getServiceKeys($serviceKey);
            foreach ($keys as $key) {
                $parts[] = $this->getServiceLocator()->get(sprintf('rabbitmq_module.%s.%s', $serviceKey, $key));
            }
        }

        return $parts;
    }

    /**
     *
     * @param $service
     * @return array
     */
    protected function getServiceKeys($service)
    {
        /** @var array $config */
        $config = $this->getServiceLocator()->get('Configuration');
        if (!isset($config['rabbitmq_module'][$service])) {
            throw new \RuntimeException(sprintf('No service "rabbitmq_module.%s" found in configuration', $service));
        }

        return array_keys($config['rabbitmq_module'][$service]);
    }
}