ic-query 0.6.4

Internet Computer query library for NNS, SNS, ICRC, and related 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

use super::{
    cache::{
        data_center_cache_request, node_cache_request, node_operator_cache_request,
        node_provider_cache_request, subnet_catalog_cache_request,
    },
    model::TopologyRefreshParts,
};
use crate::{
    nns::data_center::report::NnsDataCenterRefreshRequest,
    nns::node::report::NnsNodeRefreshRequest,
    nns::node_operator::report::NnsNodeOperatorRefreshRequest,
    nns::node_provider::report::NnsNodeProviderRefreshRequest,
    subnet_catalog::SubnetCatalogRefreshRequest,
};

pub(in crate::nns::topology::report) fn subnet_catalog_refresh_request(
    request: &impl TopologyRefreshParts,
) -> SubnetCatalogRefreshRequest {
    SubnetCatalogRefreshRequest::new(
        subnet_catalog_cache_request(request),
        request.source_endpoint(),
        request.now_unix_secs(),
        request.lock_stale_after_seconds(),
    )
    .with_dry_run(request.dry_run())
}

pub(in crate::nns::topology::report) fn node_refresh_request(
    request: &impl TopologyRefreshParts,
) -> NnsNodeRefreshRequest {
    NnsNodeRefreshRequest::new(
        node_cache_request(request),
        request.source_endpoint(),
        request.now_unix_secs(),
        request.lock_stale_after_seconds(),
    )
    .with_dry_run(request.dry_run())
}

macro_rules! component_refresh_request {
    ($name:ident, $request:path, $cache_request:ident) => {
        pub(in crate::nns::topology::report) fn $name(
            request: &impl TopologyRefreshParts,
        ) -> $request {
            <$request>::new(
                $cache_request(request),
                request.source_endpoint(),
                request.now_unix_secs(),
                request.lock_stale_after_seconds(),
            )
            .with_dry_run(request.dry_run())
        }
    };
}

component_refresh_request!(
    node_provider_refresh_request,
    NnsNodeProviderRefreshRequest,
    node_provider_cache_request
);
component_refresh_request!(
    node_operator_refresh_request,
    NnsNodeOperatorRefreshRequest,
    node_operator_cache_request
);
component_refresh_request!(
    data_center_refresh_request,
    NnsDataCenterRefreshRequest,
    data_center_cache_request
);