nodejs · nodejs-github-bot · Nov 17, 2025 · Nov 15, 2025 · Nov 15, 2025
diff --git a/test/eslint.config_partial.mjs b/test/eslint.config_partial.mjs
@@ -195,7 +195,7 @@ export default [
       `test/parallel/test-{${
         // 0x61 is code for 'a', this generates a string enumerating latin letters: 'a*,b*,…'
         Array.from({ length: 4 }, (_, i) => String.fromCharCode(0x61 + i, 42)).join(',')
-      },${
+      },http-*,${
         // 0x61 is code for 'a', this generates a string enumerating latin letters: 'z*,y*,…'
         Array.from({ length: 5 }, (_, i) => String.fromCharCode(0x61 + 25 - i, 42)).join(',')
       }}.{js,mjs,cjs}`,

diff --git a/test/parallel/test-http-1.0.js b/test/parallel/test-http-1.0.js
@@ -34,7 +34,7 @@ function test(handler, request_generator, response_validator) {
   let server_response = '';
 
   server.listen(0);
-  server.on('listening', function() {
+  server.on('listening', common.mustCall(function() {
     const c = net.createConnection(this.address().port);
 
     c.setEncoding('utf8');
@@ -53,7 +53,7 @@ function test(handler, request_generator, response_validator) {
       server.close();
       response_validator(server_response, client_got_eof, false);
     }));
-  });
+  }));
 }
 
 {

diff --git a/test/parallel/test-http-abort-queued.js b/test/parallel/test-http-abort-queued.js
@@ -52,7 +52,7 @@ server.listen(0, common.mustCall(() => {
   };
 
   const req1 = http.request(options);
-  req1.on('response', (res1) => {
+  req1.on('response', common.mustCall((res1) => {
     assert.strictEqual(Object.keys(agent.sockets).length, 1);
     assert.strictEqual(Object.keys(agent.requests).length, 0);
 
@@ -68,10 +68,10 @@ server.listen(0, common.mustCall(() => {
 
     // TODO(jasnell): This event does not appear to currently be triggered.
     // is this handler actually required?
-    req2.on('error', (err) => {
+    req2.on('error', common.mustCallAtLeast((err) => {
       // This is expected in response to our explicit abort call
       assert.strictEqual(err.code, 'ECONNRESET');
-    });
+    }, 0));
 
     req2.end();
     req2.abort();
@@ -89,7 +89,7 @@ server.listen(0, common.mustCall(() => {
         server.close();
       }), 100);
     }));
-  });
+  }));
 
   req1.end();
 }));
diff --git a/test/parallel/test-http-abort-stream-end.js b/test/parallel/test-http-abort-stream-end.js
@@ -38,21 +38,21 @@ const server = http.createServer(common.mustCall((req, res) => {
   res.end();
 }));
 
-server.listen(0, () => {
+server.listen(0, common.mustCall(() => {
   const res = common.mustCall((res) => {
-    res.on('data', (chunk) => {
+    res.on('data', common.mustCallAtLeast((chunk) => {
       size += chunk.length;
       assert(!req.aborted, 'got data after abort');
       if (size > maxSize) {
         req.abort();
         assert.strictEqual(req.aborted, true);
         size = maxSize;
       }
-    });
+    }));
 
     req.on('abort', common.mustCall(() => assert.strictEqual(size, maxSize)));
     assert.strictEqual(req.aborted, false);
   });
 
   const req = http.get(`http://localhost:${server.address().port}`, res);
-});
+}));
diff --git a/test/parallel/test-http-agent-error-on-idle.js b/test/parallel/test-http-agent-error-on-idle.js
@@ -9,7 +9,7 @@ const server = http.createServer(common.mustCall((req, res) => {
   res.end('hello world');
 }, 2));
 
-server.listen(0, () => {
+server.listen(0, common.mustCall(() => {
   const agent = new Agent({ keepAlive: true });
 
   const requestParams = {
@@ -46,4 +46,4 @@ server.listen(0, () => {
     agent.destroy();
     server.close();
   }
-});
+}));
diff --git a/test/parallel/test-http-agent-keepalive-delay.js b/test/parallel/test-http-agent-keepalive-delay.js
@@ -16,11 +16,11 @@ const server = http.createServer(common.mustCall((req, res) => {
 
 server.listen(0, common.mustCall(() => {
   const createConnection = agent.createConnection;
-  agent.createConnection = (options, ...args) => {
+  agent.createConnection = common.mustCall((options, ...args) => {
     assert.strictEqual(options.keepAlive, true);
     assert.strictEqual(options.keepAliveInitialDelay, agent.keepAliveMsecs);
     return createConnection.call(agent, options, ...args);
-  };
+  });
   http.get({
     host: 'localhost',
     port: server.address().port,

diff --git a/test/parallel/test-http-agent-maxsockets.js b/test/parallel/test-http-agent-maxsockets.js
@@ -26,13 +26,13 @@ function get(path, callback) {
   }, callback);
 }
 
-const countdown = new Countdown(2, () => {
+const countdown = new Countdown(2, common.mustCall(() => {
   const freepool = agent.freeSockets[Object.keys(agent.freeSockets)[0]];
   assert.strictEqual(freepool.length, 2,
                      `expect keep 2 free sockets, but got ${freepool.length}`);
   agent.destroy();
   server.close();
-});
+}));
 
 function dec() {
   process.nextTick(() => countdown.dec());

diff --git a/test/parallel/test-http-agent-maxtotalsockets.js b/test/parallel/test-http-agent-maxtotalsockets.js
@@ -48,12 +48,12 @@ function start(param = {}) {
   server.keepAliveTimeout = 0;
   server2.keepAliveTimeout = 0;
 
-  const countdown = new Countdown(12, () => {
+  const countdown = new Countdown(12, common.mustCall(() => {
     assert.strictEqual(getRequestCount(), 0);
     agent.destroy();
     server.close();
     server2.close();
-  });
+  }));
 
   function handler(s) {
     for (let i = 0; i < 6; i++) {

diff --git a/test/parallel/test-http-agent-remove.js b/test/parallel/test-http-agent-remove.js
@@ -2,7 +2,7 @@
 const { mustCall } = require('../common');
 
 const http = require('http');
-const { strictEqual } = require('assert');
+const assert = require('assert');
 
 const server = http.createServer(mustCall((req, res) => {
   res.flushHeaders();
@@ -14,7 +14,7 @@ server.listen(0, mustCall(() => {
   }, mustCall(() => {
     const { socket } = req;
     socket.emit('agentRemove');
-    strictEqual(socket._httpMessage, req);
+    assert.strictEqual(socket._httpMessage, req);
     socket.destroy();
     server.close();
   }));

diff --git a/test/parallel/test-http-agent-reuse-drained-socket-only.js b/test/parallel/test-http-agent-reuse-drained-socket-only.js
@@ -28,14 +28,14 @@ function sendFstReq(serverPort) {
     agent,
     host: '127.0.0.1',
     port: serverPort,
-  }, (res) => {
+  }, common.mustCall((res) => {
     res.on('data', noop);
     res.on('end', common.mustCall(() => {
       // Agent's socket reusing code is registered to process.nextTick(),
       // and will be run after this function, make sure it take effect.
       setImmediate(sendSecReq, serverPort, req.socket.localPort);
     }));
-  });
+  }));
 
  // Make the `req.socket` non drained, i.e. has some data queued to write to
   // and accept by the kernel. In Linux and Mac, we only need to call `req.end(aLargeBuffer)`.
@@ -60,8 +60,8 @@ function sendFstReq(serverPort) {
    * back the socket within SO_SNDBUF quota or only one outstanding send condition.
    */
 
-  req.on('socket', () => {
-    req.socket.on('connect', () => {
+  req.on('socket', common.mustCall(() => {
+    req.socket.on('connect', common.mustCall(() => {
       // Print tcp send buffer information
       console.log(process.report.getReport().libuv.filter((handle) => handle.type === 'tcp'));
 
@@ -81,8 +81,8 @@ function sendFstReq(serverPort) {
 
       req.end(dataLargerThanTCPSendBuf);
       assert.ok(req.socket.writableLength > 0);
-    });
-  });
+    }));
+  }));
 }
 
 function sendSecReq(serverPort, fstReqCliPort) {
@@ -92,12 +92,12 @@ function sendSecReq(serverPort, fstReqCliPort) {
     agent,
     host: '127.0.0.1',
     port: serverPort,
-  }, (res) => {
+  }, common.mustCall((res) => {
     res.on('data', noop);
     res.on('end', common.mustCall(() => {
       setImmediate(sendThrReq, serverPort, req.socket.localPort);
     }));
-  });
+  }));
 
   req.on('socket', common.mustCall((sock) => {
     assert.notStrictEqual(sock.localPort, fstReqCliPort);

diff --git a/test/parallel/test-http-agent-scheduling.js b/test/parallel/test-http-agent-scheduling.js
@@ -54,19 +54,19 @@ function defaultTest() {
       maxSockets: 5
     });
 
-    bulkRequest(url, agent, (ports) => {
-      makeRequest(url, agent, (port) => {
+    bulkRequest(url, agent, common.mustCall((ports) => {
+      makeRequest(url, agent, common.mustCall((port) => {
         assert.strictEqual(ports[ports.length - 1], port);
-        makeRequest(url, agent, (port) => {
+        makeRequest(url, agent, common.mustCall((port) => {
           assert.strictEqual(ports[ports.length - 1], port);
-          makeRequest(url, agent, (port) => {
+          makeRequest(url, agent, common.mustCall((port) => {
             assert.strictEqual(ports[ports.length - 1], port);
             server.close();
             agent.destroy();
-          });
-        });
-      });
-    });
+          }));
+        }));
+      }));
+    }));
   }
 }
 
@@ -82,19 +82,19 @@ function fifoTest() {
       scheduling: 'fifo'
     });
 
-    bulkRequest(url, agent, (ports) => {
-      makeRequest(url, agent, (port) => {
+    bulkRequest(url, agent, common.mustCall((ports) => {
      makeRequest(url, agent, common.mustCall((port) => {
         assert.strictEqual(ports[0], port);
-        makeRequest(url, agent, (port) => {
+        makeRequest(url, agent, common.mustCall((port) => {
           assert.strictEqual(ports[1], port);
-          makeRequest(url, agent, (port) => {
+          makeRequest(url, agent, common.mustCall((port) => {
             assert.strictEqual(ports[2], port);
             server.close();
             agent.destroy();
-          });
-        });
-      });
-    });
+          }));
+        }));
+      }));
+    }));
   }
 }
 
@@ -110,19 +110,19 @@ function lifoTest() {
       scheduling: 'lifo'
     });
 
-    bulkRequest(url, agent, (ports) => {
-      makeRequest(url, agent, (port) => {
+    bulkRequest(url, agent, common.mustCall((ports) => {
+      makeRequest(url, agent, common.mustCall((port) => {
         assert.strictEqual(ports[ports.length - 1], port);
-        makeRequest(url, agent, (port) => {
+        makeRequest(url, agent, common.mustCall((port) => {
           assert.strictEqual(ports[ports.length - 1], port);
-          makeRequest(url, agent, (port) => {
+          makeRequest(url, agent, common.mustCall((por
B3F9
t) => {
             assert.strictEqual(ports[ports.length - 1], port);
             server.close();
             agent.destroy();
-          });
-        });
-      });
-    });
+          }));
+        }));
+      }));
+    }));
   }
 }
 

diff --git a/test/parallel/test-http-agent-timeout-option.js b/test/parallel/test-http-agent-timeout-option.js
@@ -1,7 +1,7 @@
 'use strict';
 
 const { mustCall } = require('../common');
-const { strictEqual } = require('assert');
+const assert = require('assert');
 const { Agent, get } = require('http');
 
 // Test that the listener that forwards the `'timeout'` event from the socket to
@@ -14,10 +14,10 @@ const request = get({
 });
 
 request.on('socket', mustCall((socket) => {
-  strictEqual(socket.timeout, 50);
+  assert.strictEqual(socket.timeout, 50);
 
   const listeners = socket.listeners('timeout');
 
-  strictEqual(listeners.length, 2);
-  strictEqual(listeners[1], request.timeoutCb);
+  assert.strictEqual(listeners.length, 2);
+  assert.strictEqual(listeners[1], request.timeoutCb);
 }));
diff --git a/test/parallel/test-http-agent.js b/test/parallel/test-http-agent.js
@@ -49,20 +49,20 @@ function makeRequests(outCount, inCount, shouldFail) {
     }, outCount * inCount);
   });
 
-  server.listen(0, () => {
+  server.listen(0, common.mustCall(() => {
     const port = server.address().port;
     for (let i = 0; i < outCount; i++) {
-      setTimeout(() => {
+      setTimeout(common.mustCall(() => {
         for (let j = 0; j < inCount; j++) {
           const req = http.get({ port: port, path: '/' }, onRequest);
           if (shouldFail)
             req.on('error', common.mustCall(onRequest));
           else
             req.on('error', (e) => assert.fail(e));
         }
-      }, i);
+      }), i);
     }
-  });
+  }));
   return p;
 }
 

diff --git a/test/parallel/test-http-allow-content-length-304.js b/test/parallel/test-http-allow-content-length-304.js
@@ -13,7 +13,7 @@ const server = http.createServer(common.mustCall((req, res) => {
   res.end(null);
 }));
 
-server.listen(0, () => {
+server.listen(0, common.mustCall(() => {
   const request = http.request({
     port: server.address().port,
   });
@@ -29,4 +29,4 @@ server.listen(0, () => {
   }));
 
   request.end(null);
-});
+}));