From b216a81e263793c75ec1d3d9164bdd1529612cb8 Mon Sep 17 00:00:00 2001
From: Daniel Sockwell <daniel@codesections.com>
Date: Tue, 7 Jan 2020 17:27:46 -0500
Subject: [PATCH] Add api/v1/streaming/health API endpoint (#74)

---
 src/main.rs | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index dff1237..6a7a074 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -5,7 +5,7 @@ use flodgatt::{
 };
 use log::warn;
 use std::{collections::HashMap, env, net};
-use warp::{ws::Ws2, Filter as WarpFilter};
+use warp::{path, ws::Ws2, Filter};
 
 fn main() {
     dotenv::from_filename(
@@ -87,9 +87,11 @@ fn main() {
 
     let server_addr = net::SocketAddr::new(*cfg.address, cfg.port.0);
 
+    let health = warp::path!("api" / "v1" / "streaming" / "health").map(|| "OK");
+
     if let Some(_socket) = cfg.unix_socket.0.as_ref() {
         dbg_and_die!("Unix socket support not yet implemented");
     } else {
-        warp::serve(websocket_routes.or(sse_routes).with(cors)).run(server_addr);
+        warp::serve(health.or(websocket_routes.or(sse_routes).with(cors))).run(server_addr);
     }
 }