ic-query 0.50.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

use super::{RegistryQueryCounter, decode_message};
use crate::ic_registry::{RegistryFetchError, proto::RegistryGetLatestVersionResponse};
use candid::Principal;
use ic_agent::Agent;

#[cfg(feature = "nns-topology-host")]
pub(in crate::ic_registry) async fn get_latest_version(
    agent: &Agent,
    registry_canister: &Principal,
) -> Result<u64, RegistryFetchError> {
    get_latest_version_inner(agent, registry_canister, None).await
}

pub(in crate::ic_registry) async fn get_latest_version_counted(
    agent: &Agent,
    registry_canister: &Principal,
    counter: &RegistryQueryCounter,
) -> Result<u64, RegistryFetchError> {
    get_latest_version_inner(agent, registry_canister, Some(counter)).await
}

async fn get_latest_version_inner(
    agent: &Agent,
    registry_canister: &Principal,
    counter: Option<&RegistryQueryCounter>,
) -> Result<u64, RegistryFetchError> {
    let bytes = super::query::query(
        agent,
        registry_canister,
        "get_latest_version",
        Vec::new(),
        counter,
    )
    .await
    .map_err(|err| RegistryFetchError::AgentCall {
        method: "get_latest_version",
        reason: err.to_string(),
    })?;
    let response = decode_message::<RegistryGetLatestVersionResponse>(
        "RegistryGetLatestVersionResponse",
        &bytes,
    )?;
    Ok(response.version)
}