Allow passing agents directly.

Author: pluma

README.md

@@ -85,7 +85,8 @@ The type annotations in this documentation generally follow the definitions used
  * *databaseName* (optional): name of the active database. Default: `_system`.
  * *arangoVersion* (optional): value of the `x-arango-version` header. Default: `20300`.
  * *headers* (optional): an object with headers to send with every request.
- * *agentOptions* (optional): an object with options for the underlying [`http.Agent`](https://nodejs.org/api/http.html#http_new_agent_options). This has no effect in the browser. Default: `{maxSockets: 3, keepAlive: true, keepAliveMsecs: 1000}`.
+ * *agent* (optional): an http Agent instance to use for connections. This has no effect in the browser. Default: a new [`http.Agent`](https://nodejs.org/api/http.html#http_new_agent_options) instance configured with the *agentOptions*.
+ * *agentOptions* (optional): an object with options for the agent. This will be ignored if *agent* is also provided and has no effect in the browser. Default: `{maxSockets: 3, keepAlive: true, keepAliveMsecs: 1000}`.
 
 If *config* is a string, it will be interpreted as *config.url*.
 

dist/arango.all.js

@@ -603,7 +603,7 @@ function Connection(config) {
   if (!this.config.headers['x-arango-version']) {
     this.config.headers['x-arango-version'] = this.config.arangoVersion;
   }
-  this._request = createRequest(this.config.agentOptions);
+  this._request = createRequest(this.config.agent, this.config.agentOptions);
 }
 
 Connection.defaults = {
@@ -1812,9 +1812,8 @@ 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
+module.exports = function (agent, agentOptions) {
+  if (!agent && http.Agent) agent = new http.Agent(agentOptions); // server only
   return function request(_ref, cb) {
     var method = _ref.method;
     var url = _ref.url;

dist/arango.all.min.js

@@ -603,7 +603,7 @@ function Connection(config) {
   if (!this.config.headers['x-arango-version']) {
     this.config.headers['x-arango-version'] = this.config.arangoVersion;
   }
-  this._request = createRequest(this.config.agentOptions);
+  this._request = createRequest(this.config.agent, this.config.agentOptions);
 }
 
 Connection.defaults = {
@@ -1812,9 +1812,8 @@ 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
+module.exports = function (agent, agentOptions) {
+  if (!agent && http.Agent) agent = new http.Agent(agentOptions); // server only
   return function request(_ref, cb) {
     var method = _ref.method;
     var url = _ref.url;

dist/arango.js

@@ -19,7 +19,7 @@ function Connection(config) {
   if (!this.config.headers['x-arango-version']) {
     this.config.headers['x-arango-version'] = this.config.arangoVersion;
   }
-  this._request = createRequest(this.config.agentOptions);
+  this._request = createRequest(this.config.agent, this.config.agentOptions);
 }
 
 Connection.defaults = {

dist/arango.min.js

@@ -4,9 +4,8 @@ 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
+module.exports = function (agent, agentOptions) {
+  if (!agent && http.Agent) agent = new http.Agent(agentOptions); // server only
   return function request(_ref, cb) {
     var method = _ref.method;
     var url = _ref.url;

lib/connection.js

@@ -19,7 +19,7 @@ function Connection(config) {
   if (!this.config.headers['x-arango-version']) {
     this.config.headers['x-arango-version'] = this.config.arangoVersion;
   }
-  this._request = createRequest(this.config.agentOptions);
+  this._request = createRequest(this.config.agent, this.config.agentOptions);
 }
 
 Connection.defaults = {

lib/util/request.js

@@ -4,9 +4,8 @@ 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
+module.exports = function (agent, agentOptions) {
+  if (!agent && http.Agent) agent = new http.Agent(agentOptions); // server only
   return function request({method, url, headers, body}, cb) {
     var options = extend(parseUrl(url), {method, headers, agent});
     var callback = once(cb);