JobQueue\Application\Console\FlushTasks

Complexity

Total Complexity

4

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Test Coverage

Coverage

41.18%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	6	1
A	execute()	0	18	3

<?php

namespace JobQueue\Application\Console;

use JobQueue\Application\Utils\CommandTrait;
use JobQueue\Infrastructure\ServiceContainer;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Question\ConfirmationQuestion;

final class FlushTasks extends Command
{
    use CommandTrait;

    public function configure()
    {
        $this
            ->setName('flush')
            ->setDescription('Deletes all tasks from the queue')
            ->addOption('force', 'y', InputOption::VALUE_NONE, 'Skip validation')
        ;
    }

    /**
     *
     * @param InputInterface $input
     * @param OutputInterface $output
     * @return int
     */
    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        if (!$input->getOption('force')) {
            $helper = $this->getHelper('question'); /** @var \Symfony\Component\Console\Helper\QuestionHelper $helper */
            $question = new ConfirmationQuestion('Do you want to delete all tasks from the queue? (y/f) ', false);
            if (!$helper->ask($input, $output, $question)) {
                $output->writeln('Canceled');
                return 0;
            }
        }

        ServiceContainer::getInstance()
            ->queue
            ->flush();

        $this->formatInfoSection('Queue flushed', $output);

        return 0;
    }
}