snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-09-06 12:46:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add single_receives_data test

Browse Source
This commit is contained in:
Mubelotix
2025-07-31 14:12:09 +02:00
parent ee80fc87c9
commit 35537e0b0b
1 changed files with 36 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

56
crates/meilisearch/tests/tasks/webhook.rs
View File

@ -71,17 +71,50 @@ async fn create_webhook_server() -> WebhookHandle {
#[actix_web::test] #[actix_web::test]
async fn cli_only() { async fn cli_only() {
let WebhookHandle { server_handle, url, mut receiver } = create_webhook_server().await;
let db_path = tempfile::tempdir().unwrap(); let db_path = tempfile::tempdir().unwrap();
let server = Server::new_with_options(Opt { 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")), task_webhook_authorization_header: Some(String::from("Bearer a-secret-token")),
..default_settings(db_path.path()) ..default_settings(db_path.path())
}) })
.await .await
.unwrap(); .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"); let index = server.index("tamo");
// May be flaky: we're relying on the fact that while the first document addition is processed, the other // 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 // 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}"); 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(); server_handle.abort();
} }