4nk/sdk_relay
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update AnkFlag::Init to Handshake

Browse Source
This commit is contained in:
NicolasCantu 2025-01-09 16:12:25 +01:00 committed by Nicolas Cantu
parent 21711edd39
commit fe613fb372
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main.rs
View File

@ -216,7 +216,7 @@ async fn handle_connection(raw_stream: TcpStream, addr: SocketAddr, our_sp_addre
); );
if let Err(e) = broadcast_message( if let Err(e) = broadcast_message(
AnkFlag::Init, AnkFlag::Handshake,
format!("{}", init_msg.to_string()), format!("{}", init_msg.to_string()),
BroadcastType::Sender(addr) BroadcastType::Sender(addr)
) )

2
src/message.rs
View File

@ -215,7 +215,7 @@ pub fn process_message(raw_msg: &str, addr: SocketAddr) {
AnkFlag::Cipher => process_cipher_message(ank_msg, addr), AnkFlag::Cipher => process_cipher_message(ank_msg, addr),
AnkFlag::Commit => process_commit_message(ank_msg, addr), AnkFlag::Commit => process_commit_message(ank_msg, addr),
AnkFlag::Unknown => process_unknown_message(ank_msg, addr), AnkFlag::Unknown => process_unknown_message(ank_msg, addr),
AnkFlag::Init => log::debug!("Received init message from {}", addr), AnkFlag::Handshake => log::debug!("Received init message from {}", addr),
}, },
Err(_) => log::error!("Failed to parse network message"), Err(_) => log::error!("Failed to parse network message"),
} }