Revert "fix(Browser): multipartUpload InvalidPartOrderError by donePa…

…rts repeat (#414)"

This reverts commit 2b0967f.

lib/browser/managed_upload.js

@@ -5,7 +5,6 @@ const is = require('is-type-of');
 const util = require('util');
 const path = require('path');
 const mime = require('mime');
-const copy = require('copy-to');
 
 const proto = exports;
 
@@ -114,15 +113,8 @@ proto._resumeMultipart = function* _resumeMultipart(checkpoint, options) {
     file, fileSize, partSize, uploadId, doneParts, name,
   } = checkpoint;
 
-  const internalDoneParts = [];
-
-  if (doneParts.length > 0) {
-    copy(doneParts).to(internalDoneParts);
-  }
-
   const partOffs = this._divideParts(fileSize, partSize);
   const numParts = partOffs.length;
-  let multipartFinish = false;
 
   const uploadPartJob = function* uploadPartJob(self, partNo) {
     if (!self.isCancel()) {
@@ -134,16 +126,12 @@ proto._resumeMultipart = function* _resumeMultipart(checkpoint, options) {
         };
 
         const result = yield self._uploadPart(name, uploadId, partNo, data);
-        if (!self.isCancel() && !multipartFinish) {
-          checkpoint.doneParts.push({
-            number: partNo,
-            etag: result.res.headers.etag,
-          });
-
-          internalDoneParts.push({
+        if (!self.isCancel()) {
+          doneParts.push({
             number: partNo,
             etag: result.res.headers.etag,
           });
+          checkpoint.doneParts = doneParts;
 
           if (options && options.progress) {
             yield options.progress(doneParts.length / numParts, checkpoint, result.res);
@@ -160,7 +148,7 @@ proto._resumeMultipart = function* _resumeMultipart(checkpoint, options) {
   };
 
   const all = Array.from(new Array(numParts), (x, i) => i + 1);
-  const done = internalDoneParts.map(p => p.number);
+  const done = doneParts.map(p => p.number);
   const todo = all.filter(p => done.indexOf(p) < 0);
   const defaultParallel = 5;
   const parallel = options.parallel || defaultParallel;
@@ -180,8 +168,7 @@ proto._resumeMultipart = function* _resumeMultipart(checkpoint, options) {
     }
 
     // start uploads jobs
-    const errors = this._thunkPool(jobs, parallel);
-    multipartFinish = true;
+    const errors = yield this._thunkPool(jobs, parallel);
 
     // check errors after all jobs are completed
     if (errors && errors.length > 0) {
@@ -196,7 +183,7 @@ proto._resumeMultipart = function* _resumeMultipart(checkpoint, options) {
       throw this._makeCancelEvent();
     }
   }
-  return yield this.completeMultipartUpload(name, uploadId, internalDoneParts, options);
+  return yield this.completeMultipartUpload(name, uploadId, doneParts, options);
 };
 
 

lib/common/multipart.js

@@ -160,11 +160,10 @@ proto.uploadPart = function* uploadPart(name, uploadId, partNo, file, start, end
  *                   }
  */
 proto.completeMultipartUpload = function* completeMultipartUpload(name, uploadId, parts, options) {
-  const completeParts = parts.concat().sort((a, b) => a.number - b.number)
-    .filter((item, index, arr) => !index || item.number !== arr[index - 1].number);
+  parts.sort((a, b) => a.number - b.number);
   let xml = '<?xml version="1.0" encoding="UTF-8"?>\n<CompleteMultipartUpload>\n';
-  for (let i = 0; i < completeParts.length; i++) {
-    const p = completeParts[i];
+  for (let i = 0; i < parts.length; i++) {
+    const p = parts[i];
     xml += '<Part>\n';
     xml += `<PartNumber>${p.number}</PartNumber>\n`;
     xml += `<ETag>${p.etag}</ETag>\n`;

test/node/callback.test.js

@@ -7,7 +7,7 @@ const config = require('../config').oss;
 const { callbackServer } = require('../const');
 const mm = require('mm');
 
-describe('test/callback.test.js', () => {
+describe('test/multipart.test.js', () => {
   const { prefix } = utils;
 
   before(function* () {