::new().render();
+}
diff --git a/contracts/examples/ping-pong-egld/dapp/src/pages/home.rs b/contracts/examples/ping-pong-egld/dapp/src/pages/home.rs
new file mode 100644
index 0000000000..bc9cf26f40
--- /dev/null
+++ b/contracts/examples/ping-pong-egld/dapp/src/pages/home.rs
@@ -0,0 +1,115 @@
+use crate::{
+ components::{Button, NetworkStatusComponent},
+ requests::transaction,
+};
+use yew::prelude::*;
+
+#[function_component(HomePage)]
+pub fn home_page() -> Html {
+ let show_status = use_state(|| false);
+ let ping_result = use_state(String::new);
+ let new_sc_address = use_state(String::new);
+
+ let show_network_status = {
+ let show_status = show_status.clone();
+
+ Callback::from(move |_| {
+ show_status.set(true);
+ })
+ };
+
+ let deploy_sc = {
+ let new_sc_address = new_sc_address.clone();
+
+ Callback::from(move |_| {
+ let new_sc_address = new_sc_address.clone();
+
+ log::info!("SC setup request triggered");
+
+ wasm_bindgen_futures::spawn_local(async move {
+ match transaction::deploy_sc().await {
+ Ok(result) => {
+ new_sc_address.set(format!(
+ "New deployed address: {}",
+ result.to_bech32_string()
+ ));
+ },
+ Err(err) => {
+ log::error!("SC Setup failed: {:?}", err);
+ new_sc_address.set("SC Setup failed!".to_string());
+ },
+ }
+ });
+ })
+ };
+
+ let ping = {
+ let ping_result = ping_result.clone();
+
+ Callback::from(move |_| {
+ let ping_result = ping_result.clone();
+
+ log::info!("Ping request triggered");
+
+ wasm_bindgen_futures::spawn_local(async move {
+ match transaction::ping().await {
+ Ok(result) => {
+ ping_result.set(result);
+ },
+ Err(err) => {
+ log::error!("Ping failed: {:?}", err);
+ ping_result.set("Ping failed!".to_string());
+ },
+ }
+ });
+ })
+ };
+
+ html! {
+ <>
+
+
+
+
+
+ {
+ if *show_status {
+ html! {
+
+ }
+ }
+ else {
+ html! {}
+ }
+ }
+ {
+ if !new_sc_address.is_empty() {
+ html! {
+
+ {
+ (*new_sc_address).clone()
+ }
+
+ }
+ }
+ else {
+ html! {}
+ }
+ }
+ {
+ if !ping_result.is_empty() {
+ html! {
+
+ {
+ (*ping_result).clone()
+ }
+
+ }
+ }
+ else {
+ html! {}
+ }
+ }
+
+ }
+}
diff --git a/contracts/examples/ping-pong-egld/dapp/src/pages/mod.rs b/contracts/examples/ping-pong-egld/dapp/src/pages/mod.rs
new file mode 100644
index 0000000000..0193241d0e
--- /dev/null
+++ b/contracts/examples/ping-pong-egld/dapp/src/pages/mod.rs
@@ -0,0 +1,3 @@
+pub mod home;
+
+pub use home::*;
diff --git a/contracts/examples/ping-pong-egld/dapp/src/requests/mod.rs b/contracts/examples/ping-pong-egld/dapp/src/requests/mod.rs
new file mode 100644
index 0000000000..27f8d7c408
--- /dev/null
+++ b/contracts/examples/ping-pong-egld/dapp/src/requests/mod.rs
@@ -0,0 +1,3 @@
+mod proxy;
+pub mod query;
+pub mod transaction;
diff --git a/contracts/examples/ping-pong-egld/dapp/src/requests/proxy.rs b/contracts/examples/ping-pong-egld/dapp/src/requests/proxy.rs
new file mode 100644
index 0000000000..e5cdd4d4e0
--- /dev/null
+++ b/contracts/examples/ping-pong-egld/dapp/src/requests/proxy.rs
@@ -0,0 +1,264 @@
+// Code generated by the multiversx-sc proxy generator. DO NOT EDIT.
+
+////////////////////////////////////////////////////
+////////////////// AUTO-GENERATED //////////////////
+////////////////////////////////////////////////////
+
+#![allow(dead_code)]
+#![allow(clippy::all)]
+
+use multiversx_sc::proxy_imports::*;
+use multiversx_sc_snippets_dapp::multiversx_sc;
+
+pub struct PingPongProxy;
+
+impl TxProxyTrait for PingPongProxy
+where
+ Env: TxEnv,
+ From: TxFrom,
+ To: TxTo,
+ Gas: TxGas,
+{
+ type TxProxyMethods = PingPongProxyMethods;
+
+ fn proxy_methods(self, tx: Tx) -> Self::TxProxyMethods {
+ PingPongProxyMethods { wrapped_tx: tx }
+ }
+}
+
+pub struct PingPongProxyMethods
+where
+ Env: TxEnv,
+ From: TxFrom,
+ To: TxTo,
+ Gas: TxGas,
+{
+ wrapped_tx: Tx,
+}
+
+#[rustfmt::skip]
+impl PingPongProxyMethods
+where
+ Env: TxEnv,
+ Env::Api: VMApi,
+ From: TxFrom,
+ Gas: TxGas,
+{
+ /// Necessary configuration when deploying:
+ /// `ping_amount` - the exact EGLD amount that needs to be sent when `ping`-ing.
+ /// `duration_in_seconds` - how much time (in seconds) until contract expires.
+ /// `opt_activation_timestamp` - optionally specify the contract to only actvivate at a later date.
+ /// `max_funds` - optional funding cap, no more funds than this can be added to the contract.
+ pub fn init<
+ Arg0: ProxyArg>,
+ Arg1: ProxyArg,
+ Arg2: ProxyArg>,
+ Arg3: ProxyArg>>,
+ >(
+ self,
+ ping_amount: Arg0,
+ duration_in_seconds: Arg1,
+ opt_activation_timestamp: Arg2,
+ max_funds: Arg3,
+ ) -> TxTypedDeploy {
+ self.wrapped_tx
+ .payment(NotPayable)
+ .raw_deploy()
+ .argument(&ping_amount)
+ .argument(&duration_in_seconds)
+ .argument(&opt_activation_timestamp)
+ .argument(&max_funds)
+ .original_result()
+ }
+}
+
+#[rustfmt::skip]
+impl PingPongProxyMethods
+where
+ Env: TxEnv,
+ Env::Api: VMApi,
+ From: TxFrom,
+ To: TxTo,
+ Gas: TxGas,
+{
+ pub fn upgrade<
+ Arg0: ProxyArg>,
+ Arg1: ProxyArg,
+ Arg2: ProxyArg>,
+ Arg3: ProxyArg>>,
+ >(
+ self,
+ ping_amount: Arg0,
+ duration_in_seconds: Arg1,
+ opt_activation_timestamp: Arg2,
+ max_funds: Arg3,
+ ) -> TxTypedUpgrade {
+ self.wrapped_tx
+ .payment(NotPayable)
+ .raw_upgrade()
+ .argument(&ping_amount)
+ .argument(&duration_in_seconds)
+ .argument(&opt_activation_timestamp)
+ .argument(&max_funds)
+ .original_result()
+ }
+}
+
+#[rustfmt::skip]
+impl PingPongProxyMethods
+where
+ Env: TxEnv,
+ Env::Api: VMApi,
+ From: TxFrom,
+ To: TxTo,
+ Gas: TxGas,
+{
+ /// User sends some EGLD to be locked in the contract for a period of time.
+ /// Optional `_data` argument is ignored.
+ pub fn ping<
+ Arg0: ProxyArg,
+ >(
+ self,
+ _data: Arg0,
+ ) -> TxTypedCall {
+ self.wrapped_tx
+ .raw_call("ping")
+ .argument(&_data)
+ .original_result()
+ }
+
+ /// User can take back funds from the contract.
+ /// Can only be called after expiration.
+ pub fn pong(
+ self,
+ ) -> TxTypedCall {
+ self.wrapped_tx
+ .payment(NotPayable)
+ .raw_call("pong")
+ .original_result()
+ }
+
+ /// Send back funds to all users who pinged.
+ /// Returns
+ /// - `completed` if everything finished
+ /// - `interrupted` if run out of gas midway.
+ /// Can only be called after expiration.
+ pub fn pong_all(
+ self,
+ ) -> TxTypedCall {
+ self.wrapped_tx
+ .payment(NotPayable)
+ .raw_call("pongAll")
+ .original_result()
+ }
+
+ /// Lists the addresses of all users that have `ping`-ed,
+ /// in the order they have `ping`-ed
+ pub fn get_user_addresses(
+ self,
+ ) -> TxTypedCall>> {
+ self.wrapped_tx
+ .payment(NotPayable)
+ .raw_call("getUserAddresses")
+ .original_result()
+ }
+
+ /// Returns the current contract state as a struct
+ /// for faster fetching from external parties
+ pub fn get_contract_state(
+ self,
+ ) -> TxTypedCall> {
+ self.wrapped_tx
+ .payment(NotPayable)
+ .raw_call("getContractState")
+ .original_result()
+ }
+
+ pub fn ping_amount(
+ self,
+ ) -> TxTypedCall> {
+ self.wrapped_tx
+ .payment(NotPayable)
+ .raw_call("getPingAmount")
+ .original_result()
+ }
+
+ pub fn deadline(
+ self,
+ ) -> TxTypedCall {
+ self.wrapped_tx
+ .payment(NotPayable)
+ .raw_call("getDeadline")
+ .original_result()
+ }
+
+ /// Block timestamp of the block where the contract got activated.
+ /// If not specified in the constructor it is the the deploy block timestamp.
+ pub fn activation_timestamp(
+ self,
+ ) -> TxTypedCall {
+ self.wrapped_tx
+ .payment(NotPayable)
+ .raw_call("getActivationTimestamp")
+ .original_result()
+ }
+
+ /// Optional funding cap.
+ pub fn max_funds(
+ self,
+ ) -> TxTypedCall>> {
+ self.wrapped_tx
+ .payment(NotPayable)
+ .raw_call("getMaxFunds")
+ .original_result()
+ }
+
+ /// State of user funds.
+ /// 0 - user unknown, never `ping`-ed
+ /// 1 - `ping`-ed
+ /// 2 - `pong`-ed
+ pub fn user_status<
+ Arg0: ProxyArg,
+ >(
+ self,
+ user_id: Arg0,
+ ) -> TxTypedCall {
+ self.wrapped_tx
+ .payment(NotPayable)
+ .raw_call("getUserStatus")
+ .argument(&user_id)
+ .original_result()
+ }
+
+ /// Part of the `pongAll` status, the last user to be processed.
+ /// 0 if never called `pongAll` or `pongAll` completed..
+ pub fn pong_all_last_user(
+ self,
+ ) -> TxTypedCall {
+ self.wrapped_tx
+ .payment(NotPayable)
+ .raw_call("pongAllLastUser")
+ .original_result()
+ }
+}
+
+#[type_abi]
+#[derive(TopEncode, TopDecode, Default)]
+pub struct ContractState
+where
+ Api: ManagedTypeApi,
+{
+ pub ping_amount: BigUint,
+ pub deadline: u64,
+ pub activation_timestamp: u64,
+ pub max_funds: Option>,
+ pub pong_all_last_user: usize,
+}
+
+#[type_abi]
+#[derive(TopEncode, TopDecode, PartialEq, Eq, Clone, Copy)]
+pub enum UserStatus {
+ New,
+ Registered,
+ Withdrawn,
+}
diff --git a/contracts/examples/ping-pong-egld/dapp/src/requests/query.rs b/contracts/examples/ping-pong-egld/dapp/src/requests/query.rs
new file mode 100644
index 0000000000..0c9b5d069c
--- /dev/null
+++ b/contracts/examples/ping-pong-egld/dapp/src/requests/query.rs
@@ -0,0 +1,18 @@
+use crate::interactor::ContractInteract;
+use multiversx_sc_snippets_dapp::sdk::data::network_status::NetworkStatus;
+
+pub async fn get_network_status() -> Result {
+ let contract_interact = ContractInteract::new().await;
+ let shard = 1u8;
+
+ let response = contract_interact
+ .interactor
+ .proxy
+ .get_network_status(shard)
+ .await;
+
+ match response {
+ Ok(value) => Ok(value),
+ Err(err) => Err(err.to_string()),
+ }
+}
diff --git a/contracts/examples/ping-pong-egld/dapp/src/requests/transaction.rs b/contracts/examples/ping-pong-egld/dapp/src/requests/transaction.rs
new file mode 100644
index 0000000000..1fd3753cf6
--- /dev/null
+++ b/contracts/examples/ping-pong-egld/dapp/src/requests/transaction.rs
@@ -0,0 +1,68 @@
+use crate::interactor::ContractInteract;
+use multiversx_sc_snippets_dapp::{
+ imports::{
+ Bech32Address, BigUint, IgnoreValue, OptionalValue, ReturnsMessage,
+ ReturnsNewBech32Address, ReturnsStatus,
+ },
+ InteractorPrepareAsync,
+};
+
+use super::proxy;
+
+pub async fn deploy_sc() -> Result {
+ let mut contract_interact = ContractInteract::new().await;
+ let ping_amount = 1u64;
+ let duration_in_seconds = 5u64;
+ let opt_activation_timestamp = 2u64;
+ let max_funds = 100_000u64;
+
+ let (new_address, status, message) = contract_interact
+ .interactor
+ .tx()
+ .from(&contract_interact.wallet_address)
+ .gas(30_000_000u64)
+ .typed(proxy::PingPongProxy)
+ .init(
+ BigUint::from(ping_amount),
+ duration_in_seconds,
+ Option::Some(opt_activation_timestamp),
+ OptionalValue::Some(BigUint::from(max_funds)),
+ )
+ .code(&contract_interact.contract_code)
+ .returns(ReturnsNewBech32Address)
+ .returns(ReturnsStatus)
+ .returns(ReturnsMessage)
+ .prepare_async()
+ .run()
+ .await;
+
+ match status {
+ 0u64 => Ok(new_address),
+ _ => Err(message),
+ }
+}
+
+pub async fn ping() -> Result {
+ let mut contract_interact = ContractInteract::new().await;
+
+ let amount = 1u64;
+
+ let wallet_address = contract_interact.wallet_address.clone();
+ let current_address = contract_interact.config.current_address().clone();
+ let _data = IgnoreValue;
+
+ contract_interact
+ .interactor
+ .tx()
+ .from(wallet_address)
+ .to(Bech32Address::from_bech32_string(current_address))
+ .gas(30_000_000u64)
+ .typed(proxy::PingPongProxy)
+ .ping(_data)
+ .egld(BigUint::from(amount))
+ .prepare_async()
+ .run()
+ .await;
+
+ Ok("Ping successful!".to_string())
+}
diff --git a/contracts/examples/ping-pong-egld/dapp/src/routes.rs b/contracts/examples/ping-pong-egld/dapp/src/routes.rs
new file mode 100644
index 0000000000..3eecf5d5dc
--- /dev/null
+++ b/contracts/examples/ping-pong-egld/dapp/src/routes.rs
@@ -0,0 +1,16 @@
+use yew::prelude::*;
+use yew_router::prelude::*;
+
+use crate::pages::HomePage;
+
+#[derive(Clone, Routable, PartialEq)]
+pub enum Route {
+ #[at("/")]
+ Home,
+}
+
+pub fn switch(route: Route) -> Html {
+ match route {
+ Route::Home => html! { },
+ }
+}
diff --git a/contracts/examples/ping-pong-egld/dapp/src/styles.css b/contracts/examples/ping-pong-egld/dapp/src/styles.css
new file mode 100644
index 0000000000..e72fafe0e0
--- /dev/null
+++ b/contracts/examples/ping-pong-egld/dapp/src/styles.css
@@ -0,0 +1,29 @@
+* {
+ font-family: monospace;
+}
+
+.footer {
+ background-color: #333;
+ color: white;
+ text-align: center;
+ padding: 20px 0;
+ position: fixed;
+ bottom: 0;
+ left: 0;
+ width: 100%;
+ font-size: 14px;
+}
+
+.network-status-container {
+ font-size: 14px;
+}
+
+.btns {
+ display: flex;
+ flex-direction: row;
+ padding: 20px 0;
+ text-align: center;
+ align-items: center;
+ justify-content: center;
+ gap: 5px;
+}
\ No newline at end of file
diff --git a/contracts/examples/ping-pong-egld/dapp/trunk.toml b/contracts/examples/ping-pong-egld/dapp/trunk.toml
new file mode 100644
index 0000000000..4104a6c09b
--- /dev/null
+++ b/contracts/examples/ping-pong-egld/dapp/trunk.toml
@@ -0,0 +1,7 @@
+[serve]
+# The address to serve on LAN.
+address = "127.0.0.1"
+# The address to serve on WAN.
+# address = "0.0.0.0"
+# The port to serve on.
+port = 8006
diff --git a/contracts/feature-tests/basic-features/interact/Cargo.toml b/contracts/feature-tests/basic-features/interact/Cargo.toml
index 69597ba7e3..735d08b890 100644
--- a/contracts/feature-tests/basic-features/interact/Cargo.toml
+++ b/contracts/feature-tests/basic-features/interact/Cargo.toml
@@ -12,6 +12,7 @@ path = "src/bf_interact.rs"
[dependencies]
clap = { version = "4.4.7", features = ["derive"] }
serde = { version = "1.0", features = ["derive"] }
+tokio = { version = "1.24" }
toml = "0.8.6"
[dependencies.basic-features]
diff --git a/contracts/feature-tests/composability/interact/Cargo.toml b/contracts/feature-tests/composability/interact/Cargo.toml
index e06ae3c915..b6c02ee16b 100644
--- a/contracts/feature-tests/composability/interact/Cargo.toml
+++ b/contracts/feature-tests/composability/interact/Cargo.toml
@@ -12,6 +12,7 @@ path = "src/comp_interact_main.rs"
[dependencies]
clap = { version = "4.4.7", features = ["derive"] }
serde = { version = "1.0", features = ["derive"] }
+tokio = { version = "1.24" }
toml = "0.8.6"
[dependencies.multiversx-sc]
diff --git a/framework/snippets-dapp/Cargo.toml b/framework/snippets-dapp/Cargo.toml
new file mode 100644
index 0000000000..21ebfaefc4
--- /dev/null
+++ b/framework/snippets-dapp/Cargo.toml
@@ -0,0 +1,39 @@
+[package]
+name = "multiversx-sc-snippets-dapp"
+version = "0.53.0"
+edition = "2021"
+
+authors = ["MultiversX "]
+license = "GPL-3.0-only"
+readme = "README.md"
+repository = "https://github.com/multiversx/mx-sdk-rs"
+homepage = "https://multiversx.com/"
+documentation = "https://docs.multiversx.com/"
+description = "MultiversX framework for building smart contract interaction snippets"
+keywords = ["multiversx", "blockchain", "contract", "snippets"]
+categories = ["cryptography::cryptocurrencies"]
+
+[dependencies]
+web-sys = { version = "0.3.70" }
+js-sys = { version = "0.3.70" }
+wasm-bindgen-futures = { version = "0.4.43" }
+hex = "0.4"
+base64 = "0.22"
+log = "0.4.17"
+env_logger = "0.11"
+futures = "0.3"
+
+[dependencies.multiversx-sc-scenario]
+version = "=0.53.0"
+path = "../scenario"
+
+[dependencies.multiversx-chain-scenario-format]
+version = "0.23.0"
+path = "../../sdk/scenario-format"
+
+[dependencies.multiversx-sdk-wbg]
+version = "=0.6.0"
+path = "../../sdk/wbg"
+
+[dev-dependencies]
+serde_json = "1.0"
diff --git a/framework/snippets-dapp/README.md b/framework/snippets-dapp/README.md
new file mode 100644
index 0000000000..62a184e28c
--- /dev/null
+++ b/framework/snippets-dapp/README.md
@@ -0,0 +1,7 @@
+# MultiversX transaction snippets
+
+Provides basic functionality for interacting with smart contracts directly from Rust.
+
+It a base on top of which little interaction programs (or snippets) can be written.
+
+It is largely a wrapper around `elrond-sdk-erdrs` and `multiversx-chain-vm`.
diff --git a/framework/snippets-dapp/src/account_tool.rs b/framework/snippets-dapp/src/account_tool.rs
new file mode 100644
index 0000000000..fad13ab314
--- /dev/null
+++ b/framework/snippets-dapp/src/account_tool.rs
@@ -0,0 +1,102 @@
+use multiversx_chain_scenario_format::interpret_trait::IntoRaw;
+use multiversx_sc_scenario::{
+ imports::Bech32Address,
+ scenario_model::{Account, BytesKey, BytesValue, Scenario, SetStateStep, Step},
+};
+use multiversx_sdk_wbg::{
+ data::{address::Address, esdt::EsdtBalance},
+ gateway::GatewayProxy,
+};
+use std::collections::{BTreeMap, HashMap};
+
+/// Called directly from CLI, from `sc-meta`.
+///
+/// Retrieves an account data via the API,
+/// then formats it as a scenario set state step.
+pub async fn print_account_as_scenario_set_state(
+ api_string: String,
+ address_bech32_string: String,
+) {
+ let api = GatewayProxy::new(api_string);
+ let address = Bech32Address::from_bech32_string(address_bech32_string);
+ let set_state = retrieve_account_as_scenario_set_state(&api, &address).await;
+ let scenario = build_scenario(set_state);
+ println!("{}", scenario.into_raw().to_json_string());
+}
+
+fn build_scenario(set_state: SetStateStep) -> Scenario {
+ Scenario {
+ name: None,
+ comment: None,
+ check_gas: None,
+ steps: vec![Step::SetState(set_state)],
+ }
+}
+
+pub async fn retrieve_account_as_scenario_set_state(
+ api: &GatewayProxy,
+ address: &Bech32Address,
+) -> SetStateStep {
+ let sdk_address = Address::from_bech32_string(address.to_bech32_str()).unwrap();
+ let sdk_account = api.get_account(&sdk_address).await.unwrap();
+
+ let account_esdt = api
+ .get_account_esdt_tokens(&sdk_address)
+ .await
+ .unwrap_or_else(|err| {
+ panic!("failed to retrieve ESDT tokens for address {address}: {err}")
+ });
+ let account_esdt_roles = api
+ .get_account_esdt_roles(&sdk_address)
+ .await
+ .unwrap_or_else(|err| panic!("failed to retrieve ESDT roles for address {address}: {err}"));
+ let account_storage = api
+ .get_account_storage_keys(&sdk_address)
+ .await
+ .unwrap_or_else(|err| panic!("failed to retrieve storage for address {address}: {err}"));
+
+ let account_state = set_account(
+ sdk_account,
+ account_storage,
+ account_esdt,
+ account_esdt_roles,
+ );
+
+ let set_state_step = SetStateStep::new();
+ set_state_step.put_account(address, account_state)
+}
+
+fn set_account(
+ account: multiversx_sdk_wbg::data::account::Account,
+ account_storage: HashMap,
+ account_esdt: HashMap,
+ account_esdt_roles: HashMap>,
+) -> Account {
+ let mut account_state = Account::new()
+ .nonce(account.nonce)
+ .balance(account.balance.as_str())
+ .code(account.code);
+ account_state.username = Some(format!("str:{}", account.username.as_str()).into());
+ account_state.storage = convert_storage(account_storage);
+
+ for (_, esdt_balance) in account_esdt.iter() {
+ let token_id_expr = format!("str:{}", esdt_balance.token_identifier);
+ account_state =
+ account_state.esdt_balance(token_id_expr.as_str(), esdt_balance.balance.as_str());
+ }
+
+ for (token_id, esdt_roles) in account_esdt_roles {
+ let token_id_expr = format!("str:{token_id}");
+ account_state = account_state.esdt_roles(token_id_expr.as_str(), esdt_roles);
+ }
+
+ account_state
+}
+
+fn convert_storage(account_storage: HashMap) -> BTreeMap {
+ account_storage
+ .into_iter()
+ .filter(|(k, _)| !k.starts_with("454c524f4e44"))
+ .map(|(k, v)| (BytesKey::from(k.as_str()), BytesValue::from(v)))
+ .collect()
+}
diff --git a/framework/snippets-dapp/src/imports.rs b/framework/snippets-dapp/src/imports.rs
new file mode 100644
index 0000000000..af9bf1e455
--- /dev/null
+++ b/framework/snippets-dapp/src/imports.rs
@@ -0,0 +1,9 @@
+pub use crate::multiversx_sc_scenario::imports::*;
+
+pub use crate::{
+ dns_address_for_name, test_wallets, Interactor, InteractorPrepareAsync, StepBuffer,
+};
+
+pub use multiversx_sdk_wbg::{data::keystore::InsertPassword, wallet::Wallet};
+
+pub use env_logger;
diff --git a/framework/snippets-dapp/src/interactor.rs b/framework/snippets-dapp/src/interactor.rs
new file mode 100644
index 0000000000..882fb0440d
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor.rs
@@ -0,0 +1,109 @@
+use js_sys::Promise;
+use multiversx_sc_scenario::{
+ imports::{Bech32Address, ScenarioRunner},
+ mandos_system::{run_list::ScenarioRunnerList, run_trace::ScenarioTraceFile},
+ multiversx_sc::types::Address,
+ scenario_model::AddressValue,
+};
+use multiversx_sdk_wbg::{
+ data::{address::Address as ErdrsAddress, network_config::NetworkConfig},
+ gateway::GatewayProxy,
+ wallet::Wallet,
+};
+use std::{
+ collections::HashMap,
+ path::{Path, PathBuf},
+};
+use wasm_bindgen_futures::JsFuture;
+use web_sys::window;
+
+use crate::{account_tool::retrieve_account_as_scenario_set_state, Sender};
+
+pub const INTERACTOR_SCENARIO_TRACE_PATH: &str = "interactor_trace.scen.json";
+
+pub struct Interactor {
+ pub proxy: GatewayProxy,
+ pub network_config: NetworkConfig,
+ pub sender_map: HashMap,
+
+ pub(crate) waiting_time_ms: u64,
+ pub pre_runners: ScenarioRunnerList,
+ pub post_runners: ScenarioRunnerList,
+
+ pub current_dir: PathBuf,
+}
+
+async fn sleep(seconds: u32) {
+ let promise = Promise::new(&mut |resolve, _| {
+ if let Some(win) = window() {
+ let _ = win
+ .set_timeout_with_callback_and_timeout_and_arguments_0(
+ &resolve,
+ (seconds * 1000) as i32,
+ )
+ .expect("Failed to set timeout");
+ } else {
+ panic!("No global window object available");
+ }
+ });
+ JsFuture::from(promise).await.unwrap();
+}
+
+impl Interactor {
+ pub async fn new(gateway_url: &str) -> Self {
+ let proxy = GatewayProxy::new(gateway_url.to_string());
+ let network_config = proxy.get_network_config().await.unwrap();
+ Self {
+ proxy,
+ network_config,
+ sender_map: HashMap::new(),
+ waiting_time_ms: 0,
+ pre_runners: ScenarioRunnerList::empty(),
+ post_runners: ScenarioRunnerList::empty(),
+ current_dir: PathBuf::default(),
+ }
+ }
+
+ pub fn register_wallet(&mut self, wallet: Wallet) -> Address {
+ let address = erdrs_address_to_h256(wallet.address());
+ self.sender_map.insert(
+ address.clone(),
+ Sender {
+ address: address.clone(),
+ wallet,
+ current_nonce: None,
+ },
+ );
+ address
+ }
+
+ pub async fn sleep(&mut self, duration: u32) {
+ self.waiting_time_ms += (duration as u64) * 1000;
+ sleep(duration).await;
+ }
+
+ pub async fn with_tracer>(mut self, path: P) -> Self {
+ self.post_runners.push(ScenarioTraceFile::new(path));
+ self
+ }
+
+ pub async fn retrieve_account(&mut self, wallet_address: &Bech32Address) {
+ let set_state = retrieve_account_as_scenario_set_state(&self.proxy, wallet_address).await;
+ self.pre_runners.run_set_state_step(&set_state);
+ self.post_runners.run_set_state_step(&set_state);
+ }
+}
+
+pub(crate) fn mandos_to_erdrs_address(mandos_address: &AddressValue) -> ErdrsAddress {
+ let bytes = mandos_address.value.as_array();
+ ErdrsAddress::from_bytes(*bytes)
+}
+
+pub(crate) fn address_h256_to_erdrs(address: &Address) -> ErdrsAddress {
+ let bytes = address.as_array();
+ ErdrsAddress::from_bytes(*bytes)
+}
+
+pub(crate) fn erdrs_address_to_h256(erdrs_address: ErdrsAddress) -> Address {
+ erdrs_address.to_bytes().into()
+}
diff --git a/framework/snippets-dapp/src/interactor_dns.rs b/framework/snippets-dapp/src/interactor_dns.rs
new file mode 100644
index 0000000000..7b0ee8bdfd
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_dns.rs
@@ -0,0 +1,79 @@
+use multiversx_sc_scenario::{
+ multiversx_sc::types::Address, scenario_format::value_interpreter::keccak256,
+};
+
+#[cfg(test)]
+use multiversx_sc_scenario::bech32;
+
+fn get_initial_dns_address() -> Address {
+ Address::from_slice(&[1u8; 32])
+}
+
+fn compute_smart_contract_address(owner_address: Address, owner_nonce: u64) -> Address {
+ // 8 bytes of zero + 2 bytes for VM type + 20 bytes of hash(owner) + 2 bytes of shard(owner)
+ let owner_bytes = owner_address.as_bytes();
+ let nonce_bytes = owner_nonce.to_le_bytes();
+ let bytes_to_hash = [owner_bytes, &nonce_bytes].concat();
+ let initial_padding = [0u8; 8];
+ let vm_type: [u8; 2] = [5, 0];
+ let address = keccak256(&bytes_to_hash);
+ let address = [
+ initial_padding.as_slice(),
+ vm_type.as_slice(),
+ &address[10..30],
+ &owner_bytes[30..],
+ ]
+ .concat();
+ Address::from_slice(&address)
+}
+
+fn compute_dns_address_for_shard_id(shard_id: u8) -> Address {
+ let initial_dns_address = get_initial_dns_address();
+ let initial_dns_address_slice = initial_dns_address.as_array();
+ let shard_identifier = &[0u8, shard_id];
+ let deployer_pubkey_prefix =
+ &initial_dns_address_slice[0..initial_dns_address_slice.len() - shard_identifier.len()];
+
+ let deployer_pubkey = [deployer_pubkey_prefix, shard_identifier].concat();
+ let deployer_address = Address::from_slice(&deployer_pubkey);
+ let deployer_nonce = 0;
+ compute_smart_contract_address(deployer_address, deployer_nonce)
+}
+
+fn shard_id_from_name(name: &str) -> u8 {
+ let name_hash = keccak256(name.as_bytes());
+ name_hash[31]
+}
+
+pub fn dns_address_for_name(name: &str) -> Address {
+ let shard_id = shard_id_from_name(name);
+ compute_dns_address_for_shard_id(shard_id)
+}
+
+#[test]
+fn test_compute_dns_address() {
+ assert_eq!(
+ bech32::encode(&compute_dns_address_for_shard_id(0)),
+ "erd1qqqqqqqqqqqqqpgqnhvsujzd95jz6fyv3ldmynlf97tscs9nqqqq49en6w"
+ );
+ assert_eq!(
+ bech32::encode(&compute_dns_address_for_shard_id(1)),
+ "erd1qqqqqqqqqqqqqpgqysmcsfkqed279x6jvs694th4e4v50p4pqqqsxwywm0"
+ );
+ assert_eq!(
+ bech32::encode(&compute_dns_address_for_shard_id(2)),
+ "erd1qqqqqqqqqqqqqpgqnk5fq8sgg4vc63ffzf7qez550xe2l5jgqqpqe53dcq"
+ );
+}
+
+#[test]
+fn test_dns_for_name() {
+ assert_eq!(
+ bech32::encode(&dns_address_for_name("test.elrond")),
+ "erd1qqqqqqqqqqqqqpgqx4ca3eu4k6w63hl8pjjyq2cp7ul7a4ukqz0skq6fxj"
+ );
+ assert_eq!(
+ bech32::encode(&dns_address_for_name("helloworld.elrond")),
+ "erd1qqqqqqqqqqqqqpgqhcm9k2xkk75e47wpmvfgj8fuzwaguvzyqqrqsteg8w"
+ );
+}
diff --git a/framework/snippets-dapp/src/interactor_scenario.rs b/framework/snippets-dapp/src/interactor_scenario.rs
new file mode 100644
index 0000000000..8449bf9edc
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_scenario.rs
@@ -0,0 +1,5 @@
+mod interactor_sc_call;
+mod interactor_sc_deploy;
+mod interactor_sc_extra;
+mod interactor_transfer;
+mod interactor_vm_query;
diff --git a/framework/snippets-dapp/src/interactor_scenario/interactor_sc_call.rs b/framework/snippets-dapp/src/interactor_scenario/interactor_sc_call.rs
new file mode 100644
index 0000000000..de75ff16b1
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_scenario/interactor_sc_call.rs
@@ -0,0 +1,91 @@
+use crate::{address_h256_to_erdrs, mandos_to_erdrs_address, network_response, Interactor};
+use log::info;
+use multiversx_sc_scenario::{
+ api::StaticApi,
+ scenario::ScenarioRunner,
+ scenario_model::{ScCallStep, SetStateStep, TxCall},
+};
+use multiversx_sdk_wbg::{data::transaction::Transaction, utils::base64_encode};
+
+impl Interactor {
+ pub async fn sc_call(&mut self, mut sc_call_step: S)
+ where
+ S: AsMut,
+ {
+ let sc_call_step = sc_call_step.as_mut();
+ let tx_hash = self.launch_sc_call(sc_call_step).await;
+ let tx = self.proxy.retrieve_tx_on_network(tx_hash.clone()).await;
+
+ sc_call_step.save_response(network_response::parse_tx_response(tx));
+
+ 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);
+ }
+
+ async fn launch_sc_call(&mut self, sc_call_step: &mut ScCallStep) -> String {
+ self.pre_runners.run_sc_call_step(sc_call_step);
+
+ let sender_address = &sc_call_step.tx.from.value;
+ let mut transaction = self.tx_call_to_blockchain_tx(&sc_call_step.tx);
+ self.set_nonce_and_sign_tx(sender_address, &mut transaction)
+ .await;
+ let tx_hash = self.proxy.send_transaction(&transaction).await.unwrap();
+ println!("sc call tx hash: {tx_hash}");
+ info!("sc call tx hash: {}", tx_hash);
+
+ tx_hash
+ }
+
+ #[allow(deprecated)] // TODO
+ pub(crate) fn tx_call_to_blockchain_tx(&self, tx_call: &TxCall) -> Transaction {
+ let contract_call = tx_call.to_contract_call();
+ let contract_call_tx_data = contract_call_to_tx_data(&contract_call);
+ 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: contract_call.egld_payment.to_alloc().to_string(),
+ sender: mandos_to_erdrs_address(&tx_call.from),
+ receiver: address_h256_to_erdrs(&contract_call.basic.to.to_address()),
+ gas_price: self.network_config.min_gas_price,
+ gas_limit: tx_call.gas_limit.value,
+ data,
+ signature: None,
+ chain_id: self.network_config.chain_id.clone(),
+ version: self.network_config.min_transaction_version,
+ options: 0,
+ }
+ }
+}
+
+#[allow(deprecated)] // TODO
+fn contract_call_to_tx_data(
+ contract_call: &multiversx_sc_scenario::imports::ContractCallWithEgld,
+) -> String {
+ let mut result = String::from_utf8(
+ contract_call
+ .basic
+ .function_call
+ .function_name
+ .to_boxed_bytes()
+ .into_vec(),
+ )
+ .unwrap();
+ for argument in contract_call.basic.function_call.arg_buffer.raw_arg_iter() {
+ result.push('@');
+ result.push_str(hex::encode(argument.to_boxed_bytes().as_slice()).as_str());
+ }
+ result
+}
diff --git a/framework/snippets-dapp/src/interactor_scenario/interactor_sc_deploy.rs b/framework/snippets-dapp/src/interactor_scenario/interactor_sc_deploy.rs
new file mode 100644
index 0000000000..83bcd10f94
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_scenario/interactor_sc_deploy.rs
@@ -0,0 +1,77 @@
+use crate::{mandos_to_erdrs_address, network_response, Interactor};
+use log::info;
+use multiversx_sc_scenario::{
+ imports::Bech32Address,
+ mandos_system::ScenarioRunner,
+ scenario_model::{ScDeployStep, SetStateStep},
+};
+use multiversx_sdk_wbg::{
+ data::{address::Address as ErdrsAddress, transaction::Transaction},
+ utils::base64_encode,
+};
+
+const DEPLOY_RECEIVER: [u8; 32] = [0u8; 32];
+
+impl Interactor {
+ pub(crate) fn sc_deploy_to_blockchain_tx(&self, sc_deploy_step: &ScDeployStep) -> Transaction {
+ Transaction {
+ nonce: 0,
+ value: sc_deploy_step.tx.egld_value.value.to_string(),
+ sender: mandos_to_erdrs_address(&sc_deploy_step.tx.from),
+ receiver: ErdrsAddress::from_bytes(DEPLOY_RECEIVER),
+ gas_price: self.network_config.min_gas_price,
+ gas_limit: sc_deploy_step.tx.gas_limit.value,
+ data: Some(base64_encode(sc_deploy_step.tx.to_tx_data())),
+ signature: None,
+ chain_id: self.network_config.chain_id.clone(),
+ version: self.network_config.min_transaction_version,
+ options: 0,
+ }
+ }
+
+ pub async fn launch_sc_deploy(&mut self, sc_deploy_step: &mut ScDeployStep) -> String {
+ self.pre_runners.run_sc_deploy_step(sc_deploy_step);
+
+ let sender_address = &sc_deploy_step.tx.from.value;
+ let mut transaction = self.sc_deploy_to_blockchain_tx(sc_deploy_step);
+ self.set_nonce_and_sign_tx(sender_address, &mut transaction)
+ .await;
+ let tx_hash = self
+ .proxy
+ .send_transaction(&transaction)
+ .await
+ .expect("error sending tx (possible API failure)");
+ println!("sc deploy tx hash: {tx_hash}");
+ info!("sc deploy tx hash: {}", tx_hash);
+
+ tx_hash
+ }
+
+ pub async fn sc_deploy(&mut self, mut sc_deploy_step: S)
+ where
+ S: AsMut,
+ {
+ let sc_deploy_step = sc_deploy_step.as_mut();
+ let tx_hash = self.launch_sc_deploy(sc_deploy_step).await;
+ let tx = self.proxy.retrieve_tx_on_network(tx_hash.clone()).await;
+
+ let addr = sc_deploy_step.tx.from.clone();
+ let nonce = tx.nonce;
+ sc_deploy_step.save_response(network_response::parse_tx_response(tx));
+
+ let deploy_address = sc_deploy_step
+ .response()
+ .new_deployed_address
+ .clone()
+ .unwrap();
+ let deploy_address_bech32 = Bech32Address::from(deploy_address);
+
+ let set_state_step = SetStateStep::new().new_address(addr, nonce, &deploy_address_bech32);
+
+ println!("deploy address: {deploy_address_bech32}");
+ 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_deploy_step(sc_deploy_step);
+ }
+}
diff --git a/framework/snippets-dapp/src/interactor_scenario/interactor_sc_extra.rs b/framework/snippets-dapp/src/interactor_scenario/interactor_sc_extra.rs
new file mode 100644
index 0000000000..44e5efa744
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_scenario/interactor_sc_extra.rs
@@ -0,0 +1,209 @@
+#![allow(deprecated)]
+
+use crate::Interactor;
+use multiversx_sc_scenario::{
+ api::StaticApi,
+ multiversx_sc::{
+ abi::TypeAbiFrom,
+ codec::{TopDecodeMulti, TopEncodeMulti},
+ types::{Address, ContractCallBase},
+ },
+ scenario_model::{
+ ScCallStep, ScDeployStep, ScQueryStep, TxResponse, TypedResponse, TypedScCall,
+ TypedScDeploy, TypedScQuery,
+ },
+};
+
+impl Interactor {
+ #[deprecated(
+ since = "0.49.0",
+ note = "Please use the unified transaction syntax instead."
+ )]
+ pub async fn sc_call_use_raw_response(
+ &mut self,
+ mut step: S,
+ use_raw_response: F,
+ ) -> &mut Self
+ where
+ S: AsMut,
+ F: FnOnce(&TxResponse),
+ {
+ self.sc_call(step.as_mut()).await;
+ let response = unwrap_response(&step.as_mut().response);
+ use_raw_response(response);
+ self
+ }
+
+ #[deprecated(
+ since = "0.49.0",
+ note = "Please use the unified transaction syntax instead."
+ )]
+ pub async fn sc_call_use_result(
+ &mut self,
+ step: TypedScCall,
+ use_result: F,
+ ) -> &mut Self
+ where
+ OriginalResult: TopEncodeMulti,
+ RequestedResult: TopDecodeMulti + TypeAbiFrom,
+ F: FnOnce(TypedResponse),
+ {
+ use_result(self.sc_call_get_result(step).await);
+ self
+ }
+
+ #[deprecated(
+ since = "0.49.0",
+ note = "Please use the unified transaction syntax instead."
+ )]
+ pub async fn sc_call_get_result(
+ &mut self,
+ mut step: TypedScCall,
+ ) -> TypedResponse
+ where
+ OriginalResult: TopEncodeMulti,
+ RequestedResult: TopDecodeMulti + TypeAbiFrom,
+ {
+ self.sc_call(step.as_mut()).await;
+ let response = unwrap_response(&step.as_mut().response);
+ TypedResponse::from_raw(response)
+ }
+
+ #[deprecated(
+ since = "0.49.0",
+ note = "Please use the unified transaction syntax instead."
+ )]
+ pub async fn sc_query_use_raw_response(
+ &mut self,
+ mut step: S,
+ use_raw_response: F,
+ ) -> &mut Self
+ where
+ S: AsMut,
+ F: FnOnce(&TxResponse),
+ {
+ self.sc_query(step.as_mut()).await;
+ let response = unwrap_response(&step.as_mut().response);
+ use_raw_response(response);
+ self
+ }
+
+ #[deprecated(
+ since = "0.49.0",
+ note = "Please use the unified transaction syntax instead."
+ )]
+ pub async fn sc_query_use_result(
+ &mut self,
+ step: TypedScQuery,
+ use_result: F,
+ ) -> &mut Self
+ where
+ OriginalResult: TopEncodeMulti,
+ RequestedResult: TopDecodeMulti + TypeAbiFrom,
+ F: FnOnce(TypedResponse),
+ {
+ use_result(self.sc_query_get_result(step).await);
+ self
+ }
+
+ #[deprecated(
+ since = "0.49.0",
+ note = "Please use the unified transaction syntax instead."
+ )]
+ pub async fn sc_query_get_result(
+ &mut self,
+ mut step: TypedScQuery,
+ ) -> TypedResponse
+ where
+ OriginalResult: TopEncodeMulti,
+ RequestedResult: TopDecodeMulti + TypeAbiFrom,
+ {
+ self.sc_query(step.as_mut()).await;
+ let response = unwrap_response(&step.sc_query_step.response);
+ TypedResponse::from_raw(response)
+ }
+
+ #[deprecated(
+ since = "0.49.0",
+ note = "Please use the unified transaction syntax instead."
+ )]
+ pub async fn quick_query(&mut self, contract_call: CC) -> RequestedResult
+ where
+ CC: ContractCallBase,
+ RequestedResult: TopDecodeMulti + TypeAbiFrom,
+ {
+ let mut typed_sc_query = ScQueryStep::new().call(contract_call);
+ self.sc_query(&mut typed_sc_query).await;
+ let response = unwrap_response(&typed_sc_query.sc_query_step.response);
+ let typed_response = TypedResponse::from_raw(response);
+ typed_response.result.unwrap()
+ }
+
+ #[deprecated(
+ since = "0.49.0",
+ note = "Please use the unified transaction syntax instead."
+ )]
+ pub async fn sc_deploy_use_raw_response(
+ &mut self,
+ mut step: S,
+ use_raw_response: F,
+ ) -> &mut Self
+ where
+ S: AsMut,
+ F: FnOnce(&TxResponse),
+ {
+ self.sc_deploy(step.as_mut()).await;
+ let response = unwrap_response(&step.as_mut().response);
+ use_raw_response(response);
+ self
+ }
+
+ #[deprecated(
+ since = "0.49.0",
+ note = "Please use the unified transaction syntax instead."
+ )]
+ pub async fn sc_deploy_use_result(
+ &mut self,
+ step: TypedScDeploy,
+ use_result: F,
+ ) -> &mut Self
+ where
+ OriginalResult: TopEncodeMulti,
+ RequestedResult: TopDecodeMulti + TypeAbiFrom,
+ F: FnOnce(Address, TypedResponse),
+ {
+ let (new_address, response) = self.sc_deploy_get_result(step).await;
+ use_result(new_address, response);
+ self
+ }
+
+ #[deprecated(
+ since = "0.49.0",
+ note = "Please use the unified transaction syntax instead."
+ )]
+ pub async fn sc_deploy_get_result(
+ &mut self,
+ mut step: TypedScDeploy,
+ ) -> (Address, TypedResponse)
+ where
+ OriginalResult: TopEncodeMulti,
+ RequestedResult: TopDecodeMulti + TypeAbiFrom,
+ {
+ self.sc_deploy(step.as_mut()).await;
+ let response = unwrap_response(&step.sc_deploy_step.response);
+ let new_address = unwrap_new_address(response);
+ let response = TypedResponse::from_raw(response);
+ (new_address, response)
+ }
+}
+
+fn unwrap_response(opt_response: &Option) -> &TxResponse {
+ opt_response.as_ref().expect("response not processed")
+}
+
+fn unwrap_new_address(response: &TxResponse) -> Address {
+ response
+ .new_deployed_address
+ .clone()
+ .expect("missing new address after deploy")
+}
diff --git a/framework/snippets-dapp/src/interactor_scenario/interactor_transfer.rs b/framework/snippets-dapp/src/interactor_scenario/interactor_transfer.rs
new file mode 100644
index 0000000000..6557e4119f
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_scenario/interactor_transfer.rs
@@ -0,0 +1,23 @@
+use crate::Interactor;
+use log::info;
+use multiversx_sc_scenario::{scenario::ScenarioRunner, scenario_model::TransferStep};
+
+impl Interactor {
+ pub async fn transfer(&mut self, transfer_step: TransferStep) -> String {
+ self.pre_runners.run_transfer_step(&transfer_step);
+
+ let sender_address = &transfer_step.tx.from.value;
+ let mut transaction = self.tx_call_to_blockchain_tx(&transfer_step.tx.to_tx_call());
+ self.set_nonce_and_sign_tx(sender_address, &mut transaction)
+ .await;
+ let tx_hash = self.proxy.send_transaction(&transaction).await.unwrap();
+ println!("transfer tx hash: {tx_hash}");
+ info!("transfer tx hash: {}", tx_hash);
+
+ self.proxy.retrieve_tx_on_network(tx_hash.clone()).await;
+
+ self.post_runners.run_transfer_step(&transfer_step);
+
+ tx_hash
+ }
+}
diff --git a/framework/snippets-dapp/src/interactor_scenario/interactor_vm_query.rs b/framework/snippets-dapp/src/interactor_scenario/interactor_vm_query.rs
new file mode 100644
index 0000000000..24839d5c0a
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_scenario/interactor_vm_query.rs
@@ -0,0 +1,60 @@
+#![allow(deprecated)]
+
+use crate::{address_h256_to_erdrs, Interactor};
+use log::info;
+use multiversx_sc_scenario::{
+ api::StaticApi,
+ mandos_system::ScenarioRunner,
+ multiversx_sc::{abi::TypeAbiFrom, codec::TopDecodeMulti, types::ContractCall},
+ scenario_model::{ScQueryStep, TxResponse},
+};
+use multiversx_sdk_wbg::{data::vm::VmValueRequest, utils::base64_decode};
+
+impl Interactor {
+ pub async fn sc_query(&mut self, mut step: S) -> &mut Self
+ where
+ S: AsMut,
+ {
+ self.perform_sc_query(step.as_mut()).await;
+ self
+ }
+
+ pub async fn perform_sc_query(&mut self, step: &mut ScQueryStep) {
+ let sc_address = address_h256_to_erdrs(&step.tx.to.to_address());
+ let req = VmValueRequest {
+ sc_address: sc_address.clone(),
+ func_name: step.tx.function.clone(),
+ args: step
+ .tx
+ .arguments
+ .iter()
+ .map(|arg| hex::encode(&arg.value))
+ .collect(),
+ caller: sc_address,
+ value: "0".to_string(),
+ };
+ let result = self
+ .proxy
+ .execute_vmquery(&req)
+ .await
+ .expect("error executing VM query");
+
+ info!("{:#?}", result);
+
+ let raw_results: Vec> = result.data.return_data.iter().map(base64_decode).collect();
+
+ step.save_response(TxResponse::from_raw_results(raw_results));
+
+ self.pre_runners.run_sc_query_step(step);
+ self.post_runners.run_sc_query_step(step);
+ }
+
+ #[deprecated(since = "0.42.0", note = "Was renamed to `quick_query`.")]
+ pub async fn vm_query(&mut self, contract_call: CC) -> RequestedResult
+ where
+ CC: ContractCall,
+ RequestedResult: TopDecodeMulti + TypeAbiFrom,
+ {
+ self.quick_query(contract_call).await
+ }
+}
diff --git a/framework/snippets-dapp/src/interactor_sender.rs b/framework/snippets-dapp/src/interactor_sender.rs
new file mode 100644
index 0000000000..8bff6b42dc
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_sender.rs
@@ -0,0 +1,56 @@
+use log::debug;
+use multiversx_sc_scenario::multiversx_sc::types::Address;
+use multiversx_sdk_wbg::{data::transaction::Transaction, wallet::Wallet};
+
+use crate::{address_h256_to_erdrs, Interactor};
+
+/// A user account that can sign transactions (a pem is present).
+pub struct Sender {
+ pub address: Address,
+ pub wallet: Wallet,
+ pub current_nonce: Option,
+}
+
+impl Interactor {
+ pub async fn recall_nonce(&self, address: &Address) -> u64 {
+ let erdrs_address = address_h256_to_erdrs(address);
+ let account = self
+ .proxy
+ .get_account(&erdrs_address)
+ .await
+ .expect("failed to retrieve account nonce");
+ account.nonce
+ }
+
+ pub(crate) async fn set_nonce_and_sign_tx(
+ &mut self,
+ sender_address: &Address,
+ transaction: &mut Transaction,
+ ) {
+ // read
+ let sender = self
+ .sender_map
+ .get(sender_address)
+ .expect("the wallet that was supposed to sign is not registered");
+
+ // recall
+ let nonce = self.recall_nonce(&sender.address).await;
+ println!("sender's recalled nonce: {nonce}");
+
+ // set tx nonce
+ transaction.nonce = nonce;
+ println!("-- tx nonce: {}", transaction.nonce);
+
+ // update
+ let sender = self
+ .sender_map
+ .get_mut(sender_address)
+ .expect("the wallet that was supposed to sign is not registered");
+ sender.current_nonce = Some(nonce + 1);
+
+ // sign
+ let signature = sender.wallet.sign_tx(transaction);
+ transaction.signature = Some(hex::encode(signature));
+ debug!("transaction {:#?}", transaction);
+ }
+}
diff --git a/framework/snippets-dapp/src/interactor_tx.rs b/framework/snippets-dapp/src/interactor_tx.rs
new file mode 100644
index 0000000000..1075cc533f
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_tx.rs
@@ -0,0 +1,24 @@
+#![allow(unused_imports)] // TEMP
+
+mod interactor_exec_call;
+mod interactor_exec_deploy;
+mod interactor_exec_env;
+mod interactor_exec_step;
+mod interactor_exec_transf;
+mod interactor_exec_upgrade;
+mod interactor_prepare_async;
+mod interactor_query_call;
+mod interactor_query_env;
+mod interactor_query_step;
+
+pub use interactor_exec_env::InteractorEnvExec;
+pub use interactor_exec_step::InteractorExecStep;
+pub use interactor_prepare_async::InteractorPrepareAsync;
+pub use interactor_query_env::InteractorEnvQuery;
+pub use interactor_query_step::InteractorQueryStep;
+
+#[deprecated(since = "0.50.2", note = "Renamed to InteractorExecEnv")]
+pub type InteractorExecEnv<'a> = InteractorEnvExec<'a>;
+
+#[deprecated(since = "0.50.2", note = "Renamed to InteractorEnvQuery")]
+pub type InteractorQueryEnv<'a> = InteractorEnvQuery<'a>;
diff --git a/framework/snippets-dapp/src/interactor_tx/interactor_exec_call.rs b/framework/snippets-dapp/src/interactor_tx/interactor_exec_call.rs
new file mode 100644
index 0000000000..261ce44989
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_tx/interactor_exec_call.rs
@@ -0,0 +1,76 @@
+use multiversx_sc_scenario::{
+ api::StaticApi,
+ multiversx_sc::{
+ tuple_util::NestedTupleFlatten,
+ types::{
+ FunctionCall, RHListExec, Tx, TxBaseWithEnv, TxFromSpecified, TxGas, TxPayment,
+ TxToSpecified,
+ },
+ },
+ scenario::tx_to_step::TxToStep,
+ scenario_model::{ScCallStep, TxResponse},
+ ScenarioTxEnvData,
+};
+
+use crate::Interactor;
+
+use super::{InteractorEnvExec, InteractorExecStep, InteractorPrepareAsync};
+
+impl<'w, From, To, Payment, Gas, RH> InteractorPrepareAsync
+ for Tx, From, To, Payment, Gas, FunctionCall, RH>
+where
+ From: TxFromSpecified>,
+ To: TxToSpecified>,
+ Payment: TxPayment>,
+ Gas: TxGas>,
+ RH: RHListExec>,
+ RH::ListReturns: NestedTupleFlatten,
+{
+ type Exec = InteractorExecStep<'w, ScCallStep, RH>;
+
+ fn prepare_async(self) -> Self::Exec {
+ InteractorExecStep {
+ step_wrapper: self.tx_to_step(),
+ }
+ }
+}
+
+impl<'w, RH> InteractorExecStep<'w, ScCallStep, RH>
+where
+ RH: RHListExec>,
+ RH::ListReturns: NestedTupleFlatten,
+{
+ pub async fn run(mut self) -> ::Unpacked {
+ self.step_wrapper
+ .env
+ .world
+ .sc_call(&mut self.step_wrapper.step)
+ .await;
+ self.step_wrapper.process_result()
+ }
+}
+
+impl Interactor {
+ pub async fn chain_call(&mut self, f: F) -> &mut Self
+ where
+ From: TxFromSpecified,
+ To: TxToSpecified,
+ Payment: TxPayment,
+ Gas: TxGas,
+ RH: RHListExec,
+ F: FnOnce(
+ TxBaseWithEnv,
+ )
+ -> Tx, RH>,
+ {
+ let env = self.new_env_data();
+ let tx_base = TxBaseWithEnv::new_with_env(env);
+ let tx = f(tx_base);
+
+ let mut step_wrapper = tx.tx_to_step();
+ self.sc_call(&mut step_wrapper.step).await;
+ step_wrapper.process_result();
+
+ self
+ }
+}
diff --git a/framework/snippets-dapp/src/interactor_tx/interactor_exec_deploy.rs b/framework/snippets-dapp/src/interactor_tx/interactor_exec_deploy.rs
new file mode 100644
index 0000000000..6070158258
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_tx/interactor_exec_deploy.rs
@@ -0,0 +1,122 @@
+use multiversx_sc_scenario::{
+ multiversx_sc::{
+ tuple_util::NestedTupleFlatten,
+ types::{
+ Code, DeployCall, RHListExec, Tx, TxBaseWithEnv, TxCodeValue, TxFromSpecified, TxGas,
+ TxPayment,
+ },
+ },
+ scenario::tx_to_step::TxToStep,
+ scenario_model::{ScDeployStep, TxResponse},
+ ScenarioTxEnvData,
+};
+
+use crate::Interactor;
+
+use super::{InteractorEnvExec, InteractorExecStep, InteractorPrepareAsync};
+
+impl<'w, From, Payment, Gas, CodeValue, RH> InteractorPrepareAsync
+ for Tx<
+ InteractorEnvExec<'w>,
+ From,
+ (),
+ Payment,
+ Gas,
+ DeployCall, Code>,
+ RH,
+ >
+where
+ From: TxFromSpecified>,
+ Payment: TxPayment>,
+ Gas: TxGas>,
+ CodeValue: TxCodeValue>,
+ RH: RHListExec>,
+ RH::ListReturns: NestedTupleFlatten,
+{
+ type Exec = InteractorExecStep<'w, ScDeployStep, RH>;
+
+ fn prepare_async(self) -> Self::Exec {
+ InteractorExecStep {
+ step_wrapper: self.tx_to_step(),
+ }
+ }
+}
+
+impl<'w, RH> InteractorExecStep<'w, ScDeployStep, RH>
+where
+ RH: RHListExec>,
+ RH::ListReturns: NestedTupleFlatten,
+{
+ pub async fn run(mut self) -> ::Unpacked {
+ self.step_wrapper
+ .env
+ .world
+ .sc_deploy(&mut self.step_wrapper.step)
+ .await;
+ self.step_wrapper.process_result()
+ }
+}
+
+impl Interactor {
+ pub async fn chain_deploy(&mut self, f: F) -> &mut Self
+ where
+ From: TxFromSpecified,
+ Payment: TxPayment,
+ Gas: TxGas,
+ CodeValue: TxCodeValue,
+ RH: RHListExec,
+ F: FnOnce(
+ TxBaseWithEnv,
+ ) -> Tx<
+ ScenarioTxEnvData,
+ From,
+ (),
+ Payment,
+ Gas,
+ DeployCall>,
+ RH,
+ >,
+ {
+ let env = self.new_env_data();
+ let tx_base = TxBaseWithEnv::new_with_env(env);
+ let tx = f(tx_base);
+
+ let mut step_wrapper = tx.tx_to_step();
+ self.sc_deploy(&mut step_wrapper.step).await;
+ step_wrapper.process_result();
+
+ self
+ }
+
+ pub async fn run_deploy(
+ &mut self,
+ f: F,
+ ) -> ::Unpacked
+ where
+ From: TxFromSpecified,
+ Payment: TxPayment,
+ Gas: TxGas,
+ CodeValue: TxCodeValue,
+ RH: RHListExec,
+ RH::ListReturns: NestedTupleFlatten,
+ F: FnOnce(
+ TxBaseWithEnv,
+ ) -> Tx<
+ ScenarioTxEnvData,
+ From,
+ (),
+ Payment,
+ Gas,
+ DeployCall>,
+ RH,
+ >,
+ {
+ let env = self.new_env_data();
+ let tx_base = TxBaseWithEnv::new_with_env(env);
+ let tx = f(tx_base);
+
+ let mut step_wrapper = tx.tx_to_step();
+ self.sc_deploy(&mut step_wrapper.step).await;
+ step_wrapper.process_result()
+ }
+}
diff --git a/framework/snippets-dapp/src/interactor_tx/interactor_exec_env.rs b/framework/snippets-dapp/src/interactor_tx/interactor_exec_env.rs
new file mode 100644
index 0000000000..6473c50a91
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_tx/interactor_exec_env.rs
@@ -0,0 +1,46 @@
+use multiversx_sc_scenario::{
+ api::StaticApi,
+ multiversx_sc::types::{ManagedAddress, ManagedBuffer, Tx, TxBaseWithEnv, TxEnv},
+ scenario_model::TxExpect,
+ ScenarioTxEnv, ScenarioTxEnvData,
+};
+
+use crate::Interactor;
+
+impl Interactor {
+ pub fn tx(&mut self) -> TxBaseWithEnv> {
+ let data = self.new_env_data();
+ let env = InteractorEnvExec { world: self, data };
+ Tx::new_with_env(env)
+ }
+}
+
+/// Environment for executing transactions.
+pub struct InteractorEnvExec<'w> {
+ pub world: &'w mut Interactor,
+ pub data: ScenarioTxEnvData,
+}
+
+impl<'w> TxEnv for InteractorEnvExec<'w> {
+ type Api = StaticApi;
+
+ type RHExpect = TxExpect;
+
+ fn resolve_sender_address(&self) -> ManagedAddress {
+ panic!("Explicit sender address expected")
+ }
+
+ fn default_gas_annotation(&self) -> ManagedBuffer {
+ self.data.default_gas_annotation()
+ }
+
+ fn default_gas_value(&self) -> u64 {
+ self.data.default_gas_value()
+ }
+}
+
+impl<'w> ScenarioTxEnv for InteractorEnvExec<'w> {
+ fn env_data(&self) -> &ScenarioTxEnvData {
+ &self.data
+ }
+}
diff --git a/framework/snippets-dapp/src/interactor_tx/interactor_exec_step.rs b/framework/snippets-dapp/src/interactor_tx/interactor_exec_step.rs
new file mode 100644
index 0000000000..1d4eabf54d
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_tx/interactor_exec_step.rs
@@ -0,0 +1,15 @@
+use multiversx_sc_scenario::{
+ multiversx_sc::{tuple_util::NestedTupleFlatten, types::RHListExec},
+ scenario::tx_to_step::StepWrapper,
+ scenario_model::TxResponse,
+};
+
+use super::InteractorEnvExec;
+
+pub struct InteractorExecStep<'w, Step, RH>
+where
+ RH: RHListExec>,
+ RH::ListReturns: NestedTupleFlatten,
+{
+ pub(crate) step_wrapper: StepWrapper, Step, RH>,
+}
diff --git a/framework/snippets-dapp/src/interactor_tx/interactor_exec_transf.rs b/framework/snippets-dapp/src/interactor_tx/interactor_exec_transf.rs
new file mode 100644
index 0000000000..3ec04c0b05
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_tx/interactor_exec_transf.rs
@@ -0,0 +1,34 @@
+use multiversx_sc_scenario::{
+ multiversx_sc::types::{Tx, TxFromSpecified, TxGas, TxPayment, TxToSpecified},
+ scenario::tx_to_step::TxToStep,
+ scenario_model::TransferStep,
+};
+
+use super::{InteractorEnvExec, InteractorExecStep, InteractorPrepareAsync};
+
+impl<'w, From, To, Payment, Gas> InteractorPrepareAsync
+ for Tx, From, To, Payment, Gas, (), ()>
+where
+ From: TxFromSpecified>,
+ To: TxToSpecified>,
+ Payment: TxPayment>,
+ Gas: TxGas>,
+{
+ type Exec = InteractorExecStep<'w, TransferStep, ()>;
+
+ fn prepare_async(self) -> Self::Exec {
+ InteractorExecStep {
+ step_wrapper: self.tx_to_step(),
+ }
+ }
+}
+
+impl<'w> InteractorExecStep<'w, TransferStep, ()> {
+ pub async fn run(self) {
+ self.step_wrapper
+ .env
+ .world
+ .transfer(self.step_wrapper.step)
+ .await;
+ }
+}
diff --git a/framework/snippets-dapp/src/interactor_tx/interactor_exec_upgrade.rs b/framework/snippets-dapp/src/interactor_tx/interactor_exec_upgrade.rs
new file mode 100644
index 0000000000..af68999830
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_tx/interactor_exec_upgrade.rs
@@ -0,0 +1,105 @@
+use multiversx_sc_scenario::{
+ imports::{NotPayable, ScCallStep, TxToSpecified, UpgradeCall},
+ multiversx_sc::{
+ tuple_util::NestedTupleFlatten,
+ types::{
+ Code, DeployCall, RHListExec, Tx, TxBaseWithEnv, TxCodeValue, TxFromSpecified, TxGas,
+ TxPayment,
+ },
+ },
+ scenario::tx_to_step::{address_annotated, code_annotated, StepWrapper, TxToStep},
+ scenario_model::{ScDeployStep, TxResponse},
+ ScenarioTxEnvData,
+};
+
+use crate::Interactor;
+
+use super::{InteractorEnvExec, InteractorExecStep, InteractorPrepareAsync};
+
+impl<'w, From, To, Gas, CodeValue, RH> InteractorPrepareAsync
+ for Tx<
+ InteractorEnvExec<'w>,
+ From,
+ To,
+ NotPayable,
+ Gas,
+ UpgradeCall, Code>,
+ RH,
+ >
+where
+ From: TxFromSpecified>,
+ To: TxToSpecified>,
+ Gas: TxGas>,
+ CodeValue: TxCodeValue>,
+ RH: RHListExec>,
+ RH::ListReturns: NestedTupleFlatten,
+{
+ type Exec = InteractorExecStep<'w, ScCallStep, RH>;
+
+ fn prepare_async(self) -> Self::Exec {
+ InteractorExecStep {
+ step_wrapper: self.tx_to_step(),
+ }
+ }
+}
+
+impl<'w, From, To, Gas, RH, CodeValue> TxToStep, RH>
+ for Tx<
+ InteractorEnvExec<'w>,
+ From,
+ To,
+ NotPayable,
+ Gas,
+ UpgradeCall, Code>,
+ RH,
+ >
+where
+ From: TxFromSpecified>,
+ To: TxToSpecified>,
+ Gas: TxGas>,
+ CodeValue: TxCodeValue>,
+ RH: RHListExec>,
+ RH::ListReturns: NestedTupleFlatten,
+{
+ type Step = ScCallStep;
+
+ fn tx_to_step(self) -> StepWrapper, Self::Step, RH> {
+ let mut step =
+ tx_to_sc_call_upgrade_step(&self.env, self.from, self.to, self.gas, self.data);
+ step.expect = Some(self.result_handler.list_tx_expect());
+
+ StepWrapper {
+ env: self.env,
+ step,
+ result_handler: self.result_handler,
+ }
+ }
+}
+
+pub fn tx_to_sc_call_upgrade_step<'a, 'w: 'a, From, To, Gas, CodeValue>(
+ env: &'a InteractorEnvExec<'w>,
+ from: From,
+ to: To,
+ gas: Gas,
+ data: UpgradeCall, Code>,
+) -> ScCallStep
+where
+ From: TxFromSpecified>,
+ To: TxToSpecified>,
+ Gas: TxGas>,
+ CodeValue: TxCodeValue>,
+{
+ let mut step = ScCallStep::new()
+ .from(address_annotated(env, &from))
+ .to(address_annotated(env, &to))
+ .gas_limit(gas.gas_value(env))
+ .function("upgradeContract")
+ .argument(code_annotated(env, data.code_source))
+ .argument(data.code_metadata.to_byte_array().to_vec());
+
+ for arg in data.arg_buffer.iter_buffers() {
+ step.tx.arguments.push(arg.to_vec().into());
+ }
+
+ step
+}
diff --git a/framework/snippets-dapp/src/interactor_tx/interactor_prepare_async.rs b/framework/snippets-dapp/src/interactor_tx/interactor_prepare_async.rs
new file mode 100644
index 0000000000..073641f811
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_tx/interactor_prepare_async.rs
@@ -0,0 +1,18 @@
+use multiversx_sc_scenario::{imports::InterpreterContext, ScenarioTxEnvData};
+
+use crate::Interactor;
+
+impl Interactor {
+ pub(crate) fn new_env_data(&self) -> ScenarioTxEnvData {
+ ScenarioTxEnvData {
+ interpreter_context: InterpreterContext::new().with_dir(self.current_dir.clone()),
+ tx_hash: None,
+ }
+ }
+}
+
+pub trait InteractorPrepareAsync {
+ type Exec;
+
+ fn prepare_async(self) -> Self::Exec;
+}
diff --git a/framework/snippets-dapp/src/interactor_tx/interactor_query_call.rs b/framework/snippets-dapp/src/interactor_tx/interactor_query_call.rs
new file mode 100644
index 0000000000..5e35b5409b
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_tx/interactor_query_call.rs
@@ -0,0 +1,68 @@
+use multiversx_sc_scenario::{
+ api::StaticApi,
+ multiversx_sc::{
+ tuple_util::NestedTupleFlatten,
+ types::{FunctionCall, RHListExec, Tx, TxBaseWithEnv, TxNoPayment, TxToSpecified},
+ },
+ scenario::tx_to_step::TxToQueryStep,
+ scenario_model::TxResponse,
+ ScenarioTxEnvData,
+};
+
+use crate::Interactor;
+
+use super::{InteractorEnvQuery, InteractorPrepareAsync, InteractorQueryStep};
+
+impl<'w, To, Payment, RH> InteractorPrepareAsync
+ for Tx, (), To, Payment, (), FunctionCall, RH>
+where
+ To: TxToSpecified>,
+ Payment: TxNoPayment>,
+ RH: RHListExec>,
+ RH::ListReturns: NestedTupleFlatten,
+{
+ type Exec = InteractorQueryStep<'w, RH>;
+
+ fn prepare_async(self) -> Self::Exec {
+ InteractorQueryStep {
+ step_wrapper: self.tx_to_query_step(),
+ }
+ }
+}
+
+impl<'w, RH> InteractorQueryStep<'w, RH>
+where
+ RH: RHListExec>,
+ RH::ListReturns: NestedTupleFlatten,
+{
+ pub async fn run(mut self) -> ::Unpacked {
+ self.step_wrapper
+ .env
+ .world
+ .sc_query(&mut self.step_wrapper.step)
+ .await;
+ self.step_wrapper.process_result()
+ }
+}
+
+impl Interactor {
+ pub async fn chain_query(&mut self, f: F) -> &mut Self
+ where
+ To: TxToSpecified,
+ Payment: TxNoPayment,
+ RH: RHListExec,
+ F: FnOnce(
+ TxBaseWithEnv,
+ )
+ -> Tx, RH>,
+ {
+ let env = self.new_env_data();
+ let tx_base = TxBaseWithEnv::new_with_env(env);
+ let tx = f(tx_base);
+
+ let mut step_wrapper = tx.tx_to_query_step();
+ self.sc_query(&mut step_wrapper.step).await;
+ step_wrapper.process_result();
+ self
+ }
+}
diff --git a/framework/snippets-dapp/src/interactor_tx/interactor_query_env.rs b/framework/snippets-dapp/src/interactor_tx/interactor_query_env.rs
new file mode 100644
index 0000000000..71dcd2f3b4
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_tx/interactor_query_env.rs
@@ -0,0 +1,45 @@
+use multiversx_sc_scenario::{
+ api::StaticApi,
+ multiversx_sc::types::{ManagedAddress, ManagedBuffer, Tx, TxBaseWithEnv, TxEnv},
+ scenario_model::TxExpect,
+ ScenarioTxEnv, ScenarioTxEnvData,
+};
+
+use crate::Interactor;
+
+impl Interactor {
+ pub fn query(&mut self) -> TxBaseWithEnv> {
+ let data = self.new_env_data();
+ let env = InteractorEnvQuery { world: self, data };
+ Tx::new_with_env(env)
+ }
+}
+
+pub struct InteractorEnvQuery<'w> {
+ pub world: &'w mut Interactor,
+ pub data: ScenarioTxEnvData,
+}
+
+impl<'w> TxEnv for InteractorEnvQuery<'w> {
+ type Api = StaticApi;
+
+ type RHExpect = TxExpect;
+
+ fn resolve_sender_address(&self) -> ManagedAddress {
+ panic!("Explicit sender address expected")
+ }
+
+ fn default_gas_annotation(&self) -> ManagedBuffer {
+ self.data.default_gas_annotation()
+ }
+
+ fn default_gas_value(&self) -> u64 {
+ self.data.default_gas_value()
+ }
+}
+
+impl<'w> ScenarioTxEnv for InteractorEnvQuery<'w> {
+ fn env_data(&self) -> &ScenarioTxEnvData {
+ &self.data
+ }
+}
diff --git a/framework/snippets-dapp/src/interactor_tx/interactor_query_step.rs b/framework/snippets-dapp/src/interactor_tx/interactor_query_step.rs
new file mode 100644
index 0000000000..bbb7a0996b
--- /dev/null
+++ b/framework/snippets-dapp/src/interactor_tx/interactor_query_step.rs
@@ -0,0 +1,15 @@
+use multiversx_sc_scenario::{
+ multiversx_sc::{tuple_util::NestedTupleFlatten, types::RHListExec},
+ scenario::tx_to_step::StepWrapper,
+ scenario_model::{ScQueryStep, TxResponse},
+};
+
+use super::InteractorEnvQuery;
+
+pub struct InteractorQueryStep<'w, RH>
+where
+ RH: RHListExec>,
+ RH::ListReturns: NestedTupleFlatten,
+{
+ pub(crate) step_wrapper: StepWrapper, ScQueryStep, RH>,
+}
diff --git a/framework/snippets-dapp/src/lib.rs b/framework/snippets-dapp/src/lib.rs
new file mode 100644
index 0000000000..f3639b152e
--- /dev/null
+++ b/framework/snippets-dapp/src/lib.rs
@@ -0,0 +1,24 @@
+pub mod account_tool;
+mod interactor;
+mod interactor_dns;
+mod interactor_scenario;
+mod interactor_sender;
+mod interactor_tx;
+mod multi;
+pub mod network_response;
+pub mod test_wallets;
+
+pub use env_logger;
+pub use hex;
+pub use interactor::*;
+pub use interactor_dns::*;
+pub use interactor_sender::*;
+pub use interactor_tx::*;
+pub use log;
+pub use multi::*;
+pub use multiversx_sc_scenario::{self, multiversx_sc};
+pub use multiversx_sdk_wbg as erdrs; // TODO: remove
+pub use multiversx_sdk_wbg as sdk;
+
+/// Imports normally needed in interactors, grouped together.
+pub mod imports;
diff --git a/framework/snippets-dapp/src/multi.rs b/framework/snippets-dapp/src/multi.rs
new file mode 100644
index 0000000000..973b159858
--- /dev/null
+++ b/framework/snippets-dapp/src/multi.rs
@@ -0,0 +1,9 @@
+mod homogenous_tx_buffer;
+mod interactor_multi_sc_exec;
+mod interactor_multi_sc_process;
+mod interactor_step;
+mod step_buffer;
+
+pub use homogenous_tx_buffer::HomogenousTxBuffer;
+pub use interactor_step::InteractorStep;
+pub use step_buffer::StepBuffer;
diff --git a/framework/snippets-dapp/src/multi/homogenous_tx_buffer.rs b/framework/snippets-dapp/src/multi/homogenous_tx_buffer.rs
new file mode 100644
index 0000000000..66f5dec79f
--- /dev/null
+++ b/framework/snippets-dapp/src/multi/homogenous_tx_buffer.rs
@@ -0,0 +1,65 @@
+use multiversx_sc_scenario::{
+ multiversx_sc::{
+ tuple_util::NestedTupleFlatten,
+ types::{RHListExec, TxBaseWithEnv},
+ },
+ scenario::tx_to_step::{StepWithResponse, StepWrapper, TxToStep},
+ scenario_model::TxResponse,
+ ScenarioTxEnvData,
+};
+
+use crate::{Interactor, InteractorEnvExec, InteractorStep, StepBuffer};
+
+pub struct HomogenousTxBuffer<'w, Step, RH> {
+ env: InteractorEnvExec<'w>,
+ steps: Vec>,
+}
+
+impl Interactor {
+ /// Creates a buffer that can hold multiple transactions, and then execute them all at once.
+ ///
+ /// This buffer holds transactions of the same type (call/deploy) and with identical result handler types.
+ /// Therefore, after execution, all results will have the same type.
+ pub fn homogenous_call_buffer(&mut self) -> HomogenousTxBuffer<'_, Step, RH> {
+ let data = self.new_env_data();
+ let env = InteractorEnvExec { world: self, data };
+ HomogenousTxBuffer {
+ env,
+ steps: Vec::new(),
+ }
+ }
+}
+
+impl<'w, Step, RH> HomogenousTxBuffer<'w, Step, RH>
+where
+ Step: InteractorStep + StepWithResponse,
+ RH: RHListExec,
+ RH::ListReturns: NestedTupleFlatten,
+{
+ pub fn push_tx(&mut self, f: F) -> &mut Self
+ where
+ Tx: TxToStep,
+ F: FnOnce(TxBaseWithEnv) -> Tx,
+ {
+ let env = self.env.world.new_env_data();
+ let tx_base = TxBaseWithEnv::new_with_env(env);
+ let tx = f(tx_base);
+
+ self.steps.push(tx.tx_to_step());
+
+ self
+ }
+
+ pub async fn run(mut self) -> Vec<::Unpacked> {
+ let mut step_buffer = StepBuffer::default();
+ for step in &mut self.steps {
+ step_buffer.refs.push(&mut step.step);
+ }
+ self.env.world.multi_sc_exec(step_buffer).await;
+
+ self.steps
+ .into_iter()
+ .map(|step| step.process_result())
+ .collect()
+ }
+}
diff --git a/framework/snippets-dapp/src/multi/interactor_multi_sc_exec.rs b/framework/snippets-dapp/src/multi/interactor_multi_sc_exec.rs
new file mode 100644
index 0000000000..0b8eee4891
--- /dev/null
+++ b/framework/snippets-dapp/src/multi/interactor_multi_sc_exec.rs
@@ -0,0 +1,54 @@
+use super::interactor_multi_sc_process::{update_nonces_and_sign_tx, SenderSet, Txs};
+use crate::{network_response, Interactor, InteractorStep, StepBuffer};
+use multiversx_sdk_wbg::data::transaction::Transaction;
+
+impl Interactor {
+ pub async fn multi_sc_exec(&mut self, mut buffer: StepBuffer<'_>) {
+ for step in buffer.refs.iter_mut() {
+ step.run_step(&mut self.pre_runners);
+ }
+
+ let senders = retrieve_senders(buffer.refs.as_slice());
+ self.recall_senders_nonce(senders).await;
+
+ let txs = self.retrieve_txs(&mut buffer);
+ let results = self.process_txs(txs).await;
+
+ for (i, sc_call_step) in buffer.refs.iter_mut().enumerate() {
+ sc_call_step.set_response(network_response::parse_tx_response(
+ results.get(i).unwrap().clone(),
+ ));
+ }
+
+ for step in buffer.refs.iter_mut() {
+ step.run_step(&mut self.post_runners);
+ }
+ }
+
+ fn retrieve_txs(&mut self, buffer: &mut StepBuffer<'_>) -> Vec {
+ let mut txs = Txs::new();
+
+ for sc_call_step in &mut buffer.refs {
+ let mut transaction = sc_call_step.to_transaction(self);
+ let sender_address = &sc_call_step.sender_address().value;
+ let sender = self
+ .sender_map
+ .get_mut(sender_address)
+ .expect("sender not registered");
+
+ update_nonces_and_sign_tx(&mut transaction, sender);
+ txs.push(transaction);
+ }
+ txs
+ }
+}
+
+fn retrieve_senders(sc_call_steps: &[&mut dyn InteractorStep]) -> SenderSet {
+ let mut senders = SenderSet::new();
+
+ for sc_call_step in sc_call_steps {
+ let sender_address = &sc_call_step.sender_address().value;
+ senders.insert(sender_address.clone());
+ }
+ senders
+}
diff --git a/framework/snippets-dapp/src/multi/interactor_multi_sc_process.rs b/framework/snippets-dapp/src/multi/interactor_multi_sc_process.rs
new file mode 100644
index 0000000000..f03785f510
--- /dev/null
+++ b/framework/snippets-dapp/src/multi/interactor_multi_sc_process.rs
@@ -0,0 +1,47 @@
+use crate::{multiversx_sc::types::Address, Interactor, Sender};
+use futures::future::join_all;
+use multiversx_sdk_wbg::data::transaction::{Transaction, TransactionOnNetwork};
+use std::collections::HashSet;
+
+pub(crate) type Txs = Vec;
+pub(crate) type SenderSet = HashSet;
+
+impl Interactor {
+ pub(crate) async fn recall_senders_nonce(&mut self, senders: HashSet) {
+ for sender_address in &senders {
+ let nonce = self.recall_nonce(sender_address).await;
+ let sender = self
+ .sender_map
+ .get_mut(sender_address)
+ .expect("sender not registered");
+
+ sender.current_nonce = Some(nonce);
+ println!("sender's recalled nonce: {nonce}");
+ }
+ }
+
+ pub(crate) async fn process_txs(&mut self, txs: Vec) -> Vec {
+ let mut futures = Vec::new();
+
+ for tx in &txs {
+ let tx_hash = self
+ .proxy
+ .send_transaction(tx)
+ .await
+ .expect("failed to send transaction");
+
+ println!("process tx hash: {tx_hash} with nonce: {}", tx.nonce);
+ futures.push(self.proxy.retrieve_tx_on_network(tx_hash.clone()));
+ }
+
+ join_all(futures).await
+ }
+}
+
+pub(crate) fn update_nonces_and_sign_tx(transaction: &mut Transaction, sender: &mut Sender) {
+ transaction.nonce = sender.current_nonce.unwrap();
+ sender.current_nonce = Some(sender.current_nonce.unwrap() + 1);
+
+ let signature = sender.wallet.sign_tx(&*transaction);
+ transaction.signature = Some(hex::encode(signature));
+}
diff --git a/framework/snippets-dapp/src/multi/interactor_step.rs b/framework/snippets-dapp/src/multi/interactor_step.rs
new file mode 100644
index 0000000000..8b8d0fbc71
--- /dev/null
+++ b/framework/snippets-dapp/src/multi/interactor_step.rs
@@ -0,0 +1,55 @@
+use multiversx_sc_scenario::{
+ mandos_system::ScenarioRunner,
+ scenario_model::{AddressValue, ScCallStep, ScDeployStep, TxResponse},
+};
+use multiversx_sdk_wbg::data::transaction::Transaction;
+
+use crate::Interactor;
+
+/// Describes a scenario step that can be executed in an interactor.
+pub trait InteractorStep {
+ fn to_transaction(&self, interactor: &Interactor) -> Transaction;
+
+ fn sender_address(&self) -> &AddressValue;
+
+ fn run_step(&mut self, step_runner: &mut dyn ScenarioRunner);
+
+ fn set_response(&mut self, tx_response: TxResponse);
+}
+
+impl InteractorStep for ScCallStep {
+ fn to_transaction(&self, interactor: &Interactor) -> Transaction {
+ interactor.tx_call_to_blockchain_tx(&self.tx)
+ }
+
+ fn sender_address(&self) -> &AddressValue {
+ &self.tx.from
+ }
+
+ fn run_step(&mut self, step_runner: &mut dyn ScenarioRunner) {
+ let mut clone = self.clone();
+ step_runner.run_sc_call_step(&mut clone); // TODO: make mutability uniform
+ }
+
+ fn set_response(&mut self, response: TxResponse) {
+ self.save_response(response);
+ }
+}
+
+impl InteractorStep for ScDeployStep {
+ fn to_transaction(&self, interactor: &Interactor) -> Transaction {
+ interactor.sc_deploy_to_blockchain_tx(self)
+ }
+
+ fn sender_address(&self) -> &AddressValue {
+ &self.tx.from
+ }
+
+ fn run_step(&mut self, step_runner: &mut dyn ScenarioRunner) {
+ step_runner.run_sc_deploy_step(self);
+ }
+
+ fn set_response(&mut self, response: TxResponse) {
+ self.save_response(response);
+ }
+}
diff --git a/framework/snippets-dapp/src/multi/step_buffer.rs b/framework/snippets-dapp/src/multi/step_buffer.rs
new file mode 100644
index 0000000000..529b790ff5
--- /dev/null
+++ b/framework/snippets-dapp/src/multi/step_buffer.rs
@@ -0,0 +1,60 @@
+use multiversx_sc_scenario::scenario_model::{ScCallStep, ScDeployStep};
+
+use crate::InteractorStep;
+
+#[derive(Default)]
+pub struct StepBuffer<'a> {
+ pub refs: Vec<&'a mut dyn InteractorStep>,
+}
+
+impl<'a> StepBuffer<'a> {
+ pub fn new() -> Self {
+ Self::default()
+ }
+
+ pub fn add_sc_call<'b, S>(&'a mut self, step: &'b mut S)
+ where
+ 'b: 'a,
+ S: AsMut,
+ {
+ self.refs.push(step.as_mut());
+ }
+
+ pub fn add_sc_call_vec<'b, S>(&'a mut self, steps: &'b mut Vec)
+ where
+ 'b: 'a,
+ S: AsMut,
+ {
+ for step in steps {
+ self.refs.push(step.as_mut());
+ }
+ }
+
+ pub fn from_sc_call_vec<'b, S>(steps: &'b mut Vec) -> Self
+ where
+ 'b: 'a,
+ S: AsMut,
+ {
+ let mut buffer = Self::default();
+ for step in steps {
+ buffer.refs.push(step.as_mut());
+ }
+ buffer
+ }
+
+ pub fn from_sc_deploy_vec<'b, S>(steps: &'b mut Vec) -> Self
+ where
+ 'b: 'a,
+ S: AsMut,
+ {
+ let mut buffer = Self::default();
+ for step in steps {
+ buffer.refs.push(step.as_mut());
+ }
+ buffer
+ }
+
+ pub fn to_refs_vec(&'a self) -> Vec<&'a dyn InteractorStep> {
+ self.refs.iter().map(|r| &**r).collect()
+ }
+}
diff --git a/framework/snippets-dapp/src/network_response.rs b/framework/snippets-dapp/src/network_response.rs
new file mode 100644
index 0000000000..e77525fa16
--- /dev/null
+++ b/framework/snippets-dapp/src/network_response.rs
@@ -0,0 +1,232 @@
+use multiversx_sc_scenario::{
+ imports::{Address, ESDTSystemSCAddress},
+ multiversx_chain_vm::crypto_functions::keccak256,
+ scenario_model::{Log, TxResponse, TxResponseStatus},
+};
+use multiversx_sdk_wbg::{
+ data::transaction::{ApiSmartContractResult, Events, TransactionOnNetwork},
+ utils::base64_decode,
+};
+
+const SC_DEPLOY_PROCESSING_TYPE: &str = "SCDeployment";
+const LOG_IDENTIFIER_SIGNAL_ERROR: &str = "signalError";
+
+/// Creates a [`TxResponse`] from a [`TransactionOnNetwork`].
+pub fn parse_tx_response(tx: TransactionOnNetwork) -> TxResponse {
+ let tx_error = process_signal_error(&tx);
+ if !tx_error.is_success() {
+ return TxResponse {
+ tx_error,
+ ..Default::default()
+ };
+ }
+
+ process_success(&tx)
+}
+
+fn process_signal_error(tx: &TransactionOnNetwork) -> TxResponseStatus {
+ if let Some(event) = find_log(tx, LOG_IDENTIFIER_SIGNAL_ERROR) {
+ let topics = event.topics.as_ref();
+ if let Some(error) = process_topics_error(topics) {
+ return TxResponseStatus::signal_error(&error);
+ }
+
+ let error_raw = base64_decode(topics.unwrap().get(1).unwrap());
+ let error = String::from_utf8(error_raw).unwrap();
+ return TxResponseStatus::signal_error(&error);
+ }
+
+ TxResponseStatus::default()
+}
+
+fn process_success(tx: &TransactionOnNetwork) -> TxResponse {
+ TxResponse {
+ out: process_out(tx),
+ new_deployed_address: process_new_deployed_address(tx),
+ new_issued_token_identifier: process_new_issued_token_identifier(tx),
+ logs: process_logs(tx),
+ ..Default::default()
+ }
+}
+
+fn process_out(tx: &TransactionOnNetwork) -> Vec> {
+ let out_scr = tx.smart_contract_results.iter().find(is_out_scr);
+
+ if let Some(out_scr) = out_scr {
+ decode_scr_data_or_panic(&out_scr.data)
+ } else {
+ process_out_from_log(tx).unwrap_or_default()
+ }
+}
+
+fn process_logs(tx: &TransactionOnNetwork) -> Vec {
+ if let Some(api_logs) = &tx.logs {
+ return api_logs
+ .events
+ .iter()
+ .map(|event| Log {
+ address: Address::from_slice(&event.address.to_bytes()),
+ endpoint: event.identifier.clone(),
+ topics: extract_topics(event),
+ data: extract_data(event),
+ })
+ .collect::>();
+ }
+
+ Vec::new()
+}
+
+fn extract_data(event: &Events) -> Vec> {
+ let mut out: Vec> = Vec::new();
+ event
+ .data
+ .for_each(|data_field| out.push(data_field.clone().into_bytes()));
+ out
+}
+
+fn extract_topics(event: &Events) -> Vec> {
+ event
+ .topics
+ .clone()
+ .unwrap_or_default()
+ .into_iter()
+ .map(|s| s.into_bytes())
+ .collect()
+}
+
+fn process_out_from_log(tx: &TransactionOnNetwork) -> Option>> {
+ if let Some(logs) = &tx.logs {
+ logs.events.iter().rev().find_map(|event| {
+ if event.identifier == "writeLog" {
+ let mut out = Vec::new();
+ event.data.for_each(|data_member| {
+ let decoded_data = String::from_utf8(base64_decode(data_member)).unwrap();
+
+ if decoded_data.starts_with('@') {
+ let out_content = decode_scr_data_or_panic(decoded_data.as_str());
+ out.extend(out_content);
+ }
+ });
+ return Some(out);
+ }
+
+ None
+ })
+ } else {
+ None
+ }
+}
+
+fn process_new_deployed_address(tx: &TransactionOnNetwork) -> Option {
+ if tx.processing_type_on_destination != SC_DEPLOY_PROCESSING_TYPE {
+ return None;
+ }
+
+ let sender_address_bytes = tx.sender.to_bytes();
+ let sender_nonce_bytes = tx.nonce.to_le_bytes();
+ let mut bytes_to_hash: Vec = Vec::new();
+ bytes_to_hash.extend_from_slice(&sender_address_bytes);
+ bytes_to_hash.extend_from_slice(&sender_nonce_bytes);
+
+ let address_keccak = keccak256(&bytes_to_hash);
+
+ let mut address = [0u8; 32];
+
+ address[0..8].copy_from_slice(&[0u8; 8]);
+ address[8..10].copy_from_slice(&[5, 0]);
+ address[10..30].copy_from_slice(&address_keccak[10..30]);
+ address[30..32].copy_from_slice(&sender_address_bytes[30..32]);
+
+ Some(Address::from(address))
+}
+
+fn process_new_issued_token_identifier(tx: &TransactionOnNetwork) -> Option {
+ let original_tx_data = String::from_utf8(base64_decode(tx.data.as_ref().unwrap())).unwrap();
+
+ for scr in tx.smart_contract_results.iter() {
+ if scr.sender.to_bech32_string().unwrap() != ESDTSystemSCAddress.to_bech32_string() {
+ continue;
+ }
+
+ let prev_tx_data: &str = if let Some(prev_tx) = tx
+ .smart_contract_results
+ .iter()
+ .find(|e| e.hash == scr.prev_tx_hash)
+ {
+ prev_tx.data.as_ref()
+ } else if &scr.prev_tx_hash == tx.hash.as_ref().unwrap() {
+ &original_tx_data
+ } else {
+ continue;
+ };
+
+ let is_issue_fungible = prev_tx_data.starts_with("issue@");
+ let is_issue_semi_fungible = prev_tx_data.starts_with("issueSemiFungible@");
+ let is_issue_non_fungible = prev_tx_data.starts_with("issueNonFungible@");
+ let is_register_meta_esdt = prev_tx_data.starts_with("registerMetaESDT@");
+ let is_register_and_set_all_roles_esdt =
+ prev_tx_data.starts_with("registerAndSetAllRoles@");
+
+ if !is_issue_fungible
+ && !is_issue_semi_fungible
+ && !is_issue_non_fungible
+ && !is_register_meta_esdt
+ && !is_register_and_set_all_roles_esdt
+ {
+ continue;
+ }
+
+ if scr.data.starts_with("ESDTTransfer@") {
+ let encoded_tid = scr.data.split('@').nth(1);
+ return Some(String::from_utf8(hex::decode(encoded_tid?).unwrap()).unwrap());
+ } else if scr.data.starts_with("@00@") || scr.data.starts_with("@6f6b@") {
+ let encoded_tid = scr.data.split('@').nth(2);
+ return Some(String::from_utf8(hex::decode(encoded_tid?).unwrap()).unwrap());
+ }
+ }
+ None
+}
+
+fn find_log<'a>(tx: &'a TransactionOnNetwork, log_identifier: &str) -> Option<&'a Events> {
+ if let Some(logs) = &tx.logs {
+ logs.events
+ .iter()
+ .find(|event| event.identifier == log_identifier)
+ } else {
+ None
+ }
+}
+
+/// Checks for invalid topics.
+pub fn process_topics_error(topics: Option<&Vec>) -> Option {
+ if topics.is_none() {
+ return Some("missing topics".to_string());
+ }
+
+ let topics = topics.unwrap();
+ if topics.len() != 2 {
+ Some(format!(
+ "expected to have 2 topics, found {} instead",
+ topics.len()
+ ))
+ } else {
+ None
+ }
+}
+
+/// Decodes the data of a smart contract result.
+pub fn decode_scr_data_or_panic(data: &str) -> Vec> {
+ let mut split = data.split('@');
+ let _ = split.next().expect("SCR data should start with '@'");
+ let result_code = split.next().expect("missing result code");
+ assert_eq!(result_code, "6f6b", "result code is not 'ok'");
+
+ split
+ .map(|encoded_arg| hex::decode(encoded_arg).expect("error hex-decoding result"))
+ .collect()
+}
+
+/// Checks if the given smart contract result is an out smart contract result.
+pub fn is_out_scr(scr: &&ApiSmartContractResult) -> bool {
+ scr.nonce != 0 && scr.data.starts_with('@')
+}
diff --git a/framework/snippets-dapp/src/test_wallets.rs b/framework/snippets-dapp/src/test_wallets.rs
new file mode 100644
index 0000000000..2b79cc948d
--- /dev/null
+++ b/framework/snippets-dapp/src/test_wallets.rs
@@ -0,0 +1,65 @@
+use multiversx_sdk_wbg::wallet::Wallet;
+
+fn test_wallet(pem_file_contents: &str) -> Wallet {
+ Wallet::from_pem_file_contents(pem_file_contents.to_string()).unwrap()
+}
+
+/// Test wallet. Do not use on mainnet.
+pub fn alice() -> Wallet {
+ test_wallet(include_str!("test_wallets/alice.pem"))
+}
+
+/// Test wallet. Do not use on mainnet.
+pub fn bob() -> Wallet {
+ test_wallet(include_str!("test_wallets/bob.pem"))
+}
+
+/// Test wallet. Do not use on mainnet.
+pub fn carol() -> Wallet {
+ test_wallet(include_str!("test_wallets/carol.pem"))
+}
+
+/// Test wallet. Do not use on mainnet.
+pub fn dan() -> Wallet {
+ test_wallet(include_str!("test_wallets/dan.pem"))
+}
+
+/// Test wallet. Do not use on mainnet.
+pub fn eve() -> Wallet {
+ test_wallet(include_str!("test_wallets/eve.pem"))
+}
+
+/// Test wallet. Do not use on mainnet.
+pub fn frank() -> Wallet {
+ test_wallet(include_str!("test_wallets/frank.pem"))
+}
+
+/// Test wallet. Do not use on mainnet.
+pub fn grace() -> Wallet {
+ test_wallet(include_str!("test_wallets/grace.pem"))
+}
+
+/// Test wallet. Do not use on mainnet.
+pub fn heidi() -> Wallet {
+ test_wallet(include_str!("test_wallets/heidi.pem"))
+}
+
+/// Test wallet. Do not use on mainnet.
+pub fn ivan() -> Wallet {
+ test_wallet(include_str!("test_wallets/ivan.pem"))
+}
+
+/// Test wallet. Do not use on mainnet.
+pub fn judy() -> Wallet {
+ test_wallet(include_str!("test_wallets/judy.pem"))
+}
+
+/// Test wallet. Do not use on mainnet.
+pub fn mallory() -> Wallet {
+ test_wallet(include_str!("test_wallets/mallory.pem"))
+}
+
+/// Test wallet. Do not use on mainnet.
+pub fn mike() -> Wallet {
+ test_wallet(include_str!("test_wallets/mike.pem"))
+}
diff --git a/framework/snippets-dapp/src/test_wallets/alice.pem b/framework/snippets-dapp/src/test_wallets/alice.pem
new file mode 100644
index 0000000000..d27bb68b48
--- /dev/null
+++ b/framework/snippets-dapp/src/test_wallets/alice.pem
@@ -0,0 +1,5 @@
+-----BEGIN PRIVATE KEY for erd1qyu5wthldzr8wx5c9ucg8kjagg0jfs53s8nr3zpz3hypefsdd8ssycr6th-----
+NDEzZjQyNTc1ZjdmMjZmYWQzMzE3YTc3ODc3MTIxMmZkYjgwMjQ1ODUwOTgxZTQ4
+YjU4YTRmMjVlMzQ0ZThmOTAxMzk0NzJlZmY2ODg2NzcxYTk4MmYzMDgzZGE1ZDQy
+MWYyNGMyOTE4MWU2Mzg4ODIyOGRjODFjYTYwZDY5ZTE=
+-----END PRIVATE KEY for erd1qyu5wthldzr8wx5c9ucg8kjagg0jfs53s8nr3zpz3hypefsdd8ssycr6th-----
\ No newline at end of file
diff --git a/framework/snippets-dapp/src/test_wallets/bob.pem b/framework/snippets-dapp/src/test_wallets/bob.pem
new file mode 100644
index 0000000000..00b5bc4ef2
--- /dev/null
+++ b/framework/snippets-dapp/src/test_wallets/bob.pem
@@ -0,0 +1,5 @@
+-----BEGIN PRIVATE KEY for erd1spyavw0956vq68xj8y4tenjpq2wd5a9p2c6j8gsz7ztyrnpxrruqzu66jx-----
+YjhjYTZmODIwM2ZiNGI1NDVhOGU4M2M1Mzg0ZGEwMzNjNDE1ZGIxNTViNTNmYjVi
+OGViYTdmZjVhMDM5ZDYzOTgwNDlkNjM5ZTVhNjk4MGQxY2QyMzkyYWJjY2U0MTAy
+OWNkYTc0YTE1NjM1MjNhMjAyZjA5NjQxY2MyNjE4Zjg=
+-----END PRIVATE KEY for erd1spyavw0956vq68xj8y4tenjpq2wd5a9p2c6j8gsz7ztyrnpxrruqzu66jx-----
\ No newline at end of file
diff --git a/framework/snippets-dapp/src/test_wallets/carol.pem b/framework/snippets-dapp/src/test_wallets/carol.pem
new file mode 100644
index 0000000000..5551c9c0ee
--- /dev/null
+++ b/framework/snippets-dapp/src/test_wallets/carol.pem
@@ -0,0 +1,5 @@
+-----BEGIN PRIVATE KEY for erd1k2s324ww2g0yj38qn2ch2jwctdy8mnfxep94q9arncc6xecg3xaq6mjse8-----
+ZTI1M2E1NzFjYTE1M2RjMmFlZTg0NTgxOWY3NGJjYzk3NzNiMDU4NmVkZWFkMTVh
+OTRjYjcyMzVhNTAyNzQzNmIyYTExNTU1Y2U1MjFlNDk0NGUwOWFiMTc1NDlkODVi
+NDg3ZGNkMjZjODRiNTAxN2EzOWUzMWEzNjcwODg5YmE=
+-----END PRIVATE KEY for erd1k2s324ww2g0yj38qn2ch2jwctdy8mnfxep94q9arncc6xecg3xaq6mjse8-----
\ No newline at end of file
diff --git a/framework/snippets-dapp/src/test_wallets/dan.pem b/framework/snippets-dapp/src/test_wallets/dan.pem
new file mode 100644
index 0000000000..f112d8f6d6
--- /dev/null
+++ b/framework/snippets-dapp/src/test_wallets/dan.pem
@@ -0,0 +1,5 @@
+-----BEGIN PRIVATE KEY for erd1kyaqzaprcdnv4luvanah0gfxzzsnpaygsy6pytrexll2urtd05ts9vegu7-----
+NTRlNDc5NzQzZTUxMjhlMGUyOWRiNGQ0YTIxZDc1OWI2OTAxMjQxZmFjNzdjNTAy
+YzhlZjcwZGM3OWExMmE4YmIxM2EwMTc0MjNjMzY2Y2FmZjhjZWNmYjc3YTEyNjEw
+YTEzMGY0ODg4MTM0MTIyYzc5MzdmZWFlMGQ2ZDdkMTc=
+-----END PRIVATE KEY for erd1kyaqzaprcdnv4luvanah0gfxzzsnpaygsy6pytrexll2urtd05ts9vegu7-----
\ No newline at end of file
diff --git a/framework/snippets-dapp/src/test_wallets/eve.pem b/framework/snippets-dapp/src/test_wallets/eve.pem
new file mode 100644
index 0000000000..dcbe731fbc
--- /dev/null
+++ b/framework/snippets-dapp/src/test_wallets/eve.pem
@@ -0,0 +1,5 @@
+-----BEGIN PRIVATE KEY for erd18tudnj2z8vjh0339yu3vrkgzz2jpz8mjq0uhgnmklnap6z33qqeszq2yn4-----
+NjliODJmMzlhMTQ2MWI0MzFmOGZhMjY3Zjg3YTBiZjc5NDAyN2NlYTM3ZGM2NjE5
+MGU2NzQwYTZlNGNjY2RmMDNhZjhkOWM5NDIzYjI1NzdjNjI1MjcyMmMxZDkwMjEy
+YTQxMTFmNzIwM2Y5NzQ0Zjc2ZmNmYTFkMGEzMTAwMzM=
+-----END PRIVATE KEY for erd18tudnj2z8vjh0339yu3vrkgzz2jpz8mjq0uhgnmklnap6z33qqeszq2yn4-----
\ No newline at end of file
diff --git a/framework/snippets-dapp/src/test_wallets/frank.pem b/framework/snippets-dapp/src/test_wallets/frank.pem
new file mode 100644
index 0000000000..6d04639d50
--- /dev/null
+++ b/framework/snippets-dapp/src/test_wallets/frank.pem
@@ -0,0 +1,5 @@
+-----BEGIN PRIVATE KEY for erd1kdl46yctawygtwg2k462307dmz2v55c605737dp3zkxh04sct7asqylhyv-----
+NzgyMGE5MTE4OWM3MjdjMDc1YjQ5OWM1MjNmMGRjNDAzZmVkMzc5OTBlYzhkMzdm
+NGJkZWNiOGI2OGZkMmE5N2IzN2Y1ZDEzMGJlYjg4ODViOTBhYjU3NGE4YmZjZGQ4
+OTRjYTUzMWE3ZDNkMWYzNDMxMTU4ZDc3ZDYxODVmYmI=
+-----END PRIVATE KEY for erd1kdl46yctawygtwg2k462307dmz2v55c605737dp3zkxh04sct7asqylhyv-----
\ No newline at end of file
diff --git a/framework/snippets-dapp/src/test_wallets/grace.pem b/framework/snippets-dapp/src/test_wallets/grace.pem
new file mode 100644
index 0000000000..7b0836a5f9
--- /dev/null
+++ b/framework/snippets-dapp/src/test_wallets/grace.pem
@@ -0,0 +1,5 @@
+-----BEGIN PRIVATE KEY for erd1r69gk66fmedhhcg24g2c5kn2f2a5k4kvpr6jfw67dn2lyydd8cfswy6ede-----
+ODY5Yzk4ZGYwYjExZmRhMDgwNGQ3ODM1NGVjYTQzMWY4N2E2ZTkxMGZhZTE0MDgx
+ZjczOGMzMTZhMjVlYTQwOTFlOGE4YjZiNDlkZTViN2JlMTBhYWExNThhNWE2YTRh
+YmI0YjU2Y2MwOGY1MjRiYjVlNmNkNWYyMTFhZDNlMTM=
+-----END PRIVATE KEY for erd1r69gk66fmedhhcg24g2c5kn2f2a5k4kvpr6jfw67dn2lyydd8cfswy6ede-----
\ No newline at end of file
diff --git a/framework/snippets-dapp/src/test_wallets/heidi.pem b/framework/snippets-dapp/src/test_wallets/heidi.pem
new file mode 100644
index 0000000000..a8a693f20d
--- /dev/null
+++ b/framework/snippets-dapp/src/test_wallets/heidi.pem
@@ -0,0 +1,5 @@
+-----BEGIN PRIVATE KEY for erd1dc3yzxxeq69wvf583gw0h67td226gu2ahpk3k50qdgzzym8npltq7ndgha-----
+YjMzODcyMjMzMjFjNTg3YzM1MTE5OGFkYzI1MzFjODIwYTM3OGQzNzQ4OTU2YjNk
+YWUyZTBmNWExZGFhN2NhMTZlMjI0MTE4ZDkwNjhhZTYyNjg3OGExY2ZiZWJjYjZh
+OTVhNDcxNWRiODZkMWI1MWUwNmEwNDIyNmNmMzBmZDY=
+-----END PRIVATE KEY for erd1dc3yzxxeq69wvf583gw0h67td226gu2ahpk3k50qdgzzym8npltq7ndgha-----
\ No newline at end of file
diff --git a/framework/snippets-dapp/src/test_wallets/ivan.pem b/framework/snippets-dapp/src/test_wallets/ivan.pem
new file mode 100644
index 0000000000..e9cdb61ac6
--- /dev/null
+++ b/framework/snippets-dapp/src/test_wallets/ivan.pem
@@ -0,0 +1,5 @@
+-----BEGIN PRIVATE KEY for erd13x29rvmp4qlgn4emgztd8jgvyzdj0p6vn37tqxas3v9mfhq4dy7shalqrx-----
+MDhjNjE1NTUyMjFmMWYxMjE0M2Q3MWJiZWQ4MzFkMjk0N2U0OTRhMjJjZmQxN2I1
+NzQxMzhiY2M5ODQ1MzZkMzg5OTQ1MWIzNjFhODNlODlkNzNiNDA5NmQzYzkwYzIw
+OWIyNzg3NGM5YzdjYjAxYmIwOGIwYmI0ZGMxNTY5M2Q=
+-----END PRIVATE KEY for erd13x29rvmp4qlgn4emgztd8jgvyzdj0p6vn37tqxas3v9mfhq4dy7shalqrx-----
\ No newline at end of file
diff --git a/framework/snippets-dapp/src/test_wallets/judy.pem b/framework/snippets-dapp/src/test_wallets/judy.pem
new file mode 100644
index 0000000000..23808c01ea
--- /dev/null
+++ b/framework/snippets-dapp/src/test_wallets/judy.pem
@@ -0,0 +1,5 @@
+-----BEGIN PRIVATE KEY for erd1fggp5ru0jhcjrp5rjqyqrnvhr3sz3v2e0fm3ktknvlg7mcyan54qzccnan-----
+MDgzZmQ2ZjAxYzRjMGZiMjUzY2QzOGMxMTE5OThiNGEzYjUzZDQyOTAwOGI4Mjhl
+NzZhYzk3ZGE2ZjU4NTgyYTRhMTAxYTBmOGY5NWYxMjE4NjgzOTAwODAxY2Q5NzFj
+NjAyOGIxNTk3YTc3MWIyZWQzNjdkMWVkZTA5ZDlkMmE=
+-----END PRIVATE KEY for erd1fggp5ru0jhcjrp5rjqyqrnvhr3sz3v2e0fm3ktknvlg7mcyan54qzccnan-----
\ No newline at end of file
diff --git a/framework/snippets-dapp/src/test_wallets/mallory.pem b/framework/snippets-dapp/src/test_wallets/mallory.pem
new file mode 100644
index 0000000000..be452cd01a
--- /dev/null
+++ b/framework/snippets-dapp/src/test_wallets/mallory.pem
@@ -0,0 +1,5 @@
+-----BEGIN PRIVATE KEY for erd1z32fx8l6wk9tx4j555sxk28fm0clhr0cl88dpyam9zr7kw0hu7hsx2j524-----
+OTVjMWMwMzRlM2NmNzczNzdmMTU3NTFhYWZjZmZiMmEyZWIyZDE2NDAxYzY3MTQ0
+NDIyZTFkMDNlYzIwYWM1MjE0NTQ5MzFmZmE3NThhYjM1NjU0YTUyMDZiMjhlOWRi
+ZjFmYjhkZjhmOWNlZDA5M2JiMjg4N2ViMzlmN2U3YWY=
+-----END PRIVATE KEY for erd1z32fx8l6wk9tx4j555sxk28fm0clhr0cl88dpyam9zr7kw0hu7hsx2j524-----
\ No newline at end of file
diff --git a/framework/snippets-dapp/src/test_wallets/mike.pem b/framework/snippets-dapp/src/test_wallets/mike.pem
new file mode 100644
index 0000000000..b2c01e67eb
--- /dev/null
+++ b/framework/snippets-dapp/src/test_wallets/mike.pem
@@ -0,0 +1,5 @@
+-----BEGIN PRIVATE KEY for erd1uv40ahysflse896x4ktnh6ecx43u7cmy9wnxnvcyp7deg299a4sq6vaywa-----
+Y2JkMjYzNThmMDg0YWZlMDA0ZDUzZjQ2NzMwM2Q3MTMzZjU1MzBiYjhkODE2NzUx
+MWI3YzEyNjg1YWJjNTY4N2UzMmFmZWRjOTA0ZmUxOTM5NzQ2YWQ5NzNiZWIzODM1
+NjNjZjYzNjQyYmE2NjliMzA0MGY5Yjk0MjhhNWVkNjA=
+-----END PRIVATE KEY for erd1uv40ahysflse896x4ktnh6ecx43u7cmy9wnxnvcyp7deg299a4sq6vaywa-----
\ No newline at end of file
diff --git a/framework/snippets/src/interactor_scenario/interactor_sc_call.rs b/framework/snippets/src/interactor_scenario/interactor_sc_call.rs
index f0b01badab..6b4f71acac 100644
--- a/framework/snippets/src/interactor_scenario/interactor_sc_call.rs
+++ b/framework/snippets/src/interactor_scenario/interactor_sc_call.rs
@@ -1,3 +1,4 @@
+use crate::sdk::{data::transaction::Transaction, utils::base64_encode};
use crate::{address_h256_to_erdrs, mandos_to_erdrs_address, network_response, Interactor};
use log::info;
use multiversx_sc_scenario::{
@@ -5,7 +6,6 @@ use multiversx_sc_scenario::{
scenario::ScenarioRunner,
scenario_model::{ScCallStep, SetStateStep, TxCall},
};
-use crate::sdk::{data::transaction::Transaction, utils::base64_encode};
impl Interactor {
pub async fn sc_call(&mut self, mut sc_call_step: S)
diff --git a/framework/snippets/src/interactor_scenario/interactor_sc_deploy.rs b/framework/snippets/src/interactor_scenario/interactor_sc_deploy.rs
index 764cff02c6..4ef37bb7b4 100644
--- a/framework/snippets/src/interactor_scenario/interactor_sc_deploy.rs
+++ b/framework/snippets/src/interactor_scenario/interactor_sc_deploy.rs
@@ -1,3 +1,7 @@
+use crate::sdk::{
+ data::{address::Address as ErdrsAddress, transaction::Transaction},
+ utils::base64_encode,
+};
use crate::{mandos_to_erdrs_address, network_response, Interactor};
use log::info;
use multiversx_sc_scenario::{
@@ -5,10 +9,6 @@ use multiversx_sc_scenario::{
mandos_system::ScenarioRunner,
scenario_model::{ScDeployStep, SetStateStep},
};
-use crate::sdk::{
- data::{address::Address as ErdrsAddress, transaction::Transaction},
- utils::base64_encode,
-};
const DEPLOY_RECEIVER: [u8; 32] = [0u8; 32];
diff --git a/framework/snippets/src/interactor_scenario/interactor_vm_query.rs b/framework/snippets/src/interactor_scenario/interactor_vm_query.rs
index 87f3d444a2..b1dd0440dd 100644
--- a/framework/snippets/src/interactor_scenario/interactor_vm_query.rs
+++ b/framework/snippets/src/interactor_scenario/interactor_vm_query.rs
@@ -1,5 +1,6 @@
#![allow(deprecated)]
+use crate::sdk::{data::vm::VmValueRequest, utils::base64_decode};
use crate::{address_h256_to_erdrs, Interactor};
use log::info;
use multiversx_sc_scenario::{
@@ -8,7 +9,6 @@ use multiversx_sc_scenario::{
multiversx_sc::{abi::TypeAbiFrom, codec::TopDecodeMulti, types::ContractCall},
scenario_model::{ScQueryStep, TxResponse},
};
-use crate::sdk::{data::vm::VmValueRequest, utils::base64_decode};
impl Interactor {
pub async fn sc_query(&mut self, mut step: S) -> &mut Self
diff --git a/framework/snippets/src/interactor_sender.rs b/framework/snippets/src/interactor_sender.rs
index 37cca670b3..4e5b957eba 100644
--- a/framework/snippets/src/interactor_sender.rs
+++ b/framework/snippets/src/interactor_sender.rs
@@ -1,6 +1,6 @@
+use crate::sdk::{data::transaction::Transaction, wallet::Wallet};
use log::debug;
use multiversx_sc_scenario::multiversx_sc::types::Address;
-use crate::sdk::{data::transaction::Transaction, wallet::Wallet};
use crate::{address_h256_to_erdrs, Interactor};
diff --git a/framework/snippets/src/multi/interactor_multi_sc_process.rs b/framework/snippets/src/multi/interactor_multi_sc_process.rs
index e842a6ae15..69a7c73207 100644
--- a/framework/snippets/src/multi/interactor_multi_sc_process.rs
+++ b/framework/snippets/src/multi/interactor_multi_sc_process.rs
@@ -1,6 +1,6 @@
+use crate::sdk::data::transaction::{Transaction, TransactionOnNetwork};
use crate::{multiversx_sc::types::Address, Interactor, Sender};
use futures::future::join_all;
-use crate::sdk::data::transaction::{Transaction, TransactionOnNetwork};
use std::collections::HashSet;
pub(crate) type Txs = Vec;
diff --git a/framework/snippets/src/multi/interactor_step.rs b/framework/snippets/src/multi/interactor_step.rs
index 7b2a8a0db2..c0d38dec8c 100644
--- a/framework/snippets/src/multi/interactor_step.rs
+++ b/framework/snippets/src/multi/interactor_step.rs
@@ -1,8 +1,8 @@
+use crate::sdk::data::transaction::Transaction;
use multiversx_sc_scenario::{
mandos_system::ScenarioRunner,
scenario_model::{AddressValue, ScCallStep, ScDeployStep, TxResponse},
};
-use crate::sdk::data::transaction::Transaction;
use crate::Interactor;
diff --git a/framework/snippets/src/network_response.rs b/framework/snippets/src/network_response.rs
index a5a075d438..7e48efb523 100644
--- a/framework/snippets/src/network_response.rs
+++ b/framework/snippets/src/network_response.rs
@@ -1,12 +1,12 @@
+use crate::sdk::{
+ data::transaction::{ApiSmartContractResult, Events, TransactionOnNetwork},
+ utils::base64_decode,
+};
use multiversx_sc_scenario::{
imports::{Address, ESDTSystemSCAddress},
multiversx_chain_vm::crypto_functions::keccak256,
scenario_model::{Log, TxResponse, TxResponseStatus},
};
-use crate::sdk::{
- data::transaction::{ApiSmartContractResult, Events, TransactionOnNetwork},
- utils::base64_decode,
-};
const SC_DEPLOY_PROCESSING_TYPE: &str = "SCDeployment";
const LOG_IDENTIFIER_SIGNAL_ERROR: &str = "signalError";
diff --git a/sdk/core/src/data/network_status.rs b/sdk/core/src/data/network_status.rs
index 3f19b29a00..954fc02db0 100644
--- a/sdk/core/src/data/network_status.rs
+++ b/sdk/core/src/data/network_status.rs
@@ -1,7 +1,7 @@
use serde::{Deserialize, Serialize};
// NetworkStatus holds the network status details of a specified shard
-#[derive(Debug, Clone, Serialize, Deserialize)]
+#[derive(Debug, Default, Clone, Serialize, Deserialize, PartialEq, Eq)]
pub struct NetworkStatus {
#[serde(rename = "erd_current_round")]
pub current_round: u64,
diff --git a/sdk/reqwest/Cargo.toml b/sdk/reqwest/Cargo.toml
index 2758ada520..cb23f8851d 100644
--- a/sdk/reqwest/Cargo.toml
+++ b/sdk/reqwest/Cargo.toml
@@ -25,4 +25,4 @@ log = "0.4.17"
[dependencies.multiversx-sdk]
version = "=0.6.0"
-path = "../core"
\ No newline at end of file
+path = "../core"
diff --git a/sdk/reqwest/examples/sign_tx.rs b/sdk/reqwest/examples/sign_tx.rs
index 3320bb70c1..1e4f61ad82 100644
--- a/sdk/reqwest/examples/sign_tx.rs
+++ b/sdk/reqwest/examples/sign_tx.rs
@@ -1,7 +1,7 @@
use multiversx_sdk_reqwest::{
core::data::transaction::Transaction,
- gateway::{GatewayProxy, DEVNET_GATEWAY},
core::wallet::Wallet,
+ gateway::{GatewayProxy, DEVNET_GATEWAY},
};
#[tokio::main]
diff --git a/sdk/reqwest/examples/sign_txs.rs b/sdk/reqwest/examples/sign_txs.rs
index aadeafec51..94d86b6054 100644
--- a/sdk/reqwest/examples/sign_txs.rs
+++ b/sdk/reqwest/examples/sign_txs.rs
@@ -1,7 +1,7 @@
use multiversx_sdk_reqwest::{
core::data::transaction::Transaction,
- gateway::{GatewayProxy, DEVNET_GATEWAY},
core::wallet::Wallet,
+ gateway::{GatewayProxy, DEVNET_GATEWAY},
};
#[tokio::main]
diff --git a/sdk/reqwest/examples/vm_query.rs b/sdk/reqwest/examples/vm_query.rs
index 4671505929..8f277df35e 100644
--- a/sdk/reqwest/examples/vm_query.rs
+++ b/sdk/reqwest/examples/vm_query.rs
@@ -1,7 +1,7 @@
use multiversx_sdk_reqwest::{
core::data::{address::Address, vm::VmValueRequest},
- gateway::{GatewayProxy, DEVNET_GATEWAY},
core::wallet::Wallet,
+ gateway::{GatewayProxy, DEVNET_GATEWAY},
};
#[tokio::main]
diff --git a/sdk/reqwest/src/gateway/gateway_account.rs b/sdk/reqwest/src/gateway/gateway_account.rs
index f0de122694..d35ff86edb 100644
--- a/sdk/reqwest/src/gateway/gateway_account.rs
+++ b/sdk/reqwest/src/gateway/gateway_account.rs
@@ -1,10 +1,10 @@
+use anyhow::{anyhow, Result};
use multiversx_sdk::data::{
account::{Account, AccountResponse},
account_storage::AccountStorageResponse,
address::Address,
esdt::{EsdtBalance, EsdtBalanceResponse, EsdtRolesResponse},
};
-use anyhow::{anyhow, Result};
use std::collections::HashMap;
use super::GatewayProxy;
diff --git a/sdk/reqwest/src/gateway/gateway_block.rs b/sdk/reqwest/src/gateway/gateway_block.rs
index 7b23436f8d..27d3697305 100644
--- a/sdk/reqwest/src/gateway/gateway_block.rs
+++ b/sdk/reqwest/src/gateway/gateway_block.rs
@@ -1,8 +1,8 @@
+use anyhow::{anyhow, Result};
use multiversx_sdk::data::{
hyperblock::{HyperBlock, HyperBlockResponse},
network_status::NetworkStatusResponse,
};
-use anyhow::{anyhow, Result};
use super::GatewayProxy;
use super::METACHAIN_SHARD_ID;
diff --git a/sdk/reqwest/src/gateway/gateway_network.rs b/sdk/reqwest/src/gateway/gateway_network.rs
index 19b5d6c865..9763a61b37 100644
--- a/sdk/reqwest/src/gateway/gateway_network.rs
+++ b/sdk/reqwest/src/gateway/gateway_network.rs
@@ -1,8 +1,8 @@
+use anyhow::{anyhow, Result};
use multiversx_sdk::data::{
network_config::{NetworkConfig, NetworkConfigResponse},
network_economics::{NetworkEconomics, NetworkEconomicsResponse},
};
-use anyhow::{anyhow, Result};
use super::GatewayProxy;
diff --git a/sdk/reqwest/src/gateway/gateway_tx.rs b/sdk/reqwest/src/gateway/gateway_tx.rs
index a862f2818a..24e2377a13 100644
--- a/sdk/reqwest/src/gateway/gateway_tx.rs
+++ b/sdk/reqwest/src/gateway/gateway_tx.rs
@@ -1,3 +1,5 @@
+use anyhow::{anyhow, Result};
+use itertools::Itertools;
use multiversx_sdk::data::{
address::Address,
network_config::NetworkConfig,
@@ -8,8 +10,6 @@ use multiversx_sdk::data::{
},
vm::{ResponseVmValue, VmValueRequest, VmValuesResponseData},
};
-use anyhow::{anyhow, Result};
-use itertools::Itertools;
use super::GatewayProxy;
diff --git a/sdk/reqwest/src/gateway/gateway_tx_retrieve.rs b/sdk/reqwest/src/gateway/gateway_tx_retrieve.rs
index 527b7ef736..14256c7527 100644
--- a/sdk/reqwest/src/gateway/gateway_tx_retrieve.rs
+++ b/sdk/reqwest/src/gateway/gateway_tx_retrieve.rs
@@ -1,5 +1,5 @@
-use multiversx_sdk::data::transaction::TransactionOnNetwork;
use log::info;
+use multiversx_sdk::data::transaction::TransactionOnNetwork;
use std::time::{Duration, Instant};
use super::GatewayProxy;
diff --git a/sdk/reqwest/src/lib.rs b/sdk/reqwest/src/lib.rs
index bc2a32b091..7ec54f216c 100644
--- a/sdk/reqwest/src/lib.rs
+++ b/sdk/reqwest/src/lib.rs
@@ -1,4 +1,3 @@
-
pub mod gateway;
pub use multiversx_sdk as core;
diff --git a/sdk/wbg/Cargo.toml b/sdk/wbg/Cargo.toml
new file mode 100644
index 0000000000..dde7a335b6
--- /dev/null
+++ b/sdk/wbg/Cargo.toml
@@ -0,0 +1,29 @@
+[package]
+name = "multiversx-sdk-wbg"
+version = "0.6.0"
+edition = "2021"
+
+authors = ["MultiversX "]
+license = "MIT"
+readme = "README.md"
+repository = "https://github.com/multiversx/mx-sdk-rs"
+homepage = "https://multiversx.com/"
+documentation = "https://docs.multiversx.com/"
+description = "SDK for interacting with the MultiversX blockchain for wasm-bindgen environments"
+categories = ["cryptography::cryptocurrencies", "api-bindings"]
+keywords = ["multiversx", "blockchain", "sdk", "api", "wasm", "wasm-bindgen"]
+
+[dependencies]
+web-sys = { version = "0.3.70" }
+js-sys = { version = "0.3.70" }
+wasm-bindgen = { version = "0.2.93" }
+wasm-bindgen-futures = { version = "0.4.43" }
+gloo-net = { version = "0.6.0" }
+anyhow = "1.0.44"
+hex = "0.4.3"
+itertools = "0.13.0"
+log = "0.4.17"
+
+[dependencies.multiversx-sdk]
+version = "=0.6.0"
+path = "../core"
diff --git a/sdk/wbg/README.md b/sdk/wbg/README.md
new file mode 100644
index 0000000000..adaf311e41
--- /dev/null
+++ b/sdk/wbg/README.md
@@ -0,0 +1,5 @@
+# MultiversX SDK for Rust
+
+General purpose collection of tools & SDKs to interact with the MultiversX blockchain from Rust projects, wasm-bindgen compatible.
+
+More examples in `./examples`.
diff --git a/sdk/wbg/src/gateway.rs b/sdk/wbg/src/gateway.rs
new file mode 100644
index 0000000000..35e2668b50
--- /dev/null
+++ b/sdk/wbg/src/gateway.rs
@@ -0,0 +1,15 @@
+mod gateway_account;
+mod gateway_block;
+mod gateway_network;
+mod gateway_proxy;
+mod gateway_tx;
+mod gateway_tx_retrieve;
+
+pub use gateway_proxy::GatewayProxy;
+
+pub const MAINNET_GATEWAY: &str = "https://gateway.multiversx.com";
+pub const TESTNET_GATEWAY: &str = "https://testnet-gateway.multiversx.com";
+pub const DEVNET_GATEWAY: &str = "https://devnet-gateway.multiversx.com";
+
+// MetachainShardId will be used to identify a shard ID as metachain
+pub const METACHAIN_SHARD_ID: u32 = 0xFFFFFFFF;
diff --git a/sdk/wbg/src/gateway/gateway_account.rs b/sdk/wbg/src/gateway/gateway_account.rs
new file mode 100644
index 0000000000..bb277ef53a
--- /dev/null
+++ b/sdk/wbg/src/gateway/gateway_account.rs
@@ -0,0 +1,106 @@
+use multiversx_sdk::data::{
+ account::{Account, AccountResponse},
+ account_storage::AccountStorageResponse,
+ address::Address,
+ esdt::{EsdtBalance, EsdtBalanceResponse, EsdtRolesResponse},
+};
+use anyhow::{anyhow, Result};
+use gloo_net::http::Request;
+use std::collections::HashMap;
+
+use super::GatewayProxy;
+
+const ACCOUNT_ENDPOINT: &str = "address/";
+const KEYS_ENDPOINT: &str = "/keys/";
+
+impl GatewayProxy {
+ // get_account retrieves an account info from the network (nonce, balance)
+ pub async fn get_account(&self, address: &Address) -> Result {
+ if !address.is_valid() {
+ return Err(anyhow!("invalid address"));
+ }
+
+ let endpoint = ACCOUNT_ENDPOINT.to_string() + address.to_string().as_str();
+ let endpoint = self.get_endpoint(endpoint.as_str());
+ let resp = Request::get(&endpoint)
+ .send()
+ .await?
+ .json::()
+ .await?;
+
+ match resp.data {
+ None => Err(anyhow!("{}", resp.error)),
+ Some(b) => Ok(b.account),
+ }
+ }
+
+ // get_account_esdt_roles retrieves an all esdt roles of an account from the network
+ pub async fn get_account_esdt_roles(
+ &self,
+ address: &Address,
+ ) -> Result>> {
+ if !address.is_valid() {
+ return Err(anyhow!("invalid address"));
+ }
+
+ let endpoint = ACCOUNT_ENDPOINT.to_string() + address.to_string().as_str() + "/esdts/roles";
+ let endpoint = self.get_endpoint(endpoint.as_str());
+
+ let resp = Request::get(&endpoint)
+ .send()
+ .await?
+ .json::()
+ .await?;
+
+ match resp.data {
+ None => Err(anyhow!("{}", resp.error)),
+ Some(b) => Ok(b.roles),
+ }
+ }
+
+ // get_account_esdt_tokens retrieves an all esdt token of an account from the network
+ pub async fn get_account_esdt_tokens(
+ &self,
+ address: &Address,
+ ) -> Result> {
+ if !address.is_valid() {
+ return Err(anyhow!("invalid address"));
+ }
+
+ let endpoint = ACCOUNT_ENDPOINT.to_string() + address.to_string().as_str() + "/esdt";
+ let endpoint = self.get_endpoint(endpoint.as_str());
+ let resp = Request::get(&endpoint)
+ .send()
+ .await?
+ .json::()
+ .await?;
+
+ match resp.data {
+ None => Err(anyhow!("{}", resp.error)),
+ Some(b) => Ok(b.esdts),
+ }
+ }
+
+ // get_account_esdt_tokens retrieves an all esdt token of an account from the network
+ pub async fn get_account_storage_keys(
+ &self,
+ address: &Address,
+ ) -> Result> {
+ if !address.is_valid() {
+ return Err(anyhow!("invalid address"));
+ }
+
+ let endpoint = ACCOUNT_ENDPOINT.to_string() + address.to_string().as_str() + KEYS_ENDPOINT;
+ let endpoint = self.get_endpoint(endpoint.as_str());
+ let resp = Request::get(&endpoint)
+ .send()
+ .await?
+ .json::()
+ .await?;
+
+ match resp.data {
+ None => Err(anyhow!("{}", resp.error)),
+ Some(b) => Ok(b.pairs),
+ }
+ }
+}
diff --git a/sdk/wbg/src/gateway/gateway_block.rs b/sdk/wbg/src/gateway/gateway_block.rs
new file mode 100644
index 0000000000..c313e80f12
--- /dev/null
+++ b/sdk/wbg/src/gateway/gateway_block.rs
@@ -0,0 +1,63 @@
+use multiversx_sdk::data::{
+ hyperblock::{HyperBlock, HyperBlockResponse},
+ network_status::NetworkStatusResponse,
+};
+use anyhow::{anyhow, Result};
+use gloo_net::http::Request;
+
+use super::GatewayProxy;
+use super::METACHAIN_SHARD_ID;
+
+const GET_HYPER_BLOCK_BY_NONCE_ENDPOINT: &str = "hyperblock/by-nonce/";
+const GET_HYPER_BLOCK_BY_HASH_ENDPOINT: &str = "hyperblock/by-hash/";
+const GET_NETWORK_STATUS_ENDPOINT: &str = "network/status";
+
+impl GatewayProxy {
+ async fn get_hyper_block(&self, endpoint: &str) -> Result {
+ let endpoint = self.get_endpoint(endpoint);
+ let resp = Request::get(&endpoint)
+ .send()
+ .await?
+ .json::()
+ .await?;
+
+ match resp.data {
+ None => Err(anyhow!("{}", resp.error)),
+ Some(b) => Ok(b.hyperblock),
+ }
+ }
+
+ // get_hyper_block_by_hash retrieves a hyper block's info by hash from the network
+ pub async fn get_hyper_block_by_hash(&self, hash: &str) -> Result {
+ let endpoint = GET_HYPER_BLOCK_BY_HASH_ENDPOINT.to_string() + hash;
+ self.get_hyper_block(endpoint.as_str()).await
+ }
+
+ // get_hyper_block_by_nonce retrieves a hyper block's info by nonce from the network
+ pub async fn get_hyper_block_by_nonce(&self, nonce: u64) -> Result