updated logic to handle unexpected dbsync payload

worldcoin · Feb 28, 2024 · d9202c2 · d9202c2
1 parent 24ab7b4
commit d9202c2
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/src/coordinator.rs b/src/coordinator.rs
@@ -501,6 +501,14 @@ impl Coordinator {
             items
         } else {
             tracing::error!(?receipt_handle, "Failed to parse message body");
+
+            sqs_delete_message(
+                &self.sqs_client,
+                &self.config.queues.db_sync_queue_url,
+                receipt_handle,
+            )
+            .await?;
+
             return Ok(());
         };
 

diff --git a/src/participant.rs b/src/participant.rs
@@ -210,6 +210,14 @@ impl Participant {
             items
         } else {
             tracing::error!(?receipt_handle, "Failed to parse message body");
+
+            sqs_delete_message(
+                &self.sqs_client,
+                &self.config.queues.db_sync_queue_url,
+                receipt_handle,
+            )
+            .await?;
+
             return Ok(());
         };