AlecRabbit\Spinner\Core\DriverLinker

Complexity

Total Complexity

10

Size/Duplication

Total Lines	52
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	update()	0	4	2
A	linkTimer()	0	10	2
A	link()	0	9	2
A	assertDriverCanBeLinked()	0	7	3

<?php

declare(strict_types=1);

namespace AlecRabbit\Spinner\Core;

use AlecRabbit\Spinner\Contract\ISubject;
use AlecRabbit\Spinner\Core\Contract\IDriver;
use AlecRabbit\Spinner\Core\Contract\IDriverLinker;
use AlecRabbit\Spinner\Core\Loop\Contract\ILoop;
use AlecRabbit\Spinner\Exception\DriverCanNotBeReplaced;
use AlecRabbit\Spinner\Exception\LogicException;

final class DriverLinker implements IDriverLinker
{
    private mixed $renderTimer = null;
    private ?IDriver $driver = null;

    public function __construct(
        private readonly ILoop $loop,
    ) {
    }

    public function link(IDriver $driver): void
    {
        $this->assertDriverCanBeLinked($driver);

        $this->linkTimer($driver);

        if ($this->driver === null) {
            $this->driver = $driver;
            $driver->attach($this);
        }
    }

    /**
     * @throws LogicException
     */
    private function assertDriverCanBeLinked(IDriver $driver): void
    {
        if ($this->driver === null || $this->driver === $driver) {
            return;
        }
        throw new DriverCanNotBeReplaced(
            'Other instance of driver is already linked.'
        );
    }

    private function linkTimer(IDriver $driver): void
    {
        if ($this->renderTimer) {
            $this->loop->cancel($this->renderTimer);
        }

        $this->renderTimer =
            $this->loop->repeat(
                $driver->getInterval()->toSeconds(),
                static fn() => $driver->render(),
            );
    }

    public function update(ISubject $subject): void
    {
        if ($subject === $this->driver) {

The condition $subject === $this->driver is always false.

            $this->linkTimer($subject);
        }
    }
}