Dock\Cli\IO\InteractiveProcessRunner

Complexity

Total Complexity

9

Size/Duplication

Total Lines	71
Duplicated Lines	8.45 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	run()	0	16	2
A	followsUpWith()	0	10	1
B	getRunningProcessCallback()	6	16	5

<?php

namespace Dock\Cli\IO;

use Dock\IO\ProcessRunner;
use Dock\IO\UserInteraction;
use Symfony\Component\Process\Process;

class InteractiveProcessRunner implements ProcessRunner
{
    /**
     * @var UserInteraction
     */
    private $userInteraction;

    /**
     * @param UserInteraction $userInteraction
     */
    public function __construct(UserInteraction $userInteraction)
    {
        $this->userInteraction = $userInteraction;
    }

    /**
     * {@inheritdoc}
     */
    public function run($command, $mustSucceed = true)
    {
        $process = new Process($command);

        $this->userInteraction->write('<info>RUN</info> '.$process->getCommandLine());

        if ($mustSucceed) {
            $process->setTimeout(null);

            return $process->mustRun($this->getRunningProcessCallback($mustSucceed));
        }

        $process->run($this->getRunningProcessCallback($mustSucceed));

        return $process;
    }

    /**
     * {@inheritdoc}
     */
    public function followsUpWith($command, array $arguments = [])
    {
        $this->userInteraction->write(sprintf(
            '<info>RUN</info> %s %s',
            $command,
            implode(' ', $arguments)
        ));

        pcntl_exec($command, $arguments);
    }

    /**
     * @param bool $highlightErrors
     *
     * @return callable
     */
    private function getRunningProcessCallback($highlightErrors = true)
    {
        return function ($type, $buffer) use ($highlightErrors) {
            $lines = explode("\n", $buffer);
            $prefix = Process::ERR === $type ?
                ($highlightErrors ? '<error>ERR</error>' : 'ERR')
                : '<question>OUT</question>';

            foreach ($lines as $line) {

This code seems to be duplicated across your project.

                $line = trim($line);
                if (!empty($line)) {
                    $this->userInteraction->write($prefix.' '.$line);
                }
            }
        };
    }
}