Fix implementation of kafka routing:

* Add more response details
* Ensure request body is available when kafka route is primary
* Ensure backwards compatible properties are used

Author: rcrichton

src/middleware/router.js

@@ -61,10 +61,14 @@ function setKoaResponse(ctx, response) {
     }
   }
 
-  // Save response body of the primary route
-  ctx.resBody = Buffer.isBuffer(response.body)
-    ? response.body.toString()
-    : response.body
+  // Save response details of the primary route
+  ctx.resDetails = {
+    status: response.status,
+    headers: response.headers,
+    body: Buffer.isBuffer(response.body)
+      ? response.body.toString()
+      : response.body
+  }
 
   for (const key in response.headers) {
     const value = response.headers[key]
@@ -299,6 +303,10 @@ function sendRequestToRoutes(ctx, routes, next) {
 
       if (route.primary) {
         ctx.primaryRoute = route
+
+        // Save request body of the primary route
+        ctx.reqBody = Buffer.isBuffer(ctx.body) ? ctx.body.toString() : ctx.body
+
         promise = sendRequest(ctx, route, options)
           .then(response => {
             logger.info(`executing primary route : ${route.name}`)
@@ -493,11 +501,6 @@ function sendRequest(ctx, route, options) {
       }
     }
 
-    if (route.primary) {
-      // Save request body of the primary route
-      ctx.reqBody = Buffer.isBuffer(ctx.body) ? ctx.body.toString() : ctx.body
-    }
-
     if (response instanceof Error) {
       orchestration.error = {
         message: response.message,
@@ -668,8 +671,8 @@ function sendKafkaRequest(ctx, route) {
           path: ctx.request.url,
           pattern: channel.urlPattern,
           headers: ctx.request.headers,
-          requestBody: ctx.reqBody ?? '',
-          responseBody: ctx.resBody ?? ''
+          body: ctx.reqBody ?? '',
+          response: ctx.resDetails ?? {}
         }
 
         return producer