Epfremme\ProcessQueue\Process\ProcessManager

Complexity

Total Complexity

6

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	3
Bugs	0	Features	2

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	enqueue()	0	18	2
A	run()	0	10	3

<?php
/**
 * File ProcessManager.php
 *
 * @author Edward Pfremmer <epfremme@nerdery.com>
 */
namespace Epfremme\ProcessQueue\Process;

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\PromiseInterface;
use Symfony\Component\Process\Process;

/**
 * Class ProcessManager
 *
 * @package Epfremme\ProcessQueue\Process
 */
class ProcessManager
{
    /**
     * @var ProcessQueue
     */
    private $queue;

    /**
     * @var ProcessFactory
     */
    private $factory;

    /**
     * ProcessFactory constructor
     *
     * @param ProcessFactory $factory
     * @param null $limit
     */
    public function __construct(ProcessFactory $factory, $limit = null)
    {
        $this->queue = new ProcessQueue($limit);

        $this->factory = $factory;
    }

    /**
     * @param \SplFileInfo|string $cwd
     * @return PromiseInterface
     */
    public function enqueue($cwd = null)
    {
        $process = $this->factory->make($cwd);

        /** @var Promise $promise */
        $promise = new Promise(function() use ($process, &$promise) {
            $process->wait();
            $process->getExitCode() > 0
                ? $promise->reject($process)
                : $promise->resolve($process);
        });

        $this->queue->add($process);

        $process->setOptions([ProcessQueue::PROMISE_KEY => $promise]);

        return $promise;
    }

    public function run(\Closure $tick = null)
    {
        $queue = $this->queue;

        /** @var Process $next */
        foreach ($queue() as $next) {
            $next->start();
            $tick && $tick();
        }
    }
}