Function checkRateLimitsForRequest

lib/api/apiUtils/rateLimit/helpers.js:163–193

(checks, log)

}

function checkRateLimitsForRequest(checks, log) {
    const buckets = [];
    for (const check of checks) {
        const bucket = getTokenBucket(check.resourceClass, check.resourceId, check.measure, check.config, log);
        if (!bucket.hasCapacity()) {
            log.debug('Rate limit check: denied (no tokens available)', {
                resourceClass: check.resourceClass,
                resourceId: check.resourceId,
                measure: check.measure,
                limit: check.config.limit,
                source: check.source,
            });

            return { allowed: false, rateLimitSource: `${check.resourceClass}:${check.source}`};
        }

        buckets.push(bucket);

        log.trace('Rate limit check: allowed (token consumed)', {
            resourceClass: check.resourceClass,
            resourceId: check.resourceId,
            measure: check.measure,
            source: check.source,
        });
    }

    // buckets have already been checked for available capacity
    // no need to check return values
    buckets.forEach(bucket => bucket.tryConsume());
    return { allowed: true };
}

module.exports = {
    rateLimitApiActions,