From e81d0bca70df14bd591c7798813b3a033f2d77f8 Mon Sep 17 00:00:00 2001
From: v0idpwn <v0idpwn@gmail.com>
Date: Thu, 24 Aug 2023 00:36:09 +0300
Subject: [PATCH] Add test to delete batch

---
 core/tests/integration_test.rs | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/core/tests/integration_test.rs b/core/tests/integration_test.rs
index 45c23ffd..99d26bc2 100644
--- a/core/tests/integration_test.rs
+++ b/core/tests/integration_test.rs
@@ -870,6 +870,15 @@ async fn test_extension_api() {
         .await
         .expect("failed to delete");
     assert!(!deleted);
+
+    // delete a batch of messages
+    let m1 = queue.send(&test_queue, &del_msg).await.unwrap();
+    let m2 = queue.send(&test_queue, &del_msg).await.unwrap();
+    let m3 = queue.send(&test_queue, &del_msg).await.unwrap();
+    let delete_result = queue.delete_batch(&test_queue, &[m1, m2, m3]).await.expect("delete batch error");
+    let rowcount = rowcount(&test_queue, &queue.connection).await;
+    assert_eq!(rowcount, 0);
+    assert_eq!(delete_result, true);
 }
 
 #[tokio::test]