Glooby\TaskBundle\Command\Task\RunCommand

Complexity

Total Complexity

9

Size/Duplication

Total Lines	68
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	configure()	0	7	1
A	execute()	0	23	5
A	runId()	0	14	2

<?php

namespace Glooby\TaskBundle\Command\Task;

use Doctrine\ORM\NoResultException;
use Glooby\TaskBundle\Task\TaskRunner;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\DependencyInjection\ContainerInterface;

/**
 * @author Emil Kilhage
 */
class RunCommand extends Command
{
    protected static $defaultName = 'task:run';
    private $container;

    public function __construct(ContainerInterface $container){
        parent::__construct();
        $this->container = $container;
    }

    /**
     * Configures the current command.
     */
    protected function configure()
    {
        $this->setName('task:run');
        $this->addArgument('service', InputArgument::OPTIONAL);
        $this->addOption('silent', 'S', InputOption::VALUE_NONE);
        $this->addOption('id', null, InputOption::VALUE_REQUIRED);
    }

    /**
     * {@inheritdoc}
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $runner =  $this->container->get('glooby_task.task_runner');
        $runner->setOutput($output);

        if ($input->getOption('id')) {
            $response = $this->runId($input, $runner);

$runner is of type object|null, but the function expects a object<Glooby\TaskBundle\Task\TaskRunner>.

            if (!$input->getOption('silent')) {
                if (!empty($response)) {
                    $output->writeln("task {$input->getOption('id')} finished: $response");
                } else {
                    $output->writeln("task {$input->getOption('id')} finished");
                }
            }
        } else {
            $response = $runner->runTask($input->getArgument('service'));

            if (!$input->getOption('silent')) {
                $output->writeln($response);
            }
        }
    }

    /**
     * @param InputInterface $input
     * @param TaskRunner $runner
     * @throws NoResultException
     */
    protected function runId(InputInterface $input, TaskRunner $runner)
    {
        $task = $this->container
            ->get('doctrine')
            ->getManager()
            ->getRepository('GloobyTaskBundle:QueuedTask')
            ->find($input->getOption('id'));

        if (null === $task) {
            throw new NoResultException();
        }

        return $runner->run($task);
    }
}