BenTools\FunnelHttpClient\Storage\ArrayStorage

Complexity

Total Complexity

12

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	increment()	0	11	3
A	getRemainingCalls()	0	3	1
A	__construct()	0	4	1
A	getRemainingTime()	0	7	2
A	decrement()	0	5	2
A	isExpired()	0	7	2
A	reset()	0	4	1

<?php

namespace BenTools\FunnelHttpClient\Storage;

final class ArrayStorage implements ThrottleStorageInterface
{
    private int $currentRequests = 0;

    private float|null $startedAt = null;

    public function __construct(
        private int $maxRequests,
        private float $timeWindow
    ) {
    }

    /**
     * @inheritDoc
     */
    public function getRemainingCalls(): int
    {
        return \max(0, ($this->maxRequests - $this->currentRequests));
    }

    /**
     * @inheritDoc
     */
    public function getRemainingTime(): float
    {
        if (null === $this->startedAt) {
            return 0;
        }

        return \max(0, ($this->startedAt + $this->timeWindow) - \microtime(true));
    }

    /**
     * @inheritDoc
     */
    public function increment(): void
    {
        if ($this->isExpired()) {
            $this->reset();
        }

        if (null === $this->startedAt) {
            $this->startedAt = \microtime(true);
        }

        $this->currentRequests++;
    }

    public function decrement(): void
    {
        $this->currentRequests--;
        if ($this->currentRequests <= 0) {
            $this->reset();
        }
    }


    private function reset(): void
    {
        $this->currentRequests = 0;
        $this->startedAt = null;
    }

    private function isExpired(): bool
    {
        if (null === $this->startedAt) {
            return false;
        }

        return \microtime(true) > ($this->startedAt + $this->timeWindow);
    }
}