assay_workflow/api/
public.rs

1//! Public `/api/v1/*` endpoints — callable without authentication even when
2//! the server is configured with `--auth-issuer` or `--auth-api-key`.
3//!
4//! Two routes live here today:
5//!
6//!   - `GET /api/v1/engine/workflow/health`  — static liveness/readiness probe. Used by
7//!     Kubernetes kubelet, load balancers, and any in-cluster monitor
8//!     without a bearer token.
9//!
10//!   - `GET /api/v1/engine/workflow/version` — engine version + build profile. Used by
11//!     the CLI, dashboard, and third-party monitors to identify the
12//!     running build. Cheap, static, no sensitive data.
13//!
14//! Both are wired outside the auth middleware layer in `api/mod.rs`. The
15//! handlers live here (rather than being inlined) so Utoipa can tag and
16//! document them under a single `public` module.
17use std::sync::Arc;
18
19use axum::extract::State;
20use axum::routing::get;
21use axum::{Json, Router};
22use serde::Serialize;
23use utoipa::ToSchema;
24
25use crate::ctx::WorkflowCtx;
26use crate::store::WorkflowStore;
27
28pub fn router<S: WorkflowStore + 'static>() -> Router<Arc<WorkflowCtx<S>>> {
29    Router::new()
30        .route("/health", get(health_check))
31        .route("/version", get(version))
32}
33
34#[utoipa::path(
35    get, path = "/api/v1/engine/workflow/health",
36    tag = "public",
37    responses((status = 200, description = "Engine health — always unauthenticated")),
38)]
39pub async fn health_check() -> Json<serde_json::Value> {
40    Json(serde_json::json!({
41        "status": "ok",
42        "service": "assay-workflow",
43    }))
44}
45
46#[derive(Serialize, ToSchema)]
47pub struct VersionInfo {
48    /// Semver of the user-facing binary (or the `assay-workflow` crate when
49    /// no embedder version was supplied). Matches `assay --version`.
50    pub version: &'static str,
51    /// `release` or `debug`.
52    pub build_profile: &'static str,
53}
54
55#[utoipa::path(
56    get, path = "/api/v1/engine/workflow/version",
57    tag = "public",
58    responses((status = 200, description = "Engine version info", body = VersionInfo)),
59)]
60pub async fn version<S: WorkflowStore>(
61    State(state): State<Arc<WorkflowCtx<S>>>,
62) -> Json<VersionInfo> {
63    let version = state.binary_version.unwrap_or(env!("CARGO_PKG_VERSION"));
64    Json(VersionInfo {
65        version,
66        build_profile: if cfg!(debug_assertions) {
67            "debug"
68        } else {
69            "release"
70        },
71    })
72}
assay_workflow/api/public.rs

assay_workflow/api/
public.rs
