chore: log starting/stopping ntfy worker

This commit is contained in:
əlemi 2024-05-27 19:40:14 +02:00
parent 8c1c98a197
commit df185e2517
Signed by: alemi
GPG key ID: A4895B84D311642C

View file

@ -83,6 +83,7 @@ async fn main() {
#[cfg(feature = "ntfy")]
if let Some(topic) = args.topic {
tracing::info!("starting ntfy worker");
let events = session.events();
let target = format!("{}/{topic}", args.ntfy);
tokio::spawn(async move { handle_ntfy(target, events).await });
@ -147,6 +148,7 @@ async fn handle_ntfy(target: String, mut sub: broadcast::Receiver<session::Sessi
tracing::debug!("events channel closed: {e}");
}
}
tracing::info!("stopping ntfy worker");
}
async fn handle_ws(mut socket: WebSocket, mut sub: broadcast::Receiver<session::SessionEvent>) {