Function bucketPutRateLimit

lib/api/bucketPutRateLimit.js:58–102

* bucketPutRateLimit - create or update a bucket policy * @param {AuthInfo} authInfo - Instance of AuthInfo class with requester's info * @param {object} request - http request object * @param {object} log - Werelogs logger * @param {function} callback - callback to server * @return {undefined}

(authInfo, request, log, callback)

 * @return {undefined}
 */
function bucketPutRateLimit(authInfo, request, log, callback) {
    log.debug('processing request', { method: 'bucketPutRateLimit' });

    if (!isRateLimitServiceUser(authInfo)) {
        return callback(errors.AccessDenied);
    }

    const { bucketName } = request;
    const metadataValParams = {
        authInfo,
        bucketName,
        requestType: request.apiMethods || 'bucketPutRateLimit',
        request,
    };

    return async.waterfall([
        next => parseRequestBody(request.post, next),
        (requestBody, next) => validateRateLimitConfig(requestBody, next),
        (limitConfig, next) => standardMetadataValidateBucket(metadataValParams, request.actionImplicitDenies, log,
            (err, bucket) => {
                if (err) {
                    return next(err, bucket);
                }
                return next(null, bucket, limitConfig);
            }),
        (bucket, limitConfig, next) => {
            bucket.setRateLimitConfiguration(limitConfig);
            metadata.updateBucket(bucket.getName(), bucket, log,
                err => next(err, bucket));
        },
    ], (err, bucket) => {
        const corsHeaders = collectCorsHeaders(request.headers.origin,
            request.method, bucket);
        if (err) {
            log.trace('error processing request',
                { error: err, method: 'bucketPutRateLimit' });
            return callback(err, corsHeaders);
        }
        // Invalidate cache so new limit takes effect immediately
        cache.deleteCachedConfig(cache.namespace.bucket, bucketName);
        log.debug('invalidated rate limit cache for bucket', { bucketName });
        // TODO: implement Utapi metric support
        return callback(null, corsHeaders);
    });
}

module.exports = bucketPutRateLimit;