use axum::routing::get;
use axum::{Extension, Router};
use surrealdb_core::dbs::capabilities::RouteTarget;
use super::AppState;
use crate::ntw::error::Error as NetError;
pub fn router<S>() -> Router<S>
where
S: Clone + Send + Sync + 'static,
{
Router::new().route("/health", get(handler))
}
async fn handler(Extension(state): Extension<AppState>) -> Result<(), NetError> {
let db = &state.datastore;
if !db.allows_http_route(&RouteTarget::Health) {
warn!("Capabilities denied HTTP route request attempt, target: '{}'", &RouteTarget::Health);
return Err(NetError::ForbiddenRoute(RouteTarget::Health.to_string()));
}
db.health_check().await.map_err(|err| {
tracing::error!("Health check failed: {err}");
NetError::InvalidStorage
})
}