fix(server): update ciders for online connection

Author: ICKelin

src/codec/parser.rs

@@ -41,7 +41,7 @@ impl Parser {
         let payload_size = u16::from_be_bytes([buf[6], buf[7]]);
 
         if !Self::validate(magic, version, payload_size, buf) {
-            tracing::warn!("validate header fail: magic = {} version={} payload_size={} buf size={}", magic, version, payload_size, buf.len());
+            tracing::debug!("validate header fail: magic = {} version={} payload_size={} buf size={}", magic, version, payload_size, buf.len());
             return Err(FrameError::Invalid.into());
         }
 

src/network/connection_manager.rs

@@ -106,6 +106,7 @@ impl ConnectionManager {
     /// * `Some(Vec<ConnectionMeta>)` - List of other connections in the cluster if the address changed
     /// * `None` - If the address didn't change or the connection wasn't found
     pub fn update_connection_info(&self, cluster: &str, identity: &String,
+                                  ciders: Vec<String>,
                                   ipv6: String, port: u16,
                                   stun_ip: String, stun_port: u16) -> Option<Vec<ConnectionMeta>> {
         let mut cluster_map = self
@@ -131,6 +132,11 @@ impl ConnectionManager {
                 conn.stun_port = stun_port;
             }
 
+            if conn.ciders != ciders {
+                changed = true;
+                conn.ciders = ciders;
+            }
+
             if !changed {
                 return None;
             }

src/server/server.rs

@@ -262,12 +262,12 @@ impl Handler {
                 tracing::info!("on keepalive from {} {}:{} {}:{}",
                     frame.identity, frame.ipv6, frame.port, frame.stun_ip, frame.stun_port);
 
-                // Update connection metadata with latest IPv6 and port from keepalive
-                // If the address changed, notify other clients in the cluster
-                if let Some(cluster) = &self.cluster {
+                let client = self.client_manager.get_client(&frame.identity);
+                if let Some(client) = client {
                     let _ = self.connection_manager.update_connection_info(
-                        cluster,
+                        &client.cluster,
                         &frame.identity,
+                        client.ciders.clone(),
                         frame.ipv6.clone(),
                         frame.port,
                         frame.stun_ip.clone(),