allow providing initial data for IncomingMessage

Author: endel

example/uwebsockets_express.ts

@@ -7,6 +7,7 @@ const PORT = 8080;
 // external express router
 const users = express.Router();
 users.get("/", (req, res) => res.json({ username: "Jake Badlands" }));
+users.get("/param/:id", (req, res) => res.json({ id: req.params.id }));
 
 const app = expressify(uWS.App());
 app.use("/users", users);

package.json

@@ -1,6 +1,6 @@
 {
   "name": "uwebsockets-express",
-  "version": "1.4.0",
+  "version": "1.4.1",
   "description": "Express API compatibility layer for uWebSockets.js",
   "main": "./build/index.cjs",
   "module": "./build/index.mjs",

src/Application.ts

@@ -35,7 +35,7 @@ export class Application extends EventEmitter {
   protected handler = async (uwsResponse: uWS.HttpResponse, uwsRequest: uWS.HttpRequest) => {
     const url = uwsRequest.getUrl();
 
-    const req = new IncomingMessage(uwsRequest, uwsResponse, [], this);
+    const req = new IncomingMessage(uwsRequest, uwsResponse, this);
     const res = new ServerResponse(uwsResponse, req, this);
 
     uwsResponse.onAborted(onAbort.bind(undefined, req, res));

src/IncomingMessage.ts

@@ -33,30 +33,38 @@ export class IncomingMessage extends EventEmitter implements http.IncomingMessag
   public socket = new Socket(false, true);
 
   #_originalUrlParsed: URL;
+  private parameterNames: string[] = [];
 
   constructor(
     private req: uWS.HttpRequest,
     private res: uWS.HttpResponse,
-    private parameterNames: string[],
-    private app: Application
+    private app: Application,
+    initialData?: {
+      headers?: http.IncomingHttpHeaders;
+      url?: string;
+      method?: string;
+      body?: any;
+      query?: string;
+      remoteAddress?: ArrayBuffer;
+    }
   ) {
     super();
 
-    this._headers = {};
-    this.req.forEach((key, value) => {
-      this._headers[key] = value;
+    this._headers = initialData?.headers || {};
 
-      // workaround: also consider 'referrer'
-      if (key === "referer") {
-        this._headers['referrer'] = value;
-      }
-    });
+    if (!initialData?.headers) {
+      this.req.forEach((key, value) => this._headers[key] = value);
+    }
 
-    this.url = this.req.getUrl();
-    this.method = this.req.getMethod().toUpperCase();
+    this.url = initialData?.url || this.req.getUrl();
+    this.method = (initialData?.method || this.req.getMethod()).toUpperCase();
 
-    this._rawquery = this.req.getQuery();
-    this._remoteAddress = this.res.getRemoteAddressAsText();
+    this._rawquery = initialData?.query || this.req.getQuery();
+    this._remoteAddress = initialData?.remoteAddress || this.res.getRemoteAddressAsText();
+
+    if (this._headers['referer']) {
+      this._headers['referrer'] = this._headers['referer'];
+    }
 
     if (this._rawquery) {
       this.url += `?${this._rawquery}`;