Added Health Endpoint (#30)

* feat: added minimal health endpoint

.gitignore

@@ -2,3 +2,6 @@
 docker-compose.override.yml
 target/
 Cargo.lock
+
+*.priv.pem
+docker-compose.override.yml

src/health.rs

@@ -0,0 +1,18 @@
+use serde::Serialize;
+
+
+#[derive(Serialize)]
+pub struct HealthOutput {
+    pub summary: Verdict,
+    pub beam: BeamStatus
+}
+
+#[derive(Serialize)]
+pub enum Verdict {
+    Healthy,
+}
+
+#[derive(Serialize)]
+pub enum BeamStatus {
+    Ok,
+}

src/main.rs

@@ -20,11 +20,13 @@ use tracing::{info, warn, Level};
 use tracing_subscriber::{util::SubscriberInitExt, EnvFilter};
 use tokio::{io::AsyncWriteExt, sync::{mpsc, Mutex}};
 use futures_util::{TryFutureExt, TryStreamExt};
+use health::{BeamStatus, HealthOutput, Verdict};
 
 mod banner;
 mod beam;
 mod catalogue;
 mod config;
+mod health;
 
 static CONFIG: Lazy<Config> = Lazy::new(Config::parse);
 
@@ -67,6 +69,7 @@ async fn main() {
         .allow_headers([header::CONTENT_TYPE]);
 
     let mut app = Router::new()
+        .route("/health", get(handler_health))
         .route("/beam", post(handle_create_beam_task))
         .route("/beam/:task_id", get(handle_listen_to_beam_tasks));
 
@@ -98,6 +101,13 @@ struct LensQuery {
     query: String,
 }
 
+async fn handler_health() -> Json<HealthOutput> {
+    Json(HealthOutput {
+        summary: Verdict::Healthy,
+        beam: BeamStatus::Ok
+    })
+}
+
 async fn handle_create_beam_task(
     State(SharedState { result_log_sender_map, .. }): State<SharedState>,
     headers: HeaderMap,