ic-query 0.27.2

Internet Computer query library for 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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111

use super::{fixtures::*, *};

#[test]
fn list_report_loads_cached_catalog_and_caps_ranges() {
    let root = temp_dir("ic-query-subnet-list");
    write_catalog(&root, fixture_catalog());
    let request = list_request(&root);

    let report = build_subnet_catalog_list_report(&request).expect("list report");
    let text = subnet_catalog_list_report_text(&report);

    let _ = fs::remove_dir_all(root);
    assert_eq!(report.subnets.len(), 2);
    assert_eq!(report.subnets[0].range_count, 2);
    assert_eq!(report.subnets[0].ranges_shown, 1);
    assert!(text.contains("SUBNET"));
    assert!(text.contains("SPEC"));
    assert!(!text.contains("SPECIALIZATION"));
    for subnet in &report.subnets {
        let compact_principal = subnet.subnet_principal.chars().take(5).collect::<String>();
        assert!(text.contains(&compact_principal));
        assert!(!text.contains(&subnet.subnet_principal));
    }
    assert!(!text.contains("FETCHED_AT"));
    assert!(text.contains("showing 1 of 2 ranges"));
}

#[test]
fn list_report_refreshes_missing_catalog() {
    let root = temp_dir("ic-query-subnet-list-refresh");
    let mut catalog = fixture_catalog();
    catalog.registry_version = 987_654;
    let source = FixtureRefreshSource::ok(catalog);
    let request = list_request(&root);

    let report =
        build_subnet_catalog_list_report_with_source(&request, &source).expect("list report");
    let cached = load_cached_subnet_catalog(&cache_request(&root)).expect("cached catalog");

    let _ = fs::remove_dir_all(root);
    assert_eq!(report.registry_version, 987_654);
    assert_eq!(cached.catalog.registry_version, 987_654);
}

#[test]
fn list_report_refreshes_invalid_catalog_but_cache_only_remains_strict() {
    let root = temp_dir("ic-query-subnet-list-invalid-refresh");
    let path = subnet_catalog_path(&root, MAINNET_NETWORK);
    fs::create_dir_all(path.parent().expect("catalog parent")).expect("create parent");
    fs::write(&path, "not-json").expect("write invalid catalog");
    let request = list_request(&root);

    let error = load_cached_subnet_catalog(&request.cache).expect_err("cache-only load is strict");
    assert!(matches!(
        error,
        SubnetCatalogHostError::Catalog(CatalogError::Json(_))
    ));

    let mut catalog = fixture_catalog();
    catalog.registry_version = 987_654;
    let report =
        build_subnet_catalog_list_report_with_source(&request, &FixtureRefreshSource::ok(catalog))
            .expect("invalid catalog refreshes");

    assert_eq!(report.registry_version, 987_654);
    assert_ne!(
        fs::read_to_string(path).expect("refreshed catalog"),
        "not-json"
    );
    let _ = fs::remove_dir_all(root);
}

#[test]
fn failed_invalid_catalog_refresh_preserves_original_file() {
    let root = temp_dir("ic-query-subnet-list-invalid-refresh-failure");
    let path = subnet_catalog_path(&root, MAINNET_NETWORK);
    fs::create_dir_all(path.parent().expect("catalog parent")).expect("create parent");
    fs::write(&path, "not-json").expect("write invalid catalog");

    let error = build_subnet_catalog_list_report_with_source(
        &list_request(&root),
        &FixtureRefreshSource::err(),
    )
    .expect_err("failed refresh remains visible");

    assert!(matches!(
        error,
        SubnetCatalogHostError::Catalog(CatalogError::EmptySubnets)
    ));
    assert_eq!(
        fs::read_to_string(path).expect("preserved invalid catalog"),
        "not-json"
    );
    let _ = fs::remove_dir_all(root);
}

#[test]
fn list_report_verbose_text_keeps_full_metadata() {
    let root = temp_dir("ic-query-subnet-list-verbose");
    write_catalog(&root, fixture_catalog());
    let request = list_request(&root);

    let report = build_subnet_catalog_list_report(&request).expect("list report");
    let text = subnet_catalog_list_report_verbose_text(&report);

    let _ = fs::remove_dir_all(root);
    assert!(text.contains("catalog_path:"));
    assert!(text.contains("SPECIALIZATION"));
    assert!(text.contains("FETCHED_AT"));
    assert!(text.contains(SUBNET_A));
}