Zenstruck\ScheduleBundle\Schedule\Task\Runner\CommandTaskRunner

Complexity

Total Complexity

8

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Test Coverage

Coverage

94.74%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	getFailureMessage()	0	7	3
A	__invoke()	0	20	3
A	supports()	0	3	1

<?php

namespace Zenstruck\ScheduleBundle\Schedule\Task\Runner;

use Symfony\Component\Console\Application;
use Symfony\Component\Console\Output\BufferedOutput;
use Symfony\Component\Process\Process;
use Zenstruck\ScheduleBundle\Schedule\Task;
use Zenstruck\ScheduleBundle\Schedule\Task\CommandTask;
use Zenstruck\ScheduleBundle\Schedule\Task\Result;
use Zenstruck\ScheduleBundle\Schedule\Task\TaskRunner;

/**
 * @author Kevin Bond <kevinbond@gmail.com>
 */
final class CommandTaskRunner implements TaskRunner
{
    /** @var Application */
    private $application;

    public function __construct(Application $application)
    {
        $this->application = $application;
    }

    /**
     * @param CommandTask $task
     */
    public function __invoke(Task $task): Result
    {
        $shellVerbosityResetter = new ShellVerbosityResetter();
        $output = new BufferedOutput();
        $this->application->setCatchExceptions(false);
        $this->application->setAutoExit(false);

        try {
            $exitCode = $this->application->run($task->createCommandInput($this->application), $output);

The method createCommandInput() does not exist on Zenstruck\ScheduleBundle\Schedule\Task. It seems like you code against a sub-type of Zenstruck\ScheduleBundle\Schedule\Task such as Zenstruck\ScheduleBundle\Schedule\Task\CommandTask.

        } catch (\Throwable $e) {
            return Result::exception($task, $e, $output->fetch());
        } finally {
            $shellVerbosityResetter->reset();
        }

        if (0 === $exitCode) {
            return Result::successful($task, $output->fetch());
        }

        return Result::failure($task, "Exit {$exitCode}: {$this->getFailureMessage($exitCode)}", $output->fetch());
    }

    public function supports(Task $task): bool
    {
        return $task instanceof CommandTask;
    }

    private function getFailureMessage(int $exitCode): string
    {
        if (\class_exists(Process::class) && isset(Process::$exitCodes[$exitCode])) {
            return Process::$exitCodes[$exitCode];
        }

        return 'Unknown error';
    }
}