inth-oauth2 0.16.0

OAuth2 client
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

use chrono::{DateTime, Utc, Duration};
use serde_json::Value;

use client::response::{FromResponse, ParseError};
use token::Lifetime;

/// An expiring token which can be refreshed.
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
pub struct Refresh {
    refresh_token: String,
    expires: DateTime<Utc>,
}

impl Refresh {
    /// Returns the refresh token.
    ///
    /// See [RFC 6749, section 1.5](http://tools.ietf.org/html/rfc6749#section-1.5).
    pub fn refresh_token(&self) -> &str { &self.refresh_token }

    /// Returns the expiry time of the access token.
    pub fn expires(&self) -> &DateTime<Utc> { &self.expires }
}

impl Lifetime for Refresh {
    fn expired(&self) -> bool { self.expires < Utc::now() }
}

impl FromResponse for Refresh {
    fn from_response(json: &Value) -> Result<Self, ParseError> {
        let obj = json.as_object().ok_or(ParseError::ExpectedType("object"))?;

        let refresh_token = obj.get("refresh_token")
            .and_then(Value::as_str)
            .ok_or(ParseError::ExpectedFieldType("refresh_token", "string"))?;
        let expires_in = obj.get("expires_in")
            .and_then(Value::as_i64)
            .ok_or(ParseError::ExpectedFieldType("expires_in", "i64"))?;

        Ok(Refresh {
            refresh_token: refresh_token.into(),
            expires: Utc::now() + Duration::seconds(expires_in),
        })
    }

    fn from_response_inherit(json: &Value, prev: &Self) -> Result<Self, ParseError> {
        let obj = json.as_object().ok_or(ParseError::ExpectedType("object"))?;

        let refresh_token = obj.get("refresh_token")
            .and_then(Value::as_str)
            .or(Some(&prev.refresh_token))
            .ok_or(ParseError::ExpectedFieldType("refresh_token", "string"))?;

        let expires_in = obj.get("expires_in")
            .and_then(Value::as_i64)
            .ok_or(ParseError::ExpectedFieldType("expires_in", "i64"))?;

        Ok(Refresh {
            refresh_token: refresh_token.into(),
            expires: Utc::now() + Duration::seconds(expires_in),
        })
    }
}

#[cfg(test)]
mod tests {
    use chrono::{Utc, Duration};

    use client::response::FromResponse;
    use super::Refresh;

    #[test]
    fn from_response() {
        let json = r#"{"refresh_token":"aaaaaaaa","expires_in":3600}"#.parse().unwrap();
        let refresh = Refresh::from_response(&json).unwrap();
        assert_eq!("aaaaaaaa", refresh.refresh_token);
        assert!(refresh.expires > Utc::now());
        assert!(refresh.expires <= Utc::now() + Duration::seconds(3600));
    }

    #[test]
    fn from_response_inherit() {
        let json = r#"{"expires_in":3600}"#.parse().unwrap();
        let prev = Refresh {
            refresh_token: String::from("aaaaaaaa"),
            expires: Utc::now(),
        };
        let refresh = Refresh::from_response_inherit(&json, &prev).unwrap();
        assert_eq!("aaaaaaaa", refresh.refresh_token);
        assert!(refresh.expires > Utc::now());
        assert!(refresh.expires <= Utc::now() + Duration::seconds(3600));
    }
}