Function routeBackbeat

lib/routes/routeBackbeat.js:1706–1927

(clientIP, request, response, log)

}

function routeBackbeat(clientIP, request, response, log) {
    // Attach the apiMethod method to the request, so it can used by monitoring in the server
    // eslint-disable-next-line no-param-reassign
    request.apiMethod = 'routeBackbeat';
    const contentLength = request.headers['x-amz-decoded-content-length'] || request.headers['content-length'];
    // eslint-disable-next-line no-param-reassign
    request.parsedContentLength = Number.parseInt(contentLength?.toString() ?? '', 10);

    log.debug('routing request');
    _normalizeBackbeatRequest(request);

    log.addDefaultFields({
        clientIP,
        url: request.url,
        method: 'routeBackbeat',
        resourceType: request.resourceType,
        bucketName: request.bucketName,
        objectKey: request.objectKey,
        bytesReceived: request.parsedContentLength || 0,
        bodyLength: parseInt(request.headers['content-length'], 10) || 0,
    });
    if (request.serverAccessLog) {
        // eslint-disable-next-line no-param-reassign
        request.serverAccessLog.bucketName = request.bucketName;
        // eslint-disable-next-line no-param-reassign
        request.serverAccessLog.objectKey = request.objectKey;
        // eslint-disable-next-line no-param-reassign
        request.serverAccessLog.backbeat = true;
        // eslint-disable-next-line no-param-reassign
        request.serverAccessLog.analyticsAction = 'BACKBEAT_INVALID';
    }

    const requestContexts = prepareRequestContexts('objectReplicate', request);

    if (request.resourceType === 'expiration' || request.resourceType === 'batchdelete') {
        // Reassign a specific apiMethod, as it is needed for quota evaluation (at least), where
        // "routeBackbeat" cannot be used as it is used for all backbeat API operations...
        // eslint-disable-next-line no-param-reassign
        request.apiMethod = 'objectDelete';

        // Request account quotas, as it will not be added for the 'objectReplicate' action which
        // is used by default for all backbeat operations
        requestContexts.forEach(context => {
            context._needQuota = true; // eslint-disable-line no-param-reassign
        });
    }

    // Ensure backbeat operations like expiration can properly use quotas
    // eslint-disable-next-line no-param-reassign
    request.finalizerHooks = [];

    // Extract all the _apiMethods and store them in an array
    const apiMethods = requestContexts ? requestContexts.map(context => context._apiMethod) : [];
    // Attach the names to the current request
    // eslint-disable-next-line no-param-reassign
    request.apiMethods = apiMethods;

    // proxy api requests to Backbeat API server