Add regression test

Author: OlivierHecart

zenoh/tests/adminspace.rs

@@ -800,3 +800,99 @@ async fn test_adminspace_transports_and_links() {
     router2.close().await.unwrap();
     router1.close().await.unwrap();
 }
+
+#[cfg(feature = "stats")]
+#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
+async fn test_adminspace_regression_1() {
+    const TIMEOUT: Duration = Duration::from_secs(60);
+    const ROUTER_ENDPOINT: &str = "tcp/localhost:31002";
+    const ROUTER_CONNECT_ENDPOINT: &str = "tcp/localhost:31002?rel=1;prio=1-7";
+
+    zenoh_util::init_log_from_env_or("error");
+
+    // Create router1 with adminspace enabled
+    let router1 = {
+        let mut c = zenoh_config::Config::default();
+        c.set_mode(Some(WhatAmI::Router)).unwrap();
+        c.listen
+            .endpoints
+            .set(vec![ROUTER_ENDPOINT.parse::<EndPoint>().unwrap()])
+            .unwrap();
+        c.scouting.multicast.set_enabled(Some(false)).unwrap();
+        c.adminspace.set_enabled(true).unwrap();
+        c.adminspace.permissions.set_read(true).unwrap();
+        c.adminspace.permissions.set_write(false).unwrap();
+        // Enable QoS for priorities and reliability support
+        c.transport.unicast.qos.set_enabled(true).unwrap();
+        ztimeout!(zenoh::open(c)).unwrap()
+    };
+    let zid1 = router1.zid();
+
+    // Create router2 that connects to router1 (creates unicast transport)
+    let _router2 = {
+        let mut c = zenoh_config::Config::default();
+        c.set_mode(Some(WhatAmI::Router)).unwrap();
+        c.listen.endpoints.set(vec![]).unwrap();
+        c.connect
+            .endpoints
+            .set(vec![ROUTER_CONNECT_ENDPOINT.parse::<EndPoint>().unwrap()])
+            .unwrap();
+        c.scouting.multicast.set_enabled(Some(false)).unwrap();
+        // Enable QoS for priorities and reliability support
+        c.transport.unicast.qos.set_enabled(true).unwrap();
+        ztimeout!(zenoh::open(c)).unwrap()
+    };
+
+    // Give some time for the connection to establish
+    tokio::time::sleep(Duration::from_millis(500)).await;
+
+    let reply = router1
+        .get(format!("@/{zid1}/router?_stats=true"))
+        .await
+        .unwrap()
+        .into_iter()
+        .next();
+    assert!(reply.is_some());
+    let binding = reply.unwrap();
+    let sample = binding.result().ok().unwrap();
+
+    // Verify it's JSON encoded
+    assert_eq!(sample.encoding(), &zenoh::bytes::Encoding::APPLICATION_JSON);
+
+    // Parse and verify JSON content
+    let bytes = sample.payload().to_bytes();
+    let json: serde_json::Value =
+        serde_json::from_slice(&bytes).expect("Failed to parse transport JSON");
+
+    let sessions = navigate_json_path!(json, "sessions").1.as_array().unwrap();
+    assert_eq!(sessions.len(), 1);
+    let rx_t_bytes = navigate_json_path!(sessions[0], "stats.rx_bytes")
+        .1
+        .as_u64()
+        .unwrap();
+    let tx_t_bytes = navigate_json_path!(sessions[0], "stats.tx_bytes")
+        .1
+        .as_u64()
+        .unwrap();
+    let links = navigate_json_path!(sessions[0], "links")
+        .1
+        .as_array()
+        .unwrap();
+    assert_eq!(links.len(), 1);
+    let rx_l_bytes = navigate_json_path!(links[0], "stats.rx_bytes")
+        .1
+        .as_u64()
+        .unwrap();
+    let tx_l_bytes = navigate_json_path!(links[0], "stats.tx_bytes")
+        .1
+        .as_u64()
+        .unwrap();
+
+    assert_ne!(rx_t_bytes, 0);
+    assert_ne!(tx_t_bytes, 0);
+    assert_ne!(rx_l_bytes, 0);
+    assert_ne!(tx_l_bytes, 0);
+
+    assert_eq!(rx_t_bytes, rx_l_bytes);
+    assert_eq!(tx_t_bytes, tx_l_bytes);
+}