Churn\Process\Handler\ParallelProcessHandler::getProcessResults()

Complexity

Conditions	5
Paths	6

Size

Total Lines	18
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	ParallelProcessHandler::addToPool()	0	8	1

<?php declare(strict_types = 1);

namespace Churn\Process\Handler;

use Churn\File\File;
use Churn\Process\ChurnProcess;
use Churn\Process\Observer\OnSuccess;
use Churn\Process\ProcessFactory;
use Churn\Result\Result;
use function count;
use Generator;

class ParallelProcessHandler implements ProcessHandler
{
    /**
     * Array of completed processes.
     * @var array
     */
    private $completedProcesses;

    /**
     * Number of parallel jobs to run.
     * @var integer
     */
    private $numberOfParallelJobs;

    /**
     * ProcessManager constructor.
     * @param int $numberOfParallelJobs Number of parallel jobs to run.
     */
    public function __construct(int $numberOfParallelJobs)
    {
        $this->numberOfParallelJobs = $numberOfParallelJobs;
    }

    /**
     * Run the processes to gather information.
     * @param Generator      $filesFinder    Collection of files.
     * @param ProcessFactory $processFactory Process Factory.
     * @param OnSuccess      $onSuccess      The OnSuccess event observer.
     * @return void
     */
    public function process(
        Generator $filesFinder,
        ProcessFactory $processFactory,
        OnSuccess $onSuccess
    ): void {
        $pool = [];
        $this->completedProcesses = [];
        foreach ($filesFinder as $file) {
            while (count($pool) >= $this->numberOfParallelJobs) {
                $this->checkRunningProcesses($pool, $onSuccess);
            }
            $this->addToPool($pool, $file, $processFactory);
        }
        while (count($pool) > 0) {
            $this->checkRunningProcesses($pool, $onSuccess);
        }
    }

    /**
     * @param ChurnProcess[] $pool      Pool of processes.
     * @param OnSuccess      $onSuccess The OnSuccess event observer.
     * @return void
     */
    private function checkRunningProcesses(array &$pool, OnSuccess $onSuccess): void
    {
        foreach ($pool as $key => $process) {
            if ($process->isSuccessful()) {
                unset($pool[$key]);
                $this->sendEventIfComplete($this->getResult($process), $onSuccess);
            }
        }
    }

    /**
     * @param ChurnProcess[] $pool           Pool of processes.
     * @param File           $file           The file to process.
     * @param ProcessFactory $processFactory Process Factory.
     * @return void
     */
    private function addToPool(array &$pool, File $file, ProcessFactory $processFactory): void
    {
        $process = $processFactory->createGitCommitProcess($file);
        $process->start();
        $pool[$process->getKey()] = $process;
        $process = $processFactory->createCyclomaticComplexityProcess($file);
        $process->start();
        $pool[$process->getKey()] = $process;
    }

    /**
     * Returns the result of processes for a file.
     * @param ChurnProcess $process A successful process.
     * @return Result
     */
    private function getResult(ChurnProcess $process): Result
    {
        if (!isset($this->completedProcesses[$process->getFileName()])) {
            $this->completedProcesses[$process->getFileName()] = new Result($process->getFileName());
        }
        $result = $this->completedProcesses[$process->getFileName()];
        switch ($process->getType()) {
            case 'GitCommitProcess':
                $result->setCommits((int) $process->getOutput());
                break;
            case 'CyclomaticComplexityProcess':
                $result->setComplexity((int) $process->getOutput());
                break;
            default:
                // nothing to do
                break;
        }

        return $result;
    }

    /**
     * @param Result    $result    The result of the processes for a file.
     * @param OnSuccess $onSuccess The OnSuccess event observer.
     * @return void
     */
    private function sendEventIfComplete(Result $result, OnSuccess $onSuccess): void
    {
        if ($result->isComplete()) {
            unset($this->completedProcesses[$result->getFile()]);
            $onSuccess($result);
        }
    }
}