AlecRabbit\Spinner\Asynchronous\Factory\LoopProbeFactory

Complexity

Total Complexity

9

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	isALoopProbeClass()	0	3	1
A	registerProbes()	0	6	4
A	getProbe()	0	13	3

<?php

declare(strict_types=1);

namespace AlecRabbit\Spinner\Asynchronous\Factory;

use AlecRabbit\Spinner\Core\Contract\Loop\Contract\ILoopProbe;
use AlecRabbit\Spinner\Core\Factory\Contract\ILoopProbeFactory;
use AlecRabbit\Spinner\Exception\DomainException;
use ArrayObject;
use Traversable;

final class LoopProbeFactory implements ILoopProbeFactory
{
    /** @var ArrayObject<int, class-string<ILoopProbe>> $loopProbes */
    private ArrayObject $loopProbes;

    /**
     * @param Traversable<class-string<ILoopProbe>> $loopProbes
     */
    public function __construct(
        Traversable $loopProbes,
    ) {
        $this->loopProbes = new ArrayObject([]);
        $this->registerProbes($loopProbes);
    }

    /**
     * @param Traversable<class-string<ILoopProbe>> $loopProbes
     */
    private function registerProbes(Traversable $loopProbes): void
    {
        /** @var class-string<ILoopProbe> $loopProbe */
        foreach ($loopProbes as $loopProbe) {
            if (self::isALoopProbeClass($loopProbe) && $loopProbe::isSupported()) {
                $this->loopProbes->append($loopProbe);
            }
        }
    }

    private static function isALoopProbeClass(string $loopProbe): bool
    {
        return is_subclass_of($loopProbe, ILoopProbe::class);
    }

    public function getProbe(): ILoopProbe
    {
        /** @var class-string<ILoopProbe> $loopProbe */
        foreach ($this->loopProbes as $loopProbe) {
            if ($loopProbe::isSupported()) {
                return new $loopProbe();
            }
        }
        throw new DomainException(
            'No supported event loop found.'
            . ' Check that you have installed one of the supported event loops.'
            . ' Check your probes list if you have modified it.'
            . ' If yoy what to use library in synchronous mode, set option explicitly.'
        );
    }
}