u-sdk 0.2.2

Some useful SDKs
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

use super::Error;
use base64::engine::{Engine, general_purpose};
use percent_encoding::{AsciiSet, NON_ALPHANUMERIC, percent_encode};
use std::collections::BTreeMap;
use u_sdk_common::helper::sign_hmac_sha1;
use url::form_urlencoded;

// 签名文档：https://help.aliyun.com/document_detail/29442.html

// 定义一个函数，用于计算签名字符串
pub(crate) fn sign_params(
    query_params: &BTreeMap<String, String>,
    access_key_secret: &str,
) -> String {
    let canonical_query_string = form_urlencoded::Serializer::new(String::new())
        .extend_pairs(query_params)
        .finish()
        .replace('+', "%20")
        .replace('*', "%2A")
        .replace("%7E", "~");

    // 下边四个字符不用编码，移出需要编码的字符集
    const FRAGMENT: &AsciiSet = &NON_ALPHANUMERIC
        .remove(b'-')
        .remove(b'_')
        .remove(b'.')
        .remove(b'~');
    let percent_encode_string =
        percent_encode(canonical_query_string.as_bytes(), FRAGMENT).to_string();

    let string_to_sign = format!("{}&{}&{}", "POST", "%2F", percent_encode_string);

    let secret = format!("{}&", access_key_secret);
    let res = sign_hmac_sha1(&secret, &string_to_sign);
    general_purpose::STANDARD.encode(res)
}

#[test]
fn sign_params_test() {
    let s = "AccessKeyId=testid&AccountName=<a%b'>&Action=SingleSendMail&AddressType=1&Format=XML&HtmlBody=4&RegionId=cn-hangzhou&ReplyToAddress=true&SignatureMethod=HMAC-SHA1&SignatureNonce=c1b2c332-4cfb-4a0f-b8cc-ebe622aa0a5c&SignatureVersion=1.0&Subject=3&TagName=2&Timestamp=2016-10-20T06:27:56Z&ToAddress=1@test.com&Version=2015-11-23";
    let url = url::Url::parse(&format!("http://example.com?{}", s)).unwrap();
    let mut map = BTreeMap::new();
    for (key, value) in url.query_pairs() {
        map.insert(key.to_string(), value.to_string());
    }

    let sign = sign_params(&map, "testsecret");

    assert_eq!(sign, "llJfXJjBW3OacrVgxxsITgYaYm0=")
}

pub(crate) async fn parse_json_response<T: serde::de::DeserializeOwned>(
    resp: reqwest::Response,
) -> Result<T, Error> {
    let status = resp.status();

    if !status.is_success() {
        let body = resp.text().await.unwrap_or_default();
        return Err(Error::API { code: status, body });
    }

    let json = resp.json::<T>().await?;
    Ok(json)
}