oauth2_linode/extensions/
internal_v4_profile_endpoint.rs

1use oauth2_client::re_exports::{
2    http::header::{ACCEPT, AUTHORIZATION},
3    serde_json, thiserror, Body, Deserialize, Endpoint, HttpError, Map, Request, Response,
4    SerdeJsonError, Serialize, Value, MIME_APPLICATION_JSON,
5};
6
7// Ref https://www.linode.com/docs/api/profile/#profile-view
8pub const URL: &str = "https://api.linode.com/v4/profile";
9
10//
11#[derive(Debug, Clone)]
12pub struct MeEndpoint {
13    access_token: String,
14}
15impl MeEndpoint {
16    pub fn new(access_token: impl AsRef<str>) -> Self {
17        Self {
18            access_token: access_token.as_ref().to_owned(),
19        }
20    }
21}
22
23impl Endpoint for MeEndpoint {
24    type RenderRequestError = MeEndpointError;
25
26    type ParseResponseOutput = User;
27    type ParseResponseError = MeEndpointError;
28
29    fn render_request(&self) -> Result<Request<Body>, Self::RenderRequestError> {
30        let request = Request::builder()
31            .uri(URL)
32            .header(AUTHORIZATION, format!("Bearer {}", &self.access_token))
33            .header(ACCEPT, MIME_APPLICATION_JSON)
34            .body(vec![])
35            .map_err(MeEndpointError::MakeRequestFailed)?;
36
37        Ok(request)
38    }
39
40    fn parse_response(
41        &self,
42        response: Response<Body>,
43    ) -> Result<Self::ParseResponseOutput, Self::ParseResponseError> {
44        let body = serde_json::from_slice::<User>(response.body())
45            .map_err(MeEndpointError::DeResponseBodyFailed)?;
46
47        Ok(body)
48    }
49}
50
51#[derive(Deserialize, Serialize, Debug, Clone)]
52pub struct User {
53    pub uid: u64,
54    pub email: String,
55    pub username: String,
56    //
57    #[serde(flatten, skip_serializing_if = "Option::is_none")]
58    pub _extra: Option<Map<String, Value>>,
59}
60
61#[derive(thiserror::Error, Debug)]
62pub enum MeEndpointError {
63    #[error("MakeRequestFailed {0}")]
64    MakeRequestFailed(HttpError),
65    //
66    #[error("DeResponseBodyFailed {0}")]
67    DeResponseBodyFailed(SerdeJsonError),
68}
69
70#[cfg(test)]
71mod tests {
72    use super::*;
73
74    #[test]
75    fn de_user() {
76        match serde_json::from_str::<User>(include_str!(
77            "../../tests/response_body_json_files/v4_profile.json"
78        )) {
79            Ok(user) => {
80                assert_eq!(user.uid, 1234);
81            }
82            Err(err) => panic!("{err}"),
83        }
84    }
85}
oauth2_linode/extensions/internal_v4_profile_endpoint.rs

oauth2_linode/extensions/
internal_v4_profile_endpoint.rs
