Function callApiMethod

lib/api/api.js:434–513

(apiMethod, request, response, log, callback)

const api = {
    callApiMethod(apiMethod, request, response, log, callback) {
        // Attach the apiMethod method to the request, so it can used by monitoring in the server
        request.apiMethod = apiMethod;
        callback = wrapCallbackWithErrorCorsHeaders(
            callback, request, response, log);
        // Array of end of API callbacks, used to perform some logic
        // at the end of an API.
        request.finalizerHooks = [];

        const actionLog = monitoringMap[apiMethod];
        if (!actionLog &&
            apiMethod !== 'websiteGet' &&
            apiMethod !== 'websiteHead' &&
            apiMethod !== 'corsPreflight') {
            log.error('callApiMethod(): No actionLog for this api method', {
                apiMethod,
            });
        }
        log.addDefaultFields({
            service: 's3',
            action: actionLog,
            bucketName: request.bucketName,
        });
        if (request.objectKey) {
            log.addDefaultFields({
                objectKey: request.objectKey,
            });
        }
        if (request.serverAccessLog) {
            request.serverAccessLog.bucketName = request.bucketName;
            request.serverAccessLog.objectKey = request.objectKey;
            request.serverAccessLog.analyticsAction = actionLog;
        }

        // Initialize rate limit tracker flag
        request.rateLimitBucketAlreadyChecked = false;
        request.rateLimitAccountAlreadyChecked = false;

        const apiHandler = this[apiMethod];

        // Process the request with validation, authentication, and execution

        if (request.bucketName === undefined || !requestNeedsRateCheck(request)) {
            return process.nextTick(callApiHandler, apiMethod, apiHandler, request, response, log, callback);
        }

        const checks = [];
        const rateLimitConfig = getCachedRateLimitConfig(request);

        if (rateLimitConfig.bucket !== undefined) {
            request.rateLimitBucketAlreadyChecked = true;
            checks.push(...buildRateChecksFromConfig('bucket', request.bucketName, rateLimitConfig.bucket));
        }

        if (rateLimitConfig.account !== undefined) {
            request.rateLimitAccountAlreadyChecked = true;
            checks.push(...buildRateChecksFromConfig('account', rateLimitConfig.bucketOwner, rateLimitConfig.account));
        }