RateLimiter::handle() - Code Metrics - spatie/guzzle-rate-limiter-middleware - Measure and Improve Code Quality continuously with Scrutinizer

RateLimiter::handle() A
last analyzed 2020-07-16 06:49 UTC

↳ Parent: RateLimiter

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	15
rs	9.7666
c	0
b	0
f	0
cc	2
nc	2
nop	1

<?php

namespace Spatie\GuzzleRateLimiterMiddleware;

class RateLimiter
{
    const TIME_FRAME_MINUTE = 'minute';
    const TIME_FRAME_SECOND = 'second';

    /** @var int */
    protected $limit;

    /** @var string */
    protected $timeFrame;

    /** @var \Spatie\RateLimiter\Store */
    protected $store;

    /** @var \Spatie\GuzzleRateLimiterMiddleware\Deferrer */
    protected $deferrer;

    public function __construct(
        int $limit,
        string $timeFrame,
        Store $store,
        Deferrer $deferrer
    ) {
        $this->limit = $limit;
        $this->timeFrame = $timeFrame;
        $this->store = $store;

        $this->deferrer = $deferrer;
    }

    public function handle(callable $callback)
    {
        $delayUntilNextRequest = $this->delayUntilNextRequest();

        if ($delayUntilNextRequest > 0) {
            $this->deferrer->sleep($delayUntilNextRequest);
        }

        $this->store->push(
            $this->deferrer->getCurrentTime(),
            $this->limit
        );

        return $callback();
    }

    protected function delayUntilNextRequest(): int
    {
        $currentTimeFrameStart = $this->deferrer->getCurrentTime() - $this->timeFrameLengthInMilliseconds();

        $requestsInCurrentTimeFrame = array_values(array_filter(
            $this->store->get(),
            function (int $timestamp) use ($currentTimeFrameStart) {
                return $timestamp >= $currentTimeFrameStart;
            }
        ));

        if (count($requestsInCurrentTimeFrame) < $this->limit) {
            return 0;
        }

        $oldestRequestStartTimeRelativeToCurrentTimeFrame =
            $this->deferrer->getCurrentTime() - $requestsInCurrentTimeFrame[0];

        return $this->timeFrameLengthInMilliseconds() - $oldestRequestStartTimeRelativeToCurrentTimeFrame;
    }

    protected function timeFrameLengthInMilliseconds(): int
    {
        if ($this->timeFrame === self::TIME_FRAME_MINUTE) {
            return 60 * 1000;
        }

        return 1000;
    }
}


1			<?php
2
3			namespace Spatie\GuzzleRateLimiterMiddleware;
4
5			class RateLimiter
6			{
7			const TIME_FRAME_MINUTE = 'minute';
8			const TIME_FRAME_SECOND = 'second';
9
10			/** @var int */
11			protected $limit;
12
13			/** @var string */
14			protected $timeFrame;
15
16			/** @var \Spatie\RateLimiter\Store */
17			protected $store;
18
19			/** @var \Spatie\GuzzleRateLimiterMiddleware\Deferrer */
20			protected $deferrer;
21
22			public function __construct(
23			int $limit,
24			string $timeFrame,
25			Store $store,
26			Deferrer $deferrer
27			) {
28			$this->limit = $limit;
29			$this->timeFrame = $timeFrame;
30			$this->store = $store;
			0 ignored issues – show Documentation Bug introduced 2019-01-15 12:15 UTC by Report Bug Copy Issue Report It seems like `$store` of type `object<Spatie\GuzzleRateLimiterMiddleware\Store>` is incompatible with the declared type `object<Spatie\RateLimiter\Store>` of property `$store`. Our type inference engine has found an assignment to a property that is incompatible with the declared type of that property. Either this assignment is in error or the assigned type should be added to the documentation/type hint for that property.. Loading history...
31			$this->deferrer = $deferrer;
32			}
33
34			public function handle(callable $callback)
35			{
36			$delayUntilNextRequest = $this->delayUntilNextRequest();
37
38			if ($delayUntilNextRequest > 0) {
39			$this->deferrer->sleep($delayUntilNextRequest);
40			}
41
42			$this->store->push(
43			$this->deferrer->getCurrentTime(),
44			$this->limit
45			);
46
47			return $callback();
48			}
49
50			protected function delayUntilNextRequest(): int
51			{
52			$currentTimeFrameStart = $this->deferrer->getCurrentTime() - $this->timeFrameLengthInMilliseconds();
53
54			$requestsInCurrentTimeFrame = array_values(array_filter(
55			$this->store->get(),
56			function (int $timestamp) use ($currentTimeFrameStart) {
57			return $timestamp >= $currentTimeFrameStart;
58			}
59			));
60
61			if (count($requestsInCurrentTimeFrame) < $this->limit) {
62			return 0;
63			}
64
65			$oldestRequestStartTimeRelativeToCurrentTimeFrame =
66			$this->deferrer->getCurrentTime() - $requestsInCurrentTimeFrame[0];
67
68			return $this->timeFrameLengthInMilliseconds() - $oldestRequestStartTimeRelativeToCurrentTimeFrame;
69			}
70
71			protected function timeFrameLengthInMilliseconds(): int
72			{
73			if ($this->timeFrame === self::TIME_FRAME_MINUTE) {
74			return 60 * 1000;
75			}
76
77			return 1000;
78			}
79			}
80

spatie / guzzle-rate-limiter-middleware

RateLimiter::handle() A last analyzed 2020-07-16 06:49 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

RateLimiter::handle() A
last analyzed 2020-07-16 06:49 UTC