walle-core 0.2.1

Onebot Lib in Rust
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

use thiserror::Error;
#[cfg(feature = "websocket")]
#[cfg_attr(docsrs, doc(cfg(feature = "websocket")))]
use tokio_tungstenite::tungstenite::Error as WsError;

pub type WalleResult<T> = std::result::Result<T, WalleError>;

#[derive(Error, Debug)]
pub enum WalleError {
    // serde
    #[error("Serde Json error: {0}")]
    SerdeJsonError(#[from] serde_json::Error),
    #[error("Serde MsgPack error: {0}")]
    SerdeMsgPackError(#[from] rmp_serde::decode::Error),
    // comms
    #[error("Authorization failed")]
    AuthorizationFailed,
    #[error("Tcpconnect connect to {0} failed")]
    TcpConnectFailed(std::io::Error),
    #[cfg(feature = "websocket")]
    #[cfg_attr(docsrs, doc(cfg(feature = "websocket")))]
    #[error("Websocket upgrade failed: {0}")]
    WebsocketUpgradeFail(#[from] WsError),
    #[error("Websocket link has no peer address")]
    WebsocketNoAddress,
    /// action
    #[error("Action send error")]
    ActionSendError,
    /// resp
    #[error("Action Response Timeout")]
    ActionResponseTimeout,
    #[error("Action Response RecvError:{0}")]
    ActionResponseRecvError(#[from] tokio::sync::oneshot::error::RecvError),
    /// server
    #[error("TcpServer bind address error: {0}")]
    TcpServerBindAddressError(#[from] std::io::Error),
    /// Running Time Error
    #[error("OneBot is already running")]
    AlreadyRunning,

    // ExtendedMap
    #[error("ExtendedMap missed key: {0}")]
    MapMissedKey(String),
    #[error("ExtendedMap value type mismatch: expect {0}, got {1}")]
    MapValueTypeMismatch(String, String),
}

pub(crate) trait WalleLogExt: Sized {
    fn wran_err(&self);
    fn error_err(&self);
    fn info(self, s: &str) -> Self {
        tracing::info!(target: "Walle-core", "{}", s);
        self
    }
    fn debug(self, s: &str) -> Self {
        tracing::debug!(target: "Walle-core", "{}", s);
        self
    }
    fn trace(self, s: &str) -> Self {
        tracing::trace!(target: "Walle-core", "{}", s);
        self
    }
}

impl<T> WalleLogExt for WalleResult<T> {
    fn wran_err(&self) {
        if let Err(e) = self {
            e.wran_err();
        }
    }

    fn error_err(&self) {
        if let Err(e) = self {
            e.error_err();
        }
    }
}

impl WalleLogExt for WalleError {
    fn wran_err(&self) {
        use tracing::warn;
        warn!(target: "Walle-core","{}", self);
    }

    fn error_err(&self) {
        use tracing::error;
        error!(target: "Walle-core","{}", self);
    }
}