Cocotte\Shell\ProcessRunner

Complexity

Total Complexity

10

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	callback()	0	8	4
A	run()	0	22	3
A	mustRun()	0	5	2
A	__construct()	0	4	1

<?php declare(strict_types=1);

namespace Cocotte\Shell;

use Cocotte\Console\Style;
use Symfony\Component\Console\Helper\ProcessHelper;
use Symfony\Component\Console\Helper\ProgressBar;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Process\Exception\ProcessFailedException;
use Symfony\Component\Process\Process;

class ProcessRunner
{
    /**
     * @var Style
     */
    private $style;

    /**
     * @var ProcessHelper
     */
    private $processHelper;

    public function __construct(Style $style, ProcessHelper $processHelper)
    {
        $this->style = $style;
        $this->processHelper = $processHelper;
    }

    public function mustRun(Process $process, $displayProgressText = false)
    {
        $this->run($process, $displayProgressText);
        if (!$process->isSuccessful()) {
            throw new ProcessFailedException($process);
        }
    }

    public function run(Process $process, $displayProgressText = false)
    {
        $useProgress = !$this->style->isVerbose();
        $progressBar = $this->style->createProgressBar();
        $progressBar->setFormat('[%bar%] %message%');
        $progressBar->setMessage('');

        if ($useProgress) {
            $progressBar->start();
        }

        $this->processHelper->run(
            $this->style,
            $process,
            null,
            $this->callback($displayProgressText, $useProgress, $progressBar),
            OutputInterface::VERBOSITY_VERBOSE
        );

        if ($useProgress) {
            $progressBar->finish();
            $progressBar->clear();
        }
    }

    private function callback(bool $displayProgressText, bool $useProgress, ProgressBar $progressBar): \Closure
    {
        return function ($type, $buffer) use ($useProgress, $displayProgressText, $progressBar) {
            if ($useProgress) {
                if ($displayProgressText && Process::OUT === $type) {
                    $progressBar->setMessage(substr(preg_replace('#\s+#', ' ', $buffer), 0, 100));
                }
                $progressBar->advance();
            }
        };
    }
}