populate local cache

gamercade_app/Cargo.toml

@@ -18,6 +18,7 @@ gamercade_interface = { path = "../gamercade_interface" }
 
 rfd = "0.11.3"
 radix_fmt = "1.0.0"
+bytemuck = "1.15.0"
 
 tokio = { version = "1.28.1", features = ["full"] }
 tokio-stream = "0.1.14"

gamercade_app/src/app.rs

@@ -97,9 +97,10 @@ impl App {
                 TaskNotification::DownloadRomComplete(complete) => {
                     println!("TODO: Release download complete")
                 }
-                TaskNotification::FrontPageResponse(front_page_response) => {
-                    println!("TODO: Got Response: {front_page_response:?}");
-                }
+                TaskNotification::FrontPageResponse(mut front_page_response) => front_page_response
+                    .games
+                    .drain(..)
+                    .for_each(|game| self.directory.update_game(game)),
             }
         }
     }

gamercade_app/src/local_directory/game.rs

@@ -30,21 +30,45 @@ pub(super) fn upsert_games_table(db: &Connection) {
 }
 
 impl LocalDirectory {
-    pub fn update_game(&self, game: GameInfoBasic) {
+    pub fn update_game(&mut self, game: GameInfoBasic) {
         let tag_bytes = game
             .tags
             .into_iter()
             .map(|tag| u8::try_from(tag).unwrap())
             .collect::<Vec<_>>();
-        
+
         self.db.execute("INSERT OR REPLACE INTO games (id, title, short_description, file_checksum, rating, tags)
-        VALUES (?, ?, ?, ?, ?, ?, ?)",
+        VALUES (?, ?, ?, ?, ?, ?);",
         (game.game_id, game.title, game.short_description, game.checksum, game.average_rating, tag_bytes)).unwrap();
+
+        self.cache_dirty = true;
     }
 
     pub fn iter_games(&self) -> GameIter<'_> {
         GameIter::new(&self.cached_games)
     }
+
+    pub fn sync_games_cache(&mut self) {
+        let mut query = self.db.prepare("SELECT * FROM games;").unwrap();
+
+        self.cached_games = query
+            .query_map((), |row| {
+                let tag_bytes: Vec<u8> = row.get(4)?;
+                Ok(Game {
+                    id: row.get(0)?,
+                    title: row.get(1)?,
+                    short_description: row.get(2)?,
+                    long_description: row.get(3)?,
+                    tags: bytemuck::cast_vec(tag_bytes),
+                    rating: row.get(5)?,
+                })
+            })
+            .unwrap()
+            .flatten()
+            .collect();
+
+        self.cache_dirty = false;
+    }
 }
 
 pub struct GameIter<'a> {

gamercade_app/src/local_directory/mod.rs

@@ -25,6 +25,7 @@ type PermissionLevelDictionary = Dictionary<PermissionLevelId, PermissionLevel>;
 pub struct LocalDirectory {
     db: Connection,
     pub cached_games: Vec<Game>,
+    cache_dirty: bool,
     pub tags: TagDictionary,
     pub users: UserDictionary,
     pub permission_levels: PermissionLevelDictionary,
@@ -154,16 +155,19 @@ impl Default for LocalDirectory {
     fn default() -> Self {
         let db = Connection::open(LOCAL_DB_PATH).unwrap();
 
-        let output = Self {
+        let mut output = Self {
             tags: TagDictionary::new(&db),
             users: UserDictionary::new(&db),
             permission_levels: PermissionLevelDictionary::new(&db),
             db,
             cached_games: Vec::new(),
+            cache_dirty: true,
         };
 
         upsert_games_table(&output.db);
 
+        output.sync_games_cache();
+
         output
     }
 }