diff options
| -rw-r--r-- | src/importer.rs | 21 |
1 files changed, 17 insertions, 4 deletions
diff --git a/src/importer.rs b/src/importer.rs index ab77837..9ea7e35 100644 --- a/src/importer.rs +++ b/src/importer.rs @@ -45,13 +45,26 @@ fn get_or_refresh_token<Strava: strava::StravaApi>(strava: &Strava, conn: &PgCon } fn import_strava_user(state: ImporterState, user: models::User) { + use std::thread::sleep; + use std::time::Duration; + let strava = state.strava.read().expect("FIX"); let conn = state.conn.lock().expect("FIX"); let token = get_or_refresh_token(&*strava, &conn, &user).expect("FIX"); - let result = strava - .get("/athlete/activities", &token.access_token, EMPTY_PARAMS) - .expect("ok"); - info!("import_strava_user: Got result: {:#?}", result); + for page in 1.. { + let params = [ + ("page", &format!("{}", page)), + ("per_page", &format!("{}", 200)), + ]; + let result = strava + .get("/athlete/activities", &token.access_token, ¶ms) + .expect("ok"); + // info!("import_strava_user: Got result: {:#?}", result); + for activity in result.as_array().expect("FIX") { + info!("activity id: {} start: {}", activity["id"], activity["start_date"]); + } + sleep(Duration::from_secs(1)); + } } fn handle_command(state: ImporterState, command: Command) { |