ProcessManager::enqueue() - Code Metrics - Inspection of "Added invalid current working directory exception..." - epfremmer/process-queue - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Branch — develop (ff0d26)

by Edward

created 2015-12-22 19:42 UTC

ProcessManager::enqueue() A

↳ Parent: ProcessManager

Complexity

Conditions	2
Paths	1

Size

Total Lines	18
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	1

Metric	Value
c	2
b	0
f	1
dl	0
loc	18
rs	9.4286
cc	2
eloc	10
nc	1
nop	1

<?php
/**
 * File ProcessManager.php
 *
 * @author Edward Pfremmer <[email protected]>
 */
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();
        }
    }
}


1			<?php
2			/**
3			* File ProcessManager.php
4			*
5			* @author Edward Pfremmer <[email protected]>
6			*/
7			namespace Epfremme\ProcessQueue\Process;
8
9			use GuzzleHttp\Promise\Promise;
10			use GuzzleHttp\Promise\PromiseInterface;
11			use Symfony\Component\Process\Process;
12
13			/**
14			* Class ProcessManager
15			*
16			* @package Epfremme\ProcessQueue\Process
17			*/
18			class ProcessManager
19			{
20			/**
21			* @var ProcessQueue
22			*/
23			private $queue;
24
25			/**
26			* @var ProcessFactory
27			*/
28			private $factory;
29
30			/**
31			* ProcessFactory constructor
32			*
33			* @param ProcessFactory $factory
34			* @param null $limit
35			*/
36			public function __construct(ProcessFactory $factory, $limit = null)
37			{
38			$this->queue = new ProcessQueue($limit);
39
40			$this->factory = $factory;
41			}
42
43			/**
44			* @param \SplFileInfo\|string $cwd
45			* @return PromiseInterface
46			*/
47			public function enqueue($cwd = null)
48			{
49			$process = $this->factory->make($cwd);
50
51			/** @var Promise $promise */
52			$promise = new Promise(function() use ($process, &$promise) {
53			$process->wait();
54			$process->getExitCode() > 0
55			? $promise->reject($process)
56			: $promise->resolve($process);
57			});
58
59			$this->queue->add($process);
60
61			$process->setOptions([ProcessQueue::PROMISE_KEY => $promise]);
62
63			return $promise;
64			}
65
66			public function run(\Closure $tick = null)
67			{
68			$queue = $this->queue;
69
70			/** @var Process $next */
71			foreach ($queue() as $next) {
72			$next->start();
73			$tick && $tick();
74			}
75			}
76			}
77

epfremmer / process-queue

Branch — develop (ff0d26)

ProcessManager::enqueue() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like