add support for query string forwarding

client/index.js

@@ -1,6 +1,8 @@
 const validator = require('validator')
 const EventSource = require('eventsource')
 const superagent = require('superagent')
+const url = require('url')
+const querystring = require('querystring')
 
 class Client {
   constructor ({ source, target, logger = console }) {
@@ -16,7 +18,13 @@ class Client {
   onmessage (msg) {
     const data = JSON.parse(msg.data)
 
-    const req = superagent.post(this.target).send(data.body)
+    let target = url.parse(this.target, true)
+    let mergedQuery = Object.assign(target.query, data.query)
+    target.search = querystring.stringify(mergedQuery)
+
+    delete data.query
+
+    const req = superagent.post(target).send(data.body)
 
     delete data.body
 

client/test/index.test.js

@@ -67,6 +67,25 @@ describe('client', () => {
       // Send request to proxy server
       await request(proxy).post(channel).send(payload).expect(200)
     })
+
+    test('POST /:channel forwards query string to target url', async (done) => {
+      const queryParams = {
+        param1: 'testData1',
+        param2: 'testData2'
+      }
+
+      // Expect request to target
+      const forward = nock('http://example.com').post('/foo/bar').query(queryParams).reply(200)
+
+      // Test is done when this is called
+      client.addEventListener('message', (msg) => {
+        expect(forward.isDone()).toBe(true)
+        done()
+      })
+
+      // Send request to proxy server with query string
+      await request(proxy).post(channel).query(queryParams).send()
+    })
   })
 
   describe('createChannel', () => {

server/server.js

@@ -89,6 +89,7 @@ module.exports = (testRoute) => {
     events.emit(req.params.channel, {
       ...req.headers,
       body: req.body,
+      query: req.query,
       timestamp: Date.now()
     })
     res.status(200).end()