Churn\Process\Handler\SequentialProcessHandler

Complexity

Total Complexity

6

Size/Duplication

Total Lines	49
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	executeProcess()	0	7	2
A	process()	0	11	3

<?php

declare(strict_types=1);

namespace Churn\Process\Handler;

use Churn\Event\Broker;
use Churn\Event\Event\AfterFileAnalysisEvent;
use Churn\Process\ProcessFactory;
use Churn\Process\ProcessInterface;
use Churn\Result\Result;
use Generator;

/**
 * @internal
 */
final class SequentialProcessHandler extends BaseProcessHandler
{
    /**
     * @var Broker
     */
    private $broker;

    /**
     * @param Broker $broker The event broker.
     */
    public function __construct(Broker $broker)
    {
        $this->broker = $broker;
    }

    /**
     * Run the processes sequentially to gather information.
     *
     * @param Generator $filesFinder Collection of files.
     * @param ProcessFactory $processFactory Process Factory.
     * @psalm-param Generator<\Churn\File\File> $filesFinder
     */
    #[\Override]
    public function process(Generator $filesFinder, ProcessFactory $processFactory): void
    {
        foreach ($filesFinder as $file) {
            $result = new Result($file);

            foreach ($processFactory->createProcesses($file) as $process) {
                $this->executeProcess($process, $result);
            }

            $this->broker->notify(new AfterFileAnalysisEvent($result));
        }
    }

    /**
     * Execute a process and save the result when it's done.
     *
     * @param ProcessInterface $process The process to execute.
     * @param Result $result The result to complete.
     */
    private function executeProcess(ProcessInterface $process, Result $result): void
    {
        $process->start();

        while (!$process->isSuccessful());

        $this->saveResult($process, $result);
    }
}