ic-query 0.93.0

Internet Computer query library for CloudEngine, NNS, SNS, ICRC, system canisters, and public network metadata
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

use super::*;

#[test]
fn boundary_node_data_centers_url_appends_one_v4_resource() {
    for endpoint in [
        "https://ic-api.internetcomputer.org/api/v4",
        "https://ic-api.internetcomputer.org/api/v4/",
    ] {
        assert_eq!(
            boundary_node_data_centers_url(endpoint)
                .expect("boundary-node data-centers URL")
                .as_str(),
            "https://ic-api.internetcomputer.org/api/v4/boundary-node-data-centers"
        );
    }
}

#[test]
fn daily_stats_url_preserves_explicit_bounds() {
    let query = IcDailyStatsQuery::new(1_700_000_000, 1_700_604_800);
    let url = daily_stats_url("https://ic-api.internetcomputer.org/api/v3/", &query)
        .expect("daily-statistics URL");

    assert_eq!(url.path(), "/api/v3/daily-stats");
    assert_eq!(
        url.query(),
        Some("format=json&start=1700000000&end=1700604800")
    );
}

#[test]
fn daily_stats_wire_decoder_preserves_raw_rates_and_additive_fields() {
    let wire: DashboardDailyStats = serde_json::from_str(
        r#"{
                "daily_stats": [{
                    "average_query_transactions_per_second": "3057.0771",
                    "average_transactions_per_second": "4378.980149999999",
                    "average_update_transactions_per_second": "1321.9030499999997",
                    "blocks_per_second_average": "193.50055560014323",
                    "day": "2026-07-31",
                    "max_query_transactions_per_second": "3635.62381",
                    "max_total_transactions_per_second": "5062.08807",
                    "max_update_transactions_per_second": "1688.4959999999999",
                    "timestamp": 1785542399,
                    "future_field": {"value": 1.5}
                }],
                "future_top_level": true
            }"#,
    )
    .expect("current daily-statistics payload");

    let row = wire.daily_stats.into_iter().next().expect("one row");
    assert_eq!(row.day, "2026-07-31");
    assert_eq!(row.timestamp_unix_secs, 1_785_542_399);
    assert_eq!(row.average_transactions_per_second, "4378.980149999999");
    let json = serde_json::to_value(&row).expect("report row JSON");
    assert_eq!(json["timestamp_unix_secs"], 1_785_542_399_u64);
    assert!(json.get("timestamp").is_none());
}

#[test]
fn boundary_node_wire_decoder_preserves_zero_counts_and_additive_fields() {
    let wire: DashboardBoundaryNodeDataCenters = serde_json::from_str(
        r#"{
                "data": [{
                    "dc_id": "fr1",
                    "latitude": "50.1109",
                    "longitude": "8.6821",
                    "name": "Frankfurt",
                    "owner": "Equinix",
                    "region": "North America,US,Frankfurt",
                    "total_nodes": "0",
                    "future_field": true
                }],
                "future_top_level": true
            }"#,
    )
    .expect("current boundary-node payload");

    let row = wire.data.into_iter().next().expect("one row");
    assert_eq!(row.dc_id, "fr1");
    assert_eq!(row.region, "North America,US,Frankfurt");
    assert_eq!(row.total_nodes, "0");
}