From b565ec1497d8978ca31064fa075fbb01d9248b8b Mon Sep 17 00:00:00 2001 From: Mubelotix Date: Wed, 30 Jul 2025 15:44:42 +0200 Subject: [PATCH] Test cli behavior --- crates/meilisearch/tests/common/server.rs | 8 ++++++++ crates/meilisearch/tests/tasks/webhook.rs | 18 +++++++++++++++++- 2 files changed, 25 insertions(+), 1 deletion(-) diff --git a/crates/meilisearch/tests/common/server.rs b/crates/meilisearch/tests/common/server.rs index ad0678122..1dfe2e593 100644 --- a/crates/meilisearch/tests/common/server.rs +++ b/crates/meilisearch/tests/common/server.rs @@ -182,6 +182,10 @@ impl Server { self.service.patch("/network", value).await } + pub async fn set_webhooks(&self, value: Value) -> (Value, StatusCode) { + self.service.patch("/webhooks", value).await + } + pub async fn get_metrics(&self) -> (Value, StatusCode) { self.service.get("/metrics").await } @@ -447,6 +451,10 @@ impl Server { pub async fn get_network(&self) -> (Value, StatusCode) { self.service.get("/network").await } + + pub async fn get_webhooks(&self) -> (Value, StatusCode) { + self.service.get("/webhooks").await + } } pub fn default_settings(dir: impl AsRef) -> Opt { diff --git a/crates/meilisearch/tests/tasks/webhook.rs b/crates/meilisearch/tests/tasks/webhook.rs index b18002eb7..984cfc23e 100644 --- a/crates/meilisearch/tests/tasks/webhook.rs +++ b/crates/meilisearch/tests/tasks/webhook.rs @@ -68,12 +68,13 @@ async fn create_webhook_server() -> WebhookHandle { } #[actix_web::test] -async fn test_basic_webhook() { +async fn test_cli_webhook() { 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_authorization_header: Some(String::from("Bearer a-secret-token")), ..default_settings(db_path.path()) }) .await @@ -125,5 +126,20 @@ async fn test_basic_webhook() { 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!(webhooks, @r#" + { + "webhooks": { + "_cli": { + "url": "http://127.0.0.1:51503/", + "headers": { + "Authorization": "Bearer a-secret-token" + } + } + } + } + "#); + server_handle.abort(); }