REDROOM

Edit File Size: 2.45 KB

/home/getspomw/royalsquad.us/vendor/laravel/framework/src/Illuminate/Queue/Middleware/RateLimitedWithRedis.php

Text Base64

<?php

namespace Illuminate\Queue\Middleware;

use Illuminate\Container\Container;
use Illuminate\Contracts\Redis\Factory as Redis;
use Illuminate\Redis\Limiters\DurationLimiter;
use Illuminate\Support\InteractsWithTime;

class RateLimitedWithRedis extends RateLimited
{
    use InteractsWithTime;

/**
     * The Redis factory implementation.
     *
     * @var \Illuminate\Contracts\Redis\Factory
     */
    protected $redis;

/**
     * The timestamp of the end of the current duration by key.
     *
     * @var array
     */
    public $decaysAt = [];

/**
     * Create a new middleware instance.
     *
     * @param  string  $limiterName
     * @return void
     */
    public function __construct($limiterName)
    {
        parent::__construct($limiterName);

$this->redis = Container::getInstance()->make(Redis::class);
    }

/**
     * Handle a rate limited job.
     *
     * @param  mixed  $job
     * @param  callable  $next
     * @param  array  $limits
     * @return mixed
     */
    protected function handleJob($job, $next, array $limits)
    {
        foreach ($limits as $limit) {
            if ($this->tooManyAttempts($limit->key, $limit->maxAttempts, $limit->decaySeconds)) {
                return $this->shouldRelease
                    ? $job->release($this->getTimeUntilNextRetry($limit->key))
                    : false;
            }
        }

return $next($job);
    }

/**
     * Determine if the given key has been "accessed" too many times.
     *
     * @param  string  $key
     * @param  int  $maxAttempts
     * @param  int  $decaySeconds
     * @return bool
     */
    protected function tooManyAttempts($key, $maxAttempts, $decaySeconds)
    {
        $limiter = new DurationLimiter(
            $this->redis, $key, $maxAttempts, $decaySeconds
        );

return tap(! $limiter->acquire(), function () use ($key, $limiter) {
            $this->decaysAt[$key] = $limiter->decaysAt;
        });
    }

/**
     * Get the number of seconds that should elapse before the job is retried.
     *
     * @param  string  $key
     * @return int
     */
    protected function getTimeUntilNextRetry($key)
    {
        return ($this->decaysAt[$key] - $this->currentTime()) + 3;
    }

/**
     * Prepare the object after unserialization.
     *
     * @return void
     */
    public function __wakeup()
    {
        parent::__wakeup();

$this->redis = Container::getInstance()->make(Redis::class);
    }
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
RateLimited.php	3.33 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
RateLimitedWithRedis.php	2.45 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
Skip.php	870 B	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
SkipIfBatchCancelled.php	383 B	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
ThrottlesExceptions.php	4.91 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
ThrottlesExceptionsWithRedis.php	1.62 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
WithoutOverlapping.php	3.45 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive

Directory Contents