Cargo.lock

@@ -133,17 +133,6 @@ dependencies = [
  "pin-project-lite",
 ]
 
-[[package]]
-name = "async-trait"
-version = "0.1.77"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "c980ee35e870bd1a4d2c8294d4c04d0499e67bca1e4b5cefcc693c2fa00caea9"
-dependencies = [
- "proc-macro2",
- "quote",
- "syn 2.0.48",
-]
-
 [[package]]
 name = "atoi"
 version = "2.0.0"
@@ -431,7 +420,7 @@ dependencies = [
  "heck",
  "proc-macro2",
  "quote",
- "syn 2.0.48",
+ "syn 2.0.41",
 ]
 
 [[package]]
@@ -747,7 +736,7 @@ checksum = "487585f4d0c6655fe74905e2504d8ad6908e4db67f744eb140876906c2f3175d"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.48",
+ "syn 2.0.41",
 ]
 
 [[package]]
@@ -939,7 +928,6 @@ name = "fitnesstrax"
 version = "0.3.0"
 dependencies = [
  "async-channel",
- "async-trait",
  "chrono",
  "chrono-tz",
  "dimensioned 0.8.0",
@@ -1144,7 +1132,7 @@ checksum = "53b153fd91e4b0147f4aced87be237c98248656bb01050b96bf3ee89220a8ddb"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.48",
+ "syn 2.0.41",
 ]
 
 [[package]]
@@ -1379,7 +1367,7 @@ dependencies = [
  "proc-macro-error",
  "proc-macro2",
  "quote",
- "syn 2.0.48",
+ "syn 2.0.41",
 ]
 
 [[package]]
@@ -2455,7 +2443,7 @@ checksum = "a948666b637a0f465e8564c73e89d4dde00d72d4d473cc972f390fc3dcee7d9c"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.48",
+ "syn 2.0.41",
 ]
 
 [[package]]
@@ -2660,7 +2648,7 @@ checksum = "4359fd9c9171ec6e8c62926d6faaf553a8dc3f64e1507e76da7911b4f6a04405"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.48",
+ "syn 2.0.41",
 ]
 
 [[package]]
@@ -2804,9 +2792,9 @@ dependencies = [
 
 [[package]]
 name = "proc-macro2"
-version = "1.0.78"
+version = "1.0.70"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e2422ad645d89c99f8f3e6b88a9fdeca7fabeac836b1002371c4367c8f984aae"
+checksum = "39278fbbf5fb4f646ce651690877f89d1c5811a3d4acb27700c1cb3cdb78fd3b"
 dependencies = [
  "unicode-ident",
 ]
@@ -2848,9 +2836,9 @@ checksum = "a1d01941d82fa2ab50be1e79e6714289dd7cde78eba4c074bc5a4374f650dfe0"
 
 [[package]]
 name = "quote"
-version = "1.0.35"
+version = "1.0.33"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "291ec9ab5efd934aaf503a6466c5d5251535d108ee747472c3977cc5acc868ef"
+checksum = "5267fca4496028628a95160fc423a33e8b2e6af8a5302579e322e4b520293cae"
 dependencies = [
  "proc-macro2",
 ]
@@ -3333,7 +3321,7 @@ checksum = "43576ca501357b9b071ac53cdc7da8ef0cbd9493d8df094cd821777ea6e894d3"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.48",
+ "syn 2.0.41",
 ]
 
 [[package]]
@@ -3732,9 +3720,9 @@ dependencies = [
 
 [[package]]
 name = "syn"
-version = "2.0.48"
+version = "2.0.41"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0f3531638e407dfc0814761abb7c00a5b54992b849452a0646b7f65c9f770f3f"
+checksum = "44c8b28c477cc3bf0e7966561e3460130e1255f7a1cf71931075f1c5e7a7e269"
 dependencies = [
  "proc-macro2",
  "quote",
@@ -3830,7 +3818,7 @@ checksum = "01742297787513b79cf8e29d1056ede1313e2420b7b3b15d0a768b4921f549df"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.48",
+ "syn 2.0.41",
 ]
 
 [[package]]
@@ -3954,7 +3942,7 @@ checksum = "5b8a1e28f2deaa14e508979454cb3a223b10b938b45af148bc0986de36f1923b"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.48",
+ "syn 2.0.41",
 ]
 
 [[package]]
@@ -4075,7 +4063,7 @@ checksum = "34704c8d6ebcbc939824180af020566b01a7c01f80641264eba0999f6c2b6be7"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.48",
+ "syn 2.0.41",
 ]
 
 [[package]]
@@ -4445,7 +4433,7 @@ dependencies = [
  "once_cell",
  "proc-macro2",
  "quote",
- "syn 2.0.48",
+ "syn 2.0.41",
  "wasm-bindgen-shared",
 ]
 
@@ -4479,7 +4467,7 @@ checksum = "f0eb82fcb7930ae6219a7ecfd55b217f5f0893484b7a13022ebb2b2bf20b5283"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.48",
+ "syn 2.0.41",
  "wasm-bindgen-backend",
  "wasm-bindgen-shared",
 ]
@@ -4720,7 +4708,7 @@ checksum = "b3c129550b3e6de3fd0ba67ba5c81818f9805e58b8d7fee80a3a59d2c9fc601a"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.48",
+ "syn 2.0.41",
 ]
 
 [[package]]

fitnesstrax/app/Cargo.toml

@@ -8,7 +8,6 @@ edition = "2021"
 [dependencies]
 adw             = { version = "0.5", package = "libadwaita", features = [ "v1_4" ] }
 async-channel   = { version = "2.1" }
-async-trait     = { version = "0.1" }
 chrono          = { version = "0.4" }
 chrono-tz       = { version = "0.8" }
 dimensioned     = { version = "0.8", features = [ "serde" ] }

fitnesstrax/app/src/app.rs

@@ -14,7 +14,6 @@ General Public License for more details.
 You should have received a copy of the GNU General Public License along with FitnessTrax. If not, see <https://www.gnu.org/licenses/>.
 */
 
-use async_trait::async_trait;
 use chrono::NaiveDate;
 use emseries::{time_range, Record, RecordId, Series, Timestamp};
 use ft_core::TraxRecord;
@@ -35,32 +34,6 @@ pub enum AppError {
     Unhandled,
 }
 
-#[derive(Debug, Error)]
-pub enum ReadError {
-    #[error("no database loaded")]
-    NoDatabase,
-}
-
-#[derive(Debug, Error)]
-pub enum WriteError {
-    #[error("no database loaded")]
-    NoDatabase,
-    #[error("unhandled error")]
-    Unhandled,
-}
-
-#[async_trait]
-pub trait RecordProvider: Send + Sync {
-    async fn records(
-        &self,
-        start: NaiveDate,
-        end: NaiveDate,
-    ) -> Result<Vec<Record<TraxRecord>>, ReadError>;
-    async fn put_record(&self, record: TraxRecord) -> Result<RecordId, WriteError>;
-    async fn update_record(&self, record: Record<TraxRecord>) -> Result<(), WriteError>;
-    async fn delete_record(&self, id: RecordId) -> Result<(), WriteError>;
-}
-
 /// The real, headless application. This is where all of the logic will reside.
 #[derive(Clone)]
 pub struct App {
@@ -84,26 +57,11 @@ impl App {
         }
     }
 
-    pub async fn open_db(&self, path: PathBuf) -> Result<(), AppError> {
+    pub async fn records(
-        let db_ref = self.database.clone();
-        self.runtime
-            .spawn_blocking(move || {
-                let db = Series::open(path).map_err(|_| AppError::FailedToOpenDatabase)?;
-                *db_ref.write().unwrap() = Some(db);
-                Ok(())
-            })
-            .await
-            .unwrap()
-    }
-}
-
-#[async_trait]
-impl RecordProvider for App {
-    async fn records(
         &self,
         start: NaiveDate,
         end: NaiveDate,
-    ) -> Result<Vec<Record<TraxRecord>>, ReadError> {
+    ) -> Result<Vec<Record<TraxRecord>>, AppError> {
         let db = self.database.clone();
         self.runtime
             .spawn_blocking(move || {
@@ -119,14 +77,14 @@ impl RecordProvider for App {
                         .collect::<Vec<Record<TraxRecord>>>();
                     Ok(records)
                 } else {
-                    Err(ReadError::NoDatabase)
+                    Err(AppError::NoDatabase)
                 }
             })
             .await
             .unwrap()
     }
 
-    async fn put_record(&self, record: TraxRecord) -> Result<RecordId, WriteError> {
+    pub async fn put_record(&self, record: TraxRecord) -> Result<RecordId, AppError> {
         let db = self.database.clone();
         self.runtime
             .spawn_blocking(move || {
@@ -139,10 +97,10 @@ impl RecordProvider for App {
             })
             .await
             .unwrap()
-            .map_err(|_| WriteError::Unhandled)
+            .map_err(|_| AppError::Unhandled)
     }
 
-    async fn update_record(&self, record: Record<TraxRecord>) -> Result<(), WriteError> {
+    pub async fn update_record(&self, record: Record<TraxRecord>) -> Result<(), AppError> {
         let db = self.database.clone();
         self.runtime
             .spawn_blocking(move || {
@@ -154,10 +112,18 @@ impl RecordProvider for App {
             })
             .await
             .unwrap()
-            .map_err(|_| WriteError::Unhandled)
+            .map_err(|_| AppError::Unhandled)
     }
 
-    async fn delete_record(&self, id: RecordId) -> Result<(), WriteError> {
+    pub async fn open_db(&self, path: PathBuf) -> Result<(), AppError> {
-        unimplemented!()
+        let db_ref = self.database.clone();
+        self.runtime
+            .spawn_blocking(move || {
+                let db = Series::open(path).map_err(|_| AppError::FailedToOpenDatabase)?;
+                *db_ref.write().unwrap() = Some(db);
+                Ok(())
+            })
+            .await
+            .unwrap()
     }
 }

fitnesstrax/app/src/app_window.rs

@@ -15,8 +15,7 @@ You should have received a copy of the GNU General Public License along with Fit
 */
 
 use crate::{
-    app::{App, RecordProvider},
+    app::App,
-    types::DayInterval,
     view_models::DayDetailViewModel,
     views::{DayDetailView, HistoricalView, PlaceholderView, View, WelcomeView},
 };
@@ -134,15 +133,15 @@ impl AppWindow {
         self.swap_main(view);
     }
 
-    fn show_historical_view(&self, interval: DayInterval) {
+    fn show_historical_view(&self, records: Vec<Record<TraxRecord>>) {
-        let view = View::Historical(HistoricalView::new(self.app.clone(), interval, {
+        let view = View::Historical(HistoricalView::new(self.app.clone(), records, {
             let s = self.clone();
-            Rc::new(move |date| {
+            Rc::new(move |date, _records| {
                 let s = s.clone();
                 glib::spawn_future_local(async move {
                     let layout = gtk::Box::new(gtk::Orientation::Vertical, 0);
                     layout.append(&adw::HeaderBar::new());
-                    let view_model = DayDetailViewModel::new(date, s.app.clone()).await.unwrap();
+                    let view_model = DayDetailViewModel::new(date, s.app.clone()).await;
                     layout.append(&DayDetailView::new(view_model));
                     let page = &adw::NavigationPage::builder()
                         .title(date.format("%Y-%m-%d").to_string())
@@ -161,7 +160,10 @@ impl AppWindow {
             async move {
                 let end = Local::now().date_naive();
                 let start = end - Duration::days(7);
-                s.show_historical_view(DayInterval { start, end });
+                match s.app.records(start, end).await {
+                    Ok(records) => s.show_historical_view(records),
+                    Err(_) => s.show_welcome_view(),
+                }
             }
         });
     }

fitnesstrax/app/src/view_models/day_detail.rs

@@ -14,11 +14,7 @@ General Public License for more details.
 You should have received a copy of the GNU General Public License along with FitnessTrax. If not, see <https://www.gnu.org/licenses/>.
 */
 
-use crate::{
+use crate::{app::App, types::WeightFormatter};
-    app::{ReadError, RecordProvider, WriteError},
-    types::WeightFormatter,
-};
-use chrono::NaiveDate;
 use emseries::{Record, RecordId, Recordable};
 use ft_core::TraxRecord;
 use std::{
@@ -81,7 +77,7 @@ impl<T: Clone + emseries::Recordable> Deref for RecordState<T> {
 
 #[derive(Clone)]
 pub struct DayDetailViewModel {
-    provider: Arc<dyn RecordProvider>,
+    app: App,
     pub date: chrono::NaiveDate,
     weight: Arc<RwLock<Option<RecordState<ft_core::Weight>>>>,
     steps: Arc<RwLock<Option<RecordState<ft_core::Steps>>>>,
@@ -89,20 +85,15 @@ pub struct DayDetailViewModel {
 }
 
 impl DayDetailViewModel {
-    pub async fn new(
+    pub async fn new(date: chrono::NaiveDate, app: App) -> Self {
-        date: chrono::NaiveDate,
+        let records = app.records(date, date).await.unwrap();
-        provider: impl RecordProvider + 'static,
+
-    ) -> Result<Self, ReadError> {
         let (weight_records, records): (Vec<Record<TraxRecord>>, Vec<Record<TraxRecord>>) =
-            provider
+            records.into_iter().partition(|r| r.data.is_weight());
-                .records(date, date)
-                .await?
-                .into_iter()
-                .partition(|r| r.data.is_weight());
         let (step_records, records): (Vec<Record<TraxRecord>>, Vec<Record<TraxRecord>>) =
             records.into_iter().partition(|r| r.data.is_steps());
-        Ok(Self {
+        Self {
-            provider: Arc::new(provider),
+            app,
             date,
             weight: Arc::new(RwLock::new(
                 weight_records
@@ -129,7 +120,7 @@ impl DayDetailViewModel {
                     .map(|r| (r.id.clone(), RecordState::Original(r)))
                     .collect::<HashMap<RecordId, RecordState<TraxRecord>>>(),
             )),
-        })
+        }
     }
 
     pub fn weight(&self) -> Option<WeightFormatter> {
@@ -179,12 +170,12 @@ impl DayDetailViewModel {
                 let weight_record = s.weight.read().unwrap().clone();
                 match weight_record {
                     Some(RecordState::New(data)) => {
-                        let _ = s.provider.put_record(TraxRecord::Weight(data)).await;
+                        let _ = s.app.put_record(TraxRecord::Weight(data)).await;
                     }
                     Some(RecordState::Original(_)) => {}
                     Some(RecordState::Updated(weight)) => {
                         let _ = s
-                            .provider
+                            .app
                             .update_record(Record {
                                 id: weight.id,
                                 data: TraxRecord::Weight(weight.data),
@@ -198,12 +189,12 @@ impl DayDetailViewModel {
                 let steps_record = s.steps.read().unwrap().clone();
                 match steps_record {
                     Some(RecordState::New(data)) => {
-                        let _ = s.provider.put_record(TraxRecord::Steps(data)).await;
+                        let _ = s.app.put_record(TraxRecord::Steps(data)).await;
                     }
                     Some(RecordState::Original(_)) => {}
                     Some(RecordState::Updated(steps)) => {
                         let _ = s
-                            .provider
+                            .app
                             .update_record(Record {
                                 id: steps.id,
                                 data: TraxRecord::Steps(steps.data),
@@ -225,11 +216,11 @@ impl DayDetailViewModel {
                 for record in records {
                     match record {
                         RecordState::New(data) => {
-                            let _ = s.provider.put_record(data).await;
+                            let _ = s.app.put_record(data).await;
                         }
                         RecordState::Original(_) => {}
                         RecordState::Updated(r) => {
-                            let _ = s.provider.update_record(r.clone()).await;
+                            let _ = s.app.update_record(r.clone()).await;
                         }
                         RecordState::Deleted(_) => unimplemented!(),
                     }
@@ -242,131 +233,3 @@ impl DayDetailViewModel {
         unimplemented!();
     }
 }
-
-#[cfg(test)]
-mod test {
-    use super::*;
-    use async_trait::async_trait;
-    use dimensioned::si;
-    use emseries::Record;
-
-    struct MockProvider {
-        records: Vec<Record<TraxRecord>>,
-    }
-
-    #[async_trait]
-    impl RecordProvider for MockProvider {
-        async fn records(
-            &self,
-            start: NaiveDate,
-            end: NaiveDate,
-        ) -> Result<Vec<Record<TraxRecord>>, ReadError> {
-            let start = emseries::Timestamp::Date(start);
-            let end = emseries::Timestamp::Date(end);
-            Ok(self
-                .records
-                .iter()
-                .filter(|r| r.timestamp() >= start && r.timestamp() <= end)
-                .cloned()
-                .collect::<Vec<Record<TraxRecord>>>())
-        }
-
-        async fn put_record(&self, record: TraxRecord) -> Result<RecordId, WriteError> {
-            Err(WriteError::NoDatabase)
-        }
-
-        async fn update_record(&self, record: Record<TraxRecord>) -> Result<(), WriteError> {
-            Err(WriteError::NoDatabase)
-        }
-
-        async fn delete_record(&self, id: RecordId) -> Result<(), WriteError> {
-            Err(WriteError::NoDatabase)
-        }
-    }
-
-    async fn with_view_model<TestFn>(test: TestFn)
-    where
-        TestFn: Fn(DayDetailViewModel),
-    {
-        let oct_12 = chrono::NaiveDate::from_ymd_opt(2023, 10, 12).unwrap();
-        let oct_13 = chrono::NaiveDate::from_ymd_opt(2023, 10, 13).unwrap();
-        let provider = MockProvider {
-            records: vec![
-                Record {
-                    id: RecordId::default(),
-                    data: TraxRecord::Weight(ft_core::Weight {
-                        date: oct_12.clone(),
-                        weight: 93. * si::KG,
-                    }),
-                },
-                Record {
-                    id: RecordId::default(),
-                    data: TraxRecord::Weight(ft_core::Weight {
-                        date: oct_13.clone(),
-                        weight: 95. * si::KG,
-                    }),
-                },
-                Record {
-                    id: RecordId::default(),
-                    data: TraxRecord::Steps(ft_core::Steps {
-                        date: oct_13.clone(),
-                        count: 2500,
-                    }),
-                },
-                Record {
-                    id: RecordId::default(),
-                    data: TraxRecord::Weight(ft_core::Weight {
-                        date: oct_13.clone(),
-                        weight: 91. * si::KG,
-                    }),
-                },
-                Record {
-                    id: RecordId::default(),
-                    data: TraxRecord::Steps(ft_core::Steps {
-                        date: oct_13.clone(),
-                        count: 2750,
-                    }),
-                },
-            ],
-        };
-        let model = DayDetailViewModel::new(oct_13, provider).await.unwrap();
-        test(model)
-    }
-
-    #[tokio::test]
-    async fn it_honors_only_the_first_weight_and_step_record() {
-        with_view_model(|view_model| {
-            assert_eq!(view_model.weight().map(|val| *val), Some(95. * si::KG));
-            assert_eq!(view_model.steps(), Some(2500));
-        })
-        .await;
-    }
-
-    #[test]
-    #[ignore]
-    fn it_enforces_one_weight_and_stepcount_per_day() {}
-
-    #[test]
-    #[ignore]
-    fn it_can_construct_new_records() {}
-
-    #[test]
-    #[ignore]
-    fn it_can_update_an_existing_record() {}
-
-    #[test]
-    #[ignore]
-    fn it_can_remove_a_new_record() {}
-
-    #[test]
-    #[ignore]
-    fn it_can_delete_an_existing_record() {}
-
-    #[test]
-    #[ignore]
-    fn it_retrieve_records_by_workout() {}
-
-    #[test]
-    #[ignore]
-    fn it_summarizes_records_by_workout_type() {}
-}

fitnesstrax/app/src/views/historical_view.rs

@@ -62,11 +62,11 @@ impl ObjectSubclass for HistoricalViewPrivate {
                 let app = app.clone();
                 let list_item = list_item.clone();
                 glib::spawn_future_local(async move {
-                    let date = list_item
+                    let records = list_item
                         .downcast_ref::<gtk::ListItem>()
                         .expect("should be a ListItem")
                         .item()
-                        .and_downcast::<Date>()
+                        .and_downcast::<DayRecords>()
                         .expect("should be a DaySummary");
 
                     let summary = list_item
@@ -77,11 +77,8 @@ impl ObjectSubclass for HistoricalViewPrivate {
                         .expect("should be a DaySummary");
 
                     if let Some(app) = app.borrow().clone() {
-                        glib::spawn_future_local(async move {
+                        let view_model = DayDetailViewModel::new(records.date(), app.clone()).await;
-                            let view_model =
-                                DayDetailViewModel::new(date.date(), app).await.unwrap();
                         summary.set_data(view_model);
-                        });
                     }
                 });
             }
@@ -100,9 +97,13 @@ glib::wrapper! {
 }
 
 impl HistoricalView {
-    pub fn new<SelectFn>(app: App, interval: DayInterval, on_select_day: Rc<SelectFn>) -> Self
+    pub fn new<SelectFn>(
+        app: App,
+        records: Vec<Record<TraxRecord>>,
+        on_select_day: Rc<SelectFn>,
+    ) -> Self
     where
-        SelectFn: Fn(chrono::NaiveDate) + 'static,
+        SelectFn: Fn(chrono::NaiveDate, Vec<Record<TraxRecord>>) + 'static,
     {
         let s: Self = Object::builder().build();
         s.set_orientation(gtk::Orientation::Vertical);
@@ -110,8 +111,11 @@ impl HistoricalView {
 
         *s.imp().app.borrow_mut() = Some(app);
 
-        let mut model = gio::ListStore::new::<Date>();
+        let grouped_records =
-        model.extend(interval.days().map(Date::new));
+            GroupedRecords::new((*s.imp().time_window.borrow()).clone()).with_data(records);
+
+        let mut model = gio::ListStore::new::<DayRecords>();
+        model.extend(grouped_records.items());
         s.imp()
             .list_view
             .set_model(Some(&gtk::NoSelection::new(Some(model))));
@@ -123,8 +127,8 @@ impl HistoricalView {
                 // actually want to do here is to open a modal dialog that shows all of the details of
                 // the day and which allows the user to edit items within that dialog.
                 let item = s.model().unwrap().item(idx).unwrap();
-                let date = item.downcast_ref::<Date>().unwrap();
+                let records = item.downcast_ref::<DayRecords>().unwrap();
-                on_select_day(date.date());
+                on_select_day(records.date(), records.records());
             }
         });
 
@@ -133,9 +137,12 @@ impl HistoricalView {
         s
     }
 
-    pub fn set_interval(&self, interval: DayInterval) {
+    pub fn set_records(&self, records: Vec<Record<TraxRecord>>) {
-        let mut model = gio::ListStore::new::<Date>();
+        println!("set_records: {:?}", records);
-        model.extend(interval.days().map(Date::new));
+        let grouped_records =
+            GroupedRecords::new((self.imp().time_window.borrow()).clone()).with_data(records);
+        let mut model = gio::ListStore::new::<DayRecords>();
+        model.extend(grouped_records.items());
         self.imp()
             .list_view
             .set_model(Some(&gtk::NoSelection::new(Some(model))));
@@ -147,30 +154,152 @@ impl HistoricalView {
 }
 
 #[derive(Default)]
-pub struct DatePrivate {
+pub struct DayRecordsPrivate {
     date: RefCell<chrono::NaiveDate>,
+    records: RefCell<Vec<Record<TraxRecord>>>,
 }
 
 #[glib::object_subclass]
-impl ObjectSubclass for DatePrivate {
+impl ObjectSubclass for DayRecordsPrivate {
-    const NAME: &'static str = "Date";
+    const NAME: &'static str = "DayRecords";
-    type Type = Date;
+    type Type = DayRecords;
 }
 
-impl ObjectImpl for DatePrivate {}
+impl ObjectImpl for DayRecordsPrivate {}
 
 glib::wrapper! {
-    pub struct Date(ObjectSubclass<DatePrivate>);
+    pub struct DayRecords(ObjectSubclass<DayRecordsPrivate>);
 }
 
-impl Date {
+impl DayRecords {
-    pub fn new(date: chrono::NaiveDate) -> Self {
+    pub fn new(date: chrono::NaiveDate, records: Vec<Record<TraxRecord>>) -> Self {
         let s: Self = Object::builder().build();
+
         *s.imp().date.borrow_mut() = date;
+        *s.imp().records.borrow_mut() = records;
+
         s
     }
 
     pub fn date(&self) -> chrono::NaiveDate {
         *self.imp().date.borrow()
     }
+
+    pub fn records(&self) -> Vec<Record<TraxRecord>> {
+        self.imp().records.borrow().clone()
+    }
+
+    pub fn add_record(&self, record: Record<TraxRecord>) {
+        self.imp().records.borrow_mut().push(record);
+    }
+}
+
+// This isn't feeling quite right. DayRecords is a glib object, but I'm not sure that I want to
+// really be passing that around. It seems not generic enough. I feel like this whole grouped
+// records thing can be made more generic.
+struct GroupedRecords {
+    interval: DayInterval,
+    data: HashMap<NaiveDate, DayRecords>,
+}
+
+impl GroupedRecords {
+    fn new(interval: DayInterval) -> Self {
+        let mut s = Self {
+            interval: interval.clone(),
+            data: HashMap::new(),
+        };
+        interval.days().for_each(|date| {
+            let _ = s.data.insert(date, DayRecords::new(date, vec![]));
+        });
+        s
+    }
+
+    fn with_data(mut self, records: Vec<Record<TraxRecord>>) -> Self {
+        records.into_iter().for_each(|record| {
+            self.data
+                .entry(record.date())
+                .and_modify(|entry: &mut DayRecords| (*entry).add_record(record.clone()))
+                .or_insert(DayRecords::new(record.date(), vec![record]));
+        });
+
+        self
+    }
+
+    fn items(&self) -> impl Iterator<Item = DayRecords> + '_ {
+        self.interval.days().map(|date| {
+            self.data
+                .get(&date)
+                .cloned()
+                .unwrap_or(DayRecords::new(date, vec![]))
+        })
+    }
+}
+
+#[cfg(test)]
+mod test {
+    use super::GroupedRecords;
+    use crate::types::DayInterval;
+    use chrono::{FixedOffset, NaiveDate, TimeZone};
+    use dimensioned::si::{KG, M, S};
+    use emseries::{Record, RecordId};
+    use ft_core::{Steps, TimeDistance, TraxRecord, Weight};
+
+    #[test]
+    fn groups_records() {
+        let records = vec![
+            Record {
+                id: RecordId::default(),
+                data: TraxRecord::Steps(Steps {
+                    date: NaiveDate::from_ymd_opt(2023, 10, 13).unwrap(),
+                    count: 1500,
+                }),
+            },
+            Record {
+                id: RecordId::default(),
+                data: TraxRecord::Weight(Weight {
+                    date: NaiveDate::from_ymd_opt(2023, 10, 13).unwrap(),
+                    weight: 85. * KG,
+                }),
+            },
+            Record {
+                id: RecordId::default(),
+                data: TraxRecord::Weight(Weight {
+                    date: NaiveDate::from_ymd_opt(2023, 10, 14).unwrap(),
+                    weight: 86. * KG,
+                }),
+            },
+            Record {
+                id: RecordId::default(),
+                data: TraxRecord::BikeRide(TimeDistance {
+                    datetime: FixedOffset::west_opt(10 * 60 * 60)
+                        .unwrap()
+                        .with_ymd_and_hms(2019, 6, 15, 12, 0, 0)
+                        .unwrap(),
+                    distance: Some(1000. * M),
+                    duration: Some(150. * S),
+                    comments: Some("Test Comments".to_owned()),
+                }),
+            },
+            Record {
+                id: RecordId::default(),
+                data: TraxRecord::BikeRide(TimeDistance {
+                    datetime: FixedOffset::west_opt(10 * 60 * 60)
+                        .unwrap()
+                        .with_ymd_and_hms(2019, 6, 15, 23, 0, 0)
+                        .unwrap(),
+                    distance: Some(1000. * M),
+                    duration: Some(150. * S),
+                    comments: Some("Test Comments".to_owned()),
+                }),
+            },
+        ];
+
+        let groups = GroupedRecords::new(DayInterval {
+            start: NaiveDate::from_ymd_opt(2023, 10, 14).unwrap(),
+            end: NaiveDate::from_ymd_opt(2023, 10, 14).unwrap(),
+        })
+        .with_data(records)
+        .data;
+        assert_eq!(groups.len(), 3);
+    }
 }