oauth2_bitbucket/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
7// https://developer.atlassian.com/cloud/bitbucket/rest/api-group-users/#api-user-get
8pub const URL: &str = "https://api.bitbucket.org/2.0/user";
9
10//
11#[derive(Debug, Clone)]
12pub struct UserEndpoint {
13    access_token: String,
14}
15impl UserEndpoint {
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 UserEndpoint {
24    type RenderRequestError = UserEndpointError;
25
26    type ParseResponseOutput = User;
27    type ParseResponseError = UserEndpointError;
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(UserEndpointError::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(UserEndpointError::DeResponseBodyFailed)?;
46
47        Ok(body)
48    }
49}
50
51#[derive(Deserialize, Serialize, Debug, Clone)]
52pub struct User {
53    pub account_id: String,
54    pub username: String,
55    pub nickname: String,
56    pub links: UserLinks,
57    pub email: Option<String>,
58    //
59    #[serde(flatten, skip_serializing_if = "Option::is_none")]
60    pub _extra: Option<Map<String, Value>>,
61}
62#[derive(Deserialize, Serialize, Debug, Clone)]
63pub struct UserLinks {
64    pub avatar: UserLink,
65}
66#[derive(Deserialize, Serialize, Debug, Clone)]
67pub struct UserLink {
68    pub href: String,
69}
70
71#[derive(thiserror::Error, Debug)]
72pub enum UserEndpointError {
73    #[error("MakeRequestFailed {0}")]
74    MakeRequestFailed(HttpError),
75    //
76    #[error("DeResponseBodyFailed {0}")]
77    DeResponseBodyFailed(SerdeJsonError),
78}
79
80#[cfg(test)]
81mod tests {
82    use super::*;
83
84    #[test]
85    fn de_user() {
86        match serde_json::from_str::<User>(include_str!(
87            "../../tests/response_body_json_files/user.json"
88        )) {
89            Ok(user) => {
90                assert_eq!(
91                    user.account_id,
92                    "557058:6096354a-494e-458a-9c38-bc8ef021d382"
93                );
94            }
95            Err(err) => panic!("{err}"),
96        }
97    }
98}
oauth2_bitbucket/extensions/internal_user_endpoint.rs

oauth2_bitbucket/extensions/
internal_user_endpoint.rs
