twapi-ureq 0.2.1

Twitter OAuth library used by ureq.
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

use ureq::{Error, Request, Response};

use twapi_oauth::encode;

fn make_query(list: &Vec<(&str, &str)>, separator: &str) -> String {
    let mut result = String::from("");
    for item in list {
        if "" != result {
            result.push_str(separator);
        }
        result.push_str(&format!("{}={}", item.0, encode(item.1)));
    }
    result
}

pub(crate) fn get(
    url: &str,
    query_options: &Vec<(&str, &str)>,
    authorization: &str,
) -> Result<Response, Error> {
    let url = if query_options.len() > 0 {
        format!("{}?{}", url, make_query(query_options, "&"))
    } else {
        url.to_owned()
    };
    ureq::get(&url).set("Authorization", authorization).call()
}

pub(crate) fn post(
    url: &str,
    query_options: &Vec<(&str, &str)>,
    form_options: &Vec<(&str, &str)>,
    authorization: &str,
) -> Result<Response, Error> {
    let request = ureq::post(url).set("Authorization", authorization).set(
        "Content-Type",
        "application/x-www-form-urlencoded;charset=UTF-8",
    );
    apply_query_options(request, query_options).send_string(&make_body(form_options))
}

pub(crate) fn json(
    url: &str,
    query_options: &Vec<(&str, &str)>,
    data: serde_json::Value,
    authorization: &str,
) -> Result<Response, Error> {
    let request = ureq::post(url)
        .set("Authorization", authorization)
        .set("Content-Type", "application/json");
    apply_query_options(request, query_options).send_json(data)
}

pub(crate) fn put(
    url: &str,
    query_options: &Vec<(&str, &str)>,
    authorization: &str,
) -> Result<Response, Error> {
    let request = ureq::put(url).set("Authorization", authorization);
    apply_query_options(request, query_options).call()
}

pub(crate) fn delete(
    url: &str,
    query_options: &Vec<(&str, &str)>,
    authorization: &str,
) -> Result<Response, Error> {
    let request = ureq::delete(url).set("Authorization", authorization);
    apply_query_options(request, query_options).call()
}

pub(crate) fn multipart(
    url: &str,
    query_options: &Vec<(&str, &str)>,
    mut data: crate::form::MultiPart,
    authorization: &str,
) -> Result<Response, Error> {
    let request = ureq::post(url).set("Authorization", authorization).set(
        "Content-Type",
        &format!("multipart/form-data; boundary={}", data.boundary),
    );
    apply_query_options(request, query_options).send_bytes(&data.to_bytes())
}

fn make_body(form_options: &Vec<(&str, &str)>) -> String {
    match serde_urlencoded::to_string(form_options) {
        Ok(body) => body
            .replace('+', "%20")
            .replace('*', "%2A")
            .replace("%7E", "~")
            .into(),
        Err(_) => String::from(""),
    }
}

fn apply_query_options(request: Request, query_options: &Vec<(&str, &str)>) -> Request {
    let mut req = request;
    for query_option in query_options {
        req = req.query(query_option.0, query_option.1);
    }
    req
}