stalwartlabs/mail-server
1
1
Fork 0
mirror of https://github.com/stalwartlabs/mail-server.git synced 2024-11-10 09:32:19 +08:00
Code Issues Projects Releases Packages Wiki Activity Actions

Kubernetes (K8S) livenessProbe and readinessProbe endpoints

Browse source
This commit is contained in:
mdecimus 2024-07-04 19:49:45 +02:00
parent 176a3a90ae
commit a9cffb8d1e
1 changed files with 23 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
crates/jmap/src/api/http.rs
View file

@ -65,7 +65,7 @@ impl JMAP {
return if req.method() != Method::OPTIONS {
RequestError::unauthorized().into_http_response()
} else {
().into_http_response()
StatusCode::NO_CONTENT.into_http_response()
}
}
Err(err) => return err.into_http_response(),
@ -188,7 +188,7 @@ impl JMAP {
.await;
}
(_, &Method::OPTIONS) => {
return ().into_http_response();
return StatusCode::NO_CONTENT.into_http_response();
}
_ => (),
}
@ -265,7 +265,7 @@ impl JMAP {
}
}
(_, &Method::OPTIONS) => {
return ().into_http_response();
return StatusCode::NO_CONTENT.into_http_response();
}
_ => (),
},
@ -286,14 +286,14 @@ impl JMAP {
}
}
(_, &Method::OPTIONS) => {
return ().into_http_response();
return StatusCode::NO_CONTENT.into_http_response();
}
_ => (),
},
"api" => {
// Allow CORS preflight requests
if req.method() == Method::OPTIONS {
return ().into_http_response();
return StatusCode::NO_CONTENT.into_http_response();
}
// Authenticate user
@ -330,6 +330,22 @@ impl JMAP {
}
.into_http_response();
}
"healthz" => match path.next().unwrap_or_default() {
"live" => {
return StatusCode::OK.into_http_response();
}
"ready" => {
return {
if !self.core.storage.data.is_none() {
StatusCode::OK
} else {
StatusCode::SERVICE_UNAVAILABLE
}
}
.into_http_response();
}
_ => (),
},
_ => {
let path = req.uri().path();
return match self
@ -653,10 +669,10 @@ impl ToHttpResponse for HtmlResponse {
}
}
impl ToHttpResponse for () {
impl ToHttpResponse for StatusCode {
fn into_http_response(self) -> HttpResponse {
hyper::Response::builder()
.status(StatusCode::NO_CONTENT)
.status(self)
.body(
Full::new(Bytes::new())
.map_err(|never| match never {})