fixup: isServerRequest

Author: ronag

lib/_http_client.js

@@ -53,7 +53,6 @@ const {
   prepareError,
 } = require('_http_common');
 const { OutgoingMessage } = require('_http_outgoing');
-const { kDestroy } = require('internal/streams/destroy');
 const Agent = require('_http_agent');
 const { Buffer } = require('buffer');
 const { defaultTriggerAsyncIdScope } = require('internal/async_hooks');
@@ -610,7 +609,6 @@ function parserOnIncomingClient(res, shouldKeepAlive) {
   DTRACE_HTTP_CLIENT_RESPONSE(socket, req);
   req.res = res;
   res.req = req;
-  res[kDestroy] = null;
 
   // Add our listener first, so that we guarantee socket cleanup
   res.on('end', responseOnEnd);

lib/_http_incoming.js

@@ -31,7 +31,6 @@ const {
 } = primordials;
 
 const { Readable, finished } = require('stream');
-const { kDestroy } = require('internal/streams/destroy');
 
 const kHeaders = Symbol('kHeaders');
 const kHeadersCount = Symbol('kHeadersCount');
@@ -199,11 +198,6 @@ IncomingMessage.prototype._destroy = function _destroy(err, cb) {
   }
 };
 
-IncomingMessage.prototype[kDestroy] = function(err) {
-  this.socket = null;
-  this.destroy(err);
-};
-
 IncomingMessage.prototype._addHeaderLines = _addHeaderLines;
 function _addHeaderLines(headers, n) {
   if (headers && headers.length) {

lib/internal/streams/destroy.js

@@ -14,6 +14,7 @@ const {
   kDestroyed,
   isDestroyed,
   isFinished,
+  isServerRequest
 } = require('internal/streams/utils');
 
 const kDestroy = Symbol('kDestroy');
@@ -389,8 +390,9 @@ function destroyer(stream, err) {
   }
 
   // TODO: Remove isRequest branches.
-  if (typeof stream[kDestroy] === 'function') {
-    stream[kDestroy](err);
+  if (isServerRequest(stream)) {
+    stream.socket = null;
+    stream.destroy(err);
   } else if (isRequest(stream)) {
     stream.abort();
   } else if (isRequest(stream.req)) {
@@ -412,7 +414,6 @@ function destroyer(stream, err) {
 }
 
 module.exports = {
-  kDestroy,
   construct,
   destroyer,
   destroy,

lib/internal/streams/utils.js

@@ -164,6 +164,14 @@ function isServerResponse(stream) {
   );
 }
 
+function isServerRequest(stream) {
+  return (
+    typeof stream._consuming === 'boolean' &&
+    typeof stream._dumped === 'boolean' &&
+    stream.req?.upgradeOrConnect === undefined
+  );
+}
+
 function willEmitClose(stream) {
   if (!isStream(stream)) return null;
 
@@ -194,5 +202,7 @@ module.exports = {
   isWritableStream,
   isWritableEnded,
   isWritableFinished,
+  isServerRequest,
+  isServerResponse,
   willEmitClose,
 };