Get paged activity output from strava

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, &params)
+            .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) {