wx-sdk 0.0.9

A Wechat SDK written 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

use crate::{access_token::AccessTokenProvider, error::CommonResponse, SdkResult, WxSdk};
use serde::{Deserialize, Serialize};

#[derive(Debug, Serialize, Deserialize)]
pub struct GrantAccessToken {
    access_token: String,
    expires_in: u32,
    refresh_token: String,
    openid: String,
    scope: String,
}

#[derive(Debug, Serialize, Deserialize)]
pub struct UserInfo {
    openid: String,
    nickname: String,
    sex: u8,
    province: String,
    city: String,
    country: String,
    headimgurl: String,
    privilege: Option<Vec<String>>,
    unionid: Option<String>,
}

pub struct SnsModule<'a, T: AccessTokenProvider>(pub(crate) &'a WxSdk<T>);

impl<'a, T: AccessTokenProvider> SnsModule<'a, T> {
    /// 微信网页授权
    /// 详情请参考[微信官方文档](https://developers.weixin.qq.com/doc/offiaccount/OA_Web_Apps/Wechat_webpage_authorization.html)
    /// 第二步，通过code换取access token
    pub async fn oauth_access_token(&self, code: String) -> SdkResult<GrantAccessToken> {
        let base_url = "https://api.weixin.qq.com/sns/oauth2/access_token";
        let client = self.0.http_client.get(base_url);

        let app_id = self.0.app_id.clone();
        let app_secret = self.0.app_secret.clone();
        let client = client.query(&[
            ("appid", app_id),
            ("secret", app_secret),
            ("code", code),
            ("grant_type", "authorization_code".to_owned()),
        ]);
        let res: CommonResponse<GrantAccessToken> = client.send().await?.json().await?;
        res.into()
    }
    /// 微信网页授权
    /// 第三步：刷新access_token（如果需要）
    pub async fn oauth_refresh_token(&self, refresh_token: String) -> SdkResult<GrantAccessToken> {
        let base_url = "https://api.weixin.qq.com/sns/oauth2/refresh_token";
        let client = self.0.http_client.get(base_url);

        let app_id = self.0.app_id.clone();
        let client = client.query(&[
            ("appid", app_id),
            ("refresh_token", refresh_token),
            ("grant_type", "refresh_token".to_owned()),
        ]);
        let res: CommonResponse<GrantAccessToken> = client.send().await?.json().await?;
        res.into()
    }

    /// 微信网页授权
    /// 拉取用户信息(需scope为 snsapi_userinfo)
    pub async fn userinfo(
        &self,
        openid: String,
        access_token: String,
        lang: String,
    ) -> SdkResult<UserInfo> {
        let base_url = "https://api.weixin.qq.com/sns/userinfo";
        let client = self.0.http_client.get(base_url);

        let client = client.query(&[
            ("access_token", access_token),
            ("openid", openid),
            ("lang", lang),
        ]);
        let res: CommonResponse<UserInfo> = client.send().await?.json().await?;
        res.into()
    }
}