Merge pull request #213 from jysperm/node-ajax

在 Node.js 下用 http/https 模块重新实现 AV._ajax, 取代 xmlhttprequest 模块

Author: jysperm

lib/av.js

@@ -12,7 +12,6 @@ var AV = module.exports = {};
 AV._ = require('underscore');
 AV.VERSION = require('./version');
 AV.Promise = require('./promise');
-AV.XMLHttpRequest = require('./browserify-wrapper/xmlhttprequest').XMLHttpRequest;
 AV.localStorage = require('./localstorage');
 
 // 以下模块为了兼容原有代码，使用这种加载方式。

lib/browserify-wrapper/ajax-browser.js

@@ -0,0 +1,85 @@
+var Promise = require('../promise');
+
+module.exports = function _ajax(method, url, data, success, error) {
+  var options = {
+    success: success,
+    error: error
+  };
+
+  if (useXDomainRequest()) {
+    return ajaxIE8(method, url, data)._thenRunCallbacks(options);
+  }
+
+  var promise = new Promise();
+  var handled = false;
+
+  var xhr = new XMLHttpRequest();
+  xhr.onreadystatechange = function() {
+    if (xhr.readyState === 4) {
+      if (handled) {
+        return;
+      }
+      handled = true;
+
+      if (xhr.status >= 200 && xhr.status < 300) {
+        var response;
+        try {
+          response = JSON.parse(xhr.responseText);
+        } catch (e) {
+          promise.reject(e);
+        }
+        if (response) {
+          promise.resolve(response, xhr.status, xhr);
+        }
+      } else {
+        promise.reject(xhr);
+      }
+    }
+  };
+  xhr.open(method, url, true);
+  xhr.setRequestHeader("Content-Type", "text/plain");  // avoid pre-flight.
+  xhr.send(data);
+  return promise._thenRunCallbacks(options);
+};
+
+function useXDomainRequest() {
+  if (typeof(XDomainRequest) !== "undefined") {
+    // We're in IE 8+.
+    if ('withCredentials' in new XMLHttpRequest()) {
+      // We're in IE 10+.
+      return false;
+    }
+    return true;
+  }
+  return false;
+}
+
+function ajaxIE8(method, url, data) {
+  var promise = new Promise();
+  var xdr = new XDomainRequest();
+  xdr.onload = function() {
+    var response;
+    try {
+      response = JSON.parse(xdr.responseText);
+    } catch (e) {
+      promise.reject(e);
+    }
+    if (response) {
+      promise.resolve(response);
+    }
+  };
+  xdr.onerror = xdr.ontimeout = function() {
+    // Let's fake a real error message.
+    var fakeResponse = {
+      responseText: JSON.stringify({
+        code: AV.Error.X_DOMAIN_REQUEST,
+        error: "IE's XDomainRequest does not supply error info."
+      })
+    };
+    promise.reject(xdr);
+  };
+  xdr.onprogress = function() {};
+  xdr.open(method, url);
+  xdr.send(data);
+  return promise;
+}

lib/browserify-wrapper/ajax.js

@@ -0,0 +1,64 @@
+'use strict';
+
+var http = require('http');
+var https = require('https');
+var url = require('url');
+
+var Promise = require('../promise');
+var AV_VERSION = require('../version')
+
+// `keepAlive` option only work on Node.js 0.12+
+var httpAgent = new http.Agent({keepAlive: true});
+var httpsAgent = new https.Agent({keepAlive: true});
+
+module.exports = function _ajax(method, resourceUrl, data, success, error) {
+  var parsedUrl = url.parse(resourceUrl);
+  var promise = new Promise();
+
+  var transportModule = http;
+  var transportAgent = httpAgent;
+
+  if (parsedUrl.protocol === 'https:') {
+    transportModule = https;
+    transportAgent = httpsAgent;
+  }
+
+  var req = transportModule.request({
+    method: method,
+    protocol: parsedUrl.protocol,
+    hostname: parsedUrl.hostname,
+    port: parsedUrl.port,
+    path: parsedUrl.path,
+    agent: transportAgent,
+    headers: {
+      'Content-Type': 'text/plain',
+      'User-Agent': 'AV/' + AV_VERSION + ' (Node.js' + process.version + ')'
+    }
+  });
+
+  req.on('response', function(res) {
+    var responseText = '';
+
+    res.on('data', function(chunk) {
+      responseText += chunk.toString();
+    });
+
+    res.on('end', function() {
+      try {
+        promise.resolve(JSON.parse(responseText), res.statusCode, res);
+      } catch (err) {
+        promise.reject(err);
+      }
+    });
+  });
+
+  req.on('error', function(err) {
+    promise.reject(err);
+  });
+
+  req.end(data);
+  return promise._thenRunCallbacks({
+    success: success,
+    error: error
+  });
+}

lib/browserify-wrapper/upload-browser.js

@@ -22,7 +22,7 @@ module.exports = function upload(file, AV, saveOptions) {
     var promise = new AV.Promise();
     var handled = false;
 
-    var xhr = new AV.XMLHttpRequest();
+    var xhr = new XMLHttpRequest();
 
     if (xhr.upload) {
       xhr.upload.onprogress = saveOptions.onProgress;

lib/browserify-wrapper/xmlhttprequest-browser.js

@@ -246,95 +246,7 @@ module.exports = function(AV) {
     return new Date(Date.UTC(year, month, day, hour, minute, second, milli));
   };
 
-  AV._ajaxIE8 = function(method, url, data) {
-    var promise = new AV.Promise();
-    var xdr = new XDomainRequest();
-    xdr.onload = function() {
-      var response;
-      try {
-        response = JSON.parse(xdr.responseText);
-      } catch (e) {
-        promise.reject(e);
-      }
-      if (response) {
-        promise.resolve(response);
-      }
-    };
-    xdr.onerror = xdr.ontimeout = function() {
-      // Let's fake a real error message.
-      var fakeResponse = {
-        responseText: JSON.stringify({
-          code: AV.Error.X_DOMAIN_REQUEST,
-          error: "IE's XDomainRequest does not supply error info."
-        })
-      };
-      promise.reject(xdr);
-    };
-    xdr.onprogress = function() {};
-    xdr.open(method, url);
-    xdr.send(data);
-    return promise;
-  };
-
-   AV._useXDomainRequest = function() {
-       if (typeof(XDomainRequest) !== "undefined") {
-           // We're in IE 8+.
-           if ('withCredentials' in new XMLHttpRequest()) {
-               // We're in IE 10+.
-               return false;
-           }
-           return true;
-       }
-       return false;
-   };
-
-  AV._ajax = function(method, url, data, success, error) {
-    var options = {
-      success: success,
-      error: error
-    };
-
-    if (AV._useXDomainRequest()) {
-      return AV._ajaxIE8(method, url, data)._thenRunCallbacks(options);
-    }
-
-    var promise = new AV.Promise();
-    var handled = false;
-
-    var xhr = new AV.XMLHttpRequest();
-    xhr.onreadystatechange = function() {
-      if (xhr.readyState === 4) {
-        if (handled) {
-          return;
-        }
-        handled = true;
-
-        if (xhr.status >= 200 && xhr.status < 300) {
-          var response;
-          try {
-            response = JSON.parse(xhr.responseText);
-          } catch (e) {
-            promise.reject(e);
-          }
-          if (response) {
-            promise.resolve(response, xhr.status, xhr);
-          }
-        } else {
-          promise.reject(xhr);
-        }
-      }
-    };
-    xhr.open(method, url, true);
-    xhr.setRequestHeader("Content-Type", "text/plain");  // avoid pre-flight.
-    if (AV._isNode) {
-      // Add a special user agent just for request from node.js.
-      xhr.setRequestHeader("User-Agent",
-                           "AV/" + AV.VERSION +
-                           " (NodeJS " + process.versions.node + ")");
-    }
-    xhr.send(data);
-    return promise._thenRunCallbacks(options);
-  };
+  AV._ajax = require('./browserify-wrapper/ajax');
 
   // A self-propagating extend function.
   AV._extend = function(protoProps, classProps) {

lib/browserify-wrapper/xmlhttprequest.js

@@ -13,8 +13,7 @@
   "dependencies": {
     "localstorage-memory": "^1.0.1",
     "qiniu": "6.1.3",
-    "underscore": "^1.8.3",
-    "leancloud-xmlhttprequest": "^1.8.0"
+    "underscore": "^1.8.3"
   },
   "devDependencies": {
     "browserify": "^11.0.1",
@@ -41,8 +40,8 @@
   },
   "browser": {
     "react-native": false,
+    "./lib/browserify-wrapper/ajax.js": "./lib/browserify-wrapper/ajax-browser.js",
     "./lib/browserify-wrapper/upload.js": "./lib/browserify-wrapper/upload-browser.js",
-    "./lib/browserify-wrapper/xmlhttprequest.js": "./lib/browserify-wrapper/xmlhttprequest-browser.js",
     "./lib/browserify-wrapper/localStorage.js": "./lib/browserify-wrapper/localstorage-browser.js",
     "./lib/browserify-wrapper/parse-base64.js": "./lib/browserify-wrapper/parse-base64-browser.js"
   }