OMGeeky/yup-oauth2
1
0
Fork 0
mirror of https://github.com/OMGeeky/yup-oauth2.git synced 2026-01-22 10:05:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

Run rustfmt on authenticator.rs

Browse Source
This commit is contained in:
Lewin Bormann
2021-03-04 19:33:08 +01:00
parent 010668cc62
commit 83296afc83
1 changed files with 27 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
src/authenticator.rs
View File

@@ -26,7 +26,7 @@ struct InnerAuthenticator<C> {
/// and optionally persisting tokens to disk.
#[derive(Clone)]
pub struct Authenticator<C> {
inner: Arc<InnerAuthenticator<C>>
inner: Arc<InnerAuthenticator<C>>,
}
struct DisplayScopes<'a, T>(&'a [T]);
@@ -103,16 +103,29 @@ where
Some(app_secret),
) => {
// token is expired but has a refresh token.
let token_info =
RefreshFlow::refresh_token(&self.inner.hyper_client, app_secret, &refresh_token)
.await?;
self.inner.storage.set(hashed_scopes, token_info.clone()).await?;
let token_info = RefreshFlow::refresh_token(
&self.inner.hyper_client,
app_secret,
&refresh_token,
)
.await?;
self.inner
.storage
.set(hashed_scopes, token_info.clone())
.await?;
Ok(token_info.into())
}
_ => {
// no token in the cache or the token returned can't be refreshed.
let token_info = self.inner.auth_flow.token(&self.inner.hyper_client, scopes).await?;
self.inner.storage.set(hashed_scopes, token_info.clone()).await?;
let token_info = self
.inner
.auth_flow
.token(&self.inner.hyper_client, scopes)
.await?;
self.inner
.storage
.set(hashed_scopes, token_info.clone())
.await?;
Ok(token_info.into())
}
}
@@ -227,11 +240,13 @@ impl<C, F> AuthenticatorBuilder<C, F> {
StorageType::Disk(path) => Storage::Disk(storage::DiskStorage::new(path).await?),
};
Ok(Authenticator{ inner: Arc::new(InnerAuthenticator {
hyper_client,
storage,
auth_flow,
})})
Ok(Authenticator {
inner: Arc::new(InnerAuthenticator {
hyper_client,
storage,
auth_flow,
}),
})
}
fn with_auth_flow(auth_flow: F) -> AuthenticatorBuilder<DefaultHyperClient, F> {