http2: add tests and benchmarks

PR-URL: https://github.com/nodejs/node/pull/14239
Reviewed-By: Anna Henningsen <anna@addaleax.net>
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>

1 files changed, 71 insertions, 0 deletions

diff --git a/test/parallel/test-http2-connect-method.js b/test/parallel/test-http2-connect-method.js
new file mode 100644
index 0000000000..05ff96a3cd
--- /dev/null
+++ b/test/parallel/test-http2-connect-method.js
@@ -0,0 +1,71 @@
+// Flags: --expose-http2
+'use strict';
+
+const common = require('../common');
+const assert = require('assert');
+const net = require('net');
+const http2 = require('http2');
+const { URL } = require('url');
+
+const {
+  HTTP2_HEADER_METHOD,
+  HTTP2_HEADER_AUTHORITY,
+  NGHTTP2_CONNECT_ERROR
+} = http2.constants;
+
+const server = net.createServer(common.mustCall((socket) => {
+  let data = '';
+  socket.setEncoding('utf8');
+  socket.on('data', (chunk) => data += chunk);
+  socket.on('end', common.mustCall(() => {
+    assert.strictEqual(data, 'hello');
+  }));
+  socket.on('close', common.mustCall());
+  socket.end('hello');
+}));
+
+server.listen(0, common.mustCall(() => {
+
+  const port = server.address().port;
+
+  const proxy = http2.createServer();
+  proxy.on('stream', common.mustCall((stream, headers) => {
+    if (headers[HTTP2_HEADER_METHOD] !== 'CONNECT') {
+      stream.rstWithRefused();
+      return;
+    }
+    const auth = new URL(`tcp://${headers[HTTP2_HEADER_AUTHORITY]}`);
+    assert.strictEqual(auth.hostname, 'localhost');
+    assert.strictEqual(+auth.port, port);
+    const socket = net.connect(auth.port, auth.hostname, () => {
+      stream.respond();
+      socket.pipe(stream);
+      stream.pipe(socket);
+    });
+    socket.on('close', common.mustCall());
+    socket.on('error', (error) => {
+      stream.rstStream(NGHTTP2_CONNECT_ERROR);
+    });
+  }));
+
+  proxy.listen(0, () => {
+    const client = http2.connect(`http://localhost:${proxy.address().port}`);
+
+    const req = client.request({
+      [HTTP2_HEADER_METHOD]: 'CONNECT',
+      [HTTP2_HEADER_AUTHORITY]: `localhost:${port}`,
+    });
+
+    req.on('response', common.mustCall());
+    let data = '';
+    req.setEncoding('utf8');
+    req.on('data', (chunk) => data += chunk);
+    req.on('end', common.mustCall(() => {
+      assert.strictEqual(data, 'hello');
+      client.destroy();
+      proxy.close();
+      server.close();
+    }));
+    req.end('hello');
+  });
+}));