twitter-api-v1 0.2.1

Twitter API Standard v1.1
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

use reqwest::{Client, StatusCode};
use reqwest_oauth1::OAuthClientProvider as _;
use serde_json::Map;
use twitter_api_v2::{
    endpoints::users::lookup::{
        url_for_user_by_id, url_for_user_by_username, SingleUserResponseBody,
    },
    objects::ResponseBodyErrJson as V2ResponseBodyErrJson,
};

use crate::{
    endpoints::common::{EndpointError, EndpointRet},
    objects::User,
    secrets::TokenSecrets,
};

//
//
//
pub async fn show_user_by_id(
    secrets: &TokenSecrets,
    client: Client,
    user_id: u64,
    include_entities: Option<bool>,
) -> Result<EndpointRet<User>, EndpointError> {
    //
    let url = url_for_user_by_id(user_id);

    let mut query = Map::new();
    query.insert(
        "user.fields".into(),
        "id,name,username,profile_image_url".into(),
    );
    if include_entities == Some(true) {
        query.insert("expansions".into(), "pinned_tweet_id".into());
    }

    //
    let response = client
        .oauth1(secrets.secrets())
        .get(url)
        .query(&query)
        .send()
        .await
        .map_err(EndpointError::RespondFailed)?;

    //
    let response_status = response.status();
    let response_body = response
        .bytes()
        .await
        .map_err(EndpointError::ReadResponseBodyFailed)?;
    let response_body = response_body.as_ref();

    match response_status {
        StatusCode::OK => {
            let response_body = serde_json::from_slice::<SingleUserResponseBody>(response_body)
                .map_err(EndpointError::DeV2ResponseBodyOkJsonFailed)?;
            let user = User::try_from(response_body.data)
                .map_err(EndpointError::ConvertV2ResponseBodyOkJsonFailed)?;
            Ok(EndpointRet::Ok(user))
        }
        status => match serde_json::from_slice::<V2ResponseBodyErrJson>(response_body) {
            Ok(err_json) => Ok(EndpointRet::Other((status, Ok(err_json.into())))),
            Err(_) => Ok(EndpointRet::Other((status, Err(response_body.to_owned())))),
        },
    }
}

//
//
//
pub async fn show_user_by_screen_name(
    secrets: &TokenSecrets,
    client: Client,
    screen_name: impl AsRef<str>,
    include_entities: Option<bool>,
) -> Result<EndpointRet<User>, EndpointError> {
    //
    let url = url_for_user_by_username(screen_name);

    let mut query = Map::new();
    query.insert(
        "user.fields".into(),
        "id,name,username,profile_image_url".into(),
    );
    if include_entities == Some(true) {
        query.insert("expansions".into(), "pinned_tweet_id".into());
    }

    //
    let response = client
        .oauth1(secrets.secrets())
        .get(url)
        .query(&query)
        .send()
        .await
        .map_err(EndpointError::RespondFailed)?;

    //
    let response_status = response.status();
    let response_body = response
        .bytes()
        .await
        .map_err(EndpointError::ReadResponseBodyFailed)?;
    let response_body = response_body.as_ref();

    match response_status {
        StatusCode::OK => {
            let response_body = serde_json::from_slice::<SingleUserResponseBody>(response_body)
                .map_err(EndpointError::DeV2ResponseBodyOkJsonFailed)?;
            let user = User::try_from(response_body.data)
                .map_err(EndpointError::ConvertV2ResponseBodyOkJsonFailed)?;
            Ok(EndpointRet::Ok(user))
        }
        status => match serde_json::from_slice::<V2ResponseBodyErrJson>(response_body) {
            Ok(err_json) => Ok(EndpointRet::Other((status, Ok(err_json.into())))),
            Err(_) => Ok(EndpointRet::Other((status, Err(response_body.to_owned())))),
        },
    }
}