Node server fetch

benchmark/http/serve.js

@@ -0,0 +1,40 @@
+'use strict';
+
+const common = require('../common.js');
+const http = require('http');
+
+const bench = common.createBenchmark(main, {
+  server: ['createServer', 'serve', 'serve-fast'],
+  type: ['string', 'buffer'],
+  len: [4, 1024, 102400],
+  c: [50, 500],
+  duration: 5,
+});
+
+function main({ server: serverType, type, len, c, duration }) {
+  const body = type === 'string' ? 'C'.repeat(len) : Buffer.alloc(len, 67);
+  const headers = {
+    'Content-Length': `${len}`,
+    'Content-Type': 'application/octet-stream',
+  };
+
+  let server;
+  if (serverType === 'serve') {
+    server = http.serve(() => new Response(body, { headers }));
+  } else if (serverType === 'serve-fast') {
+    server = http.serve(() => new http.NodeResponse(body, { headers }));
+  } else {
+    server = http.createServer((request, response) => {
+      response.writeHead(200, headers);
+      response.end(body);
+    });
+  }
+
+  server.listen(0, () => {
+    bench.http({
+      connections: c,
+      duration,
+      port: server.address().port,
+    }, () => server.close());
+  });
+}

deps/undici/undici.js

@@ -12561,7 +12561,9 @@ var require_response = __commonJS({
       Response,
       cloneResponse,
       fromInnerResponse,
-      getResponseState
+      getResponseState,
+      setResponseState,
+      setResponseHeaders
     };
   }
 });
@@ -13347,6 +13349,9 @@ var require_request2 = __commonJS({
       cloneRequest,
       getRequestDispatcher,
       getRequestState,
+      setRequestState,
+      setRequestHeaders,
+      setRequestSignal,
       removeRequestAbortListener
     };
   }
@@ -18572,6 +18577,25 @@ module.exports.FormData = require_formdata().FormData;
 module.exports.Headers = require_headers().Headers;
 module.exports.Response = require_response().Response;
 module.exports.Request = require_request2().Request;
+// Exposed only through Node.js' internal Undici bundle for HTTP server use.
+// This is the single boundary through which Node.js core may reach fetch
+// internals; keep it in sync with lib/internal/http_serve_classes.js.
+module.exports.serverKit = Object.freeze({
+  kConstruct: require_symbols().kConstruct,
+  HeadersList: require_headers().HeadersList,
+  fillHeaders: require_headers().fill,
+  getHeadersList: require_headers().getHeadersList,
+  setHeadersList: require_headers().setHeadersList,
+  getHeadersGuard: require_headers().getHeadersGuard,
+  setHeadersGuard: require_headers().setHeadersGuard,
+  getRequestState: require_request2().getRequestState,
+  setRequestState: require_request2().setRequestState,
+  setRequestHeaders: require_request2().setRequestHeaders,
+  setRequestSignal: require_request2().setRequestSignal,
+  getResponseState: require_response().getResponseState,
+  setResponseState: require_response().setResponseState,
+  setResponseHeaders: require_response().setResponseHeaders
+});
 var { CloseEvent, ErrorEvent, MessageEvent, createFastMessageEvent } = require_events();
 module.exports.WebSocket = require_websocket().WebSocket;
 module.exports.CloseEvent = CloseEvent;

lib/_http_common.js

@@ -330,6 +330,7 @@ function calculateLenientFlags(httpValidation, insecureHTTPParserOption) {
 module.exports = {
   _checkInvalidHeaderChar: checkInvalidHeaderChar,
   _checkIsHttpToken: checkIsHttpToken,
+  allMethods,
   chunkExpression: /(?:^|\W)chunked(?:$|\W)/i,
   continueExpression: /(?:^|\W)100-continue(?:$|\W)/i,
   CRLF: '\r\n', // TODO: Deprecate this.

lib/http.js

@@ -42,6 +42,16 @@ const {
   Server,
   ServerResponse,
 } = require('_http_server');
+// Loaded lazily: pulling in the serve() implementation loads the undici
+// bundle, and doing that while this module is still initializing would let
+// undici capture a half-initialized http module (e.g. no maxHeaderSize).
+function serve(options, handler) {
+  return require('internal/http_serve').serve(options, handler);
+}
+
+function getRemoteMetadata(request) {
+  return require('internal/http_serve').getRemoteMetadata(request);
+}
 const {
   parseProxyUrl,
   getGlobalAgent,
@@ -201,8 +211,28 @@ module.exports = {
     parsers.max = max;
   },
   setGlobalProxyFromEnv,
+  serve,
+  getRemoteMetadata,
 };
 
+ObjectDefineProperty(module.exports, 'NodeRequest', {
+  __proto__: null,
+  configurable: true,
+  enumerable: true,
+  get() {
+    return require('internal/http_serve_classes').NodeRequest;
+  },
+});
+
+ObjectDefineProperty(module.exports, 'NodeResponse', {
+  __proto__: null,
+  configurable: true,
+  enumerable: true,
+  get() {
+    return require('internal/http_serve_classes').NodeResponse;
+  },
+});
+
 ObjectDefineProperty(module.exports, 'maxHeaderSize', {
   __proto__: null,
   configurable: true,