near_jsonrpc_primitives/types/
blocks.rs

1use serde_json::Value;
2
3#[derive(thiserror::Error, Debug, Clone, serde::Serialize, serde::Deserialize)]
4#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
5#[serde(tag = "name", content = "info", rename_all = "SCREAMING_SNAKE_CASE")]
6pub enum RpcBlockError {
7    #[error("Block not found: {error_message}")]
8    UnknownBlock {
9        // We are skipping this field for now
10        // until we can provide useful struct like block_height or block_hash
11        // that was requested
12        #[serde(skip_serializing)]
13        error_message: String,
14    },
15    #[error("There are no fully synchronized blocks yet")]
16    NotSyncedYet,
17    #[error("The node reached its limits. Try again later. More details: {error_message}")]
18    InternalError { error_message: String },
19}
20
21#[derive(Debug, serde::Serialize, serde::Deserialize, arbitrary::Arbitrary)]
22#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
23pub struct RpcBlockRequest {
24    #[serde(flatten)]
25    pub block_reference: near_primitives::types::BlockReference,
26}
27
28#[derive(Debug, serde::Serialize, serde::Deserialize)]
29#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
30pub struct RpcBlockResponse {
31    #[serde(flatten)]
32    pub block_view: near_primitives::views::BlockView,
33}
34
35impl From<RpcBlockError> for crate::errors::RpcError {
36    fn from(error: RpcBlockError) -> Self {
37        let error_data = match &error {
38            RpcBlockError::UnknownBlock { error_message } => Some(Value::String(format!(
39                "DB Not Found Error: {} \n Cause: Unknown",
40                error_message
41            ))),
42            RpcBlockError::NotSyncedYet | RpcBlockError::InternalError { .. } => {
43                Some(Value::String(error.to_string()))
44            }
45        };
46
47        let error_data_value = match serde_json::to_value(error) {
48            Ok(value) => value,
49            Err(err) => {
50                return Self::new_internal_error(
51                    None,
52                    format!("Failed to serialize RpcBlockError: {:?}", err),
53                );
54            }
55        };
56
57        Self::new_internal_or_handler_error(error_data, error_data_value)
58    }
59}
near_jsonrpc_primitives/types/blocks.rs

near_jsonrpc_primitives/types/
blocks.rs
