From fd66d5a7c76fa80fb49e088722b5f9f4604339ce Mon Sep 17 00:00:00 2001
From: Matteo Collina <hello@matteocollina.com>
Date: Wed, 15 Jul 2026 09:05:38 +0200
Subject: [PATCH] Revert "http: do not emit socket errors after complete
 response"

This reverts commit 17163ead3326a2eda3253c392474c777405a04c7.

Signed-off-by: Matteo Collina <hello@matteocollina.com>
---
 lib/_http_client.js                           | 16 +-----
 ...est-http-client-complete-response-reset.js | 55 -------------------
 2 files changed, 1 insertion(+), 70 deletions(-)
 delete mode 100644 test/parallel/test-http-client-complete-response-reset.js

diff --git a/lib/_http_client.js b/lib/_http_client.js
index d202a28f03502f..9eb3c10547d520 100644
--- a/lib/_http_client.js
+++ b/lib/_http_client.js
@@ -752,24 +752,10 @@ function socketErrorListener(err) {
   debug('SOCKET ERROR:', err.message, err.stack);
 
   if (req) {
-    const res = req.res;
-    const isUserDestroyError = err === req[kError] || err === res?.errored;
-
     // For Safety. Some additional errors might fire later on
     // and we need to make sure we don't double-fire the error event.
     socket._hadError = true;
-    // Before a response exists, the request itself failed. Once a response
-    // exists, socket teardown belongs to the IncomingMessage and is finalized
-    // by socketCloseListener. Preserve errors explicitly used to destroy the
-    // request or response, which have historically been emitted on the request.
-    if (!res || isUserDestroyError) {
-      emitErrorEvent(req, err);
-    }
-
-    if (res) {
-      socket.destroy();
-      return;
-    }
+    emitErrorEvent(req, err);
   }
 
   const parser = socket.parser;
diff --git a/test/parallel/test-http-client-complete-response-reset.js b/test/parallel/test-http-client-complete-response-reset.js
deleted file mode 100644
index aa9337dbcc5206..00000000000000
--- a/test/parallel/test-http-client-complete-response-reset.js
+++ /dev/null
@@ -1,55 +0,0 @@
-'use strict';
-
-const common = require('../common');
-const assert = require('assert');
-const http = require('http');
-
-const BODY = Buffer.alloc(2 * 1024 * 1024);
-
-const server = http.createServer(common.mustCall((request, response) => {
-  let received = 0;
-
-  request.on('data', function onData(chunk) {
-    received += chunk.length;
-    request.off('data', onData);
-    request.destroy();
-  });
-
-  response.writeHead(413, { 'content-length': 0 });
-  response.end();
-
-  request.on('end', common.mustNotCall());
-  request.on('close', common.mustCall(() => {
-    assert.strictEqual(request.complete, false);
-    assert.ok(received > 0);
-  }));
-}));
-
-server.listen(0, common.mustCall(() => {
-  let response;
-  const req = http.request({
-    method: 'POST',
-    port: server.address().port,
-    headers: {
-      'content-type': 'application/json',
-      'content-length': BODY.length,
-    },
-  }, common.mustCall((res) => {
-    response = res;
-    assert.strictEqual(res.statusCode, 413);
-    // Deliberately do not consume the response body. A response that has
-    // already been received should not be followed by a late ClientRequest
-    // socket error.
-    req.write(BODY);
-    req.end();
-  }));
-
-  req.on('error', common.mustNotCall());
-  req.on('close', common.mustCall(() => {
-    assert(response);
-    assert.strictEqual(response.complete, true);
-    server.close();
-  }));
-
-  req.flushHeaders();
-}));