binance-common 0.2.3

Common data structures, error types, and utilities shared across Binance API crates.
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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

use hmac::digest::InvalidLength;
use serde::Deserialize;
use std::fmt::Display;

#[derive(Debug)]
pub enum BinanceError {
    Api(ApiError),
    BuildRequest(String),
    Channel(String),
    Deserialize(serde_json::Error),
    IpBanned,
    InternalServer,
    Request(reqwest::Error),
    RequestTimeout,
    Signature(InvalidLength),
    TooManyRequest,
    Unknown(String),
    WebSocket(ApiError),
    WebSocketInternal(String),
}

#[derive(Debug, Deserialize)]
pub struct ApiError {
    pub code: i16,
    pub msg: String,
}

impl Display for BinanceError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            BinanceError::Api(ApiError { code, msg }) => {
                write!(f, "[BinanceError::Api] code: {}, message: {}", code, msg)
            }

            BinanceError::BuildRequest(msg) => {
                write!(f, "[BinanceError::BuildRequest] {}", msg)
            }
            BinanceError::Channel(msg) => {
                write!(f, "[BinanceError::Channel] {}", msg)
            }
            BinanceError::Deserialize(e) => {
                write!(f, "[BinanceError::Deserialize] {}", e)
            }
            BinanceError::IpBanned => {
                write!(
                    f,
                    "[BinanceError::IpBanned] IP Auto-banned due to repeated 429 responses."
                )
            }
            BinanceError::InternalServer => {
                write!(
                    f,
                    "[BinanceError::InternalServer] Binance internal server error."
                )
            }
            BinanceError::Request(e) => {
                write!(f, "[BinanceError::Request] {}", e)
            }
            BinanceError::RequestTimeout => {
                write!(f, "[BinanceError::RequestTimeout] Request timed out.")
            }
            BinanceError::Signature(e) => {
                write!(f, "[BinanceError::Signature] Signature error: {}", e)
            }
            BinanceError::TooManyRequest => {
                write!(
                    f,
                    "[BinanceError::TooManyRequest] Rate limit exceeded (HTTP 429)."
                )
            }
            BinanceError::Unknown(e) => {
                write!(f, "[BinanceError::Unknown] {}", e)
            }
            BinanceError::WebSocket(ApiError { code, msg }) => {
                write!(
                    f,
                    "[BinanceError::WebSocket] code: {}, message: {}",
                    code, msg
                )
            }
            BinanceError::WebSocketInternal(msg) => {
                write!(f, "[BinnaceError::WebSocketInternal] {}", msg)
            }
        }
    }
}

impl From<InvalidLength> for BinanceError {
    fn from(value: InvalidLength) -> Self {
        BinanceError::Signature(value)
    }
}

impl From<reqwest::Error> for BinanceError {
    fn from(value: reqwest::Error) -> Self {
        BinanceError::Request(value)
    }
}

impl From<serde_json::Error> for BinanceError {
    fn from(value: serde_json::Error) -> Self {
        BinanceError::Deserialize(value)
    }
}