Fixes formatting issues

This commit is contained in:
Pedro Turik Firmino 2024-11-06 09:54:20 -03:00
parent d0b1ba20cb
commit da4d47b5d0
2 changed files with 24 additions and 20 deletions

View File

@ -392,20 +392,22 @@ pub static VECTOR_DOCUMENTS: Lazy<Value> = Lazy::new(|| {
pub async fn shared_index_with_test_set() -> &'static Index<'static, Shared> { pub async fn shared_index_with_test_set() -> &'static Index<'static, Shared> {
static INDEX: OnceCell<Index<'static, Shared>> = OnceCell::const_new(); static INDEX: OnceCell<Index<'static, Shared>> = OnceCell::const_new();
INDEX.get_or_init(|| async { INDEX
let server = Server::new_shared(); .get_or_init(|| async {
let index = server._index("SHARED_TEST_SET").to_shared(); let server = Server::new_shared();
let url = format!("/indexes/{}/documents", urlencoding::encode(index.uid.as_ref())); let index = server._index("SHARED_TEST_SET").to_shared();
let (response, code) = index let url = format!("/indexes/{}/documents", urlencoding::encode(index.uid.as_ref()));
.service let (response, code) = index
.post_str( .service
url, .post_str(
include_str!("../assets/test_set.json"), url,
vec![("content-type", "application/json")], include_str!("../assets/test_set.json"),
) vec![("content-type", "application/json")],
.await; )
assert_eq!(code, 202); .await;
index.wait_task(response.uid()).await; assert_eq!(code, 202);
index index.wait_task(response.uid()).await;
}).await index
} })
.await
}

View File

@ -4,7 +4,10 @@ use meili_snap::*;
use urlencoding::encode as urlencode; use urlencoding::encode as urlencode;
use crate::common::encoder::Encoder; use crate::common::encoder::Encoder;
use crate::common::{shared_does_not_exists_index, shared_empty_index, shared_index_with_test_set, GetAllDocumentsOptions, Server, Value}; use crate::common::{
shared_does_not_exists_index, shared_empty_index, shared_index_with_test_set,
GetAllDocumentsOptions, Server, Value,
};
use crate::json; use crate::json;
// TODO: partial test since we are testing error, amd error is not yet fully implemented in // TODO: partial test since we are testing error, amd error is not yet fully implemented in
@ -159,7 +162,7 @@ async fn get_all_documents_no_options_with_response_compression() {
#[actix_rt::test] #[actix_rt::test]
async fn test_get_all_documents_limit() { async fn test_get_all_documents_limit() {
let index = shared_index_with_test_set().await; let index = shared_index_with_test_set().await;
let (response, code) = index let (response, code) = index
.get_all_documents(GetAllDocumentsOptions { limit: Some(5), ..Default::default() }) .get_all_documents(GetAllDocumentsOptions { limit: Some(5), ..Default::default() })
@ -191,7 +194,6 @@ async fn test_get_all_documents_offset() {
async fn test_get_all_documents_attributes_to_retrieve() { async fn test_get_all_documents_attributes_to_retrieve() {
let index = shared_index_with_test_set().await; let index = shared_index_with_test_set().await;
let (response, code) = index let (response, code) = index
.get_all_documents(GetAllDocumentsOptions { .get_all_documents(GetAllDocumentsOptions {
fields: Some(vec!["name"]), fields: Some(vec!["name"]),