fix(Uploader): use superagent to upload file directly

fix react native upload failure.

Author: leeyeh

package.json

@@ -11,19 +11,19 @@
     "test": "gulp test"
   },
   "dependencies": {
+    "debug": "^2.2.0",
     "form-data": "^1.0.0-rc4",
     "localstorage-memory": "^1.0.1",
     "md5": "^2.0.0",
     "qiniu": "6.1.3",
-    "superagent": "^1.8.3",
+    "superagent": "^2.0.0-alpha.2",
     "underscore": "^1.8.3"
   },
   "devDependencies": {
     "babel-core": "^6.4.0",
     "babel-preset-es2015": "^6.3.13",
     "browser-sync": "^2.2.1",
     "browserify": "^11.0.1",
-    "debug": "^2.1.1",
     "expect.js": "0.2.0",
     "gulp": "^3.8.10",
     "gulp-babel": "^6.1.1",
@@ -53,11 +53,9 @@
     "./src/uploader/qiniu.js": "./src/uploader/qiniu-browser.js",
     "./src/browserify-wrapper/localStorage.js": "./src/browserify-wrapper/localstorage-browser.js",
     "./src/browserify-wrapper/parse-base64.js": "./src/browserify-wrapper/parse-base64-browser.js",
-    "./src/uploader/cos.js": "./src/uploader/cos-browser.js",
     "./dist/node/uploader/qiniu.js": "./dist/node/uploader/qiniu-browser.js",
     "./dist/node/browserify-wrapper/localStorage.js": "./dist/node/browserify-wrapper/localstorage-browser.js",
-    "./dist/node/browserify-wrapper/parse-base64.js": "./dist/node/browserify-wrapper/parse-base64-browser.js",
-    "./dist/node/uploader/cos.js": "./dist/node/uploader/cos-browser.js"
+    "./dist/node/browserify-wrapper/parse-base64.js": "./dist/node/browserify-wrapper/parse-base64-browser.js"
   },
   "eslintConfig": {
     "env": {

src/ajax.js

@@ -19,11 +19,15 @@ module.exports = function _ajax(method, resourceUrl, data, headers = {}, onprogr
     .set(headers)
     .send(data)
     .end((err, res) => {
-      debug(res.status, res.body, res.text);
+      if (res) {
+        debug(res.status, res.body, res.text);
+      }
       if (err) {
-        err.statusCode = res.status;
-        err.responseText = res.text;
-        err.response = res.body;
+        if (res) {
+          err.statusCode = res.status;
+          err.responseText = res.text;
+          err.response = res.body;
+        }
         return promise.reject(err);
       }
       promise.resolve(res.body, res.status, res);

src/uploader/cos-browser.js

@@ -1,31 +1,40 @@
+/**
+ * 每位工程师都有保持代码优雅的义务
+ * Each engineer has a duty to keep the code elegant
+ **/
+
 'use strict';
-const FormData = require('form-data');
 
-const ajax = require('../ajax.js');
+const request = require('superagent');
 const Promise = require('../promise');
-const debug = require('debug')('cos');
 
-module.exports =function upload(uploadInfo, data, file) {
+module.exports = function upload(uploadInfo, data, file, saveOptions = {}) {
   file.attributes.url = uploadInfo.url;
   file._bucket = uploadInfo.bucket;
   file.id = uploadInfo.objectId;
-  const uploadUrl = uploadInfo.upload_url;
-  const body = new Buffer(data, 'base64');
-  debug(uploadUrl, data);
-  const formData = new FormData();
-  formData.append('fileContent', body);
-  formData.append('op', 'upload');
+  const uploadUrl = uploadInfo.upload_url + "?sign=" + encodeURIComponent(uploadInfo.token);
 
   const promise = new Promise();
 
-  const request = formData.submit(uploadUrl, function(err, res) {
-    debug(err, res.statusCode);
-    if (err) {
-      promise.reject(err);
-    } else {
+  const req = request('POST', uploadUrl)
+    .field('fileContent', data)
+    .field('op', 'upload')
+    .end((err, res) => {
+      if (res) {
+        debug(res.status, res.body, res.text);
+      }
+      if (err) {
+        if (res) {
+          err.statusCode = res.status;
+          err.responseText = res.text;
+          err.response = res.body;
+        }
+        return promise.reject(err);
+      }
       promise.resolve(file);
-    }
-  });
-  request.setHeader('Authorization', uploadInfo.token);
+    });
+  if (saveOptions.onprogress) {
+    req.on('progress', saveOptions.onprogress);
+  }
   return promise;
 };

src/uploader/cos.js

@@ -5,20 +5,39 @@
 
 'use strict';
 
-const ajax = require('../ajax.js');
+const request = require('superagent');
+const Promise = require('../promise');
 
-module.exports = function upload(uploadInfo, data, file, saveOptions) {
-    file.attributes.url = uploadInfo.url;
-    file._bucket = uploadInfo.bucket;
-    file.id = uploadInfo.objectId;
-    //Get the uptoken to upload files to qiniu.
-    const uptoken = uploadInfo.token;
-    const formData = new FormData();
-    formData.append('file', data);
-    formData.append('name', file.attributes.name);
-    formData.append('key', file._qiniu_key);
-    formData.append('token', uptoken);
+module.exports = function upload(uploadInfo, data, file, saveOptions = {}) {
+  file.attributes.url = uploadInfo.url;
+  file._bucket = uploadInfo.bucket;
+  file.id = uploadInfo.objectId;
+  //Get the uptoken to upload files to qiniu.
+  const uptoken = uploadInfo.token;
 
-    return ajax('POST', 'https://up.qbox.me', formData, undefined, saveOptions.onProgress)
-      .then(() => file);
+  const promise = new Promise();
+
+  const req = request('POST', 'https://up.qbox.me')
+    .field('file', data)
+    .field('name', file.attributes.name)
+    .field('key', file._qiniu_key)
+    .field('token', uptoken)
+    .end((err, res) => {
+      if (res) {
+        debug(res.status, res.body, res.text);
+      }
+      if (err) {
+        if (res) {
+          err.statusCode = res.status;
+          err.responseText = res.text;
+          err.response = res.body;
+        }
+        return promise.reject(err);
+      }
+      promise.resolve(file);
+    });
+  if (saveOptions.onprogress) {
+    req.on('progress', saveOptions.onprogress);
+  }
+  return promise;
 };

src/uploader/qiniu-browser.js

@@ -7,11 +7,16 @@ if (typeof require !== 'undefined') {
   GLOBAL.AV = require('../dist/node/av');
 }
 
-AV._config.APIServerURL = 'https://cn-stg1.avoscloud.com';
+// AV._config.APIServerURL = 'https://cn-stg1.avoscloud.com';
+// AV.init({
+//   appId: 'mxrb5nn3qz7drek0etojy5lh4yrwjnk485lqajnsgjwfxrb5',
+//   appKey: 'd7sbus0d81mrum4tko4t8gl74b27vl0rh762ff7ngrb6ymmq',
+//   masterKey: 'l0n9wu3kwnrtf2cg1b6w2l87nphzpypgff6240d0lxui2mm4'
+// });
 AV.init({
-  appId: 'mxrb5nn3qz7drek0etojy5lh4yrwjnk485lqajnsgjwfxrb5',
-  appKey: 'd7sbus0d81mrum4tko4t8gl74b27vl0rh762ff7ngrb6ymmq',
-  masterKey: 'l0n9wu3kwnrtf2cg1b6w2l87nphzpypgff6240d0lxui2mm4'
+  appId: '95TNUaOSUd8IpKNW0RSqSEOm-9Nh9j0Va',
+  appKey: 'gNAE1iHowdQvV7cqpfCMGaGN',
+  masterKey: 'ue9M9nqwD4MQNXD3oiN5rAOv'
 });
 AV.setProduction(true);
 AV._useMasterKey = true;