feat: Expose transact async for asynchronous transactions

CHANGELOG.md

@@ -2,6 +2,28 @@
 
 ## [Unreleased]
 
+### Added
+
+- [`view_*` asynchronous builders have been added which provides being able to query from a specific block hash or block height](https://github.com/near/workspaces-rs/pull/218)
+- [`{CallTransaction, Transaction}::transact_async` for performing transactions without directly having to wait for it complete it on chain](https://github.com/near/workspaces-rs/pull/222)
+
+### Changed
+
+- [Apart of the changes from adding `view_*` async builders, we have a couple breaking changes to the `view_*` functions](https://github.com/near/workspaces-rs/pull/218):
+  - `{Account, Contract, Worker}::view_state` moved `prefix` parameter into builder. i.e.
+    ```
+    worker.view_state("account_id", Some(prefix)).await?;
+    // is now
+    worker.view_state("account_id")
+        .prefix(prefix)
+        .await?;
+    // if prefix was `None`, then simply delete the None argument.
+    ```
+  - `view` function changed to be a builder, and no longer take in `args` as a parameter. It instead has been moved to the builder side.
+  - Changed `Worker::view_latest_block` to `Worker::view_block` as the default behavior is equivalent.
+  - `operations::Function` type no longer takes a lifetime parameter.
+  - `operations::CallTransaction` type takes one less lifetime parameter.
+
 ## [0.6.0]
 
 ### Added

examples/Cargo.toml

@@ -18,6 +18,10 @@ tracing = "0.1"
 tracing-subscriber = { version = "0.3.5", features = ["env-filter"] }
 workspaces = { path = "../workspaces" }
 
+[[example]]
+name = "async_transaction"
+path = "src/async_transaction.rs"
+
 [[example]]
 name = "nft"
 path = "src/nft.rs"

examples/src/async_transaction.rs

@@ -0,0 +1,24 @@
+const STATUS_MSG_WASM_FILEPATH: &str = "./examples/res/status_message.wasm";
+
+#[tokio::main]
+async fn main() -> anyhow::Result<()> {
+    let worker = workspaces::sandbox().await?;
+    let wasm = std::fs::read(STATUS_MSG_WASM_FILEPATH)?;
+    let contract = worker.dev_deploy(&wasm).await?;
+
+    let status = contract
+        .call("set_status")
+        .args_json(serde_json::json!({
+            "message": "hello_world",
+        }))
+        .transact_async()
+        .await?;
+
+    let outcome = status.await;
+    println!(
+        "Async transaction result from setting hello world: {:#?}",
+        outcome
+    );
+
+    Ok(())
+}

examples/src/fast_forward.rs

@@ -18,7 +18,7 @@ async fn main() -> anyhow::Result<()> {
         contract.call("current_env_data").view().await?.json()?;
     println!("timestamp = {}, epoch_height = {}", timestamp, epoch_height);
 
-    let block_info = worker.view_latest_block().await?;
+    let block_info = worker.view_block().await?;
     println!("BlockInfo pre-fast_forward {:?}", block_info);
 
     // Call into fast_forward. This will take a bit of time to invoke, but is
@@ -29,7 +29,7 @@ async fn main() -> anyhow::Result<()> {
         contract.call("current_env_data").view().await?.json()?;
     println!("timestamp = {}, epoch_height = {}", timestamp, epoch_height);
 
-    let block_info = worker.view_latest_block().await?;
+    let block_info = worker.view_block().await?;
     println!("BlockInfo post-fast_forward {:?}", block_info);
 
     Ok(())

examples/src/nft.rs

@@ -36,13 +36,9 @@ async fn main() -> anyhow::Result<()> {
 
     println!("nft_mint outcome: {:#?}", outcome);
 
-    let result: serde_json::Value = worker
-        .view(contract.id(), "nft_metadata", Vec::new())
-        .await?
-        .json()?;
+    let result: serde_json::Value = worker.view(contract.id(), "nft_metadata").await?.json()?;
 
     println!("--------------\n{}", result);
-
     println!("Dev Account ID: {}", contract.id());
 
     Ok(())

examples/src/ref_finance.rs

@@ -2,6 +2,7 @@ use std::collections::HashMap;
 use std::convert::TryInto;
 
 use near_units::{parse_gas, parse_near};
+use serde_json::json;
 use workspaces::network::Sandbox;
 use workspaces::{Account, AccountId, Contract, Worker};
 use workspaces::{BlockHeight, DevNetwork};
@@ -36,7 +37,7 @@ async fn create_ref(owner: &Account, worker: &Worker<Sandbox>) -> anyhow::Result
 
     owner
         .call(ref_finance.id(), "new")
-        .args_json(serde_json::json!({
+        .args_json(json!({
             "owner_id": ref_finance.id(),
             "exchange_fee": 4,
             "referral_fee": 1,
@@ -47,7 +48,7 @@ async fn create_ref(owner: &Account, worker: &Worker<Sandbox>) -> anyhow::Result
 
     owner
         .call(ref_finance.id(), "storage_deposit")
-        .args_json(serde_json::json!({}))
+        .args_json(json!({}))
         .deposit(parse_near!("30 mN"))
         .transact()
         .await?
@@ -68,7 +69,7 @@ async fn create_wnear(owner: &Account, worker: &Worker<Sandbox>) -> anyhow::Resu
 
     owner
         .call(wnear.id(), "new")
-        .args_json(serde_json::json!({
+        .args_json(json!({
             "owner_id": owner.id(),
             "total_supply": parse_near!("1,000,000,000 N"),
         }))
@@ -78,7 +79,7 @@ async fn create_wnear(owner: &Account, worker: &Worker<Sandbox>) -> anyhow::Resu
 
     owner
         .call(wnear.id(), "storage_deposit")
-        .args_json(serde_json::json!({}))
+        .args_json(json!({}))
         .deposit(parse_near!("0.008 N"))
         .transact()
         .await?
@@ -109,14 +110,14 @@ async fn create_pool_with_liquidity(
 
     ref_finance
         .call("extend_whitelisted_tokens")
-        .args_json(serde_json::json!({ "tokens": token_ids }))
+        .args_json(json!({ "tokens": token_ids }))
         .transact()
         .await?
         .into_result()?;
 
     let pool_id: u64 = ref_finance
         .call("add_simple_pool")
-        .args_json(serde_json::json!({
+        .args_json(json!({
             "tokens": token_ids,
             "fee": 25
         }))
@@ -127,7 +128,7 @@ async fn create_pool_with_liquidity(
 
     owner
         .call(ref_finance.id(), "register_tokens")
-        .args_json(serde_json::json!({
+        .args_json(json!({
             "token_ids": token_ids,
         }))
         .deposit(1)
@@ -139,7 +140,7 @@ async fn create_pool_with_liquidity(
 
     owner
         .call(ref_finance.id(), "add_liquidity")
-        .args_json(serde_json::json!({
+        .args_json(json!({
             "pool_id": pool_id,
             "amounts": token_amounts,
         }))
@@ -161,7 +162,7 @@ async fn deposit_tokens(
         ref_finance
             .as_account()
             .call(contract_id, "storage_deposit")
-            .args_json(serde_json::json!({
+            .args_json(json!({
                 "registration_only": true,
             }))
             .deposit(parse_near!("1 N"))
@@ -171,7 +172,7 @@ async fn deposit_tokens(
 
         owner
             .call(contract_id, "ft_transfer_call")
-            .args_json(serde_json::json!({
+            .args_json(json!({
                 "receiver_id": ref_finance.id(),
                 "amount": amount.to_string(),
                 "msg": "",
@@ -198,7 +199,7 @@ async fn create_custom_ft(
     // Initialize our FT contract with owner metadata and total supply available
     // to be traded and transfered into other contracts such as Ref-Finance
     ft.call("new_default_meta")
-        .args_json(serde_json::json!({
+        .args_json(json!({
             "owner_id": owner.id(),
             "total_supply": parse_near!("1,000,000,000 N").to_string(),
         }))
@@ -258,32 +259,22 @@ async fn main() -> anyhow::Result<()> {
     ///////////////////////////////////////////////////////////////////////////
 
     let ft_deposit: String = worker
-        .view(
-            ref_finance.id(),
-            "get_deposit",
-            serde_json::json!({
-                "account_id": owner.id(),
-                "token_id": ft.id(),
-            })
-            .to_string()
-            .into_bytes(),
-        )
+        .view(ref_finance.id(), "get_deposit")
+        .args_json(json!({
+            "account_id": owner.id(),
+            "token_id": ft.id(),
+        }))
         .await?
         .json()?;
     println!("Current FT deposit: {}", ft_deposit);
     assert_eq!(ft_deposit, parse_near!("100 N").to_string());
 
     let wnear_deposit: String = worker
-        .view(
-            ref_finance.id(),
-            "get_deposit",
-            serde_json::json!({
-                "account_id": owner.id(),
-                "token_id": wnear.id(),
-            })
-            .to_string()
-            .into_bytes(),
-        )
+        .view(ref_finance.id(), "get_deposit")
+        .args_json(json!({
+            "account_id": owner.id(),
+            "token_id": wnear.id(),
+        }))
         .await?
         .json()?;
 
@@ -295,18 +286,13 @@ async fn main() -> anyhow::Result<()> {
     ///////////////////////////////////////////////////////////////////////////
 
     let expected_return: String = worker
-        .view(
-            ref_finance.id(),
-            "get_return",
-            serde_json::json!({
-                "pool_id": pool_id,
-                "token_in": ft.id(),
-                "token_out": wnear.id(),
-                "amount_in": parse_near!("1 N").to_string(),
-            })
-            .to_string()
-            .into_bytes(),
-        )
+        .view(ref_finance.id(), "get_return")
+        .args_json(json!({
+            "pool_id": pool_id,
+            "token_in": ft.id(),
+            "token_out": wnear.id(),
+            "amount_in": parse_near!("1 N").to_string(),
+        }))
         .await?
         .json()?;
 
@@ -318,8 +304,8 @@ async fn main() -> anyhow::Result<()> {
 
     let actual_out = owner
         .call(ref_finance.id(), "swap")
-        .args_json(serde_json::json!({
-            "actions": vec![serde_json::json!({
+        .args_json(json!({
+            "actions": vec![json!({
                 "pool_id": pool_id,
                 "token_in": ft.id(),
                 "token_out": wnear.id(),
@@ -345,31 +331,22 @@ async fn main() -> anyhow::Result<()> {
     ///////////////////////////////////////////////////////////////////////////
 
     let ft_deposit: String = worker
-        .view(
-            ref_finance.id(),
-            "get_deposit",
-            serde_json::json!({
-                "account_id": owner.id(),
-                "token_id": ft.id(),
-            })
-            .to_string()
-            .into_bytes(),
-        )
+        .view(ref_finance.id(), "get_deposit")
+        .args_json(json!({
+            "account_id": owner.id(),
+            "token_id": ft.id(),
+        }))
         .await?
         .json()?;
     println!("New FT deposit after swap: {}", ft_deposit);
     assert_eq!(ft_deposit, parse_near!("99 N").to_string());
 
     let wnear_deposit: String = ref_finance
-        .view(
-            "get_deposit",
-            serde_json::json!({
-                "account_id": owner.id(),
-                "token_id": wnear.id(),
-            })
-            .to_string()
-            .into_bytes(),
-        )
+        .view("get_deposit")
+        .args_json(json!({
+            "account_id": owner.id(),
+            "token_id": wnear.id(),
+        }))
         .await?
         .json()?;
     println!("New WNear deposit after swap: {}", wnear_deposit);

examples/src/spooning.rs

@@ -1,5 +1,7 @@
-use borsh::{self, BorshDeserialize, BorshSerialize};
 use std::env;
+
+use borsh::{self, BorshDeserialize, BorshSerialize};
+use serde_json::json;
 use tracing::info;
 use tracing_subscriber::filter::LevelFilter;
 use tracing_subscriber::EnvFilter;
@@ -51,7 +53,7 @@ async fn deploy_status_contract(
     // This will `call` into `set_status` with the message we want to set.
     contract
         .call("set_status")
-        .args_json(serde_json::json!({
+        .args_json(json!({
             "message": msg,
         }))
         .transact()
@@ -79,7 +81,7 @@ async fn main() -> anyhow::Result<()> {
             .parse()
             .map_err(anyhow::Error::msg)?;
 
-        let mut state_items = worker.view_state(&contract_id, None).await?;
+        let mut state_items = worker.view_state(&contract_id).await?;
 
         let state = state_items.remove(b"STATE".as_slice()).unwrap();
         let status_msg = StatusMessage::try_from_slice(&state)?;
@@ -106,14 +108,10 @@ async fn main() -> anyhow::Result<()> {
 
     // Now grab the state to see that it has indeed been patched:
     let status: String = sandbox_contract
-        .view(
-            "get_status",
-            serde_json::json!({
-                "account_id": testnet_contract_id,
-            })
-            .to_string()
-            .into_bytes(),
-        )
+        .view("get_status")
+        .args_json(json!({
+            "account_id": testnet_contract_id,
+        }))
         .await?
         .json()?;
 
@@ -122,14 +120,10 @@ async fn main() -> anyhow::Result<()> {
 
     // See that sandbox state was overriden. Grabbing get_status(sandbox_contract_id) should yield Null
     let result: Option<String> = sandbox_contract
-        .view(
-            "get_status",
-            serde_json::json!({
-                "account_id": sandbox_contract.id(),
-            })
-            .to_string()
-            .into_bytes(),
-        )
+        .view("get_status")
+        .args_json(json!({
+            "account_id": sandbox_contract.id(),
+        }))
         .await?
         .json()?;
     assert_eq!(result, None);