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

oauth2_github/extensions/
internal_user_endpoint.rs
