Added support for undici

README.md

@@ -65,7 +65,8 @@ For other examples, see `example.js`.
 
 ## Options
 
-This `fastify` plugin supports the following options.
+This `fastify` plugin supports _all_ the options of
+[`fastify-reply-from`](https://github.com/fastify/fastify-reply-from) plus the following.
 
 *Note that this plugin is fully encapsulated, and non-JSON payloads will
 be streamed directly to the destination.*
@@ -82,10 +83,6 @@ The prefix to mount this plugin on. All the requests to the current server start
 
 A `beforeHandler` to be applied on all routes. Useful for performing actions before the proxy is executed (e.g. check for authentication).
 
-### http2
-
-A boolean value that indicates whether the proxy should support http2.
-
 ## Benchmarks
 
 The following benchmarks where generated on a Macbook 2018 with i5 and
@@ -95,6 +92,8 @@ The following benchmarks where generated on a Macbook 2018 with i5 and
 | `express-http-proxy` | 878.4 |
 | `http-proxy` | 3837 |
 | `fastify-http-proxy` | 4205 |
+| `fastify-http-proxy` (with
+[`undici`](https://github.com/mcollina/undici)) | 6235.6 |
 
 The results where gathered on the second run of `autocannon -c 100 -d 5
 URL`.

benchmarks/fastify-proxy.js

@@ -5,9 +5,19 @@ const proxy = require('..')
 
 async function startProxy (upstream) {
   const server = Fastify()
+  let undici = false
+
+  if (process.env.UNDICI) {
+    undici = {
+      connections: 100,
+      pipelining: 10
+    }
+  }
+
   server.register(proxy, {
     upstream,
-    http2: !!process.env.HTTP2
+    http2: !!process.env.HTTP2,
+    undici
   })
 
   await server.listen(3000)

index.js

@@ -9,10 +9,11 @@ module.exports = async function (fastify, opts) {
 
   const beforeHandler = opts.beforeHandler
 
-  fastify.register(From, {
-    base: opts.upstream,
-    http2: opts.http2
-  })
+  const fromOpts = Object.assign({}, opts)
+  fromOpts.base = opts.upstream
+  fromOpts.prefix = undefined
+
+  fastify.register(From, fromOpts)
 
   fastify.addContentTypeParser('application/json', bodyParser)
   fastify.addContentTypeParser('*', bodyParser)

package.json

@@ -36,6 +36,6 @@
     "tap": "^12.0.0"
   },
   "dependencies": {
-    "fastify-reply-from": "^0.4.5"
+    "fastify-reply-from": "^0.5.0"
   }
 }