Dock\IO\Process\InteractiveProcess

Complexity

Total Complexity

6

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	3
Bugs	0	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	updatePipe()	0	4	1
A	updateWaitStrategy()	0	4	1
A	getProcess()	0	4	1
A	__construct()	0	6	1
A	run()	0	12	2

<?php

namespace Dock\IO\Process;

use Dock\IO\Process\Pipe\Pipe;
use Dock\IO\Process\WaitStrategy\WaitStrategy;
use Symfony\Component\Process\Process;

class InteractiveProcess
{
    /**
     * @var Pipe
     */
    private $pipe;
    /**
     * @var WaitStrategy
     */
    private $waitStrategy;
    /**
     * @var Process
     */
    private $process;

    /**
     * @param Process      $process
     * @param Pipe         $pipe
     * @param WaitStrategy $waitStrategy
     */
    public function __construct(Process $process, Pipe $pipe, WaitStrategy $waitStrategy)
    {
        $this->pipe = $pipe;
        $this->waitStrategy = $waitStrategy;
        $this->process = $process;
    }

    /**
     * @param Pipe $pipe
     */
    public function updatePipe(Pipe $pipe)
    {
        $this->pipe = $pipe;
    }

    /**
     * @param WaitStrategy $waitStrategy
     */
    public function updateWaitStrategy(WaitStrategy $waitStrategy)
    {
        $this->waitStrategy = $waitStrategy;
    }

    /**
     * Run the process.
     */
    public function run()
    {
        $this->process->start(function ($type, $buffer) {
            if (Process::ERR === $type) {
                $this->pipe->error($buffer);
            } else {
                $this->pipe->output($buffer);
            }
        });

        $this->waitStrategy->wait($this->process);
    }

    /**
     * @return Process
     */
    public function getProcess()
    {
        return $this->process;
    }
}