Replaced request with http.request wrapper.

Author: pluma

dist/arango.all.js

@@ -2,7 +2,7 @@
 var promisify = require('./util/promisify');
 var extend = require('extend');
 var qs = require('querystring');
-var xhr = require('request');
+var createRequest = require('./util/request');
 var ArangoError = require('./error');
 var Route = require('./route');
 var jsonMime = /\/(json|javascript)(\W|$)/;
@@ -14,19 +14,23 @@ function Connection(config) {
     config = { url: config };
   }
   this.config = extend({}, Connection.defaults, config);
+  this.config.agentOptions = extend({}, Connection.agentDefaults, this.config.agentOptions);
   if (!this.config.headers) this.config.headers = {};
   if (!this.config.headers['x-arango-version']) {
     this.config.headers['x-arango-version'] = this.config.arangoVersion;
   }
-  this.pool = extend({}, Connection.defaults.poolOpts, this.config.poolOpts);
+  this._request = createRequest(this.config.agentOptions);
 }
 
 Connection.defaults = {
   url: 'http://localhost:8529',
   databaseName: '_system',
-  arangoVersion: 20300,
-  requestOpts: { forever: true },
-  poolOpts: { maxSockets: 5 }
+  arangoVersion: 20300
+};
+Connection.agentDefaults = {
+  maxSockets: 3,
+  keepAlive: true,
+  keepAliveMsecs: 1000
 };
 
 extend(Connection.prototype, {
@@ -65,22 +69,21 @@ extend(Connection.prototype, {
       }
     }
 
-    xhr(extend({}, Connection.defaults.requestOpts, this.config.requestOpts, {
+    this._request({
       url: this._resolveUrl(opts),
       headers: extend(headers, this.config.headers, opts.headers),
       method: (opts.method || 'get').toUpperCase(),
-      pool: this.pool,
       body: body
-    }), function (err, response, rawBody) {
-      response.rawBody = rawBody;
-      if (err) callback(err, response);else if (response.headers['content-type'].match(jsonMime)) {
+    }, function (err, res) {
+      if (err) callback(err);else if (res.headers['content-type'].match(jsonMime)) {
         try {
-          response.body = JSON.parse(rawBody);
+          res.rawBody = res.body;
+          res.body = JSON.parse(res.rawBody);
         } catch (e) {
-          return callback(extend(e, { response: response }));
+          return callback(extend(e, { response: res }));
         }
-        if (!response.body.error) callback(null, response);else callback(extend(new ArangoError(response.body), { response: response }));
-      } else callback(null, extend(response, { body: rawBody }));
+        if (!res.body.error) callback(null, res);else callback(extend(new ArangoError(res.body), { response: res }));
+      } else callback(null, extend(res, { rawBody: res.body }));
     });
     return promise;
   }

dist/arango.all.min.js

@@ -0,0 +1,9 @@
+'use strict';
+module.exports = function once(cb) {
+  var called = false;
+  return function () {
+    if (called) return;
+    called = true;
+    return cb.apply(this, arguments);
+  };
+};

dist/arango.js

@@ -0,0 +1,34 @@
+'use strict';
+var http = require('http');
+var parseUrl = require('url').parse;
+var extend = require('extend');
+var once = require('./once');
+
+module.exports = function (agentOptions) {
+  var agent;
+  if (http.Agent) agent = new http.Agent(agentOptions); // server only
+  return function request(_ref, cb) {
+    var method = _ref.method;
+    var url = _ref.url;
+    var headers = _ref.headers;
+    var body = _ref.body;
+
+    var options = extend(parseUrl(url), { method: method, headers: headers, agent: agent });
+    var callback = once(cb);
+    var req = http.request(options, function (res) {
+      var data = [];
+      res.on('data', function (b) {
+        data.push(b);
+      }).on('end', function () {
+        res.body = data.join('');
+        callback(null, res);
+      });
+    });
+    req.on('error', function (err) {
+      err.request = req;
+      callback(err);
+    });
+    if (body) req.write(body);
+    req.end();
+  };
+};

dist/arango.min.js

@@ -58,14 +58,9 @@
     "istanbul": "^0.3.14",
     "mocha": "^2.2.4",
     "uglify-js": "^2.4.21",
-    "watch": "^0.16.0",
-    "xhr": "^2.0.1"
-  },
-  "browser": {
-    "request": "xhr"
+    "watch": "^0.16.0"
   },
   "dependencies": {
-    "extend": "^2.0.1",
-    "request": "^2.55.0"
+    "extend": "^2.0.1"
   }
 }