bestool-alertd 12.0.0

(Internal) BES tooling: healthcheck daemon
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use std::sync::Arc;

use axum::{Json, extract::State, response::IntoResponse};

use crate::http_server::{state::ServerState, types::StatusResponse};

pub async fn handle_status(State(state): State<Arc<ServerState>>) -> impl IntoResponse {
	let backups_running = match &state.backups {
		Some(registry) => registry.running().await,
		None => Vec::new(),
	};
	let status = StatusResponse {
		name: "bestool-alertd".to_string(),
		version: env!("CARGO_PKG_VERSION").to_string(),
		started_at: state.started_at.to_string(),
		pid: state.pid,
		backups_running,
	};
	Json(status)
}

#[cfg(test)]
mod tests {
	use axum::{extract::State, http::StatusCode, response::IntoResponse};

	use super::*;
	use crate::http_server::test_utils::create_test_state;

	#[tokio::test]
	async fn test_status_endpoint() {
		let state = create_test_state().await;

		let response = handle_status(State(state)).await.into_response();

		assert_eq!(response.status(), StatusCode::OK);
		let body = axum::body::to_bytes(response.into_body(), usize::MAX)
			.await
			.unwrap();
		let status: StatusResponse = serde_json::from_slice(&body).unwrap();

		assert_eq!(status.name, "bestool-alertd");
		assert!(!status.version.is_empty());
	}
}