neo3 1.3.0

Production-ready Rust SDK for Neo N3 blockchain with high-level API, unified error handling, and enterprise features
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
72
73
74
75
76
77
78
79
80
81
82
83

use primitive_types::U256;

use crate::neo_clients::{JsonRpcError, ProviderError, RpcError};

use super::WsError;

#[derive(Debug, thiserror::Error)]
pub enum WsClientError {
	/// Thrown if deserialization failed
	#[error(transparent)]
	JsonError(#[from] serde_json::Error),

	/// Thrown if the response could not be parsed
	#[error(transparent)]
	JsonRpcError(#[from] JsonRpcError),

	/// Internal lib error
	#[error(transparent)]
	InternalError(#[from] WsError),

	/// Remote server sent a Close message
	#[error("Websocket closed unexpectedly")]
	UnexpectedClose,

	/// Unexpected channel closure
	#[error("Unexpected internal channel closure. This is likely a bug. Please report via github")]
	DeadChannel,

	/// Thrown if the websocket responds with binary data
	#[error("Websocket responded with unexpected binary data")]
	UnexpectedBinary(Vec<u8>),

	/// PubSubClient asked to listen to an unknown subscription id
	#[error("Attempted to listen to unknown subscription: {0:?}")]
	UnknownSubscription(U256),

	/// Too Many Reconnects
	#[error("Reconnect limit reached")]
	TooManyReconnects,
}

impl RpcError for WsClientError {
	fn as_error_response(&self) -> Option<&JsonRpcError> {
		if let WsClientError::JsonRpcError(err) = self {
			Some(err)
		} else {
			None
		}
	}

	fn as_serde_error(&self) -> Option<&serde_json::Error> {
		match self {
			WsClientError::JsonError(err) => Some(err),
			_ => None,
		}
	}
}

impl From<WsClientError> for ProviderError {
	fn from(src: WsClientError) -> Self {
		match src {
			WsClientError::JsonRpcError(err) => ProviderError::JsonRpcError(err),
			WsClientError::JsonError(err) => ProviderError::SerdeJson(err),
			WsClientError::InternalError(err) => ProviderError::CustomError(err.to_string()),
			WsClientError::UnexpectedClose => {
				ProviderError::CustomError("Websocket closed unexpectedly".into())
			},
			WsClientError::DeadChannel => {
				ProviderError::CustomError("Unexpected internal channel closure".into())
			},
			WsClientError::UnexpectedBinary(data) => ProviderError::CustomError(format!(
				"Websocket responded with unexpected binary data ({} bytes)",
				data.len()
			)),
			WsClientError::UnknownSubscription(id) => {
				ProviderError::CustomError(format!("Unknown subscription id: {id:?}"))
			},
			WsClientError::TooManyReconnects => {
				ProviderError::CustomError("Reconnect limit reached".into())
			},
		}
	}
}