ControleOnline\Command\DefaultCommand

Complexity

Total Complexity

6

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	__destruct()	0	3	1
A	addLog()	0	4	1
A	execute()	0	24	3

<?php

namespace ControleOnline\Command;

use Symfony\Component\Console\Command\Command;

The type Symfony\Component\Console\Command\Command was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Console\Input\InputInterface;

The type Symfony\Component\Console\Input\InputInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Console\Output\OutputInterface;

The type Symfony\Component\Console\Output\OutputInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Lock\LockFactory;

The type Symfony\Component\Lock\LockFactory was not found. Maybe you did not declare it correctly or list all dependencies?

use ControleOnline\Service\DatabaseSwitchService;

The type ControleOnline\Service\DatabaseSwitchService was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Console\Input\InputArgument;

The type Symfony\Component\Console\Input\InputArgument was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Console\Input\InputOption;

The type Symfony\Component\Console\Input\InputOption was not found. Maybe you did not declare it correctly or list all dependencies?

abstract class DefaultCommand extends Command
{
    protected $input;
    protected $output;
    protected $lock;
    protected $lockFactory;
    protected $databaseSwitchService;
    protected $loggerService;
    protected $skyNetService;

    abstract protected function runCommand(): int;

    public function __construct(string $name)
    {
        parent::__construct($name);
        $this->lock = $this->lockFactory->createLock($name);
        $this->addOption('domain', ['d'], InputOption::VALUE_OPTIONAL,  'Database domain identifier');
    }

    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $this->input = $input;
        $this->output = $output;

        $domain = $input->getOption('domain');

        if ($domain) {
            $this->addLog(sprintf('Executando worker para o domínio: %s', $domain));
            $this->databaseSwitchService->switchDatabaseByDomain($domain);
            $this->skyNetService->discoveryBotUser();
            return $this->runCommand();
        }

        $domains = $this->databaseSwitchService->getAllDomains();

        foreach ($domains as $domain) {
            $this->addLog(sprintf('Executando migrações para o domínio: %s', $domain));
            $this->databaseSwitchService->switchDatabaseByDomain($domain);
            $this->skyNetService->discoveryBotUser();
            $this->runCommand();
        }

        return Command::SUCCESS;
    }

    public function addLog(string|iterable $messages, int $options = 0, ?string $logName = 'integration')
    {
        $this->output->writeln($messages, $options);
        $this->loggerService->getLogger($logName)->info($messages);
    }

    public function __destruct()
    {
        $this->lock->release();
    }
}