Revert "http: fix test where aborted should not be emitted"

This reverts commit 461bf36.

PR-URL: #28699
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>

Author: Trott

doc/api/http.md

@@ -541,8 +541,7 @@ added: v0.3.8
 -->
 
 Marks the request as aborting. Calling this will cause remaining data
-in the response to be dropped and the socket to be destroyed. After
-calling this method no further errors will be emitted.
+in the response to be dropped and the socket to be destroyed.
 
 ### request.aborted
 <!-- YAML
@@ -2143,6 +2142,8 @@ will be emitted in the following order:
 * `'socket'`
 * (`req.abort()` called here)
 * `'abort'`
+* `'error'` with an error with message `'Error: socket hang up'` and code
+  `'ECONNRESET'`
 * `'close'`
 
 If `req.abort()` is called after the response is received, the following events

lib/_http_client.js

@@ -374,9 +374,7 @@ function socketCloseListener() {
       // receive a response. The error needs to
       // fire on the request.
       req.socket._hadError = true;
-      if (!req.aborted) {
-        req.emit('error', connResetException('socket hang up'));
-      }
+      req.emit('error', connResetException('socket hang up'));
     }
     req.emit('close');
   }
@@ -402,9 +400,7 @@ function socketErrorListener(err) {
     // For Safety. Some additional errors might fire later on
     // and we need to make sure we don't double-fire the error event.
     req.socket._hadError = true;
-    if (!req.aborted) {
-      req.emit('error', err);
-    }
+    req.emit('error', err);
   }
 
   // Handle any pending data
@@ -438,9 +434,7 @@ function socketOnEnd() {
     // If we don't have a response then we know that the socket
     // ended prematurely and we need to emit an error on the request.
     req.socket._hadError = true;
-    if (!req.aborted) {
-      req.emit('error', connResetException('socket hang up'));
-    }
+    req.emit('error', connResetException('socket hang up'));
   }
   if (parser) {
     parser.finish();
@@ -463,9 +457,7 @@ function socketOnData(d) {
     freeParser(parser, req, socket);
     socket.destroy();
     req.socket._hadError = true;
-    if (!req.aborted) {
-      req.emit('error', ret);
-    }
+    req.emit('error', ret);
   } else if (parser.incoming && parser.incoming.upgrade) {
     // Upgrade (if status code 101) or CONNECT
     var bytesParsed = ret;

test/parallel/test-http-client-aborted.js

@@ -23,7 +23,8 @@ server.listen(0, common.localhostIPv4, common.mustCall(() => {
     }));
   }));
   req.on('timeout', common.mustCall(() => req.abort()));
-  req.on('abort', common.mustCall(() => {
+  req.on('error', common.mustCall((err) => {
+    assert.strictEqual(err.message, 'socket hang up');
     server.close();
   }));
 }));

test/parallel/test-http-client-no-error-after-aborted.js

@@ -34,7 +34,7 @@ const server = createServer(common.mustCall((req, res) => {
     }));
   }).listen(0, () => {
     external = get(`http://127.0.0.1:${server.address().port}`);
-    external.on('abort', common.mustCall(() => {
+    external.on('error', common.mustCall(() => {
       server.close();
       internal.close();
     }));