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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134

use std::process;

use super::error_message::{sc_call_err_message, simulate_gas_sc_call_err_message};
use crate::{InteractorBase, SimulateGas, network_response};
use multiversx_sc_scenario::{
    imports::Bech32Address,
    scenario::ScenarioRunner,
    scenario_model::{ScCallStep, SetStateStep, TxCall},
};
use multiversx_sdk::{
    data::transaction::Transaction, gateway::SimulateTxRequest, utils::base64_encode,
};
use multiversx_sdk::{
    gateway::{GatewayAsyncService, SendTxRequest},
    retrieve_tx_on_network,
};

impl<GatewayProxy> InteractorBase<GatewayProxy>
where
    GatewayProxy: GatewayAsyncService,
{
    pub async fn sc_call(&mut self, sc_call_step: &mut ScCallStep) {
        let mut transaction = self.tx_call_to_blockchain_signed_tx(sc_call_step).await;

        if SimulateGas::is_mandos_simulate_gas_marker(&sc_call_step.tx.gas_limit) {
            let sim_gas = self.sc_call_simulate_transaction(&transaction).await;
            let gas = SimulateGas::adjust_simulated_gas(sim_gas);
            sc_call_step.tx.gas_limit = gas.into();
            transaction.gas_limit = gas;

            // sign again, because gas changed
            let sender_address = &sc_call_step.tx.from.value;
            self.sign_tx(sender_address, &mut transaction);
        }

        self.pre_runners.run_sc_call_step(sc_call_step);

        let tx_hash = self.launch_sc_call(&transaction).await;

        self.generate_blocks_until_tx_processed(&tx_hash)
            .await
            .unwrap();
        let (tx, return_code) = retrieve_tx_on_network(&self.proxy, tx_hash).await;

        sc_call_step.save_response(network_response::parse_tx_response(tx, return_code));

        if let Some(token_identifier) = sc_call_step.response().new_issued_token_identifier.clone()
        {
            println!("token identifier: {}", token_identifier);
            let set_state_step = SetStateStep::new().new_token_identifier(token_identifier);

            self.pre_runners.run_set_state_step(&set_state_step);
            self.post_runners.run_set_state_step(&set_state_step);
        }

        self.post_runners.run_sc_call_step(sc_call_step);
    }

    pub async fn sc_call_simulate(&mut self, sc_call_step: &ScCallStep) -> u64 {
        let transaction = self.tx_call_to_blockchain_signed_tx(sc_call_step).await;
        self.sc_call_simulate_transaction(&transaction).await
    }

    async fn tx_call_to_blockchain_signed_tx(&mut self, sc_call_step: &ScCallStep) -> Transaction {
        let sender_address = &sc_call_step.tx.from.value;
        let mut transaction = self.tx_call_to_blockchain_tx(&sc_call_step.tx);
        self.set_tx_nonce_update_sender(sender_address, &mut transaction)
            .await;
        self.sign_tx(sender_address, &mut transaction);

        transaction
    }

    async fn launch_sc_call(&mut self, transaction: &Transaction) -> String {
        let tx_hash = self.proxy.request(SendTxRequest(transaction)).await;

        match tx_hash {
            Ok(tx_hash) => {
                println!("sc call tx hash: {tx_hash}");
                log::info!("sc call tx hash: {tx_hash}");
                tx_hash
            }
            Err(err) => {
                println!("sc call error: {err}");
                log::error!("sc call error: {err}");
                sc_call_err_message(&err);
                process::exit(1)
            }
        }
    }

    async fn sc_call_simulate_transaction(&mut self, transaction: &Transaction) -> u64 {
        let result = self.proxy.request(SimulateTxRequest(transaction)).await;

        match result {
            Ok(gas) => {
                println!("Gas simulation for the SC call: {gas} units.");
                log::info!("Gas simulation for the SC call: {gas} units.");
                gas
            }
            Err(err) => {
                println!("Gas simulation error: {err}");
                log::error!("Gas simulation error: {err}");
                simulate_gas_sc_call_err_message(&err);
                process::exit(1)
            }
        }
    }

    pub(crate) fn tx_call_to_blockchain_tx(&self, tx_call: &TxCall) -> Transaction {
        let hrp = self.get_hrp();
        let normalized = tx_call.normalize();
        let contract_call_tx_data = normalized.compute_data_field();
        let data = if contract_call_tx_data.is_empty() {
            None
        } else {
            Some(String::from_utf8(base64_encode(contract_call_tx_data).into()).unwrap())
        };

        Transaction {
            nonce: 0,
            value: normalized.egld_value.value.to_string(),
            sender: Bech32Address::encode_address(hrp, normalized.from.to_address()),
            receiver: Bech32Address::encode_address(hrp, normalized.to.to_address()),
            gas_price: self.network_config.min_gas_price,
            gas_limit: normalized.gas_limit.value,
            data,
            signature: None,
            chain_id: self.network_config.chain_id.clone(),
            version: self.network_config.min_transaction_version,
            options: 0,
        }
    }
}