Function putData

lib/routes/routeBackbeat.js:394–481

(request, response, bucketInfo, objMd, log, callback)

}

function putData(request, response, bucketInfo, objMd, log, callback) {
    if (request.serverAccessLog) {
        // eslint-disable-next-line no-param-reassign
        request.serverAccessLog.replication = true;
    }
    let errMessage;
    const canonicalID = request.headers['x-scal-canonical-id'];
    if (canonicalID === undefined) {
        errMessage = 'bad request: missing x-scal-canonical-id header';
        log.error(errMessage);
        return callback(errorInstances.BadRequest.customizeDescription(errMessage));
    }
    const contentMD5 = request.headers['content-md5'];
    if (contentMD5 === undefined) {
        errMessage = 'bad request: missing content-md5 header';
        log.error(errMessage);
        return callback(errorInstances.BadRequest.customizeDescription(errMessage));
    }
    const context = {
        bucketName: request.bucketName,
        owner: canonicalID,
        namespace: NAMESPACE,
        objectKey: request.objectKey,
    };
    const payloadLen = parseInt(request.headers['content-length'], 10);
    const backendInfoObj = locationConstraintCheck(request, null, bucketInfo, log);
    if (backendInfoObj.err) {
        log.error('error getting backendInfo', {
            error: backendInfoObj.err,
            method: 'routeBackbeat',
        });
        return callback(errors.InternalError);
    }
    const backendInfo = backendInfoObj.backendInfo;
    const isV2Request = request.query.v2 === '';
    return createCipherBundle(bucketInfo, isV2Request, log, (err, cipherBundle) => {
        if (err) {
            log.error('error creating cipher bundle', {
                error: err,
                method: 'routeBackbeat',
            });
            return callback(errors.InternalError);
        }
        return dataStore(
            context,
            cipherBundle,
            request,
            payloadLen,
            {},
            backendInfo,
            log,
            (err, retrievalInfo, md5) => {
                if (err) {
                    log.error('error putting data', {
                        error: err,
                        method: 'putData',
                    });
                    return callback(err);