animethemes-server/app/Jobs/Middleware/ExternalProfileSiteRateLimited.php

<?php

declare(strict_types=1);

namespace App\Jobs\Middleware;

use App\Concerns\DetectsRedis;
use App\Enums\Models\List\ExternalProfileSite;
use Illuminate\Contracts\Redis\LimiterTimeoutException;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\Redis;

class ExternalProfileSiteRateLimited
{
    use DetectsRedis;

    /**
     * @throws LimiterTimeoutException
     */
    public function handle(mixed $job, callable $next): void
    {
        $definition = Arr::get($this->definition(), $job->profile->site->value);

        if ($this->appUsesRedis()) {
            Redis::throttle(Arr::get($definition, 'key'))
                ->block(0)
                ->allow(Arr::get($definition, 'allow'))
                ->every(Arr::get($definition, 'every'))
                ->then(
                    fn () => $next($job),
                    function () use ($job, $definition): void {
                        // Could not obtain lock...
                        $job->release(Arr::get($definition, 'every'));
                    }
                );
        } else {
            $next($job);
        }
    }

    /**
     * Get the rate limit definition of the site.
     *
     * @return array<int, array<string, string|int>>
     */
    protected function definition(): array
    {
        // Note: Full use is not allowed because of admin.
        return [
            ExternalProfileSite::ANILIST->value => [ // AniList rate limiting is 30/min
                'key' => ExternalProfileSite::ANILIST->name,
                'allow' => 1,
                'every' => 3,
            ],
            ExternalProfileSite::MAL->value => [ // MAL rate limiting is 90/min
                'key' => ExternalProfileSite::MAL->name,
                'allow' => 4,
                'every' => 3,
            ],
        ];
    }
}