mirror of
https://github.com/meilisearch/MeiliSearch
synced 2024-12-02 01:25:45 +01:00
set test for healthyness
This commit is contained in:
parent
83cf683db4
commit
116a637cfd
@ -40,10 +40,10 @@ whoami = "0.6"
|
|||||||
tide = "0.5.1"
|
tide = "0.5.1"
|
||||||
async-std = { version = "1.0.1", features = ["unstable", "attributes"] }
|
async-std = { version = "1.0.1", features = ["unstable", "attributes"] }
|
||||||
|
|
||||||
|
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
http-service-mock = "0.4.0"
|
http-service-mock = "0.4.0"
|
||||||
http-service = "0.4.0"
|
http-service = "0.4.0"
|
||||||
|
|
||||||
tempdir = "0.3.7"
|
tempdir = "0.3.7"
|
||||||
|
|
||||||
[build-dependencies]
|
[build-dependencies]
|
||||||
|
48
meilisearch-http/tests/health.rs
Normal file
48
meilisearch-http/tests/health.rs
Normal file
@ -0,0 +1,48 @@
|
|||||||
|
use http_service::Body;
|
||||||
|
use serde_json::json;
|
||||||
|
use std::convert::Into;
|
||||||
|
|
||||||
|
mod common;
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn test_healthyness() {
|
||||||
|
let mut server = common::setup_server().unwrap();
|
||||||
|
|
||||||
|
// Check that the server is healthy
|
||||||
|
|
||||||
|
let req = http::Request::get("/health").body(Body::empty()).unwrap();
|
||||||
|
let res = server.simulate(req).unwrap();
|
||||||
|
assert_eq!(res.status(), 200);
|
||||||
|
|
||||||
|
// Set the serve Unhealthy
|
||||||
|
|
||||||
|
let body = json!({
|
||||||
|
"health": false,
|
||||||
|
}).to_string().into_bytes();
|
||||||
|
|
||||||
|
let req = http::Request::put("/health").body(Body::from(body)).unwrap();
|
||||||
|
let res = server.simulate(req).unwrap();
|
||||||
|
assert_eq!(res.status(), 200);
|
||||||
|
|
||||||
|
// Check that the server is unhealthy
|
||||||
|
|
||||||
|
let req = http::Request::get("/health").body(Body::empty()).unwrap();
|
||||||
|
let res = server.simulate(req).unwrap();
|
||||||
|
assert_eq!(res.status(), 503);
|
||||||
|
|
||||||
|
// Set the server healthy
|
||||||
|
|
||||||
|
let body = json!({
|
||||||
|
"health": true,
|
||||||
|
}).to_string().into_bytes();
|
||||||
|
|
||||||
|
let req = http::Request::put("/health").body(Body::from(body)).unwrap();
|
||||||
|
let res = server.simulate(req).unwrap();
|
||||||
|
assert_eq!(res.status(), 200);
|
||||||
|
|
||||||
|
// Check if the server is healthy
|
||||||
|
|
||||||
|
let req = http::Request::get("/health").body(Body::empty()).unwrap();
|
||||||
|
let res = server.simulate(req).unwrap();
|
||||||
|
assert_eq!(res.status(), 200);
|
||||||
|
}
|
@ -1,17 +0,0 @@
|
|||||||
// use async_std::prelude::*;
|
|
||||||
// use async_std::task;
|
|
||||||
// use std::time::Duration;
|
|
||||||
|
|
||||||
// use serde::{Deserialize, Serialize};
|
|
||||||
use http_service::Body;
|
|
||||||
|
|
||||||
mod common;
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn create_index() {
|
|
||||||
let mut server = common::setup_server().unwrap();
|
|
||||||
|
|
||||||
let req = http::Request::get("/health").body(Body::empty()).unwrap();
|
|
||||||
let res = server.simulate(req).unwrap();
|
|
||||||
assert_eq!(res.status(), 200);
|
|
||||||
}
|
|
Loading…
Reference in New Issue
Block a user