From 35537e0b0b2065243650af43727bfc5ac016c377 Mon Sep 17 00:00:00 2001
From: Mubelotix <simon@meilisearch.com>
Date: Thu, 31 Jul 2025 14:12:09 +0200
Subject: [PATCH] Add single_receives_data test

---
 crates/meilisearch/tests/tasks/webhook.rs | 56 +++++++++++++++--------
 1 file changed, 36 insertions(+), 20 deletions(-)

diff --git a/crates/meilisearch/tests/tasks/webhook.rs b/crates/meilisearch/tests/tasks/webhook.rs
index 3d27d6be6..14946e415 100644
--- a/crates/meilisearch/tests/tasks/webhook.rs
+++ b/crates/meilisearch/tests/tasks/webhook.rs
@@ -71,17 +71,50 @@ async fn create_webhook_server() -> WebhookHandle {
 
 #[actix_web::test]
 async fn cli_only() {
-    let WebhookHandle { server_handle, url, mut receiver } = create_webhook_server().await;
-
     let db_path = tempfile::tempdir().unwrap();
     let server = Server::new_with_options(Opt {
-        task_webhook_url: Some(Url::parse(&url).unwrap()),
+        task_webhook_url: Some(Url::parse("https://example-cli.com/").unwrap()),
         task_webhook_authorization_header: Some(String::from("Bearer a-secret-token")),
         ..default_settings(db_path.path())
     })
     .await
     .unwrap();
 
+    let (webhooks, code) = server.get_webhooks().await;
+    snapshot!(code, @"200 OK");
+    snapshot!(webhooks, @r#"
+    {
+      "results": [
+        {
+          "uuid": "00000000-0000-0000-0000-000000000000",
+          "isEditable": false,
+          "url": "https://example-cli.com/",
+          "headers": {
+            "Authorization": "Bearer a-secret-token"
+          }
+        }
+      ]
+    }
+    "#);
+}
+
+#[actix_web::test]
+async fn single_receives_data() {
+    let WebhookHandle { server_handle, url, mut receiver } = create_webhook_server().await;
+
+    let server = Server::new().await;
+
+    let (value, code) = server.create_webhook(json!({ "url": url })).await;
+    snapshot!(code, @"201 Created");
+    snapshot!(json_string!(value, { ".uuid" => "[uuid]", ".url" => "[ignored]" }), @r#"
+    {
+      "uuid": "[uuid]",
+      "isEditable": true,
+      "url": "[ignored]",
+      "headers": {}
+    }
+    "#);
+
     let index = server.index("tamo");
     // May be flaky: we're relying on the fact that while the first document addition is processed, the other
     // operations will be received and will be batched together. If it doesn't happen it's not a problem
@@ -128,23 +161,6 @@ async fn cli_only() {
 
     assert!(nb_tasks == 5, "We should have received the 5 tasks but only received {nb_tasks}");
 
-    let (webhooks, code) = server.get_webhooks().await;
-    snapshot!(code, @"200 OK");
-    snapshot!(json_string!(webhooks, { ".results[].url" => "[ignored]" }), @r#"
-    {
-      "results": [
-        {
-          "uuid": "00000000-0000-0000-0000-000000000000",
-          "isEditable": false,
-          "url": "[ignored]",
-          "headers": {
-            "Authorization": "Bearer a-secret-token"
-          }
-        }
-      ]
-    }
-    "#);
-
     server_handle.abort();
 }