ibc-test-framework 0.32.2

Framework for writing integration tests for IBC relayers 
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

use eyre::eyre;

use crate::chain::exec::simple_exec;
use crate::error::{handle_generic_error, Error};

pub fn query_wasm_list_code(
    chain_id: &str,
    command_path: &str,
    home_path: &str,
    rpc_listen_address: &str,
) -> Result<String, Error> {
    let exec_output = simple_exec(
        chain_id,
        command_path,
        &[
            "--home",
            home_path,
            "--chain-id",
            chain_id,
            "--node",
            rpc_listen_address,
            "query",
            "wasm",
            "list-codes",
            "--output",
            "json",
        ],
    )?;

    let json_output: serde_json::Value =
        serde_json::from_str(&exec_output.stdout).map_err(handle_generic_error)?;

    let code_id = json_output
        .get("code_infos")
        .and_then(|code_infos| code_infos.as_array())
        .and_then(|code_infos| code_infos.first())
        .and_then(|code_info| code_info.get("code_id"))
        .and_then(|code_infos| code_infos.as_str())
        .ok_or_else(|| eyre!("Failed to retrieve wasm code ID"))?;

    Ok(code_id.to_string())
}

pub fn query_wasm_list_contracts_by_code(
    chain_id: &str,
    command_path: &str,
    home_path: &str,
    rpc_listen_address: &str,
    code_id: &str,
) -> Result<String, Error> {
    let exec_output = simple_exec(
        chain_id,
        command_path,
        &[
            "--home",
            home_path,
            "--chain-id",
            chain_id,
            "--node",
            rpc_listen_address,
            "query",
            "wasm",
            "list-contract-by-code",
            code_id,
            "--output",
            "json",
        ],
    )?;

    let json_output: serde_json::Value =
        serde_json::from_str(&exec_output.stdout).map_err(handle_generic_error)?;

    let contrat = json_output
        .get("contracts")
        .and_then(|contracts| contracts.as_array())
        .and_then(|contracts| contracts.first())
        .and_then(|contract| contract.as_str())
        .ok_or_else(|| eyre!("Failed to retrieve wasm contract address"))?;

    Ok(contrat.to_string())
}