hardcoresushi/AIRA
1
0
Fork 0
Code Issues Pull Requests Projects Releases 3 Wiki Activity

Log websocket messages in debug build

Browse Source
This commit is contained in:
Matéo Duparc 2021-08-02 21:22:56 +02:00
parent 8c8ede431c
commit dce526922e
Signed by: hardcoresushi
GPG Key ID: 007F84120107191E
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main.rs
View File

@ -69,7 +69,6 @@ async fn start_websocket_server(global_vars: Arc<RwLock<GlobalVars>>) -> u16 {
fn discover_peers(session_manager: Arc<SessionManager>) { fn discover_peers(session_manager: Arc<SessionManager>) {
tokio::spawn(async move { tokio::spawn(async move {
discovery::discover_peers(move |discovery_manager, ip| { discovery::discover_peers(move |discovery_manager, ip| {
println!("New peer discovered: {}", ip);
let session_manager = session_manager.clone(); let session_manager = session_manager.clone();
if session_manager.is_identity_loaded() { if session_manager.is_identity_loaded() {
tokio::spawn( async move { tokio::spawn( async move {
@ -153,6 +152,8 @@ async fn websocket_worker(mut ui_connection: UiConnection, global_vars: Arc<RwLo
ui_connection.write_message(tungstenite::Message::Pong(Vec::new())); //not sure if I'm doing this right ui_connection.write_message(tungstenite::Message::Pong(Vec::new())); //not sure if I'm doing this right
} else if msg.is_text() { } else if msg.is_text() {
let msg = msg.into_text().unwrap(); let msg = msg.into_text().unwrap();
#[cfg(debug_assertions)]
println!("Message: {}", msg);
let mut ui_connection = ui_connection.clone(); let mut ui_connection = ui_connection.clone();
let session_manager = session_manager.clone(); let session_manager = session_manager.clone();
handle.spawn(async move { handle.spawn(async move {