Fix for #3069 - Failing to handle schedule event body params due to f…

lib/plugins/aws/package/compile/events/schedule/index.js

@@ -61,6 +61,20 @@ class AwsCompileScheduledEvents {
               }
 
               if (Input && typeof Input === 'object') {
+                if (_.has(Input, 'body') && typeof Input.body === 'string') {
+                  try {
+                    Input.body = JSON.parse(Input.body);
+                  } catch (error) {
+                    const errorMessage = [
+                      'The body of the schedule event associated with',
+                      ` ${functionName} was passed as a string`,
+                      ' but it failed to parse to a JSON object.',
+                      ' Please check the docs for more info.',
+                    ].join('');
+                    throw new this.serverless.classes
+                      .Error(errorMessage);
+                  }
+                }
                 Input = JSON.stringify(Input);
               }
               if (Input && typeof Input === 'string') {

lib/plugins/aws/package/compile/events/schedule/index.test.js

@@ -287,6 +287,46 @@ describe('AwsCompileScheduledEvents', () => {
       expect(() => awsCompileScheduledEvents.compileScheduledEvents()).to.throw(Error);
     });
 
+    it('should not throw an error when Input body is a valid JSON string', () => {
+      awsCompileScheduledEvents.serverless.service.functions = {
+        first: {
+          events: [
+            {
+              schedule: {
+                rate: 'rate(10 minutes)',
+                enabled: false,
+                input: {
+                  body: '{ "functionId": "..." }',
+                },
+              },
+            },
+          ],
+        },
+      };
+
+      expect(() => awsCompileScheduledEvents.compileScheduledEvents()).not.to.throw(Error);
+    });
+
+    it('should throw an error when Input body is an invalid JSON string', () => {
+      awsCompileScheduledEvents.serverless.service.functions = {
+        first: {
+          events: [
+            {
+              schedule: {
+                rate: 'rate(10 minutes)',
+                enabled: false,
+                input: {
+                  body: 'an invalid input body',
+                },
+              },
+            },
+          ],
+        },
+      };
+
+      expect(() => awsCompileScheduledEvents.compileScheduledEvents()).to.throw(Error);
+    });
+
     it('should not create corresponding resources when scheduled events are not given', () => {
       awsCompileScheduledEvents.serverless.service.functions = {
         first: {