Function _checkMultipleBackendRequest

lib/routes/routeBackbeat.js:138–209

(request, log)

}

function _checkMultipleBackendRequest(request, log) {
    const { headers, query } = request;
    const storageType = headers['x-scal-storage-type'];
    const { operation } = query;
    let errMessage;
    if (storageType === undefined) {
        errMessage = 'bad request: missing x-scal-storage-type header';
        log.error(errMessage);
        return errorInstances.BadRequest.customizeDescription(errMessage);
    }
    if (operation === 'putpart' && headers['x-scal-part-number'] === undefined) {
        errMessage = 'bad request: missing part-number header';
        log.error(errMessage);
        return errorInstances.BadRequest.customizeDescription(errMessage);
    }
    const isMPUOperation = ['putpart', 'completempu', 'abortmpu'].includes(operation);
    if (isMPUOperation && headers['x-scal-upload-id'] === undefined) {
        errMessage = 'bad request: missing upload-id header';
        log.error(errMessage);
        return errorInstances.BadRequest.customizeDescription(errMessage);
    }
    if (operation === 'putobject' && headers['x-scal-canonical-id'] === undefined) {
        errMessage = 'bad request: missing x-scal-canonical-id header';
        log.error(errMessage);
        return errorInstances.BadRequest.customizeDescription(errMessage);
    }
    // Ensure the external backend has versioning before asserting version ID.
    if (
        !constants.versioningNotImplBackends[storageType] &&
        (operation === 'puttagging' || operation === 'deletetagging')
    ) {
        if (headers['x-scal-data-store-version-id'] === undefined) {
            errMessage = 'bad request: missing x-scal-data-store-version-id header';
            log.error(errMessage);
            return errorInstances.BadRequest.customizeDescription(errMessage);
        }
        if (headers['x-scal-source-bucket'] === undefined) {
            errMessage = 'bad request: missing x-scal-source-bucket header';
            log.error(errMessage);
            return errorInstances.BadRequest.customizeDescription(errMessage);
        }
        if (headers['x-scal-replication-endpoint-site'] === undefined) {
            errMessage = 'bad request: missing ' + 'x-scal-replication-endpoint-site';
            log.error(errMessage);
            return errorInstances.BadRequest.customizeDescription(errMessage);
        }
    }
    if (operation === 'putobject' && headers['content-md5'] === undefined) {
        errMessage = 'bad request: missing content-md5 header';
        log.error(errMessage);
        return errorInstances.BadRequest.customizeDescription(errMessage);
    }
    if (headers['x-scal-storage-class'] === undefined) {
        errMessage = 'bad request: missing x-scal-storage-class header';
        log.error(errMessage);
        return errorInstances.BadRequest.customizeDescription(errMessage);
    }
    const location = locationConstraints[headers['x-scal-storage-class']];