wechat-minapp 1.3.5

A rust sdk for wechat miniprogram server api
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
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
//! 微信小程序错误处理模块
//!
//! 该模块定义了与微信小程序 API 交互过程中可能遇到的所有错误类型,
//! 包括微信官方错误码映射和第三方库错误转换。
//!
//! # 错误类型
//!
//! 模块包含两种主要的错误类型:
//!
//! - [`Error`][]: 主要的错误枚举,包含所有可能的错误情况
//! - [`ErrorCode`]: 微信官方错误码的 Rust 枚举表示
//!
//! # 错误处理示例
//!
//! ```no_run
//! use wechat_minapp::error::{Error, ErrorCode};
//!
//! // 处理微信 API 返回的错误
//! fn handle_wechat_error(errcode: i32, errmsg: String) -> Result<(), Error> {
//!     if let Some(code) = ErrorCode::from_repr(errcode) {
//!         return Err(Error::from((code, errmsg)));
//!     }
//!     Ok(())
//! }
//!
//! // 处理网络错误
//! async fn make_api_request() -> Result<(), Error> {
//!     let client = reqwest::Client::new();
//!     let response = client.get("https://api.weixin.qq.com/some/endpoint")
//!         .send()
//!         .await?; // 自动转换为 Error::Reqwest
//!     Ok(())
//! }
//! ```
//!
//! # 错误转换
//!
//! 模块自动实现了从常见第三方库错误到 [`Error`] 的转换:
//!
//! - `reqwest::Error` → `Error::Reqwest`
//! - `serde_json::Error` → `Error::SerdeJson`
//! - `base64::DecodeError` → `Error::Base64Decode`
//! - `aes::cipher::InvalidLength` → `Error::AesInvalidLength`
//!
//! 这使得错误处理更加方便,可以使用 `?` 操作符自动转换。

use serde_repr::Deserialize_repr;

use aes::cipher::InvalidLength as AesInvalidLength;
use aes::cipher::block_padding::UnpadError;
use base64::DecodeError as Base64DecodeError;
use reqwest::Error as ReqwestError;
use serde_json::Error as SerdeJsonError;
use strum::Display;

/// 微信小程序 SDK 错误枚举
///
/// 包含了所有可能遇到的错误类型,包括微信 API 错误、网络错误、加解密错误等。
///
/// # 错误分类
///
/// ## 微信 API 错误
///
/// 这些错误对应微信官方文档中的错误码:
///
/// - `InvalidCredential`: 凭证无效
/// - `InvalidCode`: 登录 code 无效
/// - `RateLimitExceeded`: API 调用频率限制
/// - 等等...
///
/// ## 第三方库错误
///
/// 自动转换的第三方库错误:
///
/// - `Reqwest`: HTTP 请求错误
/// - `SerdeJson`: JSON 序列化/反序列化错误
/// - `Base64Decode`: Base64 解码错误
/// - `AesInvalidLength`: AES 加解密长度错误
///
/// ## 系统错误
///
/// - `System`: 微信系统繁忙
/// - `InternalServer`: 内部服务器错误
///
/// # 示例
///
/// ```no_run
/// use wechat_minapp::error::Error;
///
/// async function make_request() -> Result<(), Error> {
///     // 使用 ? 操作符自动转换错误
///     let response = reqwest::get("https://api.weixin.qq.com/endpoint").await?;
///     let data: serde_json::Value = response.json().await?;
///     Ok(())
/// }
/// ```
///
/// # 序列化
///
/// 此枚举使用 `thiserror` 派生宏,提供了良好的错误消息格式。
/// 每个变体都包含描述性的错误信息。
#[non_exhaustive]
#[derive(Debug, thiserror::Error)]
pub enum Error {
    // #[error("system error: {0}")]
    // System(String),
    // #[error("invalid credential: {0}")]
    // InvalidCredential(String),
    // #[error("invalid grant type: {0}")]
    // InvalidGrantType(String),
    // #[error("invalid app id: {0}")]
    // InvalidAppId(String),
    // #[error("invalid code: {0}")]
    // InvalidCode(String),
    // #[error("invalid parameter: {0}")]
    // InvalidParameter(String),
    // #[error("invalid secret: {0}")]
    // InvalidSecret(String),
    // #[error("forbidden ip: {0}")]
    // ForbiddenIp(String),
    // #[error("code blocked: {0}")]
    // CodeBlocked(String),
    // #[error("secret frozen: {0}")]
    // SecretFrozen(String),
    // #[error("missing access token: {0}")]
    // MissingAccessToken(String),
    // #[error("missing app id: {0}")]
    // MissingAppId(String),
    // #[error("missing secret: {0}")]
    // MissingSecret(String),
    // #[error("missing code: {0}")]
    // MissingCode(String),
    // #[error("required post method: {0}")]
    // RequiredPostMethod(String),
    // #[error("daily request limit exceeded: {0}")]
    // DailyRequestLimitExceeded(String),
    // #[error("rate limit exceeded: {0}")]
    // RateLimitExceeded(String),
    // #[error("forbidden token: {0}")]
    // ForbiddenToken(String),
    // #[error("account frozen: {0}")]
    // AccountFrozen(String),
    // #[error("third party token: {0}")]
    // ThirdPartyToken(String),
    // #[error("session key not existed or expired: {0}")]
    // SessionKeyNotExistedOrExpired(String),
    // #[error("invalid signature method: {0}")]
    // InvalidSignatureMethod(String),
    // #[error("invalid signature: {0}")]
    // InvalidSignature(String),
    // #[error("confirm required: {0}")]
    // ConfirmRequired(String),
    // #[error("request denied one day: {0}")]
    // RequestDeniedOneDay(String),
    // #[error("request denied one hour: {0}")]
    // RequestDeniedOneHour(String),
    // #[error("unpad error: {0}")]
    // Unpad(UnpadError),
    // #[error("aes invalid length: {0}")]
    // AesInvalidLength(#[from] AesInvalidLength),
    // #[error("base64 decode error: {0}")]
    // Base64Decode(#[from] Base64DecodeError),
    // #[error("reqwest: {0}")]
    // Reqwest(#[from] ReqwestError),
    // #[error("json error: {0}")]
    // SerdeJson(#[from] SerdeJsonError),
    // #[error("internal error: {0}")]
    // InternalServer(String),
    /// 微信系统繁忙,请稍候再试
    #[error("system error: {0}")]
    System(String),

    /// 获取 access_token 时 AppSecret 错误,或者 access_token 无效
    #[error("invalid credential: {0}")]
    InvalidCredential(String),

    /// 不合法的凭证类型
    #[error("invalid grant type: {0}")]
    InvalidGrantType(String),

    /// 不合法的 AppID,请检查 AppID 的正确性
    #[error("invalid app id: {0}")]
    InvalidAppId(String),

    /// 登录 code 无效或已过期
    #[error("invalid code: {0}")]
    InvalidCode(String),

    /// 请求参数错误
    #[error("invalid parameter: {0}")]
    InvalidParameter(String),

    /// 无效的 appsecret,请检查 appsecret 的正确性
    #[error("invalid secret: {0}")]
    InvalidSecret(String),

    /// IP 地址不在白名单中
    #[error("forbidden ip: {0}")]
    ForbiddenIp(String),

    /// 高风险等级用户,小程序登录被拦截
    #[error("code blocked: {0}")]
    CodeBlocked(String),

    /// AppSecret 已被冻结,请登录小程序平台解冻
    #[error("secret frozen: {0}")]
    SecretFrozen(String),

    /// 缺少 access_token 参数
    #[error("missing access token: {0}")]
    MissingAccessToken(String),

    /// 缺少 appid 参数
    #[error("missing app id: {0}")]
    MissingAppId(String),

    /// 缺少 secret 参数
    #[error("missing secret: {0}")]
    MissingSecret(String),

    /// 缺少 code 参数
    #[error("missing code: {0}")]
    MissingCode(String),

    /// 需要 POST 请求
    #[error("required post method: {0}")]
    RequiredPostMethod(String),

    /// 调用超过天级别频率限制
    #[error("daily request limit exceeded: {0}")]
    DailyRequestLimitExceeded(String),

    /// API 调用太频繁,请稍候再试
    #[error("rate limit exceeded: {0}")]
    RateLimitExceeded(String),

    /// 禁止使用 token 接口
    #[error("forbidden token: {0}")]
    ForbiddenToken(String),

    /// 账号已冻结
    #[error("account frozen: {0}")]
    AccountFrozen(String),

    /// 第三方平台 API 需要使用第三方平台专用 token
    #[error("third party token: {0}")]
    ThirdPartyToken(String),

    /// session_key 不存在或已过期
    #[error("session key not existed or expired: {0}")]
    SessionKeyNotExistedOrExpired(String),

    /// 无效的签名方法
    #[error("invalid signature method: {0}")]
    InvalidSignatureMethod(String),

    /// 无效的签名
    #[error("invalid signature: {0}")]
    InvalidSignature(String),

    /// 此次调用需要管理员确认,请耐心等候
    #[error("confirm required: {0}")]
    ConfirmRequired(String),

    /// 该IP调用请求已被公众号管理员拒绝,请24小时后再试
    #[error("request denied one day: {0}")]
    RequestDeniedOneDay(String),

    /// 该IP调用请求已被公众号管理员拒绝,请1小时后再试
    #[error("request denied one hour: {0}")]
    RequestDeniedOneHour(String),

    /// AES 解密时数据填充错误
    #[error("unpad error: {0}")]
    Unpad(UnpadError),

    /// AES 加解密长度错误
    #[error("aes invalid length: {0}")]
    AesInvalidLength(#[from] AesInvalidLength),

    /// Base64 解码错误
    #[error("base64 decode error: {0}")]
    Base64Decode(#[from] Base64DecodeError),

    /// HTTP 请求错误
    #[error("reqwest: {0}")]
    Reqwest(#[from] ReqwestError),

    /// JSON 序列化/反序列化错误
    #[error("json error: {0}")]
    SerdeJson(#[from] SerdeJsonError),

    /// 内部服务器错误
    #[error("internal error: {0}")]
    InternalServer(String),
}

impl From<UnpadError> for Error {
    fn from(error: UnpadError) -> Self {
        Error::Unpad(error)
    }
}

/// 微信官方错误码枚举
///
/// 对应微信小程序 API 返回的错误码,每个错误码都有对应的中文描述。
///
/// # 使用示例
///
/// ```
/// use wechat_minapp::error::ErrorCode;
///
/// // 从数值获取错误码
/// if let Some(error_code) = ErrorCode::from_repr(40029) {
///     println!("错误: {}", error_code);
///     // 输出: "错误: code 无效"
/// }
///
/// // 获取错误码的数值
/// let code_value = ErrorCode::InvalidCode as i32;
/// assert_eq!(code_value, 40029);
/// ```
///
/// # 错误码说明
///
/// 完整的错误码列表请参考:
/// [微信官方文档 - 全局返回码说明](https://developers.weixin.qq.com/miniprogram/dev/OpenApiDoc/#%E5%85%A8%E5%B1%80%E8%BF%94%E5%9B%9E%E7%A0%81%E8%AF%B4%E6%98%8E)
#[derive(Debug, Deserialize_repr, Display)]
#[repr(i32)]
pub enum ErrorCode {
    #[strum(serialize = "系统繁忙,此时请开发者稍候再试")]
    System = -1,
    #[strum(
        serialize = "获取 access_token 时 AppSecret 错误,或者 access_token 无效。请开发者认真比对 AppSecret 的正确性,或查看是否正在为恰当的公众号调用接口"
    )]
    InvalidCredential = 40001,
    #[strum(serialize = "不合法的凭证类型")]
    InvalidGrantType = 40002,
    #[strum(serialize = "不合法的 AppID ,请开发者检查 AppID 的正确性,避免异常字符,注意大小写")]
    InvalidAppId = 40013,
    #[strum(serialize = "code 无效")]
    InvalidCode = 40029,
    #[strum(serialize = "参数错误")]
    InvalidParameter = 40097,
    #[strum(serialize = "无效的appsecret,请检查appsecret的正确性")]
    InvalidSecret = 40125,
    #[strum(serialize = "将ip添加到ip白名单列表即可")]
    ForbiddenIp = 40164,
    #[strum(serialize = "高风险等级用户,小程序登录拦截 。风险等级详见用户安全解方案")]
    CodeBlocked = 40226,
    #[strum(serialize = "AppSecret已被冻结,请登录小程序平台解冻后再次调用")]
    SecretFrozen = 40243,
    #[strum(serialize = "缺少 access token 参数")]
    MissingAccessToken = 41001,
    #[strum(serialize = "缺少 appid 参数")]
    MissingAppId = 41002,
    #[strum(serialize = "缺少 secret 参数")]
    MissingSecret = 41004,
    MissingCode = 41008,
    #[strum(serialize = "需要 POST 请求")]
    RequiredPostMethod = 43002,
    #[strum(serialize = "调用超过天级别频率限制。可调用clear_quota接口恢复调用额度。")]
    DailyRequestLimitExceeded = 45009,
    #[strum(serialize = "API 调用太频繁,请稍候再试")]
    RateLimitExceeded = 45011,
    #[strum(serialize = "禁止使用 token 接口")]
    ForbiddenToken = 50004,
    #[strum(serialize = "账号已冻结")]
    AccountFrozen = 50007,
    #[strum(serialize = "第三方平台 API 需要使用第三方平台专用 token")]
    ThirdPartyToken = 61024,
    #[strum(serialize = "session_key is not existed or expired")]
    SessionKeyNotExistedOrExpired = 87007,
    #[strum(serialize = "invalid sig_method")]
    InvalidSignatureMethod = 87008,
    #[strum(serialize = "无效的签名")]
    InvalidSignature = 87009,
    #[strum(serialize = "此次调用需要管理员确认,请耐心等候")]
    ConfirmRequired = 89503,
    #[strum(
        serialize = "该IP调用求请求已被公众号管理员拒绝,请24小时后再试,建议调用前与管理员沟通确认"
    )]
    RequestDeniedOneDay = 89506,
    #[strum(
        serialize = "该IP调用求请求已被公众号管理员拒绝,请1小时后再试,建议调用前与管理员沟通确认"
    )]
    RequestDeniedOneHour = 89507,
}

impl From<(ErrorCode, String)> for Error {
    /// 从微信错误码和消息创建 Error
    ///
    /// # 参数
    ///
    /// - `(code, message)`: 微信错误码和对应的错误消息
    ///
    /// # 返回
    ///
    /// 对应的 `Error` 枚举变体
    fn from((code, message): (ErrorCode, String)) -> Self {
        use ErrorCode::*;

        match code {
            System => Error::System(message),
            InvalidCredential => Error::InvalidCredential(message),
            InvalidGrantType => Error::InvalidGrantType(message),
            InvalidAppId => Error::InvalidAppId(message),
            InvalidCode => Error::InvalidCode(message),
            InvalidParameter => Error::InvalidParameter(message),
            InvalidSecret => Error::InvalidSecret(message),
            ForbiddenIp => Error::ForbiddenIp(message),
            CodeBlocked => Error::CodeBlocked(message),
            SecretFrozen => Error::SecretFrozen(message),
            MissingAccessToken => Error::MissingAccessToken(message),
            MissingAppId => Error::MissingAppId(message),
            MissingSecret => Error::MissingSecret(message),
            MissingCode => Error::MissingCode(message),
            RequiredPostMethod => Error::RequiredPostMethod(message),
            DailyRequestLimitExceeded => Error::DailyRequestLimitExceeded(message),
            RateLimitExceeded => Error::RateLimitExceeded(message),
            ForbiddenToken => Error::ForbiddenToken(message),
            AccountFrozen => Error::AccountFrozen(message),
            ThirdPartyToken => Error::ThirdPartyToken(message),
            SessionKeyNotExistedOrExpired => Error::SessionKeyNotExistedOrExpired(message),
            InvalidSignatureMethod => Error::InvalidSignatureMethod(message),
            InvalidSignature => Error::InvalidSignature(message),
            ConfirmRequired => Error::ConfirmRequired(message),
            RequestDeniedOneDay => Error::RequestDeniedOneDay(message),
            RequestDeniedOneHour => Error::RequestDeniedOneHour(message),
        }
    }
}