Ola\RabbitMqAdminToolkitBundle\Command\VhostDefineCommand

Complexity

Total Complexity

17

Size/Duplication

Total Lines	138
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	5

Test Coverage

Coverage

95.08%

Importance

Changes

0

<?php
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;

class VhostDefineCommand extends Command
{
    protected static $defaultName = 'rabbitmq:vhost:define';

    private ContainerInterface $serviceLocator;

This code did not parse for me. Apparently, there is an error somewhere around this line:

Syntax error, unexpected T_STRING, expecting T_FUNCTION or T_CONST

    private array $vhostList;

    private VhostHandler $vhostHandler;

    private bool $silentFailure;

    public function __construct(
        ContainerInterface $serviceLocator,
        array $vhostList,
        VhostHandler $vhostHandler,
        bool $silentFailure
    ) {
        parent::__construct();

        $this->serviceLocator = $serviceLocator;
        $this->vhostList = $vhostList;
        $this->vhostHandler = $vhostHandler;
        $this->silentFailure = $silentFailure;
    }

    /**
     * {@inheritDoc}
     */
    protected function configure()
    {
        $this
            ->setDescription('Create or update a vhost')
            ->addArgument('vhost', InputArgument::OPTIONAL, 'Which vhost should be configured ?')
        ;
    }

    /**
     * {@inheritDoc}
     */
    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $vhostList = $this->getVhostList($input);

        foreach ($vhostList as $vhost) {
            try {
                $this->comment($input, $output, sprintf(
                    'Define rabbitmq <info>%s</info> vhost configuration',
                    $vhost
                ));

                $vhostConfiguration = $this->getVhostConfiguration($vhost);
                $this->vhostHandler->define($vhostConfiguration);

                $this->success($input, $output, sprintf(
                    'Rabbitmq "%s" vhost configuration successfully %s !',
                    $vhost,
                    !$this->vhostHandler->exists($vhostConfiguration) ? 'created' : 'updated'
                ));
            } catch (\Exception $e) {
                if (!$this->silentFailure) {
                    throw $e;
                }
            }
        }

        return 0;
    }

    /**
     * Return Vhosts to process
     *
     * @param InputInterface $input
     *
     * @return array
     */
    private function getVhostList(InputInterface $input): array
    {
        $inputVhost = $input->getArgument('vhost');

        return empty($inputVhost) ? $this->vhostList : [$inputVhost];
    }

    /**
     * @param string $vhost
     *
     * @return VhostConfiguration
     *
     * @throws \InvalidArgumentException
     */
    private function getVhostConfiguration(string $vhost): VhostConfiguration
    {
        $serviceName = sprintf(
            OlaRabbitMqAdminToolkitExtension::VHOST_MANAGER_SERVICE_TEMPLATE,
            $vhost
        );

        if (!$this->serviceLocator->has($serviceName)) {
            throw new \InvalidArgumentException(sprintf(
                'No configuration service found for vhost : "%s"',
                $vhost
            ));
        }

        return $this->serviceLocator->get($serviceName);
    }

    /**
     * @param InputInterface $input
     * @param OutputInterface $output
     * @param string $message
     */
    private function comment(InputInterface $input, OutputInterface $output, string $message): void
    {
        $io = $this->getIO($input, $output);

        if (null !== $io && method_exists($io, 'comment')) {
            $io->comment($message);
        } else {
            $output->writeln(sprintf('<comment>%s</comment>', $message));
        }
    }

    /**
     * @param InputInterface $input
     * @param OutputInterface $output
     * @param string $message
     */
    private function success(InputInterface $input, OutputInterface $output, string $message): void
    {
        $io = $this->getIO($input, $output);

        if (null !== $io) {
            $io->success($message);
        } else {
            $output->writeln(sprintf('<info>%s</info>', $message));