Dock\IO\Process\InteractiveProcessBuilder

Complexity

Total Complexity

6

Size/Duplication

Total Lines	123
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	4
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	forCommand()	0	8	1
A	disableOutput()	0	6	1
A	withoutTimeout()	0	6	1
A	ifTakesMoreThan()	0	9	1
A	getManager()	0	15	1

<?php

namespace Dock\IO\Process;

use Dock\IO\Process\Pipe\NullPipe;
use Dock\IO\Process\Pipe\Pipe;
use Dock\IO\Process\WaitStrategy\TimeoutWait;
use Dock\IO\Process\WaitStrategy\WaitStrategy;
use Dock\IO\UserInteraction;
use Symfony\Component\Process\Process;

class InteractiveProcessBuilder
{
    /**
     * Default process timeout, in seconds.
     */
    const DEFAULT_TIMEOUT = 60;

    /**
     * @var InteractiveProcessManager
     */
    private $manager;

    /**
     * @var UserInteraction
     */
    private $userInteraction;

    /**
     * @var string
     */
    private $command;

    /**
     * @var Pipe
     */
    private $pipe;

    /**
     * @var WaitStrategy
     */
    private $waitStrategy;

    /**
     * Timeout of the built process, in seconds.
     *
     * @var int
     */
    private $timeout;

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

    /**
     * Set the process command.
     *
     * @param string $command
     *
     * @return InteractiveProcessBuilder
     */
    public function forCommand($command)
    {
        $this->command = $command;
        $this->pipe = new NullPipe();
        $this->manager = new InteractiveProcessManager($this->userInteraction);

        return $this;
    }

    /**
     * @return InteractiveProcessBuilder
     */
    public function disableOutput()
    {
        $this->pipe = new NullPipe();

        return $this;
    }

    /**
     * @return InteractiveProcessBuilder
     */
    public function withoutTimeout()
    {
        $this->timeout = null;

        return $this;
    }

    /**
     * Makes the process to call the given callback after the given time.
     *
     * @param int      $milliSeconds
     * @param callable $callback
     *
     * @return InteractiveProcessBuilder
     */
    public function ifTakesMoreThan($milliSeconds, callable $callback)
    {
        $manager = $this->manager;
        $this->waitStrategy = new TimeoutWait($milliSeconds, function () use ($callback, $manager) {
            $callback($manager);
        });

        return $this;
    }

    /**
     * Get generated process manager.
     *
     * @return InteractiveProcessManager
     */
    public function getManager()
    {
        $symfonyProcess = new Process($this->command);
        $symfonyProcess->setTimeout($this->timeout);

        $process = new InteractiveProcess(
            $symfonyProcess,
            $this->pipe,
            $this->waitStrategy
        );

        $this->manager->setProcess($process);

        return $this->manager;
    }
}