http: fix client response close & aborted

Fixes: https://github.com/nodejs/node/issues/20102
Fixes: https://github.com/nodejs/node/issues/20101
Fixes: https://github.com/nodejs/node/issues/1735

- Response should always emit close.
- Response should always emit aborted if aborted.
- Response should always emit close after request has emitted close.

PR-URL: https://github.com/nodejs/node/pull/20075
Fixes: https://github.com/nodejs/node/issues/17352
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Reviewed-By: James M Snell <jasnell@gmail.com>
Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com>

lib/_http_client.js

@@ -340,26 +340,33 @@ function socketCloseListener() {
 
   // NOTE: It's important to get parser here, because it could be freed by
   // the `socketOnData`.
-  var parser = socket.parser;
+  const parser = socket.parser;
-  if (req.res && req.res.readable) {
+  const res = req.res;
+  if (res) {
     // Socket closed before we emitted 'end' below.
-    if (!req.res.complete) {
+    if (!res.complete) {
-      req.res.aborted = true;
+      res.aborted = true;
-      req.res.emit('aborted');
+      res.emit('aborted');
     }
-    var res = req.res;
+    req.emit('close');
-    res.on('end', function() {
+    if (res.readable) {
+      res.on('end', function() {
+        this.emit('close');
+      });
+      res.push(null);
+    } else {
       res.emit('close');
-    });
+    }
-    res.push(null);
+  } else {
-  } else if (!req.res && !req.socket._hadError) {
+    if (!req.socket._hadError) {
-    // This socket error fired before we started to
+      // This socket error fired before we started to
-    // receive a response. The error needs to
+      // receive a response. The error needs to
-    // fire on the request.
+      // fire on the request.
-    req.socket._hadError = true;
+      req.socket._hadError = true;
-    req.emit('error', createHangUpError());
+      req.emit('error', createHangUpError());
+    }
+    req.emit('close');
   }
-  req.emit('close');
 
   // Too bad.  That output wasn't getting written.
   // This is pretty terrible that it doesn't raise an error.

test/parallel/test-http-response-close.js

@@ -23,29 +23,50 @@
 const common = require('../common');
 const http = require('http');
 
-const server = http.createServer(common.mustCall(function(req, res) {
+{
-  res.writeHead(200);
+  const server = http.createServer(
-  res.write('a');
+    common.mustCall((req, res) => {
+      res.writeHead(200);
+      res.write('a');
+    })
+  );
+  server.listen(
+    0,
+    common.mustCall(() => {
+      http.get(
+        { port: server.address().port },
+        common.mustCall((res) => {
+          res.on('data', common.mustCall(() => {
+            res.destroy();
+          }));
+          res.on('close', common.mustCall(() => {
+            server.close();
+          }));
+        })
+      );
+    })
+  );
+}
 
-  req.on('close', common.mustCall(function() {
+{
-    console.error('request aborted');
+  const server = http.createServer(
-  }));
+    common.mustCall((req, res) => {
-  res.on('close', common.mustCall(function() {
+      res.writeHead(200);
-    console.error('response aborted');
+      res.end('a');
-  }));
+    })
-}));
+  );
-server.listen(0);
+  server.listen(
-
+    0,
-server.on('listening', function() {
+    common.mustCall(() => {
-  console.error('make req');
+      http.get(
-  http.get({
+        { port: server.address().port },
-    port: this.address().port
+        common.mustCall((res) => {
-  }, function(res) {
+          res.on('close', common.mustCall(() => {
-    console.error('got res');
+            server.close();
-    res.on('data', function(data) {
+          }));
-      console.error('destroy res');
+          res.resume();
-      res.destroy();
+        })
-      server.close();
+      );
-    });
+    })
-  });
+  );
-});
+}