Function uploadPartCopy

tests/sur/quota.js:244–316

(bucket, key, partNumber, partSize, sleepDuration, keyToCopy, callback)

}

function uploadPartCopy(bucket, key, partNumber, partSize, sleepDuration, keyToCopy, callback) {
    const ETags = [];
    let uploadId = null;
    const parts = 5;
    const partNumbers = Array.from(Array(parts).keys());
    const initiateMPUParams = {
        Bucket: bucket,
        Key: key,
    };
    if (!s3Config.isQuotaInflightEnabled()) {
        mockScuba.incrementBytesForBucket(bucket, parts * partSize);
    }
    return async.waterfall([
        next => s3Client.send(new CreateMultipartUploadCommand(initiateMPUParams))
            .then(data => {
                uploadId = data.UploadId;
                return next();
            })
            .catch(next),
        next => {
            const uploadPartParams = {
                Bucket: bucket,
                Key: key,
                PartNumber: partNumber + 1,
                UploadId: uploadId,
                Body: Buffer.alloc(partSize),
            };
            return s3Client.send(new UploadPartCommand(uploadPartParams))
                .then(data => {
                    ETags[partNumber] = data.ETag;
                    return next();
                })
                .catch(next);
        },
        next => wait(sleepDuration, next),
        next => {
            const copyPartParams = {
                Bucket: bucket,
                CopySource: `${bucket}/${keyToCopy}`,
                Key: `${key}-copy`,
                PartNumber: partNumber + 1,
                UploadId: uploadId,
            };
            return s3Client.send(new UploadPartCopyCommand(copyPartParams))
                .then(data => {
                    ETags[partNumber] = data.CopyPartResult.ETag;
                    return next(null, data.CopyPartResult.ETag);
                })
                .catch(next);
        },
        next => {
            const params = {
                Bucket: bucket,
                Key: key,
                MultipartUpload: {
                    Parts: partNumbers.map(n => ({
                        ETag: ETags[n],
                        PartNumber: n + 1,