supporting req.query object forwarding to origin

Author: Rolando Santamaria Maso

README.md

@@ -155,6 +155,9 @@ module.exports.handler = serverless(service)
       //   // we can optionally reply from here if required
       //   res.end('Hello World!')
       //
+      //   // we can optionally update the request query params from here if required
+      //   req.query.category = 'js'
+      //
       //   return true // truthy value returned will abort the request forwarding
       },
       onResponse (req, res, stream) {  

index.js

@@ -97,7 +97,8 @@ const handler = (route, proxy, proxyHandler) => async (req, res, next) => {
       const proxyOpts = Object.assign({
         request: {
           timeout: req.timeout || route.timeout
-        }
+        },
+        queryString: req.query
       }, route.hooks)
 
       proxyHandler(req, res, req.url, proxy, proxyOpts)

test/config.js

@@ -73,6 +73,30 @@ module.exports = async () => {
       target: 'http://localhost:3000',
       methods: ['GET', 'POST']
     },
+    {
+      pathRegex: '',
+      prefix: '/qs',
+      prefixRewrite: '/qs',
+      target: 'http://localhost:3000',
+      methods: ['GET'],
+      hooks: {
+        onRequest: (req) => {
+          req.query.name = 'fast-gateway'
+        }
+      }
+    },
+    {
+      pathRegex: '',
+      prefix: '/qs2',
+      prefixRewrite: '/qs',
+      target: 'http://localhost:3000',
+      methods: ['GET'],
+      hooks: {
+        queryString: {
+          name: 'qs-overwrite'
+        }
+      }
+    },
     {
       pathRegex: '',
       prefix: '/endpoint-proxy-methods-put',

test/smoke.test.js

@@ -19,7 +19,7 @@ describe('API Gateway', () => {
       name: 'endpoint-proxy'
     }))
     remote.get('/info', (req, res) => res.send({
-      name: 'fastify-gateway'
+      name: 'fast-gateway'
     }))
     remote.get('/chunked', (req, res) => {
       res.write('user')
@@ -55,6 +55,12 @@ describe('API Gateway', () => {
     remote.post('/endpoint-proxy-methods', (req, res) => res.send({
       name: 'endpoint-proxy-methods'
     }))
+    remote.get('/qs', (req, res) => {
+      res.send(req.query)
+    })
+    remote.get('/qs2', (req, res) => {
+      res.send(req.query)
+    })
 
     await remote.start(3000)
   })
@@ -178,7 +184,7 @@ describe('API Gateway', () => {
       .get('/users/info')
       .expect(200)
       .then((response) => {
-        expect(response.body.name).to.equal('fastify-gateway')
+        expect(response.body.name).to.equal('fast-gateway')
       })
   })
 
@@ -305,6 +311,24 @@ describe('API Gateway', () => {
       })
   })
 
+  it('GET /qs - 200', async () => {
+    await request(gateway)
+      .get('/qs')
+      .expect(200)
+      .then((response) => {
+        expect(response.body.name).to.equal('fast-gateway')
+      })
+  })
+
+  it('GET /qs2 - 200', async () => {
+    await request(gateway)
+      .get('/qs2?name=fast-gateway')
+      .expect(200)
+      .then((response) => {
+        expect(response.body.name).to.equal('qs-overwrite')
+      })
+  })
+
   it('GET /lambda/hi', async () => {
     await request(gateway)
       .get('/lambda/hi')