allow providing initial data for IncomingMessage

Author: endel

example/uwebsockets_express.ts

@@ -13,6 +13,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);

src/Application.ts

@@ -41,7 +41,7 @@ export class Application extends EventEmitter implements express.Application {
 
   protected init() {
     this.uWSApp.any("/*", async (uwsResponse, uwsRequest) => {
-      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

@@ -35,27 +35,39 @@ export class IncomingMessage extends EventEmitter implements http.IncomingMessag
   public socket = new Socket(true, 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.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();
+
+    // workaround: also consider 'referrer'
+    if (this.headers['referer']) {
+      this.headers['referrer'] = this.headers['referer'];
+    }
 
     if (this._rawquery) {
       this.url += `?${this._rawquery}`;