searchengines-web/MeiliSearch
searchengines-web/MeiliSearch
1
0
Fork 0
mirror of https://github.com/meilisearch/MeiliSearch synced 2024-11-26 14:54:27 +01:00
Code Issues Releases Wiki Activity

Await the last insert task

Browse Source
This commit is contained in:
Clément Renault 2022-10-27 10:57:32 +02:00
parent 8bc602a7dd
commit 7e355958e0
No known key found for this signature in database
GPG Key ID: 92ADA4E935E71FA4
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
meilisearch-http/tests/auth/authorization.rs
View File

@ -272,7 +272,8 @@ async fn access_authorized_stats_restricted_index() {
let index = server.index("products"); let index = server.index("products");
let (response, code) = index.create(Some("product_id")).await; let (response, code) = index.create(Some("product_id")).await;
assert_eq!(202, code, "{:?}", &response); assert_eq!(202, code, "{:?}", &response);
index.wait_task(0).await; let task_id = response["taskUid"].as_u64().unwrap();
index.wait_task(task_id).await;
// create key with access on `products` index only. // create key with access on `products` index only.
let content = json!({ let content = json!({
@ -312,7 +313,8 @@ async fn access_authorized_stats_no_index_restriction() {
let index = server.index("products"); let index = server.index("products");
let (response, code) = index.create(Some("product_id")).await; let (response, code) = index.create(Some("product_id")).await;
assert_eq!(202, code, "{:?}", &response); assert_eq!(202, code, "{:?}", &response);
index.wait_task(0).await; let task_id = response["taskUid"].as_u64().unwrap();
index.wait_task(task_id).await;
// create key with access on all indexes. // create key with access on all indexes.
let content = json!({ let content = json!({
@ -352,7 +354,8 @@ async fn list_authorized_indexes_restricted_index() {
let index = server.index("products"); let index = server.index("products");
let (response, code) = index.create(Some("product_id")).await; let (response, code) = index.create(Some("product_id")).await;
assert_eq!(202, code, "{:?}", &response); assert_eq!(202, code, "{:?}", &response);
index.wait_task(0).await; let task_id = response["taskUid"].as_u64().unwrap();
index.wait_task(task_id).await;
// create key with access on `products` index only. // create key with access on `products` index only.
let content = json!({ let content = json!({
@ -393,7 +396,8 @@ async fn list_authorized_indexes_no_index_restriction() {
let index = server.index("products"); let index = server.index("products");
let (response, code) = index.create(Some("product_id")).await; let (response, code) = index.create(Some("product_id")).await;
assert_eq!(202, code, "{:?}", &response); assert_eq!(202, code, "{:?}", &response);
index.wait_task(0).await; let task_id = response["taskUid"].as_u64().unwrap();
index.wait_task(task_id).await;
// create key with access on all indexes. // create key with access on all indexes.
let content = json!({ let content = json!({
@ -433,7 +437,8 @@ async fn list_authorized_tasks_restricted_index() {
let index = server.index("products"); let index = server.index("products");
let (response, code) = index.create(Some("product_id")).await; let (response, code) = index.create(Some("product_id")).await;
assert_eq!(202, code, "{:?}", &response); assert_eq!(202, code, "{:?}", &response);
index.wait_task(0).await; let task_id = response["taskUid"].as_u64().unwrap();
index.wait_task(task_id).await;
// create key with access on `products` index only. // create key with access on `products` index only.
let content = json!({ let content = json!({
@ -473,7 +478,8 @@ async fn list_authorized_tasks_no_index_restriction() {
let index = server.index("products"); let index = server.index("products");
let (response, code) = index.create(Some("product_id")).await; let (response, code) = index.create(Some("product_id")).await;
assert_eq!(202, code, "{:?}", &response); assert_eq!(202, code, "{:?}", &response);
index.wait_task(0).await; let task_id = response["taskUid"].as_u64().unwrap();
index.wait_task(task_id).await;
// create key with access on all indexes. // create key with access on all indexes.
let content = json!({ let content = json!({