feat: error handling

README.md

@@ -78,7 +78,7 @@ Then we'll go directly into making a call into the contract, and initialize the
         .call(&worker, "new_default_meta")
         .args_json(json!({
             "owner_id": contract.id(),
-        }))?
+        }))
         .transact()
         .await?;
 
@@ -100,7 +100,7 @@ Afterwards, let's mint an NFT via `nft_mint`. This showcases some extra argument
                 "dscription": "Tallest mountain in charted solar system",
                 "copies": 1,
             },
-        }))?
+        }))
         .deposit(deposit)
         // nft_mint might consume more than default gas, so supply our own gas value:
         .gas(near_units::parse_gas("300 T"))
@@ -160,7 +160,7 @@ async fn call_my_func(worker: Worker<impl Network>, contract: &Contract) -> anyh
     contract.call(&worker, "contract_function")
         .args_json(serde_json::json!({
             "message": msg,
-        })?
+        })
         .transact()
         .await?;
     Ok(())
@@ -220,7 +220,7 @@ Following that we will have to init the contract again with our own metadata. Th
         .args_json(serde_json::json!({
             "arg1": value1,
             "arg2": value2,
-        }))?
+        }))
         .transact()
         .await?;
 

examples/src/croncat.rs

@@ -69,7 +69,7 @@ async fn main() -> anyhow::Result<()> {
             "function_id": "increment",
             "cadence": "*/1 * * * * *",
             "recurring": true,
-        }))?
+        }))
         .max_gas()
         .deposit(parse_near!("1 N"))
         .transact()
@@ -101,7 +101,7 @@ pub async fn run_scheduled_tasks(
     // Register the agent to eventually execute the task
     let outcome = agent
         .call(&worker, contract.id(), "register_agent")
-        .args_json(json!({}))?
+        .args_json(json!({}))
         .deposit(parse_near!("0.00226 N"))
         .transact()
         .await?;
@@ -110,7 +110,7 @@ pub async fn run_scheduled_tasks(
     // Check the right agent was registered correctly:
     let registered_agent = contract
         .call(&worker, "get_agent")
-        .args_json(json!({ "account_id": agent.id() }))?
+        .args_json(json!({ "account_id": agent.id() }))
         .view()
         .await?
         .json::<Option<Agent>>()?
@@ -148,7 +148,7 @@ pub async fn run_scheduled_tasks(
     // the manager contract, and we want to eventually withdraw this amount.
     let agent_details = contract
         .call(&worker, "get_agent")
-        .args_json(json!({"account_id": agent.id()}))?
+        .args_json(json!({"account_id": agent.id()}))
         .view()
         .await?
         .json::<Option<Agent>>()?
@@ -167,7 +167,7 @@ pub async fn run_scheduled_tasks(
     // contract:
     let agent_details = contract
         .call(&worker, "get_agent")
-        .args_json(json!({"account_id": agent.id() }))?
+        .args_json(json!({"account_id": agent.id() }))
         .view()
         .await?
         .json::<Option<Agent>>()?
@@ -191,7 +191,7 @@ pub async fn run_scheduled_tasks(
     // Check to see if the agent has been successfully unregistered
     let removed_agent: Option<Agent> = contract
         .call(&worker, "get_agent")
-        .args_json(json!({"account_id": agent.id() }))?
+        .args_json(json!({"account_id": agent.id() }))
         .view()
         .await?
         .json()?;

examples/src/nft.rs

@@ -14,7 +14,7 @@ async fn main() -> anyhow::Result<()> {
         .call(&worker, "new_default_meta")
         .args_json(json!({
                 "owner_id": contract.id(),
-        }))?
+        }))
         .transact()
         .await?;
 
@@ -31,7 +31,7 @@ async fn main() -> anyhow::Result<()> {
                 "dscription": "Tallest mountain in charted solar system",
                 "copies": 1,
             },
-        }))?
+        }))
         .deposit(deposit)
         .transact()
         .await?;

examples/src/ref_finance.rs

@@ -40,13 +40,13 @@ async fn create_ref(owner: &Account, worker: &Worker<Sandbox>) -> anyhow::Result
             "owner_id": ref_finance.id(),
             "exchange_fee": 4,
             "referral_fee": 1,
-        }))?
+        }))
         .transact()
         .await?;
 
     owner
         .call(&worker, ref_finance.id(), "storage_deposit")
-        .args_json(serde_json::json!({}))?
+        .args_json(serde_json::json!({}))
         .deposit(parse_near!("30 mN"))
         .transact()
         .await?;
@@ -69,13 +69,13 @@ async fn create_wnear(owner: &Account, worker: &Worker<Sandbox>) -> anyhow::Resu
         .args_json(serde_json::json!({
             "owner_id": owner.id(),
             "total_supply": parse_near!("1,000,000,000 N"),
-        }))?
+        }))
         .transact()
         .await?;
 
     owner
         .call(&worker, wnear.id(), "storage_deposit")
-        .args_json(serde_json::json!({}))?
+        .args_json(serde_json::json!({}))
         .deposit(parse_near!("0.008 N"))
         .transact()
         .await?;
@@ -105,7 +105,7 @@ async fn create_pool_with_liquidity(
 
     ref_finance
         .call(worker, "extend_whitelisted_tokens")
-        .args_json(serde_json::json!({ "tokens": token_ids }))?
+        .args_json(serde_json::json!({ "tokens": token_ids }))
         .transact()
         .await?;
 
@@ -114,7 +114,7 @@ async fn create_pool_with_liquidity(
         .args_json(serde_json::json!({
             "tokens": token_ids,
             "fee": 25
-        }))?
+        }))
         .deposit(parse_near!("3 mN"))
         .transact()
         .await?
@@ -124,7 +124,7 @@ async fn create_pool_with_liquidity(
         .call(&worker, ref_finance.id(), "register_tokens")
         .args_json(serde_json::json!({
             "token_ids": token_ids,
-        }))?
+        }))
         .deposit(1)
         .transact()
         .await?;
@@ -136,7 +136,7 @@ async fn create_pool_with_liquidity(
         .args_json(serde_json::json!({
             "pool_id": pool_id,
             "amounts": token_amounts,
-        }))?
+        }))
         .deposit(parse_near!("1 N"))
         .transact()
         .await?;
@@ -157,7 +157,7 @@ async fn deposit_tokens(
             .call(&worker, contract_id, "storage_deposit")
             .args_json(serde_json::json!({
                 "registration_only": true,
-            }))?
+            }))
             .deposit(parse_near!("1 N"))
             .transact()
             .await?;
@@ -168,7 +168,7 @@ async fn deposit_tokens(
                 "receiver_id": ref_finance.id(),
                 "amount": amount.to_string(),
                 "msg": "",
-            }))?
+            }))
             .gas(parse_gas!("200 Tgas") as u64)
             .deposit(1)
             .transact()
@@ -193,7 +193,7 @@ async fn create_custom_ft(
         .args_json(serde_json::json!({
             "owner_id": owner.id(),
             "total_supply": parse_near!("1,000,000,000 N").to_string(),
-        }))?
+        }))
         .transact()
         .await?;
 
@@ -318,7 +318,7 @@ async fn main() -> anyhow::Result<()> {
                 "amount_in": parse_near!("1 N").to_string(),
                 "min_amount_out": "1",
             })],
-        }))?
+        }))
         .deposit(1)
         .gas(parse_gas!("100 Tgas") as u64)
         .transact()

examples/src/spooning.rs

@@ -54,7 +54,7 @@ async fn deploy_status_contract(
         .call(worker, "set_status")
         .args_json(serde_json::json!({
             "message": msg,
-        }))?
+        }))
         .transact()
         .await?;
 

examples/src/status_message.rs

@@ -13,7 +13,7 @@ async fn main() -> anyhow::Result<()> {
         .call(&worker, "set_status")
         .args_json(json!({
             "message": "hello_world",
-        }))?
+        }))
         .transact()
         .await?;
     println!("set_status: {:?}", outcome);

workspaces/Cargo.toml

@@ -24,6 +24,7 @@ rand = "0.8.4"
 reqwest = { version = "0.11", features = ["json"] }
 serde = "1.0"
 serde_json = "1.0"
+thiserror = "1.0"
 tokio = { version = "1", features = ["full"] }
 tokio-retry = "0.3"
 tracing = "0.1"