Process Unknown message

2024-05-06 10:48:56 +02:00 · 2024-05-06 10:48:56 +02:00 · 4455c76663
commit 4455c76663
parent ec8e4ebef8
1 changed files with 12 additions and 1 deletions
--- 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"),