diff --git a/src/storage/s3.js b/src/storage/s3.js index 68e483bad..173f62003 100644 --- a/src/storage/s3.js +++ b/src/storage/s3.js @@ -322,9 +322,13 @@ function copy(apiConfig, oldFilePath, newFilePath) { UploadId: uploadId }; + events.emit('progress', `Copying part ${params.PartNumber} - ${params.CopySource} ${params.CopySourceRange}`); + s3.uploadPartCopy(params, function (error, result) { if (error) return done(error); + events.emit('progress', `Uploaded part ${params.PartNumber} - Etag: ${result.CopyPartResult.ETag}`); + uploadedParts.push({ ETag: result.CopyPartResult.ETag, PartNumber: partNumber }); if (endBytes < size) { @@ -340,6 +344,8 @@ function copy(apiConfig, oldFilePath, newFilePath) { UploadId: uploadId }; + events.emit('progress', `Finishing multipart copy - ${params.Key}`); + s3.completeMultipartUpload(params, done); }).on('retry', function (response) { ++retryCount;