Merge pull request #762 from shivang007/sqs-batch-failure-error-stack

Sqs batch failure error stack
middyjs · Jan 4, 2022 · b9b8ee1 · b9b8ee1
2 parents 313315b + 60c9453
commit b9b8ee1
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/packages/sqs-partial-batch-failure/index.js b/packages/sqs-partial-batch-failure/index.js
@@ -77,7 +77,9 @@ const sqsPartialBatchFailureMiddleware = (opts = {}) => {
     await deleteSqsMessages(fulfilledRecords)
 
     const errorMessage = getErrorMessage(rejectedReasons)
-    throw new Error(errorMessage)
+    const error = new Error(errorMessage)
+    error.originalErrors = rejectedReasons
+    throw error
   }
 
   return {
@@ -86,10 +88,11 @@ const sqsPartialBatchFailureMiddleware = (opts = {}) => {
 }
 
 const getRejectedReasons = (response) => {
-  const rejected = response.filter((r) => r.status === 'rejected')
-  const rejectedReasons = rejected.map((r) => r.reason?.message)
+  const filteredRes = response
+    .filter((r) => r.status === 'rejected')
+    .map((r) => r.reason)
 
-  return rejectedReasons
+  return filteredRes
 }
 
 const getFulfilledRecords = (records, response) => {
@@ -108,6 +111,6 @@ const getEntries = (fulfilledRecords) => {
 }
 
 const getErrorMessage = (rejectedReasons) => {
-  return rejectedReasons.join('\n')
+  return rejectedReasons.map(error => error.message).join('\n')
 }
 module.exports = sqsPartialBatchFailureMiddleware