Function _createAndAbortMpu

tests/unit/api/multipartDelete.js:39–95

(usEastSetting, fakeUploadID, locationConstraint,
    callback)

const westLocation = 'scality-internal-file';

function _createAndAbortMpu(usEastSetting, fakeUploadID, locationConstraint,
    callback) {
    config.locationConstraints['us-east-1'].legacyAwsBehavior =
        usEastSetting;
    const post = '<?xml version="1.0" encoding="UTF-8"?>' +
        '<CreateBucketConfiguration ' +
        'xmlns="http://s3.amazonaws.com/doc/2006-03-01/">' +
        `<LocationConstraint>${locationConstraint}</LocationConstraint>` +
        '</CreateBucketConfiguration>';
    const testBucketPutRequest = Object.assign({ post }, bucketPutRequest);
    async.waterfall([
        next => bucketPut(authInfo, testBucketPutRequest, log, next),
        (corsHeaders, next) =>
            initiateMultipartUpload(authInfo, initiateRequest, log, next),
        (result, corsHeaders, next) => parseString(result, next),
        (json, next) => {
            // use uploadId parsed from initiateMpu request to construct
            // uploadPart and deleteMpu requests
            const uploadId =
                json.InitiateMultipartUploadResult.UploadId[0];
            const partBody = Buffer.from('I am a part\n', 'utf8');
            const partRequest = new DummyRequest({
                bucketName,
                namespace,
                objectKey,
                headers: { host: `${bucketName}.s3.amazonaws.com` },
                url: `/${objectKey}?partNumber=1&uploadId=${uploadId}`,
                query: {
                    partNumber: '1',
                    uploadId,
                },
                actionImplicitDenies: false,
            }, partBody);
            const testUploadId = fakeUploadID ? 'nonexistinguploadid' :
                uploadId;
            const deleteMpuRequest = {
                bucketName,
                namespace,
                objectKey,
                headers: { host: `${bucketName}.s3.amazonaws.com` },
                url: `/${objectKey}?uploadId=${testUploadId}`,
                query: { uploadId: testUploadId },
                actionImplicitDenies: false,
            };
            next(null, partRequest, deleteMpuRequest);
        },
        (partRequest, deleteMpuRequest, next) =>
            objectPutPart(authInfo, partRequest, undefined, log, err => {
                if (err) {
                    return next(err);
                }
                return next(null, deleteMpuRequest);
            }),
        (deleteMpuRequest, next) =>
            multipartDelete(authInfo, deleteMpuRequest, log, next),
    ], callback);
}