Function objectMPU

tests/utapi/awsNodeSdk.js:128–173

(bucket, key, parts, partSize, callback)

}

function objectMPU(bucket, key, parts, partSize, callback) {
    let ETags = [];
    let uploadId = null;
    const partNumbers = Array.from(Array(parts).keys());
    const initiateMPUParams = { Bucket: bucket, Key: key };
    async.waterfall([
        next => s3Client.send(new CreateMultipartUploadCommand(initiateMPUParams))
            .then(data => {
                uploadId = data.UploadId;
                return next();
            })
            .catch(next),
        next =>
            async.mapLimit(partNumbers, 1, (partNumber, callback) => {
                const body = Buffer.alloc(partSize);
                const uploadPartParams = {
                    Bucket: bucket,
                    Key: key,
                    PartNumber: partNumber + 1,
                    UploadId: uploadId,
                    Body: body,
                };
                s3Client.send(new UploadPartCommand(uploadPartParams))
                    .then(data => callback(null, data.ETag))
                    .catch(callback);
            }, (err, results) => {
                if (err) {
                    return next(err);
                }
                ETags = results;
                return next();
            }),
        next => {
            const completeRequest = { Parts: partNumbers.map(n => ({ ETag: ETags[n], PartNumber: n + 1 })) };
            const params = {
                Bucket: bucket,
                Key: key,
                MultipartUpload: completeRequest,
                UploadId: uploadId,
            };
            s3Client.send(new CompleteMultipartUploadCommand(params))
                .then(data => next(null, data))
                .catch(next);
        },
    ], callback);
}

function removeVersions(buckets, cb) {
    async.each(buckets, (bucket, done) => removeAllVersions({ Bucket: bucket }, done), cb);