multiversx-sc-snippets 0.65.1

MultiversX framework for building smart contract interaction snippets
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

#![allow(deprecated)]

use std::process;

use super::error_message::query_err_message;
use crate::InteractorBase;
use multiversx_sc_scenario::{
    imports::ReturnCode,
    mandos_system::ScenarioRunner,
    scenario_model::{ScQueryStep, TxResponse, TxResponseStatus},
};
use multiversx_sdk::data::vm::VMQueryInput;
use multiversx_sdk::gateway::{GatewayAsyncService, VMQueryRequest};

impl<GatewayProxy> InteractorBase<GatewayProxy>
where
    GatewayProxy: GatewayAsyncService,
{
    pub async fn perform_sc_query(&mut self, step: &mut ScQueryStep) {
        let hrp = self.network_config.address_hrp.clone();

        let sc_address = step.tx.to.to_address().to_bech32(&hrp);
        let req = VMQueryInput {
            sc_address,
            func_name: step.tx.function.clone(),
            args: step
                .tx
                .arguments
                .iter()
                .map(|arg| hex::encode(&arg.value))
                .collect(),
        };
        let result = match self.proxy.request(VMQueryRequest(&req)).await {
            Ok(r) => r,
            Err(err) => {
                query_err_message(&err);
                process::exit(1);
            }
        };

        if result.data.is_ok() {
            let raw_results = result.data.return_data_base64_decode();
            step.save_response(TxResponse::from_raw_results(raw_results));
        } else {
            log::error!(
                "VM query error, code: {}, message: {}",
                result.data.return_code,
                result.data.return_message
            );
            step.save_response(TxResponse {
                tx_error: TxResponseStatus {
                    status: ReturnCode::VMQueryError,
                    message: result.data.return_message.clone(),
                },
                ..Default::default()
            })
        }

        self.pre_runners.run_sc_query_step(step);
        self.post_runners.run_sc_query_step(step);
    }
}