AlecRabbit\Spinner\Core\DriverLinker

Complexity

Total Complexity

13

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

7 Methods

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

<?php

declare(strict_types=1);


namespace AlecRabbit\Spinner\Core;

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

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

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

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

        if ($this->optionLinker === OptionLinker::ENABLED) {
            $this->linkTimer($driver);

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

    private function assertDriver(IDriver $driver): void
    {
        if ($this->driver === null || $this->driver === $driver) {
            return;
        }
        throw new LogicException(
            'Other instance of Driver is already linked.'
        );
    }

    private function linkTimer(IDriver $driver): void
    {
        $this->unlinkTimer();

        $interval = $driver->getInterval()->toSeconds();

        $this->timer =
            $this->loop->repeat(
                $interval,
                static fn() => $driver->render()
            );
    }

    private function unlinkTimer(): void
    {
        if ($this->timer) {
            $this->loop->cancel($this->timer);
            $this->timer = null;
        }
    }

    private function observe(IDriver $driver): void
    {
        $this->driver = $driver;
        $driver->attach($this);
    }

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

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

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