GravityMedia\Commander\Commander\TaskRunner

Complexity

Total Complexity

11

Size/Duplication

Total Lines	129
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	6

Test Coverage

Coverage

100%

Importance

Changes	4
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	__invoke()	0	5	1
A	logMessage()	0	13	3
A	renderOutput()	0	12	3
A	runAll()	0	6	2
A	run()	0	12	1

<?php
/**
 * This file is part of the Commander project.
 *
 * @author Daniel Schröder <daniel.schroeder@gravitymedia.de>
 */

namespace GravityMedia\Commander\Commander;

use Monolog\Logger;
use Psr\Log\LoggerInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Process\Process;

/**
 * Task runner class.
 *
 * @package GravityMedia\Commander\Commander
 */
class TaskRunner
{
    /**
     * The task manager.
     *
     * @var TaskManager
     */
    protected $taskManager;

    /**
     * The output.
     *
     * @var OutputInterface
     */
    protected $output;

    /**
     * The logger.
     *
     * @var null|LoggerInterface
     */
    protected $logger;

    /**
     * Create task runner object.
     *
     * @param TaskManager          $taskManager
     * @param OutputInterface      $output
     * @param null|LoggerInterface $logger
     */
    public function __construct(TaskManager $taskManager, OutputInterface $output, LoggerInterface $logger = null)
    {
        $this->taskManager = $taskManager;
        $this->output = $output;
        $this->logger = $logger;
    }

    /**
     * Gets called when the object is used as a callback.
     *
     * @param string $type
     * @param string $buffer
     *
     * @return void
     */
    public function __invoke($type, $buffer)
    {
        $this->logMessage($type, $buffer);
        $this->renderOutput($type, $buffer);
    }

    /**
     * Log message.
     *
     * @param string $type
     * @param string $message
     *
     * @return void
     */
    protected function logMessage($type, $message)
    {
        if (null === $this->logger) {
            return;
        }

        $logLevel = Logger::INFO;
        if (Process::ERR === $type) {
            $logLevel = Logger::ERROR;
        }

        $this->logger->log($logLevel, $message);
    }

    /**
     * Render output.
     *
     * @param string $type
     * @param string $message
     *
     * @return void
     */
    protected function renderOutput($type, $message)
    {
        if ($this->output->isQuiet()) {
            return;
        }

        if (Process::ERR === $type) {
            $message = sprintf('<error>%s</error>', $message);
        }

        $this->output->writeln($message);
    }

    /**
     * Run all tasks from the task manager.
     *
     * @param int $timeout
     *
     * @return void
     */
    public function runAll($timeout)
    {
        while (null !== $task = $this->taskManager->findNextTask()) {
            $this->run($task, $timeout);
        }
    }

    /**
     * Run single task.
     *
     * @param Task $task
     * @param int  $timeout
     *
     * @return void
     */
    public function run($task, $timeout)
    {
        $process = new Process($task->getEntity()->getCommandline());
        $process->setTimeout($timeout);
        $process->start($this);

        $task->defer($process->getPid(), function () use ($process) {
            $process->wait($this);

            return $process->getExitCode();
        });
    }
}