diff --git a/src/main.rs b/src/main.rs index 129bbbf..6eb1ee9 100644 --- a/src/main.rs +++ b/src/main.rs @@ -31,7 +31,7 @@ fn handle_fanout_ws(mut req: Request, chan: &str) -> Response { } fn handle_fanout(req: Request) -> Response { - let chan = req.get_header_str("FANOUT").unwrap_or("test") + let chan = req.get_header_str("FANOUT").unwrap_or("test"); match req.get_url().path() { "/stream/long-poll" => fanout_util::grip_response("text/plain", "response", chan), "/stream/plain" => fanout_util::grip_response("text/plain", "stream", chan), @@ -53,7 +53,7 @@ fn main() -> Result<(), Error> { if req.get_path().starts_with("/stream/") { return Ok(if req.get_header_str("Grip-Sig").is_some() { // Request is from Fanout - + handle_fanout(req).send_to_client(); } else { // Not from fanout, hand it off to Fanout to manage