promises-features - interactor

Cargo.toml

@@ -145,6 +145,7 @@ members = [
   "contracts/feature-tests/composability/local-esdt-and-nft/meta",
   "contracts/feature-tests/composability/promises-features",
   "contracts/feature-tests/composability/promises-features/meta",
+  "contracts/feature-tests/composability/promises-features/interactor",
   "contracts/feature-tests/composability/proxy-test-first",
   "contracts/feature-tests/composability/proxy-test-first/meta",
   "contracts/feature-tests/composability/proxy-test-second",

contracts/feature-tests/composability/promises-features/interactor/.gitignore

@@ -0,0 +1,3 @@
+# Pem files are used for interactions, but shouldn't be committed
+*.pem
+state.toml

contracts/feature-tests/composability/promises-features/interactor/Cargo.toml

@@ -0,0 +1,28 @@
+[package]
+name = "rust-interact"
+version = "0.0.0"
+authors = ["you"]
+edition = "2021"
+publish = false
+
+[[bin]]
+name = "rust-interact"
+path = "src/interactor_main.rs"
+
+[lib]
+path = "src/interact.rs"
+
+[dependencies.promises-features]
+path = ".."
+
+[dependencies.multiversx-sc-snippets]
+version = "0.56.0"
+path = "../../../../../framework/snippets"
+
+[dependencies]
+clap = { version = "4.4.7", features = ["derive"] }
+serde = { version = "1.0", features = ["derive"] }
+toml = "0.8.6"
+
+[features]
+chain-simulator-tests = []

contracts/feature-tests/composability/promises-features/interactor/config.toml

@@ -0,0 +1,5 @@
+# chain_type = 'simulator'
+# gateway_uri = 'http://localhost:8085'
+
+chain_type = 'real'
+gateway_uri = 'https://devnet-gateway.multiversx.com'

contracts/feature-tests/composability/promises-features/interactor/src/config.rs

@@ -0,0 +1,51 @@
+#![allow(unused)]
+
+use serde::Deserialize;
+use std::io::Read;
+
+/// Config file
+const CONFIG_FILE: &str = "config.toml";
+
+#[derive(Debug, Deserialize)]
+#[serde(rename_all = "lowercase")]
+pub enum ChainType {
+    Real,
+    Simulator,
+}
+
+/// Contract Interact configuration
+#[derive(Debug, Deserialize)]
+pub struct Config {
+    pub gateway_uri: String,
+    pub chain_type: ChainType,
+}
+
+impl Config {
+    // Deserializes config from file
+    pub fn new() -> Self {
+        let mut file = std::fs::File::open(CONFIG_FILE).unwrap();
+        let mut content = String::new();
+        file.read_to_string(&mut content).unwrap();
+        toml::from_str(&content).unwrap()
+    }
+
+    pub fn chain_simulator_config() -> Self {
+        Config {
+            gateway_uri: "http://localhost:8085".to_owned(),
+            chain_type: ChainType::Simulator,
+        }
+    }
+
+    // Returns the gateway URI
+    pub fn gateway_uri(&self) -> &str {
+        &self.gateway_uri
+    }
+
+    // Returns if chain type is chain simulator
+    pub fn use_chain_simulator(&self) -> bool {
+        match self.chain_type {
+            ChainType::Real => false,
+            ChainType::Simulator => true,
+        }
+    }
+}

contracts/feature-tests/composability/promises-features/interactor/src/interactor_cli.rs

@@ -0,0 +1,105 @@
+use clap::{Args, Parser, Subcommand};
+
+/// Adder Interact CLI
+#[derive(Default, PartialEq, Eq, Debug, Parser)]
+#[command(version, about)]
+#[command(propagate_version = true)]
+pub struct InteractCli {
+    #[command(subcommand)]
+    pub command: Option<InteractCliCommand>,
+}
+
+/// Adder Interact CLI Commands
+#[derive(Clone, PartialEq, Eq, Debug, Subcommand)]
+pub enum InteractCliCommand {
+    #[command(name = "deploy", about = "Deploy contract")]
+    Deploy,
+    #[command(name = "callback-data", about = "Callback data")]
+    CallbackData,
+    #[command(name = "callback-data-at-index", about = "Callback data at index")]
+    CallbackDataAtIndex(CallbackDataAtIndexArgs),
+    #[command(name = "clear_callback_data", about = "Clear callback data")]
+    ClearCallbackData,
+    #[command(
+        name = "forward-promise-accept-funds",
+        about = "Forward promise accept funds"
+    )]
+    ForwardPromiseAcceptFunds(ForwardPromiseFundsArgs),
+    #[command(
+        name = "forward-promise-retrieve-funds",
+        about = "Forward promise retrieve funds"
+    )]
+    ForwardPromiseRetrieveFunds(ForwardPromiseFundsArgs),
+    #[command(name = "forward-payment-callback", about = "Forward payment callback")]
+    ForwardPaymentCallback(ForwardPromiseFundsArgs),
+    #[command(name = "promise-raw-single-token", about = "Promise raw single token")]
+    PromiseRawSingleToken(PromiseRawSingleTokenArgs),
+    #[command(
+        name = "promise-raw-multi-transfer",
+        about = "Promise raw multi transfer"
+    )]
+    PromiseRawMultiTransfer(PromiseRawMultiTransferArgs),
+    #[command(
+        name = "forward-sync-retrieve-funds-bt",
+        about = "Forward sync retrieve funds bt"
+    )]
+    ForwardSyncRetrieveFundsBt(ForwardPromiseFundsArgs),
+    #[command(
+        name = "forward-sync-retrieve-funds-bt-twice",
+        about = "Forward sync retrieve funds bt twice"
+    )]
+    ForwardSyncRetrieveFundsBtTwice(ForwardPromiseFundsArgs),
+    #[command(
+        name = "forward-promise-retrieve-funds-back-transfers",
+        about = "Forward sync retrieve funds bt twice"
+    )]
+    ForwardPromiseRetrieveFundsBackTransfers(ForwardPromiseFundsArgs),
+}
+
+#[derive(Default, Clone, PartialEq, Eq, Debug, Args)]
+pub struct CallbackDataAtIndexArgs {
+    #[arg(short = 'i', long = "index")]
+    pub index: u32,
+}
+
+#[derive(Default, Clone, PartialEq, Eq, Debug, Args)]
+pub struct ForwardPromiseFundsArgs {
+    #[arg(short = 'i', long = "token-id")]
+    pub token_id: String,
+    #[arg(short = 'n', long = "token-nonce")]
+    pub token_nonce: u64,
+    #[arg(short = 'a', long = "token-amount")]
+    pub token_amount: u64,
+    #[arg(short = 't', long = "to")]
+    pub to: String,
+}
+
+#[derive(Default, Clone, PartialEq, Eq, Debug, Args)]
+pub struct PromiseRawSingleTokenArgs {
+    #[arg(short = 'i', long = "token-id")]
+    pub token_id: String,
+    #[arg(short = 'n', long = "token-nonce")]
+    pub token_nonce: u64,
+    #[arg(short = 'a', long = "token-amount")]
+    pub token_amount: u64,
+    #[arg(short = 't', long = "to")]
+    pub to: String,
+    #[arg(short = 'e', long = "endpoint-name")]
+    pub endpoint_name: String,
+    #[arg(short = 'g', long = "gas-limit")]
+    pub gas_limit: u64,
+    #[arg(short = 'x', long = "extra-gas-for-callback")]
+    pub extra_gas_for_callback: u64,
+    #[arg(short = 'a', long = "args")]
+    pub args: String,
+}
+
+#[derive(Default, Clone, PartialEq, Eq, Debug, Args)]
+pub struct PromiseRawMultiTransferArgs {
+    #[arg(short = 't', long = "to")]
+    pub to: String,
+    #[arg(short = 'e', long = "endpoint-name")]
+    pub endpoint_name: String,
+    #[arg(short = 'x', long = "extra-gas-for-callback")]
+    pub extra_gas_for_callback: u64,
+}

contracts/feature-tests/composability/promises-features/interactor/src/interactor_main.rs

@@ -0,0 +1,7 @@
+use multiversx_sc_snippets::imports::*;
+use rust_interact::promises_features_cli;
+
+#[tokio::main]
+async fn main() {
+    promises_features_cli().await;
+}

contracts/feature-tests/composability/promises-features/interactor/src/interactor_state.rs

@@ -0,0 +1,50 @@
+use multiversx_sc_snippets::imports::*;
+use serde::{Deserialize, Serialize};
+use std::{
+    io::{Read, Write},
+    path::Path,
+};
+
+/// State file
+const STATE_FILE: &str = "state.toml";
+
+/// Promise-Features Interact state
+#[derive(Debug, Default, Serialize, Deserialize)]
+pub struct State {
+    promises_features_address: Option<Bech32Address>,
+}
+
+impl State {
+    // Deserializes state from file
+    pub fn load_state() -> Self {
+        if Path::new(STATE_FILE).exists() {
+            let mut file = std::fs::File::open(STATE_FILE).unwrap();
+            let mut content = String::new();
+            file.read_to_string(&mut content).unwrap();
+            toml::from_str(&content).unwrap()
+        } else {
+            Self::default()
+        }
+    }
+
+    /// Sets the promise features address
+    pub fn set_promises_features_address(&mut self, address: Bech32Address) {
+        self.promises_features_address = Some(address);
+    }
+
+    /// Returns the promise features contract
+    pub fn current_promises_features_address(&self) -> &Bech32Address {
+        self.promises_features_address
+            .as_ref()
+            .expect("no known promises features contract, deploy first")
+    }
+}
+
+impl Drop for State {
+    // Serializes state to file
+    fn drop(&mut self) {
+        let mut file = std::fs::File::create(STATE_FILE).unwrap();
+        file.write_all(toml::to_string(self).unwrap().as_bytes())
+            .unwrap();
+    }
+}