fix(AWS EventBridge): Ensure proper support for deadLetterConfig

serverless · Sep 30, 2021 · 77cdf54 · 77cdf54
1 parent abbb18d
commit 77cdf54
Show file tree

Hide file tree

Showing 4 changed files with 27 additions and 35 deletions.
diff --git a/docs/providers/aws/events/event-bridge.md b/docs/providers/aws/events/event-bridge.md
@@ -202,10 +202,9 @@ functions:
             source:
               - saas.external
           deadLetterConfig:
-            targetArn:
-              Fn::GetAtt:
-                - QueueName
-                - Arn
+            Fn::GetAtt:
+              - QueueName
+              - Arn
 ```
 
 ## Adding a retry policy to an event rule

diff --git a/docs/providers/aws/guide/serverless.yml.md b/docs/providers/aws/guide/serverless.yml.md
@@ -568,6 +568,13 @@ functions:
             inputPathsMap:
               eventTime: '$.time'
             inputTemplate: '{"time": <eventTime>, "key1": "value1"}'
+          retryPolicy:
+            maximumEventAge: 3600
+            maximumRetryAttempts: 3
+          deadLetterConfig:
+            Fn::GetAtt:
+              - QueueName
+              - Arn
       - cloudFront:
           eventType: viewer-response
           includeBody: true

diff --git a/lib/plugins/aws/package/compile/events/eventBridge/index.js b/lib/plugins/aws/package/compile/events/eventBridge/index.js
@@ -102,15 +102,7 @@ class AwsCompileEventBridgeEvents {
             },
           },
         },
-        deadLetterConfig: {
-          type: 'object',
-          properties: {
-            targetArn: {
-              $ref: '#/definitions/awsArn',
-            },
-          },
-          additionalProperties: false,
-        },
+        deadLetterConfig: { $ref: '#/definitions/awsArn' },
       },
       anyOf: [{ required: ['pattern'] }, { required: ['schedule'] }],
     });
@@ -193,7 +185,7 @@ class AwsCompileEventBridgeEvents {
                 );
               }
               DeadLetterConfig = {
-                TargetArn: DeadLetterConfig.targetArn,
+                Arn: DeadLetterConfig,
               };
             }
 
@@ -509,35 +501,33 @@ class AwsCompileEventBridgeEvents {
   }
 
   configureTarget({ target, Input, InputPath, InputTransformer, RetryPolicy, DeadLetterConfig }) {
-    if (Input) {
+    if (RetryPolicy) {
       target = Object.assign(target, {
-        Input: JSON.stringify(Input),
+        RetryPolicy,
       });
-      return target;
     }
-    if (InputPath) {
+
+    if (DeadLetterConfig) {
       target = Object.assign(target, {
-        InputPath,
+        DeadLetterConfig,
       });
-      return target;
     }
-    if (InputTransformer) {
+
+    if (Input) {
       target = Object.assign(target, {
-        InputTransformer,
+        Input: JSON.stringify(Input),
       });
       return target;
     }
-
-    if (RetryPolicy) {
+    if (InputPath) {
       target = Object.assign(target, {
-        RetryPolicy,
+        InputPath,
       });
       return target;
     }
-
-    if (DeadLetterConfig) {
+    if (InputTransformer) {
       target = Object.assign(target, {
-        DeadLetterConfig,
+        InputTransformer,
       });
       return target;
     }

diff --git a/test/unit/lib/plugins/aws/package/compile/events/eventBridge/index.test.js b/test/unit/lib/plugins/aws/package/compile/events/eventBridge/index.test.js
@@ -319,9 +319,7 @@ describe('EventBridgeEvents', () => {
                   {
                     eventBridge: {
                       deadLetterConfig: {
-                        targetArn: {
-                          'Fn::GetAtt': ['not-supported', 'Arn'],
-                        },
+                        'Fn::GetAtt': ['not-supported', 'Arn'],
                       },
                       pattern: {
                         source: ['aws.something'],
@@ -399,9 +397,7 @@ describe('EventBridgeEvents', () => {
       };
 
       const deadLetterConfig = {
-        targetArn: {
-          'Fn::GetAtt': ['test', 'Arn'],
-        },
+        'Fn::GetAtt': ['test', 'Arn'],
       };
 
       const getRuleResourceEndingWith = (resources, ending) =>
@@ -550,7 +546,7 @@ describe('EventBridgeEvents', () => {
       it('should support deadLetterConfig configuration', () => {
         const deadLetterConfigRuleTarget = getRuleResourceEndingWith(cfResources, '7').Properties
           .Targets[0];
-        expect(deadLetterConfigRuleTarget.DeadLetterConfig).to.have.property('TargetArn');
+        expect(deadLetterConfigRuleTarget.DeadLetterConfig).to.have.property('Arn');
       });
 
       it('should create a rule that depends on created EventBus', () => {