OMGeeky/yup-oauth2
1
0
Fork 0
mirror of https://github.com/OMGeeky/yup-oauth2.git synced 2026-02-23 15:50:00 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix(rustup): use std::time::Duration and Thread::sleep

Browse Source
This commit is contained in:
Sebastian Thiel
2016-01-30 13:44:36 +01:00
parent 05816a1ac2
commit c2bb59b4c5
5 changed files with 27 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
changelog.md
View File

@@ -110,7 +110,7 @@ This release essentially make yup-oauth2 work on rustc *stable*.
#### Bug Fixes
* **rustup** replace sleep with sleep_ms ([727c1d80](https://github.com/Byron/yup-oauth2/commit/727c1d801b4ae8f7b7cb80050139926bbcb9bf48))
* **rustup** replace sleep with sleep ([727c1d80](https://github.com/Byron/yup-oauth2/commit/727c1d801b4ae8f7b7cb80050139926bbcb9bf48))

12
examples/auth.rs
View File

@@ -11,8 +11,8 @@ use chrono::{Local};
use getopts::{HasArg,Options,Occur,Fail};
use std::env;
use std::default::Default;
use time::Duration;
use std::thread::sleep_ms;
use std::time::Duration;
use std::thread::sleep;
fn usage(program: &str, opts: &Options, err: Option<Fail>) -> ! {
@@ -69,9 +69,9 @@ fn main() {
You have time until {} to do that.
Do not terminate the program until you deny or grant access !",
pi.user_code, pi.verification_url, pi.expires_at.with_timezone(&Local));
let delay = Duration::seconds(5);
let delay = Duration::from_secs(5);
println!("Browser opens automatically in {} seconds", delay);
sleep_ms(delay.num_milliseconds() as u32);
sleep(delay);
open::that(&pi.verification_url).ok();
println!("DONE - waiting for authorization ...");
}
@@ -81,7 +81,7 @@ fn main() {
connector: hyper::net::HttpConnector
});
match oauth2::Authenticator::new(&secret, StdoutHandler, client,
match oauth2::Authenticator::new(&secret, StdoutHandler, client,
oauth2::NullStorage, None).token(&m.free) {
Ok(t) => {
println!("Authentication granted !");
@@ -94,4 +94,4 @@ fn main() {
std::process::exit(10);
}
}
}
}

12
src/device.rs
View File

@@ -1,7 +1,9 @@
use std::iter::IntoIterator;
use time::Duration;
use std::time::Duration;
use std::default::Default;
use std::fmt;
use std::i64;
use time;
use hyper;
use hyper::header::ContentType;
@@ -230,8 +232,8 @@ impl<C> DeviceFlow<C>
let pi = PollInformation {
user_code: decoded.user_code,
verification_url: decoded.verification_url,
expires_at: UTC::now() + Duration::seconds(decoded.expires_in),
interval: Duration::seconds(decoded.interval),
expires_at: UTC::now() + time::Duration::seconds(decoded.expires_in),
interval: Duration::from_secs(i64::abs(decoded.interval) as u64),
};
self.state = Some(DeviceFlowState::Pending(pi.clone()));
@@ -337,7 +339,7 @@ impl<C> DeviceFlow<C>
pub mod tests {
use super::*;
use std::default::Default;
use time::Duration;
use std::time::Duration;
use hyper;
use yup_hyper_mock::{SequentialConnector, MockStream};
@@ -394,7 +396,7 @@ pub mod tests {
match flow.request_code("bogus_client_id",
"bogus_secret",
&["https://www.googleapis.com/auth/youtube.upload"]) {
Ok(pi) => assert_eq!(pi.interval, Duration::seconds(0)),
Ok(pi) => assert_eq!(pi.interval, Duration::from_secs(0)),
_ => unreachable!(),
}

21
src/helper.rs
View File

@@ -2,7 +2,7 @@ use std::iter::IntoIterator;
use std::borrow::BorrowMut;
use std::collections::HashMap;
use std::hash::{SipHasher, Hash, Hasher};
use std::thread::sleep_ms;
use std::thread::sleep;
use std::cmp::min;
use std::error::Error;
use std::fmt;
@@ -11,7 +11,8 @@ use std::convert::From;
use common::{Token, FlowType, ApplicationSecret};
use device::{PollInformation, RequestError, DeviceFlow, PollError};
use refresh::{RefreshResult, RefreshFlow};
use chrono::{DateTime, UTC, Duration, Local};
use chrono::{DateTime, UTC, Local};
use std::time::Duration;
use hyper;
@@ -203,7 +204,7 @@ impl<D, S, C> Authenticator<D, S, C>
RequestError::HttpError(err) => {
match self.delegate.connection_error(&err) {
Retry::Abort|Retry::Skip => return Err(Box::new(StringError::from(&err as &Error))),
Retry::After(d) => sleep_ms(d.num_milliseconds() as u32),
Retry::After(d) => sleep(d),
}
},
RequestError::InvalidClient
@@ -234,7 +235,7 @@ impl<D, S, C> Authenticator<D, S, C>
match self.delegate.connection_error(err) {
Retry::Abort|Retry::Skip
=> return Err(Box::new(StringError::from(err as &Error))),
Retry::After(d) => sleep_ms(d.num_milliseconds() as u32),
Retry::After(d) => sleep(d),
}
},
&&PollError::Expired(ref t) => {
@@ -251,7 +252,7 @@ impl<D, S, C> Authenticator<D, S, C>
match self.delegate.pending(&pi) {
Retry::Abort|Retry::Skip
=> return Err(Box::new(StringError::new("Pending authentication aborted".to_string(), None))),
Retry::After(d) => sleep_ms(min(d, pi.interval).num_milliseconds() as u32),
Retry::After(d) => sleep(min(d, pi.interval)),
},
Ok(Some(token)) => return Ok(token)
}
@@ -301,7 +302,7 @@ impl<D, S, C> GetToken for Authenticator<D, S, C>
return Err(Box::new(StringError::new(
err.description().to_string(),
None))),
Retry::After(d) => sleep_ms(d.num_milliseconds() as u32),
Retry::After(d) => sleep(d),
}
},
RefreshResult::RefreshError(ref err_str, ref err_description) => {
@@ -322,7 +323,7 @@ impl<D, S, C> GetToken for Authenticator<D, S, C>
Retry::Skip => break,
Retry::Abort => return Err(Box::new(err)),
Retry::After(d) => {
sleep_ms(d.num_milliseconds() as u32);
sleep(d);
continue;
}
}
@@ -351,7 +352,7 @@ impl<D, S, C> GetToken for Authenticator<D, S, C>
Retry::Skip => break,
Retry::Abort => return Err(Box::new(err)),
Retry::After(d) => {
sleep_ms(d.num_milliseconds() as u32);
sleep(d);
continue;
}
}
@@ -367,7 +368,7 @@ impl<D, S, C> GetToken for Authenticator<D, S, C>
match self.delegate.token_storage_failure(false, &err) {
Retry::Abort|Retry::Skip => Err(Box::new(err)),
Retry::After(d) => {
sleep_ms(d.num_milliseconds() as u32);
sleep(d);
continue
}
}
@@ -437,7 +438,7 @@ pub trait AuthenticatorDelegate {
/// * Only used in `DeviceFlow`. Return value will only be used if it
/// is larger than the interval desired by the server.
fn pending(&mut self, &PollInformation) -> Retry {
Retry::After(Duration::seconds(5))
Retry::After(Duration::from_secs(5))
}
/// The server has returned a `user_code` which must be shown to the user,

4
src/lib.rs.in
View File

@@ -9,8 +9,8 @@ extern crate log;
#[cfg(test)]
extern crate yup_hyper_mock;
extern crate mime;
extern crate url;
extern crate time;
extern crate url;
extern crate itertools;
mod device;
@@ -21,5 +21,5 @@ mod helper;
pub use device::{DeviceFlow, PollInformation, PollError};
pub use refresh::{RefreshFlow, RefreshResult};
pub use common::{Token, FlowType, ApplicationSecret, ConsoleApplicationSecret, Scheme, TokenType};
pub use helper::{TokenStorage, NullStorage, MemoryStorage, Authenticator,
pub use helper::{TokenStorage, NullStorage, MemoryStorage, Authenticator,
AuthenticatorDelegate, Retry, DefaultAuthenticatorDelegate, GetToken};