feat(ext): add app-side library for NEAR

crates/sdk/libs/near/src/jsonrpc.rs

@@ -25,7 +25,7 @@ impl Client {
         }
     }
 
-    pub fn call<M>(&self, method: M) -> Result<M::Response, Error<RpcError<M::Error>>>
+    pub fn call<M>(&self, method: M) -> Result<M::Response, Error<M::Error>>
     where
         M: RpcMethod,
     {
@@ -42,9 +42,9 @@ impl Client {
         let response = unsafe { env::ext::fetch(&self.url, "POST", &headers, &body) }
             .map_err(Error::FetchError)?;
 
-        serde_json::from_slice::<Response<M::Response, RpcError<M::Error>>>(&response)?
+        serde_json::from_slice::<Response<M::Response, M::Error>>(&response)?
             .data
-            .map_err(|e| Error::ServerError(e))
+            .map_err(Error::ServerError)
     }
 }
 

crates/sdk/libs/near/src/query.rs

@@ -1,70 +1,12 @@
 use serde_json::json;
 
-use crate::types::{AccountId, BlockHash, BlockHeight, BlockId, BlockReference, ShardId};
+use crate::types::{BlockHash, BlockHeight, BlockId};
 use crate::views::{
     AccessKeyList, AccessKeyView, AccountView, CallResult, ContractCodeView, QueryRequest,
     ViewStateResult,
 };
 use crate::RpcMethod;
 
-#[derive(thiserror::Error, Debug, serde::Serialize, serde::Deserialize)]
-#[serde(tag = "name", content = "info", rename_all = "SCREAMING_SNAKE_CASE")]
-pub enum RpcQueryError {
-    #[error("There are no fully synchronized blocks on the node yet")]
-    NoSyncedBlocks,
-    #[error("The node does not track the shard ID {requested_shard_id}")]
-    UnavailableShard { requested_shard_id: ShardId },
-    #[error(
-        "The data for block #{block_height} is garbage collected on this node, use an archival node to fetch historical data"
-    )]
-    GarbageCollectedBlock {
-        block_height: BlockHeight,
-        block_hash: calimero_primitives::hash::Hash,
-    },
-    #[error("Block either has never been observed on the node or has been garbage collected: {block_reference:?}")]
-    UnknownBlock { block_reference: BlockReference },
-    #[error("Account ID {requested_account_id} is invalid")]
-    InvalidAccount {
-        requested_account_id: AccountId,
-        block_height: BlockHeight,
-        block_hash: calimero_primitives::hash::Hash,
-    },
-    #[error("account {requested_account_id} does not exist while viewing")]
-    UnknownAccount {
-        requested_account_id: AccountId,
-        block_height: BlockHeight,
-        block_hash: calimero_primitives::hash::Hash,
-    },
-    #[error(
-        "Contract code for contract ID #{contract_account_id} has never been observed on the node"
-    )]
-    NoContractCode {
-        contract_account_id: AccountId,
-        block_height: BlockHeight,
-        block_hash: calimero_primitives::hash::Hash,
-    },
-    #[error("State of contract {contract_account_id} is too large to be viewed")]
-    TooLargeContractState {
-        contract_account_id: AccountId,
-        block_height: BlockHeight,
-        block_hash: calimero_primitives::hash::Hash,
-    },
-    #[error("Access key for public key {public_key} has never been observed on the node")]
-    UnknownAccessKey {
-        public_key: String,
-        block_height: BlockHeight,
-        block_hash: calimero_primitives::hash::Hash,
-    },
-    #[error("Function call returned an error: {vm_error}")]
-    ContractExecutionError {
-        vm_error: String,
-        block_height: BlockHeight,
-        block_hash: calimero_primitives::hash::Hash,
-    },
-    #[error("The node reached its limits. Try again later. More details: {error_message}")]
-    InternalError { error_message: String },
-}
-
 #[derive(serde::Serialize, Debug)]
 pub struct RpcQueryRequest {
     pub block_id: BlockId,
@@ -93,7 +35,7 @@ pub enum QueryResponseKind {
 
 impl RpcMethod for RpcQueryRequest {
     type Response = RpcQueryResponse;
-    type Error = RpcQueryError;
+    type Error = String;
 
     fn method_name(&self) -> &str {
         "query"

crates/sdk/libs/near/src/types.rs

@@ -7,7 +7,6 @@ pub type AccountId = near_account_id::AccountId;
 pub type StorageUsage = u64;
 pub type Nonce = u64;
 pub type Balance = u128;
-pub type ShardId = u64;
 
 #[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
 #[serde(untagged)]
@@ -16,32 +15,6 @@ pub enum BlockId {
     Hash(BlockHash),
 }
 
-#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
-#[serde(rename_all = "snake_case")]
-pub enum BlockReference {
-    BlockId(BlockId),
-    Finality(Finality),
-    SyncCheckpoint(SyncCheckpoint),
-}
-
-#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
-#[serde(rename_all = "snake_case")]
-pub enum SyncCheckpoint {
-    Genesis,
-    EarliestAvailable,
-}
-
-#[derive(serde::Serialize, serde::Deserialize, Default, Clone, Debug)]
-pub enum Finality {
-    #[serde(rename = "optimistic")]
-    None,
-    #[serde(rename = "near-final")]
-    DoomSlug,
-    #[serde(rename = "final")]
-    #[default]
-    Final,
-}
-
 #[serde_as]
 #[derive(serde::Deserialize, Clone, Debug)]
 #[serde(transparent)]