diff --git a/src/main.rs b/src/main.rs index 59a2515..2a61286 100644 --- a/src/main.rs +++ b/src/main.rs @@ -498,7 +498,18 @@ async fn handle_connection( } } AnkFlag::Error => unimplemented!(), - AnkFlag::Unknown => unimplemented!(), + AnkFlag::Unknown => { + debug!("Received an unknown message"); + if let Err(e) = broadcast_message( + peers.clone(), + AnkFlag::Unknown, + serde_json::to_string(&ank_msg.content) + .expect("This should not fail"), + BroadcastType::ExcludeSender(addr), + ) { + log::error!("Failed to send message with error: {}", e); + } + }, AnkFlag::Prd => unimplemented!(), }, Err(_) => log::error!("Failed to parse network message"),