Basebuilder\Scheduling\Command\Run

Complexity

Total Complexity

14

Size/Duplication

Total Lines	86
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	configure()	0	6	1
B	execute()	0	33	5
A	runEvent()	0	11	3
A	handleProcessOutput()	0	7	4

<?php

namespace Basebuilder\Scheduling\Command;

use Basebuilder\Scheduling\Event;
use Basebuilder\Scheduling\Event\Process;
use Basebuilder\Scheduling\Schedule;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

/**
 * This command runs all scheduled tasks that are due for execution, replacing the need for multiple CRON jobs
 */
class Run extends Command
{
    /**
     * @var Schedule
     */
    protected $schedule;

    protected $minimumVerbosity = OutputInterface::VERBOSITY_VERBOSE;

    /**
     * @param Schedule    $schedule
     * @param string|null $name
     */
    public function __construct(Schedule $schedule, $name = null)
    {
        $this->schedule = $schedule;
        parent::__construct($name);
    }

    /**
     * @inheritdoc
     */
    protected function configure()
    {
        $this
            ->setName('scheduler:run')
            ->addArgument('force', InputArgument::OPTIONAL, 'Force a event to run');
    }

    /**
     * @inheritdoc
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $schedule = $this->schedule;

        $forcedEventName = $input->getArgument('force');

        if ($forcedEventName) {
            $events = array_filter($schedule->allEvents(), function (Event $event) use ($forcedEventName) {
                return $event->getName() === $forcedEventName;
            });

            if (count($events) < 1) {
                throw new \RuntimeException('No events with that name');
            }

            $this->runEvent(array_shift($events), $output);
            exit;

The method execute() contains an exit expression.

        }

        $events = $schedule->dueEvents();

        if ($output->getVerbosity() >= $this->minimumVerbosity) {
            $output->writeln(
                '======================================================' . PHP_EOL .
                '# Running schedule for <info>' . $schedule->getName() . '</info>' . PHP_EOL .
                '======================================================'
            );
        }

        foreach ($events as $event) {
            $this->runEvent($event, $output);
        }
    }

    protected function runEvent(Event $event, OutputInterface $output)
    {
        if ($output->getVerbosity() >= $this->minimumVerbosity) {
            $output->writeln('Running event <info>"' . (string) $event . '"</info>');
        }

        $result = $event->run();
        if ($event instanceof Process)  {
            $this->handleProcessOutput($result, $output);
        }
    }

    protected function handleProcessOutput(\Symfony\Component\Process\Process $process, OutputInterface $output)
    {
        if ($process->isTerminated() && $output->getVerbosity() >= $this->minimumVerbosity) {
            $tag = $process->isSuccessful() ? 'info' : 'error';
            $output->writeln('Exit code: <' . $tag . '>' . $process->getExitCode() . '</' . $tag . '>');
        }
    }
}