Fix SQS consumer - preserve original batch after transform

sfount · Apr 22, 2020 · b09d381 · b09d381
1 parent 09140cf
commit b09d381
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/consumers/SQSConsumer.ts b/src/consumers/SQSConsumer.ts
@@ -45,7 +45,7 @@ export default class SQSConsumer implements Consumer {
 		for (const batch of batches) {
 			const params: SQS.SendMessageBatchRequest = {
 				QueueUrl: this.queueUrl,
-				Entries: batch.map(this.messageBuilder.transform)
+				Entries: [ ...batch ].map(this.messageBuilder.transform)
 			}
 			sqs.sendMessageBatch(params, (error: AWSError, data) => {
 				if (error) {
@@ -65,7 +65,8 @@ export default class SQSConsumer implements Consumer {
 					'batch_id': batchId,
 					'messages': batch.map((entry, index) => ({
 						'id': params.Entries[index].Id,
-						'primary_column': entry[Object.keys(entry)[0]]
+						'primary_column': entry[Object.keys(entry)[0]],
+						'body': entry
 					})),
 					'failed': data.Failed.map((entry) => ({
 						'id': entry.Id,