在 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');
 
 // 以下模块为了兼容原有代码，使用这种加载方式。
@@ -34,5 +33,8 @@ require('./status')(AV);
 require('./search')(AV);
 require('./insight')(AV);
 
+// Node.js platform specific
+require('./browserify-wrapper/node-ajax')(AV);
+
 // Backward compatibility
 AV.AV = AV;

lib/browserify-wrapper/node-ajax.js

@@ -0,0 +1,63 @@
+'use strict';
+
+var http = require('http');
+var https = require('https');
+var url = require('url');
+
+module.exports = function(AV) {
+  // `keepAlive` option only work on Node.js 0.12+
+  AV._httpAgent = new http.Agent({keepAlive: true});
+  AV._httpsAgent = new https.Agent({keepAlive: true});
+
+  AV._ajax = function _ajax(method, resourceUrl, data, success, error) {
+    var parsedUrl = url.parse(resourceUrl);
+    var promise = new AV.Promise();
+
+    var transportModule = http;
+    var transportAgent = AV._httpAgent;
+
+    if (parsedUrl.protocol === 'https:') {
+      transportModule = https;
+      transportAgent = AV._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/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",