Copy the properties of http.IncomingMessage.prototype to request object by deep cloning

.gitignore

@@ -12,3 +12,4 @@ sls-next-build
 .DS_Store
 yarn.lock
 dist
+.vscode

packages/apigw-lambda-compat/lib/__tests__/compatLayer.request.test.js

@@ -1,4 +1,5 @@
 const create = require("../compatLayer");
+const http = require("http");
 
 describe("compatLayer.request", () => {
   it("request url path", () => {
@@ -276,4 +277,33 @@ describe("compatLayer.request", () => {
     expect(req.connection).toEqual({});
     done();
   });
+
+  it("request preserve http.IncomingMessage.prototype property", () => {
+    const exampleProperty = "I'm an example property";
+    http.IncomingMessage.prototype.exampleProperty = exampleProperty;
+    const { req } = create({
+      requestContext: {
+        path: ""
+      }
+    });
+
+    expect(typeof req.exampleProperty !== "undefined").toEqual(true);
+    expect(req.exampleProperty).toEqual(exampleProperty);
+  });
+
+  it("request preserve http.IncomingMessage.prototype function", () => {
+    const exampleFunction = function() {
+      return "I'm an example function.";
+    };
+    http.IncomingMessage.prototype.exampleFunction = exampleFunction;
+    const { req } = create({
+      requestContext: {
+        path: ""
+      }
+    });
+
+    expect(typeof req.exampleFunction === "function").toEqual(true);
+    expect(req.exampleFunction()).toEqual(exampleFunction());
+    expect(req.exampleFunction.toString()).toEqual(exampleFunction.toString());
+  });
 });

packages/apigw-lambda-compat/lib/compatLayer.js

@@ -1,5 +1,6 @@
 const Stream = require("stream");
 const queryString = require("querystring");
+const http = require("http");
 
 const reqResMapper = (event, callback) => {
   const base64Support = process.env.BINARY_SUPPORT === "yes";
@@ -11,7 +12,8 @@ const reqResMapper = (event, callback) => {
   };
   let responsePromise;
 
-  const req = new Stream.Readable();
+  const newStream = new Stream.Readable();
+  const req = Object.assign(newStream, http.IncomingMessage.prototype);
   req.url =
     (event.requestContext.path || event.path || "").replace(
       new RegExp("^/" + event.requestContext.stage),

packages/lambda-at-edge-compat/__tests__/next-aws-cloudfront.request.test.js

@@ -1,4 +1,5 @@
 const create = require("../next-aws-cloudfront");
+const http = require("http");
 
 const { SPECIAL_NODE_HEADERS } = create;
 
@@ -194,4 +195,33 @@ describe("Request Tests", () => {
     expect(req.connection).toEqual({});
     done();
   });
+
+  it("request preserve http.IncomingMessage.prototype property", () => {
+    const exampleProperty = "I'm an example property";
+    http.IncomingMessage.prototype.exampleProperty = exampleProperty;
+    const { req } = create({
+      request: {
+        uri: ""
+      }
+    });
+
+    expect(typeof req.exampleProperty !== "undefined").toEqual(true);
+    expect(req.exampleProperty).toEqual(exampleProperty);
+  });
+
+  it("request preserve http.IncomingMessage.prototype function", () => {
+    const exampleFunction = function() {
+      return "I'm an example function.";
+    };
+    http.IncomingMessage.prototype.exampleFunction = exampleFunction;
+    const { req } = create({
+      request: {
+        uri: ""
+      }
+    });
+
+    expect(typeof req.exampleFunction === "function").toEqual(true);
+    expect(req.exampleFunction()).toEqual(exampleFunction());
+    expect(req.exampleFunction.toString()).toEqual(exampleFunction.toString());
+  });
 });

packages/lambda-at-edge-compat/next-aws-cloudfront.js

@@ -1,5 +1,6 @@
 const Stream = require("stream");
 const zlib = require("zlib");
+const http = require("http");
 
 const specialNodeHeaders = [
   "age",
@@ -89,7 +90,8 @@ const handler = event => {
     headers: {}
   };
 
-  const req = new Stream.Readable();
+  const newStream = new Stream.Readable();
+  const req = Object.assign(newStream, http.IncomingMessage.prototype);
   req.url = cfRequest.uri;
   req.method = cfRequest.method;
   req.rawHeaders = [];