MeiliSearch/meilisearch-http/tests/common/service.rs

124 lines
3.9 KiB
Rust
Raw Normal View History

2022-10-18 15:14:18 +02:00
use std::sync::Arc;
use actix_web::http::header::ContentType;
2022-10-20 18:00:07 +02:00
use actix_web::http::StatusCode;
use actix_web::test;
use actix_web::test::TestRequest;
use index_scheduler::IndexScheduler;
use meilisearch_auth::AuthController;
2022-10-20 18:00:07 +02:00
use meilisearch_http::{analytics, create_app, Opt};
2021-02-18 19:50:52 +01:00
use serde_json::Value;
use crate::common::encoder::Encoder;
2021-02-18 19:50:52 +01:00
2021-09-28 18:10:09 +02:00
pub struct Service {
2022-10-18 15:14:18 +02:00
pub index_scheduler: Arc<IndexScheduler>,
pub auth: AuthController,
2021-09-28 18:10:09 +02:00
pub options: Opt,
pub api_key: Option<String>,
2021-09-28 18:10:09 +02:00
}
2021-02-18 19:50:52 +01:00
impl Service {
pub async fn post(&self, url: impl AsRef<str>, body: Value) -> (Value, StatusCode) {
self.post_encoded(url, body, Encoder::Plain).await
}
2021-02-18 19:50:52 +01:00
pub async fn post_encoded(
&self,
url: impl AsRef<str>,
body: Value,
encoder: Encoder,
) -> (Value, StatusCode) {
let mut req = test::TestRequest::post().uri(url.as_ref());
req = self.encode(req, body, encoder);
self.request(req).await
2021-02-18 19:50:52 +01:00
}
/// Send a test post request from a text body, with a `content-type:application/json` header.
2021-03-15 18:11:10 +01:00
pub async fn post_str(
&self,
url: impl AsRef<str>,
body: impl AsRef<str>,
) -> (Value, StatusCode) {
let req = test::TestRequest::post()
.uri(url.as_ref())
.set_payload(body.as_ref().to_string())
.insert_header(("content-type", "application/json"));
self.request(req).await
}
2021-02-18 19:50:52 +01:00
pub async fn get(&self, url: impl AsRef<str>) -> (Value, StatusCode) {
let req = test::TestRequest::get().uri(url.as_ref());
self.request(req).await
2021-02-18 19:50:52 +01:00
}
2021-02-18 20:28:10 +01:00
pub async fn put(&self, url: impl AsRef<str>, body: Value) -> (Value, StatusCode) {
self.put_encoded(url, body, Encoder::Plain).await
}
pub async fn put_encoded(
&self,
url: impl AsRef<str>,
body: Value,
encoder: Encoder,
) -> (Value, StatusCode) {
let mut req = test::TestRequest::put().uri(url.as_ref());
req = self.encode(req, body, encoder);
self.request(req).await
}
pub async fn patch(&self, url: impl AsRef<str>, body: Value) -> (Value, StatusCode) {
self.patch_encoded(url, body, Encoder::Plain).await
}
2021-02-18 20:28:10 +01:00
pub async fn patch_encoded(
&self,
url: impl AsRef<str>,
body: Value,
encoder: Encoder,
) -> (Value, StatusCode) {
let mut req = test::TestRequest::patch().uri(url.as_ref());
req = self.encode(req, body, encoder);
self.request(req).await
2021-02-18 20:28:10 +01:00
}
2021-02-18 20:44:33 +01:00
pub async fn delete(&self, url: impl AsRef<str>) -> (Value, StatusCode) {
let req = test::TestRequest::delete().uri(url.as_ref());
self.request(req).await
}
pub async fn request(&self, mut req: test::TestRequest) -> (Value, StatusCode) {
2022-10-18 15:14:18 +02:00
let app = test::init_service(create_app(
self.index_scheduler.clone().into(),
self.auth.clone(),
self.options.clone(),
analytics::MockAnalytics::new(&self.options),
true,
))
.await;
2021-02-18 20:44:33 +01:00
if let Some(api_key) = &self.api_key {
req = req.insert_header(("Authorization", ["Bearer ", api_key].concat()));
}
let req = req.to_request();
let res = test::call_service(&app, req).await;
2021-02-18 20:44:33 +01:00
let status_code = res.status();
let body = test::read_body(res).await;
let response = serde_json::from_slice(&body).unwrap_or_default();
(response, status_code)
}
fn encode(&self, req: TestRequest, body: Value, encoder: Encoder) -> TestRequest {
let bytes = serde_json::to_string(&body).expect("Failed to serialize test data to json");
let encoded_body = encoder.encode(bytes);
let header = encoder.header();
match header {
Some(header) => req.insert_header(header),
None => req,
}
.set_payload(encoded_body)
.insert_header(ContentType::json())
}
2021-02-18 19:50:52 +01:00
}