From 681d3a88780ca91f4d52d9a79e4031cdf6fdb9c4 Mon Sep 17 00:00:00 2001
From: Alexander Schueren <sha@amazon.com>
Date: Mon, 15 Apr 2024 14:09:34 +0200
Subject: [PATCH 1/2] add DeadLetterQueueSourceArn attribute

---
 packages/parser/src/schemas/sqs.ts         | 1 +
 packages/parser/tests/events/sqsEvent.json | 3 ++-
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/packages/parser/src/schemas/sqs.ts b/packages/parser/src/schemas/sqs.ts
index 09aed635ea..b2634a3e02 100644
--- a/packages/parser/src/schemas/sqs.ts
+++ b/packages/parser/src/schemas/sqs.ts
@@ -17,6 +17,7 @@ const SqsAttributesSchema = z.object({
   SentTimestamp: z.string(),
   SequenceNumber: z.string().optional(),
   AWSTraceHeader: z.string().optional(),
+  DeadLetterQueueSourceArn: z.string().optional(), // Undocumented, but used by AWS to support their re-drive functionality in the console
 });
 
 const SqsRecordSchema = z.object({
diff --git a/packages/parser/tests/events/sqsEvent.json b/packages/parser/tests/events/sqsEvent.json
index 2bfcd1c7b8..9bc0a394b4 100644
--- a/packages/parser/tests/events/sqsEvent.json
+++ b/packages/parser/tests/events/sqsEvent.json
@@ -30,7 +30,8 @@
         "ApproximateReceiveCount": "1",
         "SentTimestamp": "1545082650636",
         "SenderId": "AIDAIENQZJOLO23YVJ4VO",
-        "ApproximateFirstReceiveTimestamp": "1545082650649"
+        "ApproximateFirstReceiveTimestamp": "1545082650649",
+        "DeadLetterQueueSourceArn": "arn:aws:sqs:us-east-2:123456789012:my-queue-dead"
       },
       "messageAttributes": {},
       "md5OfBody": "e4e68fb7bd0e697a0ae8f1bb342846b3",

From 1c1a5c0dc89034d074c805fa5b9ab92944dad8a4 Mon Sep 17 00:00:00 2001
From: Alexander Schueren <sha@amazon.com>
Date: Mon, 15 Apr 2024 15:02:01 +0200
Subject: [PATCH 2/2] move comment

---
 packages/parser/src/schemas/sqs.ts | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/packages/parser/src/schemas/sqs.ts b/packages/parser/src/schemas/sqs.ts
index b2634a3e02..5484246e0d 100644
--- a/packages/parser/src/schemas/sqs.ts
+++ b/packages/parser/src/schemas/sqs.ts
@@ -17,7 +17,10 @@ const SqsAttributesSchema = z.object({
   SentTimestamp: z.string(),
   SequenceNumber: z.string().optional(),
   AWSTraceHeader: z.string().optional(),
-  DeadLetterQueueSourceArn: z.string().optional(), // Undocumented, but used by AWS to support their re-drive functionality in the console
+  /**
+   * Undocumented, but used by AWS to support their re-drive functionality in the console
+   */
+  DeadLetterQueueSourceArn: z.string().optional(),
 });
 
 const SqsRecordSchema = z.object({