ic-query 0.29.3

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

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

#[cfg(feature = "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> {
    if let Some(counter) = counter {
        counter.record_call();
    }
    let bytes = agent
        .query(registry_canister, "get_latest_version")
        .with_arg(Vec::<u8>::new())
        .call()
        .await
        .map_err(|err| RegistryFetchError::AgentCall {
            method: "get_latest_version",
            reason: err.to_string(),
        })?;
    let response = decode_message::<RegistryGetLatestVersionResponse>(
        "RegistryGetLatestVersionResponse",
        &bytes,
    )?;
    Ok(response.version)
}