.commitlintrc.js

@@ -0,0 +1,3 @@
+module.exports = {
+  extends: ['@commitlint/config-conventional']
+};

index.js

@@ -4,7 +4,6 @@
  * Module dependencies.
  */
 const methods = require('methods');
-const http = require('http');
 let http2;
 try {
   http2 = require('http2'); // eslint-disable-line global-require
@@ -32,15 +31,12 @@ module.exports = function(app, options = {}) {
           'supertest: this version of Node.js does not support http2'
         );
       }
-      app = http2.createServer(app); // eslint-disable-line no-param-reassign
-    } else {
-      app = http.createServer(app); // eslint-disable-line no-param-reassign
     }
   }
 
   methods.forEach(function(method) {
     obj[method] = function(url) {
-      var test = new Test(app, method, url);
+      var test = new Test(app, method, url, options.http2);
       if (options.http2) {
         test.http2();
       }

lib/test.js

@@ -5,10 +5,17 @@
  */
 
 const { inspect } = require('util');
+const http = require('http');
 const { STATUS_CODES } = require('http');
 const { Server } = require('tls');
 const { deepStrictEqual } = require('assert');
 const { Request } = require('superagent');
+let http2;
+try {
+  http2 = require('http2'); // eslint-disable-line global-require
+} catch (_) {
+  // eslint-disable-line no-empty
+}
 
 /** @typedef {import('superagent').Response} Response */
 
@@ -22,9 +29,17 @@ class Test extends Request {
    * @param {String} path
    * @api public
    */
-  constructor (app, method, path) {
+  constructor (app, method, path, optHttp2) {
     super(method.toUpperCase(), path);
 
+    if (typeof app === 'function') {
+      if (optHttp2) {
+        app = http2.createServer(app); // eslint-disable-line no-param-reassign
+      } else {
+        app = http.createServer(app); // eslint-disable-line no-param-reassign
+      }
+    }
+
     this.redirects(0);
     this.buffer();
     this.app = app;

package.json

@@ -1,14 +1,16 @@
 {
   "name": "supertest",
   "description": "SuperAgent driven library for testing HTTP servers",
-  "version": "7.0.0",
+  "version": "7.1.0",
   "author": "TJ Holowaychuk",
   "contributors": [],
   "dependencies": {
     "methods": "^1.1.2",
     "superagent": "^9.0.1"
   },
   "devDependencies": {
+    "@commitlint/cli": "17",
+    "@commitlint/config-conventional": "17",
     "body-parser": "^1.20.2",
     "cookie-parser": "^1.4.6",
     "eslint": "^8.32.0",

test/supertest.js

@@ -34,7 +34,7 @@ describe('request(url)', function () {
     });
 
     server = app.listen(function () {
-      const url = 'http://localhost:' + server.address().port;
+      const url = 'http://127.0.0.1:' + server.address().port;
       request(url)
         .get('/')
         .expect('hello', done);
@@ -51,7 +51,7 @@ describe('request(url)', function () {
       });
 
       server = app.listen(function () {
-        const url = 'http://localhost:' + server.address().port;
+        const url = 'http://127.0.0.1:' + server.address().port;
         const test = request(url).get('/');
         test.end(function (err, res) {
           this.should.eql(test);
@@ -79,6 +79,23 @@ describe('request(app)', function () {
       });
   });
 
+  it('should not ECONNRESET on multiple simultaneous tests', function (done) {
+    const app = express();
+
+    app.get('/', function (req, res) {
+      res.send('hey');
+    });
+
+    const test = request(app);
+
+    const requestCount = 10;
+
+    const requests = [];
+    for (let i = 0; i < requestCount; i += 1) requests.push(test.get('/'));
+
+    global.Promise.all(requests).then(() => done(), done);
+  });
+
   it('should work with an active server', function (done) {
     const app = express();
     let server;
@@ -107,7 +124,7 @@ describe('request(app)', function () {
     });
 
     server = app.listen(function () {
-      const url = 'http://localhost:' + server.address().port;
+      const url = 'http://127.0.0.1:' + server.address().port;
       request(url)
         .get('/')
         .end(function (err, res) {
@@ -328,7 +345,7 @@ describe('request(app)', function () {
       });
 
       server = app.listen(function () {
-        const url = 'http://localhost:' + server.address().port;
+        const url = 'http://127.0.0.1:' + server.address().port;
         request(url)
           .get('/')
           .timeout(1)
@@ -348,7 +365,7 @@ describe('request(app)', function () {
       });
 
       server = app.listen(function () {
-        const url = 'http://localhost:' + server.address().port;
+        const url = 'http://127.0.0.1:' + server.address().port;
         server.close();
         request(url)
           .get('/')
@@ -381,7 +398,7 @@ describe('request(app)', function () {
 
   describe('.expect(status)', function () {
     it('should handle connection error', function (done) {
-      const req = request.agent('http://localhost:1234');
+      const req = request.agent('http://127.0.0.1:1234');
 
       req
         .get('/')