Function createMPU

tests/unit/utils/mpuUtils.js:79–106

(namespace, bucketName, objectKey, logger, cb)

}

function createMPU(namespace, bucketName, objectKey, logger, cb) {
    let testUploadId;
    async.waterfall([
        next => {
            const initiateMPURequest = createinitiateMPURequest(namespace,
                                                                bucketName,
                                                                objectKey);
            initiateMultipartUpload(authInfo, initiateMPURequest, logger, next);
        },
        (result, corsHeaders, next) => xml2js.parseString(result, next),
        (json, next) => {
            testUploadId = json.InitiateMultipartUploadResult.UploadId[0];
            const partRequest =
            createPutPartRequest(namespace, bucketName, objectKey, 1, testUploadId);
            objectPutPart(authInfo, partRequest, undefined, logger, next);
        },
        (hexDigest, corsHeaders, next) => {
            const completeRequest =
                createCompleteRequest(namespace, bucketName, objectKey, testUploadId);
            completeMultipartUpload(authInfo, completeRequest, logger, next);
        },
    ], err => {
        assert.ifError(err);
        cb(null, testUploadId);
    });

    return testUploadId;
}


module.exports = {