snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-02-23 19:15:31 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Fix the insta tests

Browse Source
This commit is contained in:
Kerollmops 2025-02-20 11:25:50 +01:00
parent 1b1172ad16
commit 9d314ace09
No known key found for this signature in database
GPG Key ID: F250A4C4E3AE5F5F
7 changed files with 111 additions and 75 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

144
crates/meilisearch/tests/batches/mod.rs
View File

@ -283,7 +283,7 @@ async fn test_summarized_document_addition_or_update() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 0, "uid": 0,
"progress": null, "progress": null,
@ -301,13 +301,15 @@ async fn test_summarized_document_addition_or_update() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]",
"writeChannelCongestion": "[writeChannelCongestion]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
let (task, _status_code) = let (task, _status_code) =
index.add_documents(json!({ "id": 42, "content": "doggos & fluff" }), Some("id")).await; index.add_documents(json!({ "id": 42, "content": "doggos & fluff" }), Some("id")).await;
@ -322,7 +324,7 @@ async fn test_summarized_document_addition_or_update() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 1, "uid": 1,
"progress": null, "progress": null,
@ -340,13 +342,15 @@ async fn test_summarized_document_addition_or_update() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]",
"writeChannelCongestion": "[writeChannelCongestion]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
} }
#[actix_web::test] #[actix_web::test]
@ -365,7 +369,7 @@ async fn test_summarized_delete_documents_by_batch() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 0, "uid": 0,
"progress": null, "progress": null,
@ -383,13 +387,14 @@ async fn test_summarized_delete_documents_by_batch() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
index.create(None).await; index.create(None).await;
let (task, _status_code) = index.delete_batch(vec![42]).await; let (task, _status_code) = index.delete_batch(vec![42]).await;
@ -404,7 +409,7 @@ async fn test_summarized_delete_documents_by_batch() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 2, "uid": 2,
"progress": null, "progress": null,
@ -422,13 +427,14 @@ async fn test_summarized_delete_documents_by_batch() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
} }
#[actix_web::test] #[actix_web::test]
@ -449,7 +455,7 @@ async fn test_summarized_delete_documents_by_filter() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 0, "uid": 0,
"progress": null, "progress": null,
@ -468,13 +474,14 @@ async fn test_summarized_delete_documents_by_filter() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
index.create(None).await; index.create(None).await;
let (task, _status_code) = let (task, _status_code) =
@ -490,7 +497,7 @@ async fn test_summarized_delete_documents_by_filter() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 2, "uid": 2,
"progress": null, "progress": null,
@ -509,13 +516,14 @@ async fn test_summarized_delete_documents_by_filter() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
index.update_settings(json!({ "filterableAttributes": ["doggo"] })).await; index.update_settings(json!({ "filterableAttributes": ["doggo"] })).await;
let (task, _status_code) = let (task, _status_code) =
@ -550,7 +558,8 @@ async fn test_summarized_delete_documents_by_filter() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
@ -566,7 +575,16 @@ async fn test_summarized_delete_document_by_id() {
let (task, _status_code) = index.delete_document(1).await; let (task, _status_code) = index.delete_document(1).await;
index.wait_task(task.uid()).await.failed(); index.wait_task(task.uid()).await.failed();
let (batch, _) = index.get_batch(0).await; let (batch, _) = index.get_batch(0).await;
snapshot!(batch, assert_json_snapshot!(batch,
{
".uid" => "[uid]",
".duration" => "[duration]",
".enqueuedAt" => "[date]",
".startedAt" => "[date]",
".finishedAt" => "[date]",
".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]"
},
@r#" @r#"
{ {
"uid": "[uid]", "uid": "[uid]",
@ -585,7 +603,8 @@ async fn test_summarized_delete_document_by_id() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
@ -624,7 +643,8 @@ async fn test_summarized_delete_document_by_id() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
@ -661,7 +681,7 @@ async fn test_summarized_settings_update() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 0, "uid": 0,
"progress": null, "progress": null,
@ -688,13 +708,14 @@ async fn test_summarized_settings_update() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
} }
#[actix_web::test] #[actix_web::test]
@ -713,7 +734,7 @@ async fn test_summarized_index_creation() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 0, "uid": 0,
"progress": null, "progress": null,
@ -728,13 +749,14 @@ async fn test_summarized_index_creation() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
let (task, _status_code) = index.create(Some("doggos")).await; let (task, _status_code) = index.create(Some("doggos")).await;
index.wait_task(task.uid()).await.failed(); index.wait_task(task.uid()).await.failed();
@ -748,7 +770,7 @@ async fn test_summarized_index_creation() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 1, "uid": 1,
"progress": null, "progress": null,
@ -765,13 +787,14 @@ async fn test_summarized_index_creation() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
} }
#[actix_web::test] #[actix_web::test]
@ -900,7 +923,7 @@ async fn test_summarized_index_update() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 0, "uid": 0,
"progress": null, "progress": null,
@ -915,13 +938,14 @@ async fn test_summarized_index_update() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
let (task, _status_code) = index.update(Some("bones")).await; let (task, _status_code) = index.update(Some("bones")).await;
index.wait_task(task.uid()).await.failed(); index.wait_task(task.uid()).await.failed();
@ -935,7 +959,7 @@ async fn test_summarized_index_update() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 1, "uid": 1,
"progress": null, "progress": null,
@ -952,13 +976,14 @@ async fn test_summarized_index_update() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
// And run the same two tests once the index do exists. // And run the same two tests once the index do exists.
index.create(None).await; index.create(None).await;
@ -990,7 +1015,8 @@ async fn test_summarized_index_update() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
@ -1010,7 +1036,7 @@ async fn test_summarized_index_update() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 4, "uid": 4,
"progress": null, "progress": null,
@ -1027,13 +1053,14 @@ async fn test_summarized_index_update() {
}, },
"indexUids": { "indexUids": {
"test": 1 "test": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
} }
#[actix_web::test] #[actix_web::test]
@ -1055,7 +1082,7 @@ async fn test_summarized_index_swap() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 0, "uid": 0,
"progress": null, "progress": null,
@ -1077,13 +1104,14 @@ async fn test_summarized_index_swap() {
"types": { "types": {
"indexSwap": 1 "indexSwap": 1
}, },
"indexUids": {} "indexUids": {},
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
server.index("doggos").create(None).await; server.index("doggos").create(None).await;
let (task, _status_code) = server.index("cattos").create(None).await; let (task, _status_code) = server.index("cattos").create(None).await;
@ -1103,7 +1131,7 @@ async fn test_summarized_index_swap() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 1, "uid": 1,
"progress": null, "progress": null,
@ -1118,13 +1146,14 @@ async fn test_summarized_index_swap() {
}, },
"indexUids": { "indexUids": {
"doggos": 1 "doggos": 1
} },
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
} }
#[actix_web::test] #[actix_web::test]
@ -1146,7 +1175,7 @@ async fn test_summarized_batch_cancelation() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 1, "uid": 1,
"progress": null, "progress": null,
@ -1163,13 +1192,14 @@ async fn test_summarized_batch_cancelation() {
"types": { "types": {
"taskCancelation": 1 "taskCancelation": 1
}, },
"indexUids": {} "indexUids": {},
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
} }
#[actix_web::test] #[actix_web::test]
@ -1191,7 +1221,7 @@ async fn test_summarized_batch_deletion() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 1, "uid": 1,
"progress": null, "progress": null,
@ -1208,13 +1238,14 @@ async fn test_summarized_batch_deletion() {
"types": { "types": {
"taskDeletion": 1 "taskDeletion": 1
}, },
"indexUids": {} "indexUids": {},
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
} }
#[actix_web::test] #[actix_web::test]
@ -1233,7 +1264,7 @@ async fn test_summarized_dump_creation() {
".stats.callTrace" => "[callTrace]", ".stats.callTrace" => "[callTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]" ".stats.writeChannelCongestion" => "[writeChannelCongestion]"
}, },
@r#" @r###"
{ {
"uid": 0, "uid": 0,
"progress": null, "progress": null,
@ -1248,11 +1279,12 @@ async fn test_summarized_dump_creation() {
"types": { "types": {
"dumpCreation": 1 "dumpCreation": 1
}, },
"indexUids": {} "indexUids": {},
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]" "finishedAt": "[date]"
} }
"#); "###);
} }

5
crates/meilisearch/tests/dumps/snapshots/mod.rs/import_dump_v6_containing_batches_and_enqueued_tasks/batches.snap
View File

@ -1,6 +1,5 @@
--- ---
source: crates/meilisearch/tests/dumps/mod.rs source: crates/meilisearch/tests/dumps/mod.rs
snapshot_kind: text
--- ---
{ {
"results": [ "results": [
@ -21,7 +20,9 @@ snapshot_kind: text
}, },
"indexUids": { "indexUids": {
"kefir": 1 "kefir": 1
} },
"callTrace": "[callTrace]",
"writeChannelCongestion": "[writeChannelCongestion]"
}, },
"duration": "[date]", "duration": "[date]",
"startedAt": "[date]", "startedAt": "[date]",

3
crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterEnqueuedAt_equal_2025-01-16T16_47_41.snap
View File

@ -18,7 +18,8 @@ source: crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs
"types": { "types": {
"upgradeDatabase": 1 "upgradeDatabase": 1
}, },
"indexUids": {} "indexUids": {},
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",

3
crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterFinishedAt_equal_2025-01-16T16_47_41.snap
View File

@ -18,7 +18,8 @@ source: crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs
"types": { "types": {
"upgradeDatabase": 1 "upgradeDatabase": 1
}, },
"indexUids": {} "indexUids": {},
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",

3
crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterStartedAt_equal_2025-01-16T16_47_41.snap
View File

@ -18,7 +18,8 @@ source: crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs
"types": { "types": {
"upgradeDatabase": 1 "upgradeDatabase": 1
}, },
"indexUids": {} "indexUids": {},
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",

4
crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/the_whole_batch_queue_once_everything_has_been_processed.snap
View File

@ -1,6 +1,5 @@
--- ---
source: crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs source: crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs
snapshot_kind: text
--- ---
{ {
"results": [ "results": [
@ -19,7 +18,8 @@ snapshot_kind: text
"types": { "types": {
"upgradeDatabase": 1 "upgradeDatabase": 1
}, },
"indexUids": {} "indexUids": {},
"callTrace": "[callTrace]"
}, },
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",

24
crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs
View File

@ -159,7 +159,7 @@ async fn check_the_index_scheduler(server: &Server) {
let (tasks, _) = server.tasks_filter("limit=1000").await; let (tasks, _) = server.tasks_filter("limit=1000").await;
snapshot!(json_string!(tasks, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "the_whole_task_queue_once_everything_has_been_processed"); snapshot!(json_string!(tasks, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "the_whole_task_queue_once_everything_has_been_processed");
let (batches, _) = server.batches_filter("limit=1000").await; let (batches, _) = server.batches_filter("limit=1000").await;
snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "the_whole_batch_queue_once_everything_has_been_processed"); snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "the_whole_batch_queue_once_everything_has_been_processed");
// Tests all the tasks query parameters // Tests all the tasks query parameters
let (tasks, _) = server.tasks_filter("uids=10").await; let (tasks, _) = server.tasks_filter("uids=10").await;
@ -186,32 +186,32 @@ async fn check_the_index_scheduler(server: &Server) {
// Tests all the batches query parameters // Tests all the batches query parameters
let (batches, _) = server.batches_filter("uids=10").await; let (batches, _) = server.batches_filter("uids=10").await;
snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_uids_equal_10"); snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_uids_equal_10");
let (batches, _) = server.batches_filter("batchUids=10").await; let (batches, _) = server.batches_filter("batchUids=10").await;
snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_batchUids_equal_10"); snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_batchUids_equal_10");
let (batches, _) = server.batches_filter("statuses=canceled").await; let (batches, _) = server.batches_filter("statuses=canceled").await;
snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_statuses_equal_canceled"); snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_statuses_equal_canceled");
// types has already been tested above to retrieve the upgrade database // types has already been tested above to retrieve the upgrade database
let (batches, _) = server.batches_filter("canceledBy=19").await; let (batches, _) = server.batches_filter("canceledBy=19").await;
snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_canceledBy_equal_19"); snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_canceledBy_equal_19");
let (batches, _) = server.batches_filter("beforeEnqueuedAt=2025-01-16T16:47:41Z").await; let (batches, _) = server.batches_filter("beforeEnqueuedAt=2025-01-16T16:47:41Z").await;
snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_beforeEnqueuedAt_equal_2025-01-16T16_47_41"); snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_beforeEnqueuedAt_equal_2025-01-16T16_47_41");
let (batches, _) = server.batches_filter("afterEnqueuedAt=2025-01-16T16:47:41Z").await; let (batches, _) = server.batches_filter("afterEnqueuedAt=2025-01-16T16:47:41Z").await;
snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_afterEnqueuedAt_equal_2025-01-16T16_47_41"); snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_afterEnqueuedAt_equal_2025-01-16T16_47_41");
let (batches, _) = server.batches_filter("beforeStartedAt=2025-01-16T16:47:41Z").await; let (batches, _) = server.batches_filter("beforeStartedAt=2025-01-16T16:47:41Z").await;
snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_beforeStartedAt_equal_2025-01-16T16_47_41"); snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_beforeStartedAt_equal_2025-01-16T16_47_41");
let (batches, _) = server.batches_filter("afterStartedAt=2025-01-16T16:47:41Z").await; let (batches, _) = server.batches_filter("afterStartedAt=2025-01-16T16:47:41Z").await;
snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_afterStartedAt_equal_2025-01-16T16_47_41"); snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_afterStartedAt_equal_2025-01-16T16_47_41");
let (batches, _) = server.batches_filter("beforeFinishedAt=2025-01-16T16:47:41Z").await; let (batches, _) = server.batches_filter("beforeFinishedAt=2025-01-16T16:47:41Z").await;
snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_beforeFinishedAt_equal_2025-01-16T16_47_41"); snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_beforeFinishedAt_equal_2025-01-16T16_47_41");
let (batches, _) = server.batches_filter("afterFinishedAt=2025-01-16T16:47:41Z").await; let (batches, _) = server.batches_filter("afterFinishedAt=2025-01-16T16:47:41Z").await;
snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_afterFinishedAt_equal_2025-01-16T16_47_41"); snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_afterFinishedAt_equal_2025-01-16T16_47_41");
let (stats, _) = server.stats().await; let (stats, _) = server.stats().await;
snapshot!(stats, @r###" snapshot!(stats, @r###"
{ {
"databaseSize": 438272, "databaseSize": 438272,
"usedDatabaseSize": 196608, "usedDatabaseSize": 200704,
"lastUpdate": "2025-01-23T11:36:22.634859166Z", "lastUpdate": "2025-01-23T11:36:22.634859166Z",
"indexes": { "indexes": {
"kefir": { "kefir": {