feat(eventbridge): add detail configuration

Author: jcortega

lib/package/eventbridge/compileMethodsToEventBridge.js

@@ -122,6 +122,10 @@ module.exports = {
       return `$input.params().querystring.${http.source.queryStringParam}`
     }
 
+    if (http.source.bodyParam) {
+      return `$util.parseJson($input.body).${http.source.bodyParam}`
+    }
+
     return `${http.source}`
   },
 
@@ -134,23 +138,40 @@ module.exports = {
       return `$input.params().path.${http.detailType.pathParam}`
     }
 
-    if (http.source.queryStringParam) {
+    if (http.detailType.queryStringParam) {
       return `$input.params().querystring.${http.detailType.queryStringParam}`
     }
 
+    if (http.detailType.bodyParam) {
+      return `$util.parseJson($input.body).${http.detailType.bodyParam}`
+    }
+
     return `${http.detailType}`
   },
 
+  getEventBridgeDetail(http) {
+    if (!_.has(http, 'detail')) {
+      return '$util.escapeJavaScript($input.body)'
+    }
+
+    if (http.detail.bodyParam) {
+      return `$util.escapeJavaScript($util.parseJson($input.body).${http.detail.bodyParam})`
+    }
+
+    return '$util.escapeJavaScript($input.body)'
+  },
+
   buildDefaultEventBridgeRequestTemplate(http) {
     const sourceParam = this.getEventBridgeSource(http)
     const detailTypeParam = this.getEventBridgeDetailType(http)
+    const detailParam = this.getEventBridgeDetail(http)
 
     return {
       'Fn::Sub': [
         '{"Entries":[{"Detail": "${Detail}","DetailType": "${DetailType}","EventBusName": "${EventBusName}","Source": "${Source}"}]}',
         {
           EventBusName: http.eventBusName,
-          Detail: '$util.escapeJavaScript($input.body)',
+          Detail: `${detailParam}`,
           DetailType: `${detailTypeParam}`,
           Source: `${sourceParam}`
         }

lib/package/eventbridge/compileMethodsToEventBridge.test.js

@@ -901,4 +901,33 @@ describe('#compileMethodsToEventBridge()', () => {
         .ApiGatewayMethodeventbridgePost.Properties.RequestParameters
     ).to.be.deep.equal({ 'method.request.header.Custom-Header': true })
   })
+
+  it('should set detail when detail is provided as bodyParam', () => {
+    const httpWithoutRequestTemplate = {
+      path: 'foo',
+      method: 'post',
+      eventBusName: 'myEventBus',
+      detailType: 'myDetailType',
+      source: 'myEventSource',
+      detail: {
+        bodyParam: 'data.detail'
+      }
+    }
+
+    const resource = serverlessApigatewayServiceProxy.getEventBridgeMethodIntegration(
+      httpWithoutRequestTemplate
+    )
+
+    expect(
+      resource.Properties.Integration.RequestTemplates['application/json']['Fn::Sub']
+    ).to.be.deep.equal([
+      '{"Entries":[{"Detail": "${Detail}","DetailType": "${DetailType}","EventBusName": "${EventBusName}","Source": "${Source}"}]}',
+      {
+        EventBusName: 'myEventBus',
+        Detail: '$util.escapeJavaScript($util.parseJson($input.body).data.detail)',
+        DetailType: 'myDetailType',
+        Source: 'myEventSource'
+      }
+    ])
+  })
 })