Function createMPU

tests/unit/api/bucketDelete.js:34–84

(testRequest, initiateRequest, deleteOverviewMPUObj, cb)

const mpuBucket = `${constants.mpuBucketPrefix}${bucketName}`;

function createMPU(testRequest, initiateRequest, deleteOverviewMPUObj, cb) {
    async.waterfall([
        next => bucketPut(authInfo, testRequest, log, next),
        (corsHeaders, next) => initiateMultipartUpload(authInfo,
            initiateRequest, log, next),
        (result, corsHeaders, next) => {
            parseString(result, next);
        },
        (json, next) => {
            const testUploadId = json.InitiateMultipartUploadResult.UploadId[0];
            const md5Hash = crypto.createHash('md5');
            const bufferBody = Buffer.from(postBody);
            md5Hash.update(bufferBody);
            const calculatedHash = md5Hash.digest('hex');
            const partRequest = new DummyRequest({
                bucketName,
                objectKey: objectName,
                namespace,
                url: `/${objectName}?partNumber=1&uploadId=${testUploadId}`,
                headers: { host: `${bucketName}.s3.amazonaws.com` },
                query: {
                    partNumber: '1',
                    uploadId: testUploadId,
                },
                calculatedHash,
            }, postBody);
            objectPutPart(authInfo, partRequest, undefined, log, err => {
                if (err) {
                    return next(err);
                }
                return next(null, testUploadId);
            });
        },
    ], (err, testUploadId) => {
        assert.strictEqual(err, null);
        const mpuBucketKeyMap =
            metadataMem.metadata.keyMaps.get(mpuBucket);
        assert.strictEqual(mpuBucketKeyMap.size, 2);
        if (deleteOverviewMPUObj) {
            const overviewKey = `overview${constants.splitter}` +
            `${objectName}${constants.splitter}${testUploadId}`;
            // remove overview key from in mem mpu bucket
            mpuBucketKeyMap.delete(overviewKey);
            assert.strictEqual(mpuBucketKeyMap.size, 1);
        }
        bucketDelete(authInfo, testRequest, log, err => {
            assert.strictEqual(err, null);
            cb();
        });
    });
}

describe('bucketDelete API', () => {
    beforeEach(() => {