afast 0.0.13

AFast: high-performance async Rust web framework with HTTP, WS, TCP support, automatic client generation, validation, and documentation.
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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138

pub enum Error {
    DecodeError,
    EncodeError,
    ClientError,
    ServerError,
    CustomError(u16, String),
}

impl Error {
    pub fn decode_error() -> Self {
        #[cfg(not(feature = "trace"))]
        {
            Self::DecodeError
        }
        #[cfg(feature = "trace")]
        Self::CustomError(400, capture_user_backtrace("400 DecodeError"))
    }

    pub fn encode_error() -> Self {
        #[cfg(not(feature = "trace"))]
        {
            Self::EncodeError
        }
        #[cfg(feature = "trace")]
        Self::CustomError(500, capture_user_backtrace("500 EncodeError"))
    }

    pub fn client_error() -> Self {
        #[cfg(not(feature = "trace"))]
        {
            Self::ClientError
        }
        #[cfg(feature = "trace")]
        Self::CustomError(400, capture_user_backtrace("400 Bad Request"))
    }

    pub fn server_error() -> Self {
        #[cfg(not(feature = "trace"))]
        {
            Self::ServerError
        }
        #[cfg(feature = "trace")]
        Self::CustomError(500, capture_user_backtrace("500 Internal Server Error"))
    }

    pub fn custom_error(code: u16, message: String) -> Self {
        Self::CustomError(code, message)
    }

    pub fn client(message: &str) -> Self {
        #[cfg(not(feature = "trace"))]
        {
            Self::CustomError(400, message.to_string())
        }
        #[cfg(feature = "trace")]
        Self::CustomError(400, capture_user_backtrace(message))
    }

    pub fn server(message: &str) -> Self {
        #[cfg(not(feature = "trace"))]
        {
            Self::CustomError(500, message.to_string())
        }
        #[cfg(feature = "trace")]
        Self::CustomError(500, capture_user_backtrace(message))
    }
}

impl std::fmt::Debug for Error {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            Error::DecodeError => write!(f, "Decode error"),
            Error::EncodeError => write!(f, "Encode error"),
            Error::ClientError => write!(f, "400 Bad Request"),
            Error::ServerError => write!(f, "500 Internal Server Error"),
            Error::CustomError(code, message) => write!(f, " {} Custom error: {}", code, message),
        }
    }
}

impl std::fmt::Display for Error {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            Error::DecodeError => write!(f, "Decode error"),
            Error::EncodeError => write!(f, "Encode error"),
            Error::ClientError => write!(f, "400 Bad Request"),
            Error::ServerError => write!(f, "500 Internal Server Error"),
            Error::CustomError(code, message) => write!(f, " {} Custom error: {}", code, message),
        }
    }
}

impl std::error::Error for Error {}

#[cfg(feature = "trace")]
pub fn capture_user_backtrace(message: &str) -> String {
    use backtrace::Backtrace;

    let mut out = Vec::new();
    out.push(message.to_string());

    let bt = Backtrace::new();

    for frame in bt.frames() {
        for sym in frame.symbols() {
            let path = sym.filename().map(|p| p.to_string_lossy().to_string());

            // 获取当前库名
            let self_crate = env!("CARGO_PKG_NAME");

            // 过滤规则：只保留用户项目源代码
            let is_user_code = match path {
                Some(ref p) => {
                    // 过滤掉标准库 / 注册表 / rustc 构建路径 / 你的库自身
                    !p.contains(".cargo/registry")
                        && !p.contains("rustc")
                        && !p.contains("std/src")
                        && !p.contains(self_crate)   // 不显示库自身
                        && p.contains("src/") // 用户工程文件基本都在 src/
                }
                None => false,
            };

            if !is_user_code {
                continue;
            }

            if let Some(p) = sym.filename() {
                let line = sym.lineno().unwrap_or(0);
                out.push(format!("{}:{}", p.display(), line));
            } else if let Some(name) = sym.name() {
                out.push(format!("{}", name));
            }
        }
    }

    out.join("\n")
}