Bump dependency

Cargo.toml

@@ -12,17 +12,17 @@ rust-version = "1.67.1"
 
 [dependencies]
 log = "0.4.17"
-borsh = "0.10.2"
+borsh = "1.3.0"
 serde = "1.0.145"
 reqwest = { version = "0.11.12", features = ["json"], default-features = false }
 thiserror = "1.0.37"
 serde_json = "1.0.85"
 lazy_static = "1.4.0"
 
-near-crypto = "0.17.0"
-near-primitives = "0.17.0"
-near-chain-configs = "0.17.0"
-near-jsonrpc-primitives = "0.17.0"
+near-crypto = "0.19.0"
+near-primitives = "0.19.0"
+near-chain-configs = "0.19.0"
+near-jsonrpc-primitives = "0.19.0"
 
 [dev-dependencies]
 tokio = { version = "1.0", features = ["macros", "rt-multi-thread"] }

examples/contract_change_method.rs

@@ -44,7 +44,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         nonce: current_nonce + 1,
         receiver_id: "nosedive.testnet".parse()?,
         block_hash: access_key_query_response.block_hash,
-        actions: vec![Action::FunctionCall(FunctionCallAction {
+        actions: vec![Action::FunctionCall(Box::new(FunctionCallAction {
             method_name: "rate".to_string(),
             args: json!({
                 "account_id": other_account,
@@ -54,7 +54,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             .into_bytes(),
             gas: 100_000_000_000_000, // 100 TeraGas
             deposit: 0,
-        })],
+        }))],
     };
 
     let request = methods::broadcast_tx_async::RpcBroadcastTxAsyncRequest {
@@ -68,8 +68,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         let response = client
             .call(methods::tx::RpcTransactionStatusRequest {
                 transaction_info: TransactionInfo::TransactionId {
-                    hash: tx_hash,
-                    account_id: signer.account_id.clone(),
+                    tx_hash,
+                    sender_account_id: signer.account_id.clone(),
                 },
             })
             .await;

examples/contract_change_method_commit.rs

@@ -42,7 +42,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         nonce: current_nonce + 1,
         receiver_id: "nosedive.testnet".parse()?,
         block_hash: access_key_query_response.block_hash,
-        actions: vec![Action::FunctionCall(FunctionCallAction {
+        actions: vec![Action::FunctionCall(Box::new(FunctionCallAction {
             method_name: "rate".to_string(),
             args: json!({
                 "account_id": other_account,
@@ -52,7 +52,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             .into_bytes(),
             gas: 100_000_000_000_000, // 100 TeraGas
             deposit: 0,
-        })],
+        }))],
     };
 
     let request = methods::broadcast_tx_commit::RpcBroadcastTxCommitRequest {

examples/create_account.rs

@@ -140,13 +140,13 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             block_hash: latest_hash,
             actions: vec![
                 Action::CreateAccount(CreateAccountAction {}),
-                Action::AddKey(AddKeyAction {
+                Action::AddKey(Box::new(AddKeyAction {
                     access_key: near_primitives::account::AccessKey {
                         nonce: 0,
                         permission: near_primitives::account::AccessKeyPermission::FullAccess,
                     },
                     public_key: new_key_pair.public_key(),
-                }),
+                })),
                 Action::Transfer(TransferAction {
                     deposit: initial_deposit,
                 }),
@@ -166,7 +166,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             nonce: current_nonce + 1,
             receiver_id: contract_id,
             block_hash: latest_hash,
-            actions: vec![Action::FunctionCall(FunctionCallAction {
+            actions: vec![Action::FunctionCall(Box::new(FunctionCallAction {
                 method_name: "create_account".to_string(),
                 args: json!({
                     "new_account_id": new_account_id,
@@ -176,7 +176,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                 .into_bytes(),
                 gas: 300_000_000_000_000,
                 deposit: initial_deposit,
-            })],
+            }))],
         }
     };
 
@@ -202,8 +202,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         let response = client
             .call(methods::tx::RpcTransactionStatusRequest {
                 transaction_info: TransactionInfo::TransactionId {
-                    hash: tx_hash,
-                    account_id: signer.account_id.clone(),
+                    tx_hash,
+                    sender_account_id: signer.account_id.clone(),
                 },
             })
             .await;

examples/query_tx.rs

@@ -96,8 +96,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         match client
             .call(methods::tx::RpcTransactionStatusRequest {
                 transaction_info: methods::tx::TransactionInfo::TransactionId {
-                    hash: tx_hash,
-                    account_id,
+                    tx_hash,
+                    sender_account_id: account_id,
                 },
             })
             .await

src/lib.rs

@@ -45,8 +45,8 @@
 //!
 //!    let tx_status_request = methods::tx::RpcTransactionStatusRequest {
 //!        transaction_info: TransactionInfo::TransactionId {
-//!            hash: "9FtHUFBQsZ2MG77K3x3MJ9wjX3UT8zE1TczCrhZEcG8U".parse()?,
-//!            account_id: "miraclx.near".parse()?,
+//!            tx_hash: "9FtHUFBQsZ2MG77K3x3MJ9wjX3UT8zE1TczCrhZEcG8U".parse()?,
+//!            sender_account_id: "miraclx.near".parse()?,
 //!        },
 //!    };
 //!
@@ -450,7 +450,7 @@ mod tests {
             matches!(
                 tx_status,
                 Ok(methods::tx::RpcTransactionStatusResponse { ref transaction, .. })
-                if transaction.signer_id.as_ref() == "miraclx.near"
+                if transaction.signer_id == "miraclx.near"
                 && transaction.hash == "9FtHUFBQsZ2MG77K3x3MJ9wjX3UT8zE1TczCrhZEcG8U".parse()?
             ),
             "expected an Ok(RpcTransactionStatusResponse) with matching signer_id + hash, found [{:?}]",

src/methods/broadcast_tx_async.rs

@@ -10,11 +10,12 @@ pub struct RpcBroadcastTxAsyncRequest {
 }
 
 impl From<RpcBroadcastTxAsyncRequest>
-    for near_jsonrpc_primitives::types::transactions::RpcBroadcastTransactionRequest
+    for near_jsonrpc_primitives::types::transactions::RpcSendTransactionRequest
 {
     fn from(this: RpcBroadcastTxAsyncRequest) -> Self {
         Self {
             signed_transaction: this.signed_transaction,
+            wait_until: near_primitives::views::TxExecutionStatus::None,
         }
     }
 }

src/methods/broadcast_tx_commit.rs

@@ -11,11 +11,12 @@ pub struct RpcBroadcastTxCommitRequest {
 }
 
 impl From<RpcBroadcastTxCommitRequest>
-    for near_jsonrpc_primitives::types::transactions::RpcBroadcastTransactionRequest
+    for near_jsonrpc_primitives::types::transactions::RpcSendTransactionRequest
 {
     fn from(this: RpcBroadcastTxCommitRequest) -> Self {
         Self {
             signed_transaction: this.signed_transaction,
+            wait_until: near_primitives::views::TxExecutionStatus::None,
         }
     }
 }

src/methods/experimental/check_tx.rs

@@ -11,11 +11,12 @@ pub struct RpcCheckTxRequest {
 }
 
 impl From<RpcCheckTxRequest>
-    for near_jsonrpc_primitives::types::transactions::RpcBroadcastTransactionRequest
+    for near_jsonrpc_primitives::types::transactions::RpcSendTransactionRequest
 {
     fn from(this: RpcCheckTxRequest) -> Self {
         Self {
             signed_transaction: this.signed_transaction,
+            wait_until: near_primitives::views::TxExecutionStatus::None,
         }
     }
 }

src/methods/experimental/tx_status.rs

@@ -12,11 +12,12 @@ pub struct RpcTransactionStatusRequest {
 }
 
 impl From<RpcTransactionStatusRequest>
-    for near_jsonrpc_primitives::types::transactions::RpcTransactionStatusCommonRequest
+    for near_jsonrpc_primitives::types::transactions::RpcTransactionStatusRequest
 {
     fn from(this: RpcTransactionStatusRequest) -> Self {
         Self {
             transaction_info: this.transaction_info,
+            wait_until: near_primitives::views::TxExecutionStatus::None,
         }
     }
 }
@@ -34,10 +35,14 @@ impl RpcMethod for RpcTransactionStatusRequest {
     fn params(&self) -> Result<serde_json::Value, io::Error> {
         Ok(match &self.transaction_info {
             TransactionInfo::Transaction(signed_transaction) => {
-                json!([common::serialize_signed_transaction(signed_transaction)?])
+                match signed_transaction {
+                    near_jsonrpc_primitives::types::transactions::SignedTransaction::SignedTransaction(tx) => {
+                        json!([common::serialize_signed_transaction(tx)?])
+                    },
+                }
             }
-            TransactionInfo::TransactionId { hash, account_id } => {
-                json!([hash, account_id])
+            TransactionInfo::TransactionId { tx_hash,sender_account_id } => {
+                json!([tx_hash, sender_account_id])
             }
         })
     }

src/methods/mod.rs

@@ -177,9 +177,7 @@ mod common {
     pub fn serialize_signed_transaction(
         tx: &near_primitives::transaction::SignedTransaction,
     ) -> Result<String, io::Error> {
-        Ok(near_primitives::serialize::to_base64(
-            &borsh::BorshSerialize::try_to_vec(&tx)?,
-        ))
+        Ok(near_primitives::serialize::to_base64(&borsh::to_vec(&tx)?))
     }
 
     // adv_*

src/methods/tx.rs

@@ -14,8 +14,8 @@
 //!
 //! let request = methods::tx::RpcTransactionStatusRequest {
 //!     transaction_info: methods::tx::TransactionInfo::TransactionId {
-//!         hash: tx_hash,
-//!         account_id: "itranscend.near".parse()?,
+//!         tx_hash,
+//!         sender_account_id: "itranscend.near".parse()?,
 //!    }
 //! };
 //!
@@ -38,11 +38,12 @@ pub struct RpcTransactionStatusRequest {
 }
 
 impl From<RpcTransactionStatusRequest>
-    for near_jsonrpc_primitives::types::transactions::RpcTransactionStatusCommonRequest
+    for near_jsonrpc_primitives::types::transactions::RpcTransactionStatusRequest
 {
     fn from(this: RpcTransactionStatusRequest) -> Self {
         Self {
             transaction_info: this.transaction_info,
+            wait_until: near_primitives::views::TxExecutionStatus::None,
         }
     }
 }
@@ -58,10 +59,14 @@ impl RpcMethod for RpcTransactionStatusRequest {
     fn params(&self) -> Result<serde_json::Value, io::Error> {
         Ok(match &self.transaction_info {
             TransactionInfo::Transaction(signed_transaction) => {
-                json!([common::serialize_signed_transaction(signed_transaction)?])
+                match signed_transaction {
+                    near_jsonrpc_primitives::types::transactions::SignedTransaction::SignedTransaction(tx) => {
+                        json!([common::serialize_signed_transaction(tx)?])
+                    }
+                }
             }
-            TransactionInfo::TransactionId { hash, account_id } => {
-                json!([hash, account_id])
+            TransactionInfo::TransactionId { tx_hash,sender_account_id, ..} => {
+                json!([tx_hash, sender_account_id])
             }
         })
     }