zelo72
/
flodgatt
mirror of https://github.com/mastodon/flodgatt
1
0
Fork 0
Code Issues Releases Wiki Activity

Add api/v1/streaming/health API endpoint (#74)

This commit is contained in:
Daniel Sockwell 2020-01-07 17:27:46 -05:00 committed by GitHub
parent bf529a901b
commit b216a81e26
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main.rs
View File

@ -5,7 +5,7 @@ use flodgatt::{
}; };
use log::warn; use log::warn;
use std::{collections::HashMap, env, net}; use std::{collections::HashMap, env, net};
use warp::{ws::Ws2, Filter as WarpFilter}; use warp::{path, ws::Ws2, Filter};
fn main() { fn main() {
dotenv::from_filename( dotenv::from_filename(
@ -87,9 +87,11 @@ fn main() {
let server_addr = net::SocketAddr::new(*cfg.address, cfg.port.0); 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() { if let Some(_socket) = cfg.unix_socket.0.as_ref() {
dbg_and_die!("Unix socket support not yet implemented"); dbg_and_die!("Unix socket support not yet implemented");
} else { } 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);
} }
} }