fmt

eclipse-zenoh · Dec 9, 2024 · 0f321f4 · 0f321f4
1 parent d7b5d1b
commit 0f321f4
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 9 deletions.
diff --git a/zenoh-plugin-remote-api/src/handle_control_message.rs b/zenoh-plugin-remote-api/src/handle_control_message.rs
@@ -73,17 +73,24 @@ pub(crate) async fn handle_control_message(
             let session_info = state_map.session.info();
 
             let zid = session_info.zid().await.to_string();
-            let z_peers: Vec<String> = session_info.peers_zid().await.map(|x|x.to_string()).collect();
-            let z_routers: Vec<String> = session_info.routers_zid().await.map(|x|x.to_string()).collect();
+            let z_peers: Vec<String> = session_info
+                .peers_zid()
+                .await
+                .map(|x| x.to_string())
+                .collect();
+            let z_routers: Vec<String> = session_info
+                .routers_zid()
+                .await
+                .map(|x| x.to_string())
+                .collect();
 
             let session_info = SessionInfo {
                 zid,
                 z_routers,
                 z_peers,
             };
 
-            let remote_api_message =
-                RemoteAPIMsg::Data(DataMsg::SessionInfo(session_info));
+            let remote_api_message = RemoteAPIMsg::Data(DataMsg::SessionInfo(session_info));
 
             if let Err(e) = state_map.websocket_tx.send(remote_api_message) {
                 error!("Forward Sample Channel error: {e}");

diff --git a/zenoh-plugin-remote-api/src/interface.rs b/zenoh-plugin-remote-api/src/interface.rs
@@ -71,7 +71,7 @@ pub enum DataMsg {
     Sample(SampleWS, Uuid),
     // GetReply
     GetReply(ReplyWS),
-    // 
+    //
     SessionInfo(SessionInfo),
 
     // Bidirectional
@@ -82,9 +82,9 @@ pub enum DataMsg {
 #[ts(export)]
 #[derive(Debug, Serialize, Deserialize)]
 pub struct SessionInfo {
-    pub zid: String, 
-    pub z_routers:Vec<String>,
-    pub z_peers:Vec<String>,
+    pub zid: String,
+    pub z_routers: Vec<String>,
+    pub z_peers: Vec<String>,
 }
 
 #[derive(TS)]
@@ -117,7 +117,7 @@ pub enum ControlMsg {
     CloseSession,
     Session(Uuid),
 
-    // 
+    //
     SessionInfo,
 
     // Session Action Messages