near-api 0.8.6

Rust library to interact with NEAR Protocol via RPC API
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

use async_trait::async_trait;
use near_openapi_client::types::{
    ErrorWrapperForRpcQueryError, JsonRpcRequestForQuery, JsonRpcRequestForQueryMethod,
    JsonRpcResponseForRpcQueryResponseAndRpcQueryError, RpcQueryError, RpcQueryResponse,
};

use crate::{
    NetworkConfig,
    advanced::{RpcType, query_request::QueryRequest},
    common::utils::{is_critical_query_error, to_retry_error},
    config::RetryResponse,
    errors::SendRequestError,
};
use near_api_types::Reference;

#[derive(Clone, Debug)]
pub struct SimpleQueryRpc {
    pub request: QueryRequest,
}

#[async_trait]
impl RpcType for SimpleQueryRpc {
    type RpcReference = Reference;
    type Response = RpcQueryResponse;
    type Error = RpcQueryError;
    async fn send_query(
        &self,
        client: &near_openapi_client::Client,
        _network: &NetworkConfig,
        reference: &Reference,
    ) -> RetryResponse<RpcQueryResponse, SendRequestError<RpcQueryError>> {
        let request = self.request.clone().to_rpc_query_request(reference.clone());
        let response = client
            .query(&JsonRpcRequestForQuery {
                id: "0".to_string(),
                jsonrpc: "2.0".to_string(),
                method: JsonRpcRequestForQueryMethod::Query,
                params: request,
            })
            .await
            .map(|r| r.into_inner())
            .map_err(SendRequestError::from);

        match response {
            Ok(JsonRpcResponseForRpcQueryResponseAndRpcQueryError::Variant0 { result, .. }) => {
                RetryResponse::Ok(result)
            }
            Ok(JsonRpcResponseForRpcQueryResponseAndRpcQueryError::Variant1 { error, .. }) => {
                let error = SendRequestError::from(error);
                to_retry_error(error, is_critical_query_error)
            }
            Err(err) => to_retry_error(err, is_critical_query_error),
        }
    }
}

impl From<ErrorWrapperForRpcQueryError> for SendRequestError<RpcQueryError> {
    fn from(err: ErrorWrapperForRpcQueryError) -> Self {
        match err {
            ErrorWrapperForRpcQueryError::InternalError(internal_error) => {
                Self::InternalError(internal_error)
            }
            ErrorWrapperForRpcQueryError::RequestValidationError(
                rpc_request_validation_error_kind,
            ) => Self::RequestValidationError(rpc_request_validation_error_kind),
            ErrorWrapperForRpcQueryError::HandlerError(server_error) => {
                Self::ServerError(server_error)
            }
        }
    }
}