diff --git a/warzone/crates/warzone-server/src/routes/ws.rs b/warzone/crates/warzone-server/src/routes/ws.rs index 6b0be7e..a2d4f1e 100644 --- a/warzone/crates/warzone-server/src/routes/ws.rs +++ b/warzone/crates/warzone-server/src/routes/ws.rs @@ -65,7 +65,7 @@ async fn handle_socket(socket: WebSocket, state: AppState, fingerprint: String) } // Spawn task to forward push messages to WS - let fp_clone = fingerprint.clone(); + let _fp_clone = fingerprint.clone(); let mut push_task = tokio::spawn(async move { while let Some(msg) = push_rx.recv().await { if ws_tx.send(Message::Binary(msg.into())).await.is_err() { diff --git a/warzone/crates/warzone-server/src/state.rs b/warzone/crates/warzone-server/src/state.rs index 67dea12..b275f26 100644 --- a/warzone/crates/warzone-server/src/state.rs +++ b/warzone/crates/warzone-server/src/state.rs @@ -1,6 +1,6 @@ use std::collections::HashMap; use std::sync::Arc; -use tokio::sync::{broadcast, Mutex, mpsc}; +use tokio::sync::{Mutex, mpsc}; use crate::db::Database; @@ -52,6 +52,7 @@ impl AppState { } /// Unregister a WS connection. + #[allow(dead_code)] pub async fn unregister_ws(&self, fingerprint: &str, sender: &WsSender) { let mut conns = self.connections.lock().await; if let Some(senders) = conns.get_mut(fingerprint) {