add logic to handle unexpected payload

src/coordinator.rs

@@ -121,15 +121,26 @@ impl Coordinator {
 
             let body = message.body.context("Missing message body")?;
 
-            let UniquenessCheckRequest {
-                plain_code: template,
+            if let Ok(UniquenessCheckRequest {
+                plain_code,
                 signup_id,
-            } = serde_json::from_str(&body)
-                .context("Failed to parse message")?;
+            }) = serde_json::from_str::<UniquenessCheckRequest>(&body)
+            {
+                self.uniqueness_check(receipt_handle, plain_code, signup_id)
+                    .await?;
+            } else {
+                tracing::error!(
+                    ?receipt_handle,
+                    "Failed to parse template from message"
+                );
 
-            // Process the query
-            self.uniqueness_check(receipt_handle, template, signup_id)
+                sqs_delete_message(
+                    &self.sqs_client,
+                    &self.config.queues.queries_queue_url,
+                    receipt_handle,
+                )
                 .await?;
+            }
         }
         Ok(())
     }