Fresh\CentrifugoBundle\Command\InfoCommand

Complexity

Total Complexity

11

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	0

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	13	1
A	execute()	0	29	5
A	writeParameter()	0	23	5

<?php
/*
 * This file is part of the FreshCentrifugoBundle.
 *
 * (c) Artem Henvald <genvaldartem@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Fresh\CentrifugoBundle\Command;

use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;

/**
 * InfoCommand.
 *
 * @author Artem Henvald <genvaldartem@gmail.com>
 */
final class InfoCommand extends AbstractCommand
{
    protected static $defaultName = 'centrifugo:info';

    /**
     * {@inheritdoc}
     */
    protected function configure(): void
    {
        $this
            ->setDescription('Get information about running Centrifugo nodes')
            ->setHelp(
                <<<'HELP'
The <info>%command.name%</info> command allows to get information about running Centrifugo nodes:

Read more at https://centrifugal.github.io/centrifugo/server/http_api/#info
HELP
            )
        ;
    }

    /**
     * {@inheritdoc}
     */
    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $io = new SymfonyStyle($input, $output);

        try {
            $data = $this->centrifugo->info();

            if (!empty($data['nodes'])) {
                $io->title('Info');

                foreach ($data['nodes'] as $nodeInfo) {
                    $io->section(\sprintf('<comment>Node</comment> <info>%s</info>', $nodeInfo['name']));
                    foreach ($nodeInfo as $key => $value) {
                        $this->writeParameter($io, $key, $value);
                    }
                }

                $io->newLine();
            } else {
                $io->success('NO DATA');
            }
        } catch (\Throwable $e) {
            $io->error($e->getMessage());

            return $e->getCode();
        }

        return 0;
    }

    /**
     * @param SymfonyStyle $io
     * @param string       $key
     * @param array|mixed  $value
     * @param int          $padding
     * @param bool         $last
     */
    private function writeParameter(SymfonyStyle $io, string $key, $value, int $padding = 0, bool $last = false): void
    {
        $formattedKey = $key;
        if ($padding > 0) {
            $formattedKey = $last ? '└ ' : '├ ';
            $formattedKey .= $key;
            $formattedKey = \str_pad($formattedKey, \strlen($formattedKey) + $padding, ' ', \STR_PAD_LEFT);
        }

        if (!\is_array($value)) {
            $text = \sprintf('<info>%s</info>: %s', $formattedKey, (string) $value);
            $io->text($text);
        } else {
            $io->text(\sprintf('<info>%s</info>', $formattedKey));

            $total = \count($value);
            $i = 0;
            foreach ($value as $innerKey => $innerValue) {
                ++$i;
                $this->writeParameter($io, $innerKey, $innerValue, $padding + 2, $total === $i);
            }
        }
    }
}