diff --git a/fitbit_lib/src/fitbit_statistics_summary.rs b/fitbit_lib/src/fitbit_statistics_summary.rs index 07ec3612..9dba7a67 100644 --- a/fitbit_lib/src/fitbit_statistics_summary.rs +++ b/fitbit_lib/src/fitbit_statistics_summary.rs @@ -136,8 +136,14 @@ impl FitbitStatisticsSummary { count: i64, } - let query = - Self::get_fitbit_statistics_query("count(*)", start_date.as_ref(), end_date.as_ref(), None, None, "")?; + let query = Self::get_fitbit_statistics_query( + "count(*)", + start_date.as_ref(), + end_date.as_ref(), + None, + None, + "", + )?; let conn = pool.get().await?; let count: Count = query.fetch_one(&conn).await?; diff --git a/fitbit_lib/src/scale_measurement.rs b/fitbit_lib/src/scale_measurement.rs index a824c6a8..78788713 100644 --- a/fitbit_lib/src/scale_measurement.rs +++ b/fitbit_lib/src/scale_measurement.rs @@ -315,8 +315,14 @@ impl ScaleMeasurement { count: i64, } - let query = - Self::get_scale_measurement_query("count(*)", start_date.as_ref(), end_date.as_ref(), None, None, "")?; + let query = Self::get_scale_measurement_query( + "count(*)", + start_date.as_ref(), + end_date.as_ref(), + None, + None, + "", + )?; let conn = pool.get().await?; let count: Count = query.fetch_one(&conn).await?; diff --git a/garmin_models/src/fitbit_activity.rs b/garmin_models/src/fitbit_activity.rs index a82d433f..0913e7eb 100644 --- a/garmin_models/src/fitbit_activity.rs +++ b/garmin_models/src/fitbit_activity.rs @@ -103,8 +103,14 @@ impl FitbitActivity { count: i64, } - let query = - Self::get_fitbit_activity_query("count(*)", start_date.as_ref(), end_date.as_ref(), None, None, "")?; + let query = Self::get_fitbit_activity_query( + "count(*)", + start_date.as_ref(), + end_date.as_ref(), + None, + None, + "", + )?; let conn = pool.get().await?; let count: Count = query.fetch_one(&conn).await?; diff --git a/garmin_models/src/garmin_sync.rs b/garmin_models/src/garmin_sync.rs index a7a6be5f..88186f5f 100644 --- a/garmin_models/src/garmin_sync.rs +++ b/garmin_models/src/garmin_sync.rs @@ -189,7 +189,8 @@ impl GarminSync { bucket: &str, pool: &PgPool, ) -> Result<(usize, usize), Error> { - exponential_retry(|| async move { self.get_and_process_keys_impl(bucket, pool).await }).await + exponential_retry(|| async move { self.get_and_process_keys_impl(bucket, pool).await }) + .await } async fn process_files( diff --git a/garmin_models/src/strava_activity.rs b/garmin_models/src/strava_activity.rs index 4b9aa8d0..98313ff5 100644 --- a/garmin_models/src/strava_activity.rs +++ b/garmin_models/src/strava_activity.rs @@ -118,8 +118,14 @@ impl StravaActivity { count: i64, } - let query = - Self::get_strava_activity_query("count(*)", start_date.as_ref(), end_date.as_ref(), None, None, "")?; + let query = Self::get_strava_activity_query( + "count(*)", + start_date.as_ref(), + end_date.as_ref(), + None, + None, + "", + )?; let conn = pool.get().await?; let count: Count = query.fetch_one(&conn).await?; @@ -362,8 +368,7 @@ mod tests { let buf = include_str!("../../tests/data/strava_training_activities.json"); let js: StravaActivityHarJson = serde_json::from_str(buf)?; let activities: Vec = js.models.into_iter().map(Into::into).collect(); - println!("{activities:#?}"); - assert!(false); + assert_eq!(activities.len(), 20); Ok(()) } }