WyriHaximus\React\Cron

Complexity

Total Complexity

7

Size/Duplication

Total Lines	52
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

90.48%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	create()	0	4	1
A	tick()	0	6	2
A	perform()	0	16	3

<?php declare(strict_types=1);

namespace WyriHaximus\React;

use React\EventLoop\LoopInterface;
use WyriHaximus\React\Mutex\Memory;
use WyriHaximus\React\Mutex\MutexInterface;

final class Cron
{
    /** @var ActionInterface[] */
    private $actions;

    /** @var MutexInterface */
    private $mutex;

    /**
     * @param SchedulerInterface $scheduler
     * @param MutexInterface     $mutex
     * @param ActionInterface[]  $actions
     */
    private function __construct(SchedulerInterface $scheduler, MutexInterface $mutex, ActionInterface ...$actions)
    {
        $this->actions = $actions;

It seems like $actions of type array<integer,array<integer,object<WyriHaximus\React\ActionInterface>>> is incompatible with the declared type array<integer,object<WyriHaximus\React\ActionInterface>> of property $actions.

        $this->mutex = $mutex;

        $scheduler->schedule(function (): void {
            $this->tick();
        });
    }

    public static function create(LoopInterface $loop, ActionInterface ...$actions)
    {
        return new self(new Scheduler($loop), new Memory(), ...$actions);
    }

    private function tick(): void
    {
        foreach ($this->actions as $action) {
            $this->perform($action);
        }
    }

    private function perform(ActionInterface $action): void
    {
        if ($action->isDue() === false) {
            return;
        }

        $this->mutex->acquire($action->getKey())->then(function ($lock) use ($action) {
            if ($lock === false) {
                return;
            }

            return $action->perform()->then(function () use ($action, $lock) {
                return $this->mutex->release($lock);
            });
        })->done();
    }
}