Add view call to NearClient

near-client/src/client.rs

@@ -10,12 +10,13 @@ use crate::{
         crypto::{ED25519PublicKey, ED25519Signature, Keypair},
         near::{
             Action, Chunks, FinalExecutionOutcomeView, FinalExecutionStatus, FunctionCallAction,
-            SignedTransaction, Transaction,
+            SignedTransaction, Transaction, ViewResult,
         },
     },
     Error,
 };
 
+use serde::de::DeserializeOwned;
 use serde_json::{json, Value};
 use url::Url;
 
@@ -85,6 +86,38 @@ impl NearClient {
             .prev_block_hash)
     }
 
+    pub async fn view<'a, T: DeserializeOwned>(
+        &'a self,
+        contract_id: &'a AccountId,
+        method: &'static str,
+        args: Option<Value>,
+    ) -> Result<T> {
+        let view_result = self
+            .rpc_client
+            .request::<ViewResult>(
+                "query",
+                Some(json!({
+                    "request_type": "call_function",
+                    "finality": "optimistic",
+                    "account_id": contract_id,
+                    "method_name": method,
+                    "args_base64": args
+                        .map(|value| serde_json::to_vec(&value))
+                        .transpose()
+                        .map_err(Error::ArgsSerialize)?
+                        .map(base64::encode)
+                        .unwrap_or_default()
+                })),
+            )
+            .await
+            .map_err(|error| Error::Rpc {
+                error,
+                method: "query",
+            })?;
+
+        serde_json::from_slice(&view_result.result).map_err(Error::DeserializeTxResp)
+    }
+
     pub fn call<'a>(
         &'a self,
         signer: &'a mut Signer,
@@ -93,17 +126,12 @@ impl NearClient {
     ) -> TransactionBuilder {
         TransactionBuilder::new(self, signer, method, contract_id)
     }
-
-    pub fn view<'a>(&'a self, _contract_id: &'a AccountId, _method: &'static str) {}
 }
 
 pub struct Call<'a>(TransactionBuilder<'a>);
 
 impl<'a> Call<'a> {
-    pub async fn commit<T>(self) -> Result<T>
-    where
-        T: serde::de::DeserializeOwned,
-    {
+    pub async fn commit<T: DeserializeOwned>(self) -> Result<T> {
         let transaction_bytes = serialize_transaction(&self.0).await?;
 
         let execution_outcome = self

near-client/src/types/near.rs

@@ -352,12 +352,3 @@ pub struct ViewResult {
     pub result: Vec<u8>,
     pub logs: Vec<String>,
 }
-
-#[derive(Debug, Clone, Serialize, Deserialize)]
-pub struct View {
-    pub request_type: String,
-    pub finality: String,
-    pub method_name: String,
-    #[serde(with = "base64_format")]
-    pub args_base64: Vec<u8>,
-}