Use a client connection pool

README.md

@@ -312,3 +312,7 @@ any):
   [couch-login](https://npmjs.org/package/couch-login).
 * `sessionToken` {string} A random identifier for this set of client requests.
   Default = 8 random hexadecimal bytes.
+* `maxSockets` {Number} The maximum number of connections that will be open per
+  origin (unique combination of protocol:host:port). Passed to the
+  [httpAgent](https://nodejs.org/api/http.html#http_agent_maxsockets).
+  Default = 50

index.js

@@ -39,6 +39,7 @@ function RegClient (config) {
   if (typeof this.config.retry.factor !== 'number') this.config.retry.factor = 10
   if (typeof this.config.retry.minTimeout !== 'number') this.config.retry.minTimeout = 10000
   if (typeof this.config.retry.maxTimeout !== 'number') this.config.retry.maxTimeout = 60000
+  if (typeof this.config.maxSockets !== 'number') this.config.maxSockets = 50
 
   this.config.userAgent = this.config.userAgent || 'node/' + process.version
   this.config.defaultTag = this.config.defaultTag || 'latest'

lib/initialize.js

@@ -4,9 +4,6 @@ var HttpsAgent = require('https').Agent
 
 var pkg = require('../package.json')
 
-var httpAgent
-var httpsAgent
-
 module.exports = initialize
 
 function initialize (uri, method, accept, headers) {
@@ -24,7 +21,7 @@ function initialize (uri, method, accept, headers) {
     cert: this.config.ssl.certificate,
     key: this.config.ssl.key,
     ca: this.config.ssl.ca,
-    agent: getAgent(uri.protocol, this.config)
+    pool: getAgent.call(this, uri.protocol)
   }
 
   // allow explicit disabling of proxy in environment via CLI
@@ -55,28 +52,30 @@ function initialize (uri, method, accept, headers) {
   return opts
 }
 
-function getAgent (protocol, config) {
+function getAgent (protocol) {
   if (protocol === 'https:') {
-    if (!httpsAgent) {
-      httpsAgent = new HttpsAgent({
+    if (!this.httpsAgent) {
+      this.httpsAgent = new HttpsAgent({
         keepAlive: true,
-        localAddress: config.proxy.localAddress,
-        rejectUnauthorized: config.ssl.strict,
-        ca: config.ssl.ca,
-        cert: config.ssl.certificate,
-        key: config.ssl.key
+        maxSockets: this.config.maxSockets,
+        localAddress: this.config.proxy.localAddress,
+        rejectUnauthorized: this.config.ssl.strict,
+        ca: this.config.ssl.ca,
+        cert: this.config.ssl.certificate,
+        key: this.config.ssl.key
       })
     }
 
-    return httpsAgent
+    return this.httpsAgent
   } else {
-    if (!httpAgent) {
-      httpAgent = new HttpAgent({
+    if (!this.httpAgent) {
+      this.httpAgent = new HttpAgent({
         keepAlive: true,
-        localAddress: config.proxy.localAddress
+        maxSockets: this.config.maxSockets,
+        localAddress: this.config.proxy.localAddress
       })
     }
 
-    return httpAgent
+    return this.httpAgent
   }
 }

test/initialize.js

@@ -1,4 +1,5 @@
 var test = require('tap').test
+var url = require('url')
 
 // var server = require('./lib/server.js')
 var Client = require('../')
@@ -28,7 +29,40 @@ test('defaulted initialization', function (t) {
   t.ok(options.headers['user-agent'], 'user-agent preset')
 
   var HttpAgent = require('http').Agent
-  t.ok(options.agent instanceof HttpAgent, 'got an HTTP agent for an HTTP URL')
+  t.ok(options.pool instanceof HttpAgent, 'got an HTTP agent for an HTTP URL')
+  t.equal(options.pool.maxSockets, 50, 'maxSockets set to a reasonable default')
+
+  t.end()
+})
+
+test('intializing with maxSockets set works for http', function (t) {
+  var client = new Client({ maxSockets: Infinity })
+  var options = client.initialize(
+    url.parse('http://localhost:1337/'),
+    'GET',
+    'application/json',
+    {}
+  )
+
+  var HttpAgent = require('http').Agent
+  t.ok(options.pool instanceof HttpAgent, 'got an HTTP agent for an HTTP URL')
+  t.equal(options.pool.maxSockets, Infinity, 'request uses configured value for maxSockets')
+
+  t.end()
+})
+
+test('intializing with maxSockets set works for https', function (t) {
+  var client = new Client({ maxSockets: Infinity })
+  var options = client.initialize(
+    url.parse('https://localhost:1337/'),
+    'GET',
+    'application/json',
+    {}
+  )
+
+  var HttpsAgent = require('https').Agent
+  t.ok(options.pool instanceof HttpsAgent, 'got an HTTPS agent for an HTTPS URL')
+  t.equal(options.pool.maxSockets, Infinity, 'request uses configured value for maxSockets')
 
   t.end()
 })
@@ -86,6 +120,6 @@ test('initializing with a certificate should map down to the https agent', funct
     'application/json',
     {}
   )
-  t.equal(options.agent.options.cert, certificate, 'certificate will be saved properly on agent')
+  t.equal(options.pool.options.cert, certificate, 'certificate will be saved properly on agent')
   t.end()
 })