Default token expiry

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "gcp_auth"
-version = "0.7.5"
+version = "0.7.6"
 repository = "https://github.com/hrvolapeter/gcp_auth"
 description = "Google cloud platform (GCP) authentication using default and custom service accounts"
 documentation = "https://docs.rs/gcp_auth/"

src/types.rs

@@ -36,7 +36,7 @@ impl Token {
         Token {
             inner: Arc::new(InnerToken {
                 access_token,
-                expires_at: None,
+                expires_at: OffsetDateTime::now_utc() + Duration::seconds(3600),
             }),
         }
     }
@@ -55,11 +55,10 @@ impl fmt::Debug for Token {
 struct InnerToken {
     access_token: String,
     #[serde(
-        default,
         deserialize_with = "deserialize_time",
         rename(deserialize = "expires_in")
     )]
-    expires_at: Option<OffsetDateTime>,
+    expires_at: OffsetDateTime,
 }
 
 impl Token {
@@ -68,12 +67,7 @@ impl Token {
     /// This takes an additional 30s margin to ensure the token can still be reasonably used
     /// instead of expiring right after having checked.
     pub fn has_expired(&self) -> bool {
-        self.inner
-            .expires_at
-            .map(|expiration_time| {
-                expiration_time - Duration::seconds(30) <= OffsetDateTime::now_utc()
-            })
-            .unwrap_or(false)
+        self.inner.expires_at - Duration::seconds(30) <= OffsetDateTime::now_utc()
     }
 
     /// Get str representation of the token.
@@ -82,7 +76,7 @@ impl Token {
     }
 
     /// Get expiry of token, if available
-    pub fn expires_at(&self) -> Option<OffsetDateTime> {
+    pub fn expires_at(&self) -> OffsetDateTime {
         self.inner.expires_at
     }
 }
@@ -140,14 +134,12 @@ impl fmt::Debug for Signer {
     }
 }
 
-fn deserialize_time<'de, D>(deserializer: D) -> Result<Option<OffsetDateTime>, D::Error>
+fn deserialize_time<'de, D>(deserializer: D) -> Result<OffsetDateTime, D::Error>
 where
     D: Deserializer<'de>,
 {
-    let s: Option<i64> = Deserialize::deserialize(deserializer)?;
-    let s =
-        s.map(|seconds_from_now| OffsetDateTime::now_utc() + Duration::seconds(seconds_from_now));
-    Ok(s)
+    let seconds_from_now: i64 = Deserialize::deserialize(deserializer)?;
+    Ok(OffsetDateTime::now_utc() + Duration::seconds(seconds_from_now))
 }
 
 pub(crate) fn client() -> HyperClient {
@@ -171,7 +163,7 @@ mod tests {
         let token = Token {
             inner: Arc::new(InnerToken {
                 access_token: "abc123".to_string(),
-                expires_at: Some(OffsetDateTime::from_unix_timestamp(123).unwrap()),
+                expires_at: OffsetDateTime::from_unix_timestamp(123).unwrap(),
             }),
         };
         let s = serde_json::to_string(&token).unwrap();
@@ -191,17 +183,20 @@ mod tests {
         assert_eq!(token.as_str(), "abc123");
 
         // Testing time is always racy, give it 1s leeway.
-        let expires_at = token.expires_at().unwrap();
+        let expires_at = token.expires_at();
         assert!(expires_at < expires + Duration::seconds(1));
         assert!(expires_at > expires - Duration::seconds(1));
     }
 
     #[test]
-    fn test_deserialise_no_time() {
-        let s = r#"{"access_token":"abc123"}"#;
-        let token: Token = serde_json::from_str(s).unwrap();
+    fn test_token_from_string() {
+        let s = String::from("abc123");
+        let token = Token::from_string(s);
+        let expires = OffsetDateTime::now_utc() + Duration::seconds(3600);
 
         assert_eq!(token.as_str(), "abc123");
-        assert!(token.expires_at().is_none());
+        assert!(!token.has_expired());
+        assert!(token.expires_at() < expires + Duration::seconds(1));
+        assert!(token.expires_at() > expires - Duration::seconds(1));
     }
 }