feat: add inputTransformer option

Author: zirkelc

lib/deploy/events/cloudWatchEvent/compileCloudWatchEventEvents.js

@@ -23,6 +23,9 @@ module.exports = {
             let Name;
             let EventBusName;
             let IamRole;
+            let InputTransformer;
+            let InputPathsMap;
+            let InputTemplate;
 
             if (typeof eventRule === 'object') {
               if (!eventRule.event) {
@@ -41,14 +44,17 @@ module.exports = {
               }
               Input = eventRule.input;
               InputPath = eventRule.inputPath;
+              InputTransformer = eventRule.inputTransformer;
+              InputPathsMap = InputTransformer && eventRule.inputTransformer.inputPathsMap;
+              InputTemplate = InputTransformer && eventRule.inputTransformer.inputTemplate;
               Description = eventRule.description;
               Name = eventRule.name;
               EventBusName = JSON.stringify(eventRule.eventBusName);
               IamRole = eventRule.iamRole;
 
-              if (Input && InputPath) {
+              if ([Input, InputPath, InputTransformer].filter(Boolean).length > 1) {
                 const errorMessage = [
-                  'You can\'t set both input & inputPath properties at the',
+                  'You can\'t set input, inputPath and inputTransformer properties at the',
                   'same time for cloudwatch events.',
                   'Please check the AWS docs for more info',
                 ].join('');
@@ -62,6 +68,16 @@ module.exports = {
                 // escape quotes to favor JSON.parse
                 Input = Input.replace(/\"/g, '\\"'); // eslint-disable-line
               }
+
+              // no need to escape quotes in inputPathsMap
+              // because we add it as an object to the template
+              if (InputPathsMap && typeof InputPathsMap === 'object') {
+                InputPathsMap = JSON.stringify(InputPathsMap);
+              }
+              if (InputTemplate && typeof InputTemplate === 'string') {
+                // escape quotes to favor JSON.parse
+                InputTemplate = InputTemplate.replace(/\"/g, '\\"'); // eslint-disable-line
+              }
             } else {
               const errorMessage = [
                 `CloudWatch event of stateMachine "${stateMachineName}" is not an object`,
@@ -92,6 +108,10 @@ module.exports = {
                   "Targets": [{
                     ${Input ? `"Input": "${Input.replace(/\\n|\\r/g, '')}",` : ''}
                     ${InputPath ? `"InputPath": "${InputPath.replace(/\r?\n/g, '')}",` : ''}
+                    ${InputTransformer ? `"InputTransformer": {
+                      "InputPathsMap": ${InputPathsMap},
+                      "InputTemplate": "${InputTemplate}"
+                    },` : ''}
                     "Arn": { "Ref": "${stateMachineLogicalId}" },
                     "Id": "${cloudWatchId}",
                     ${IamRole ? `"RoleArn":"${IamRole}"` : `"RoleArn": {

lib/deploy/events/cloudWatchEvent/compileCloudWatchEventEvents.test.js

@@ -357,7 +357,43 @@ describe('awsCompileCloudWatchEventEvents', () => {
         .Properties.Targets[0].Input).to.equal('{"key":"value"}');
     });
 
-    itParam('should throw an error when both Input and InputPath are set', ['cloudwatchEvent', 'eventBridge'], (source) => {
+    itParam('should respect inputTransformer variable', ['cloudwatchEvent', 'eventBridge'], (source) => {
+      serverlessStepFunctions.serverless.service.stepFunctions = {
+        stateMachines: {
+          first: {
+            events: [
+              {
+                [source]: {
+                  event: {
+                    source: ['aws.ec2'],
+                    'detail-type': ['EC2 Instance State-change Notification'],
+                    detail: { state: ['pending'] },
+                  },
+                  enabled: false,
+                  inputTransformer: {
+                    inputPathsMap: {
+                      stage: '$.stageVariables',
+                    },
+                    inputTemplate: '{ "stage": <stage> }',
+                  },
+                },
+              },
+            ],
+          },
+        },
+      };
+
+      serverlessStepFunctions.compileCloudWatchEventEvents();
+
+      expect(serverlessStepFunctions.serverless.service
+        .provider.compiledCloudFormationTemplate.Resources.FirstEventsRuleCloudWatchEvent1
+        .Properties.Targets[0].InputTransformer.InputPathsMap).to.have.property('stage', '$.stageVariables');
+      expect(serverlessStepFunctions.serverless.service
+        .provider.compiledCloudFormationTemplate.Resources.FirstEventsRuleCloudWatchEvent1
+        .Properties.Targets[0].InputTransformer.InputTemplate).to.equal('{ "stage": <stage> }');
+    });
+
+    itParam('should throw an error when Input and InputPath and InputTransformer are set', ['cloudwatchEvent', 'eventBridge'], (source) => {
       serverlessStepFunctions.serverless.service.stepFunctions = {
         stateMachines: {
           first: {
@@ -374,6 +410,12 @@ describe('awsCompileCloudWatchEventEvents', () => {
                     key: 'value',
                   },
                   inputPath: '$.stageVariables',
+                  inputTransformer: {
+                    inputPathsMap: {
+                      stage: '$.stageVariables',
+                    },
+                    inputTemplate: '{ "stage": <stage> }',
+                  },
                 },
               },
             ],