diff --git a/src/resources/streamPipes.ts b/src/resources/streamPipes.ts index c7dafc0..4c3264d 100644 --- a/src/resources/streamPipes.ts +++ b/src/resources/streamPipes.ts @@ -18,6 +18,11 @@ export const streamPipesResource: ServerlessExtended["resources"] = { }, }, + EventsDLQueue: { + Type: "AWS::SQS::Queue", + Properties: {}, + }, + PipeRole: { Type: "AWS::IAM::Role", Properties: { @@ -146,6 +151,9 @@ export const streamPipesResource: ServerlessExtended["resources"] = { dynamodb: "", }), }, + DeadLetterConfig: { + Arn: getAttribute("EventsDLQueue", "Arn"), + }, }, ], }, diff --git a/src/types/extendedSlsTypes.ts b/src/types/extendedSlsTypes.ts index 3205da6..39ce59d 100644 --- a/src/types/extendedSlsTypes.ts +++ b/src/types/extendedSlsTypes.ts @@ -5,6 +5,7 @@ import { IAMRoleProps, LogsLogGroupProps, PipesPipeProps, + SQSQueueProps, } from "@awboost/cfntypes"; import type { IamRoleStatement, Serverless } from "serverless/aws"; import type StepFunctions from "serverless-step-functions"; @@ -22,6 +23,7 @@ type SlsResource = | Resource<"AWS::Events::EventBus", EventsEventBusProps> | Resource<"AWS::IAM::Role", IAMRoleProps> | Resource<"AWS::Logs::LogGroup", LogsLogGroupProps> + | Resource<"AWS::SQS::Queue", SQSQueueProps> | Resource<"AWS::Events::Rule", EventsRuleProps> | Resource<"AWS::Pipes::Pipe", PipesPipeProps>;