From faceae34c53b2dad53da76fe5e672ab1770da4eb Mon Sep 17 00:00:00 2001
From: Ian Storm Taylor <ian@ianstormtaylor.com>
Date: Sun, 13 Dec 2020 16:25:14 -0800
Subject: [PATCH] http: attach request as res.req

This change makes it possible for userland http-related modules
to pave over edge cases that require referencing the original request
when handling a response--making a "Lodash for HTTP" library possible.
More information and research in https://github.com/nodejs/node/issues/28673

Fixes: https://github.com/nodejs/node/issues/28673
---
 doc/api/http.md                               |  9 +++++
 doc/api/http2.md                              |  9 +++++
 lib/_http_server.js                           |  1 +
 lib/internal/http2/compat.js                  |  4 ++
 test/parallel/test-http-server.js             |  2 +
 .../test-http2-compat-serverresponse.js       | 40 +++++++++++++++++++
 6 files changed, 65 insertions(+)
 create mode 100644 test/parallel/test-http2-compat-serverresponse.js

diff --git a/doc/api/http.md b/doc/api/http.md
index 8851ae8d6e4893..0302da4b19426b 100644
--- a/doc/api/http.md
+++ b/doc/api/http.md
@@ -1589,6 +1589,15 @@ Removes a header that's queued for implicit sending.
 response.removeHeader('Content-Encoding');
 ```
 
+### `response.req`
+<!-- YAML
+added: REPLACEME
+-->
+
+* {http.IncomingMessage}
+
+A reference to the original HTTP `request` object.
+
 ### `response.sendDate`
 <!-- YAML
 added: v0.7.5
diff --git a/doc/api/http2.md b/doc/api/http2.md
index ddb5658d25367f..25b66b0163dea1 100644
--- a/doc/api/http2.md
+++ b/doc/api/http2.md
@@ -3418,6 +3418,15 @@ Removes a header that has been queued for implicit sending.
 response.removeHeader('Content-Encoding');
 ```
 
+### `response.req`
+<!-- YAML
+added: REPLACEME
+-->
+
+* {http2.Http2ServerRequest}
+
+A reference to the original HTTP2 `request` object.
+
 #### `response.sendDate`
 <!-- YAML
 added: v8.4.0
diff --git a/lib/_http_server.js b/lib/_http_server.js
index 419b08a7a0986d..eb33ea3b111873 100644
--- a/lib/_http_server.js
+++ b/lib/_http_server.js
@@ -173,6 +173,7 @@ function ServerResponse(req) {
 
   if (req.method === 'HEAD') this._hasBody = false;
 
+  this.req = req;
   this.sendDate = true;
   this._sent100 = false;
   this._expect_continue = false;
diff --git a/lib/internal/http2/compat.js b/lib/internal/http2/compat.js
index a0251ffbafecd2..8d196f74b610d4 100644
--- a/lib/internal/http2/compat.js
+++ b/lib/internal/http2/compat.js
@@ -522,6 +522,10 @@ class Http2ServerResponse extends Stream {
     return this[kStream].headersSent;
   }
 
+  get req() {
+    return this[kStream][kRequest];
+  }
+
   get sendDate() {
     return this[kState].sendDate;
   }
diff --git a/test/parallel/test-http-server.js b/test/parallel/test-http-server.js
index f591cd59fc63c2..dcefc761728d36 100644
--- a/test/parallel/test-http-server.js
+++ b/test/parallel/test-http-server.js
@@ -49,6 +49,8 @@ const server = http.createServer(function(req, res) {
   res.id = request_number;
   req.id = request_number++;
 
+  assert.strictEqual(res.req, req);
+
   if (req.id === 0) {
     assert.strictEqual(req.method, 'GET');
     assert.strictEqual(url.parse(req.url).pathname, '/hello');
diff --git a/test/parallel/test-http2-compat-serverresponse.js b/test/parallel/test-http2-compat-serverresponse.js
new file mode 100644
index 00000000000000..379677a68f81e1
--- /dev/null
+++ b/test/parallel/test-http2-compat-serverresponse.js
@@ -0,0 +1,40 @@
+'use strict';
+
+const common = require('../common');
+if (!common.hasCrypto)
+  common.skip('missing crypto');
+const assert = require('assert');
+const h2 = require('http2');
+
+// Http2ServerResponse should expose convenience properties
+
+const server = h2.createServer();
+server.listen(0, common.mustCall(function() {
+  const port = server.address().port;
+  server.once('request', common.mustCall(function(request, response) {
+    assert.strictEqual(response.req, request);
+
+    response.on('finish', common.mustCall(function() {
+      process.nextTick(() => {
+        server.close();
+      });
+    }));
+    response.end();
+  }));
+
+  const url = `http://localhost:${port}`;
+  const client = h2.connect(url, common.mustCall(function() {
+    const headers = {
+      ':path': '/foobar',
+      ':method': 'GET',
+      ':scheme': 'http',
+      ':authority': `localhost:${port}`
+    };
+    const request = client.request(headers);
+    request.on('end', common.mustCall(function() {
+      client.close();
+    }));
+    request.end();
+    request.resume();
+  }));
+}));