Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory :  /home/corals/rentpix.corals.io/vendor/spatie/ray/src/Support/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

<?php

namespace Spatie\Ray\Support;

class RateLimiter
{
    /** @var int|null */
    protected $maxCalls;

    /** @var int|null */
    protected $maxPerSecond;

    /** @var CacheStore */
    protected $cache;

    /** @var bool */
    protected $notified;

    private function __construct(?int $maxCalls, ?int $maxPerSecond)
    {
        $this->maxCalls = $maxCalls;
        $this->maxPerSecond = $maxPerSecond;
        $this->cache = new CacheStore(new SystemClock());
    }

    public static function disabled(): self
    {
        return new self(null, null);
    }

    public function hit(): self
    {
        $this->cache()->hit();

        return $this;
    }

    public function max(?int $maxCalls): self
    {
        $this->maxCalls = $maxCalls;

        return $this;
    }

    public function perSecond(?int $callsPerSecond): self
    {
        $this->maxPerSecond = $callsPerSecond;

        return $this;
    }

    public function isMaxReached(): bool
    {
        if ($this->maxCalls === null) {
            return false;
        }

        $reached = $this->cache()->count() >= $this->maxCalls;

        if ($reached === false) {
            $this->notified = false;
        }

        return $reached;
    }

    public function isMaxPerSecondReached(): bool
    {
        if ($this->maxPerSecond === null) {
            return false;
        }

        $reached = $this->cache()->countLastSecond() >= $this->maxPerSecond;

        if ($reached === false) {
            $this->notified = false;
        }

        return $reached;
    }

    public function clear(): self
    {
        $this->maxCalls = null;
        $this->maxPerSecond = null;

        $this->cache()->clear();

        return $this;
    }

    public function isNotified(): bool
    {
        return $this->notified;
    }

    public function notify(): void
    {
        $this->notified = true;
    }

    public function cache(): CacheStore
    {
        return $this->cache;
    }
}