https://github.com/fastify/fast-proxy/issues/30

.gitignore

@@ -57,4 +57,7 @@ typings/
 # dotenv environment variables file
 .env
 
-.vscode/
+.vscode/
+
+# jetbrains webstorm
+.idea

index.js

@@ -110,7 +110,7 @@ module.exports = (opts) => {
         }
 
         if (onResponse) {
-          onResponse(req, res, stream)
+          onResponse(req, res, stream, response)
         } else {
           res.statusCode = statusCode
           pump(stream, res)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "fast-proxy",
-  "version": "1.6.2",
+  "version": "1.6.3",
   "description": "Forward your HTTP request to another server.",
   "main": "index.js",
   "scripts": {

test/4.opts.test.js

@@ -36,7 +36,8 @@ describe('fast-proxy smoke', () => {
       proxy(req, res, req.url, {
         base: req.headers.base,
         queryString: { age: 33 },
-        onResponse (req, res, stream) {
+        onResponse (req, res, stream, response) {
+          res.statusCode = response.statusCode
           pump(stream, res)
         }
       })
@@ -50,10 +51,15 @@ describe('fast-proxy smoke', () => {
     service = require('restana')()
     service.use(bodyParser.json())
 
-    service.get('/service/headers', (req, res) => {
-      res.setHeader('url', req.url)
-      res.send()
-    })
+    service
+      .get('/service/headers', (req, res) => {
+        res.setHeader('url', req.url)
+        res.send()
+      })
+      .get('/service/302', (req, res) => {
+        res.statusCode = 302
+        res.end()
+      })
 
     await service.start(3000)
   })
@@ -86,6 +92,12 @@ describe('fast-proxy smoke', () => {
       })
   })
 
+  it('should support http status in on response', async () => {
+    await request(gHttpServer)
+      .get('/service/302')
+      .expect(302)
+  })
+
   it('close all', async () => {
     close()
     await gateway.close()