valmojr/armatak
1
0
Fork 0
mirror of https://github.com/valmojr/armatak.git synced 2026-06-13 16:03:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

removed info for each received information on ws

Browse Source
This commit is contained in:
Valmo Trindade
2024-10-23 22:56:33 -03:00
parent acb3a49f85
commit 4a8d9f0182
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/commands.rs
View File

@@ -46,7 +46,6 @@ impl WsServer {
for client in clients_guard.iter() { for client in clients_guard.iter() {
client.send(message.clone()).unwrap(); client.send(message.clone()).unwrap();
} }
info!("Broadcasting message: {}", message);
} }
Ok(WsCommand::Stop) => { Ok(WsCommand::Stop) => {
running = false; running = false;
@@ -63,7 +62,7 @@ impl WsServer {
} }
fn send_message<T: IntoMessage>(&self, payload: T) { fn send_message<T: IntoMessage>(&self, payload: T) {
let message = payload.into_message(); // Convert the payload to a String let message = payload.into_message();
self.tx.send(WsCommand::SendMessage(message)).unwrap(); self.tx.send(WsCommand::SendMessage(message)).unwrap();
} }
@@ -92,6 +91,7 @@ pub fn start() -> &'static str {
pub fn message(payload: String) -> &'static str { pub fn message(payload: String) -> &'static str {
if let Some(ref server) = *WEBSOCKET_SERVER.lock().unwrap() { if let Some(ref server) = *WEBSOCKET_SERVER.lock().unwrap() {
info!("Broadcasting message: {}", payload);
server.send_message(payload); server.send_message(payload);
} else { } else {
info!("WebSocket server is not running."); info!("WebSocket server is not running.");
@@ -117,4 +117,4 @@ pub fn stop() -> &'static str {
} }
"Stopping WebSocket server" "Stopping WebSocket server"
} }