zelo72/flodgatt
1
0
Fork 0
mirror of https://github.com/mastodon/flodgatt synced 2025-04-11 22:58:25 +02:00
Code Issues 2 Releases Wiki Activity

Improve logging

Browse Source 
Add more descriptive messages for the logging triggered by the
websocket server.
This commit is contained in:
Daniel Sockwell 2019-03-05 09:19:38 -05:00
parent 7a0b11e240
commit fffd3b6b4d
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/api/ws.rs
View File

@ -15,18 +15,26 @@ impl Actor for WebsocketActor {
/// Handler for ws::Message message /// Handler for ws::Message message
impl StreamHandler<ws::Message, ws::ProtocolError> for WebsocketActor { impl StreamHandler<ws::Message, ws::ProtocolError> for WebsocketActor {
fn started(&mut self, ctx: &mut Self::Context) { fn started(&mut self, ctx: &mut Self::Context) {
ctx.run_interval(Duration::from_secs(HEARTBEAT_INTERVAL_SECONDS), |_, inner_ctx| { ctx.run_interval(
inner_ctx.ping(""); Duration::from_secs(HEARTBEAT_INTERVAL_SECONDS),
}); |_, inner_ctx| {
inner_ctx.ping("Ping from StreamHandler");
},
);
} }
// This appears to be an echo server based on the actix_web documentation
// We won't actually need echo functionality in the final server
fn handle(&mut self, msg: ws::Message, ctx: &mut Self::Context) { fn handle(&mut self, msg: ws::Message, ctx: &mut Self::Context) {
debug!("Message {:?}", msg); debug!("Message {:?}", msg);
let red = ctx.state().redis.send(Command(RespValue::SimpleString("GET".into()))); let red = ctx
.state()
.redis
.send(Command(RespValue::SimpleString("GET".into())));
match msg { match msg {
ws::Message::Pong(msg) => debug!("{}", msg), ws::Message::Pong(msg) => debug!("matched: {}", msg),
ws::Message::Text(text) => ctx.text(text), ws::Message::Text(text) => ctx.text(text),
_ => (), _ => (),
} }