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

Initial WIP Unix socket implementation

This commit is contained in:
Daniel Sockwell 2020-01-08 09:21:39 -05:00
parent b216a81e26
commit 9cc395e28c
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main.rs
View File

@ -1,5 +1,5 @@
use flodgatt::{
config, dbg_and_die, err,
config, err,
parse_client_request::{sse, user, ws},
redis_to_client_stream::{self, ClientAgent},
};
@ -89,8 +89,12 @@ fn main() {
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");
if let Some(socket) = &*cfg.unix_socket {
warn!("Using Unix sockets is a WIP that is currently unsupported and untested.");
std::fs::remove_file(socket).unwrap();
use tokio::net::UnixListener;
let incoming = UnixListener::bind(socket).unwrap().incoming();
warp::serve(health.or(websocket_routes.or(sse_routes).with(cors))).run_incoming(incoming);
} else {
warp::serve(health.or(websocket_routes.or(sse_routes).with(cors))).run(server_addr);
}