From 4b14bbb4f4b6480575f1e258abf9e5ae98ab43a0 Mon Sep 17 00:00:00 2001
From: Teknique <teknique@honeypot.net>
Date: Wed, 31 May 2023 15:49:21 -0700
Subject: [PATCH] Add stats JSON serde tests

---
 .../veilid_api/tests/test_serialize_json.rs   | 102 ++++++++++++++++++
 1 file changed, 102 insertions(+)

diff --git a/veilid-core/src/veilid_api/tests/test_serialize_json.rs b/veilid-core/src/veilid_api/tests/test_serialize_json.rs
index 1f9f28fe..8e3a9109 100644
--- a/veilid-core/src/veilid_api/tests/test_serialize_json.rs
+++ b/veilid-core/src/veilid_api/tests/test_serialize_json.rs
@@ -36,9 +36,111 @@ pub async fn test_safetyspec() {
     assert_eq!(orig, copy);
 }
 
+pub async fn test_latencystats() {
+    let orig = LatencyStats {
+        fastest: AlignedU64::from(1234),
+        average: AlignedU64::from(2345),
+        slowest: AlignedU64::from(3456),
+    };
+    let copy = deserialize_json(&serialize_json(&orig)).unwrap();
+
+    assert_eq!(orig, copy);
+}
+
+pub async fn test_transferstats() {
+    let orig = TransferStats {
+        total: AlignedU64::from(1_000_000),
+        maximum: AlignedU64::from(3456),
+        average: AlignedU64::from(2345),
+        minimum: AlignedU64::from(1234),
+    };
+    let copy = deserialize_json(&serialize_json(&orig)).unwrap();
+
+    assert_eq!(orig, copy);
+}
+
+pub async fn test_transferstatsdownup() {
+    let orig = TransferStatsDownUp {
+        down: TransferStats {
+            total: AlignedU64::from(1_000_000),
+            maximum: AlignedU64::from(3456),
+            average: AlignedU64::from(2345),
+            minimum: AlignedU64::from(1234),
+        },
+        up: TransferStats {
+            total: AlignedU64::from(1_000_000 * 2),
+            maximum: AlignedU64::from(3456 * 2),
+            average: AlignedU64::from(2345 * 2),
+            minimum: AlignedU64::from(1234 * 2),
+        },
+    };
+    let copy = deserialize_json(&serialize_json(&orig)).unwrap();
+
+    assert_eq!(orig, copy);
+}
+
+pub async fn test_rpcstats() {
+    let orig = RPCStats {
+        messages_sent: 1_000_000,
+        messages_rcvd: 2_000_000,
+        questions_in_flight: 42,
+        last_question_ts: Some(AlignedU64::from(1685569084280)),
+        last_seen_ts: Some(AlignedU64::from(1685569101256)),
+        first_consecutive_seen_ts: Some(AlignedU64::from(1685569111851)),
+        recent_lost_answers: 5,
+        failed_to_send: 3,
+    };
+    let copy = deserialize_json(&serialize_json(&orig)).unwrap();
+
+    assert_eq!(orig, copy);
+}
+
+pub async fn test_peerstats() {
+    let orig = PeerStats {
+        time_added: AlignedU64::from(1685569176894),
+        rpc_stats: RPCStats {
+            messages_sent: 1_000_000,
+            messages_rcvd: 2_000_000,
+            questions_in_flight: 42,
+            last_question_ts: Some(AlignedU64::from(1685569084280)),
+            last_seen_ts: Some(AlignedU64::from(1685569101256)),
+            first_consecutive_seen_ts: Some(AlignedU64::from(1685569111851)),
+            recent_lost_answers: 5,
+            failed_to_send: 3,
+        },
+        latency: Some(LatencyStats {
+            fastest: AlignedU64::from(1234),
+            average: AlignedU64::from(2345),
+            slowest: AlignedU64::from(3456),
+        }),
+        transfer: TransferStatsDownUp {
+            down: TransferStats {
+                total: AlignedU64::from(1_000_000),
+                maximum: AlignedU64::from(3456),
+                average: AlignedU64::from(2345),
+                minimum: AlignedU64::from(1234),
+            },
+            up: TransferStats {
+                total: AlignedU64::from(1_000_000 * 2),
+                maximum: AlignedU64::from(3456 * 2),
+                average: AlignedU64::from(2345 * 2),
+                minimum: AlignedU64::from(1234 * 2),
+            },
+        },
+    };
+    let copy = deserialize_json(&serialize_json(&orig)).unwrap();
+
+    assert_eq!(orig, copy);
+}
+
 pub async fn test_all() {
     test_round_trip_peerinfo().await;
     test_alignedu64().await;
     test_fourcc().await;
     test_safetyspec().await;
+    test_latencystats().await;
+    test_transferstats().await;
+    test_transferstatsdownup().await;
+    test_rpcstats().await;
+    test_peerstats().await;
 }