zaphar/kitchen
1
0
Fork 0
mirror of https://github.com/zaphar/kitchen.git synced 2025-07-22 19:40:14 -04:00
Code Issues Packages Projects Releases Wiki Activity

dev: use cursor for the get_all_recipes

Browse Source
This commit is contained in:
Jeremy Wall 2024-07-12 18:40:42 -04:00
parent 1f90cc2ef6
commit f173204d2d
1 changed files with 60 additions and 61 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

65
web/src/api.rs
View File

@ -109,17 +109,19 @@ impl LocalStore {
pub async fn migrate(&self) { pub async fn migrate(&self) {
// 1. migrate app-state from localstore to indexeddb // 1. migrate app-state from localstore to indexeddb
if let Ok(Some(v)) = self.old_store.get("app_state") { if let Ok(Some(v)) = self.old_store.get(APP_STATE_KEY) {
if let Ok(Some(local_state)) = from_str::<Option<AppState> >(&v) { if let Ok(Some(local_state)) = from_str::<Option<AppState>>(&v) {
self.store_app_state(&local_state).await; self.store_app_state(&local_state).await;
} }
} }
let _ = self.old_store.remove_item(APP_STATE_KEY);
// 2. migrate user-state from localstore to indexeddb // 2. migrate user-state from localstore to indexeddb
if let Ok(Some(v)) = self.old_store.get(USER_DATA_KEY) { if let Ok(Some(v)) = self.old_store.get(USER_DATA_KEY) {
if let Ok(local_user_data) = from_str::<Option<UserData> >(&v) { if let Ok(local_user_data) = from_str::<Option<UserData>>(&v) {
self.set_user_data(local_user_data.as_ref()).await; self.set_user_data(local_user_data.as_ref()).await;
} }
} }
let _ = self.old_store.remove_item(USER_DATA_KEY);
// 3. Recipes? // 3. Recipes?
} }
@ -139,10 +141,7 @@ impl LocalStore {
.object_store(js_lib::STATE_STORE_NAME) .object_store(js_lib::STATE_STORE_NAME)
.expect("Failed to get object store"); .expect("Failed to get object store");
object_store object_store
.put_kv( .put_kv(&key, &state)
&key,
&state,
)
.await .await
.expect("Failed to write to object store"); .expect("Failed to write to object store");
Ok(()) Ok(())
@ -258,40 +257,34 @@ impl LocalStore {
Ok(keys) Ok(keys)
}) })
.await .await
.expect("Failed to get storage keys").into_iter() .expect("Failed to get storage keys")
.into_iter()
} }
/// Gets all the recipes from local storage. /// Gets all the recipes from local storage.
pub async fn get_recipes(&self) -> Option<Vec<RecipeEntry>> { pub async fn get_recipes(&self) -> Option<Vec<RecipeEntry>> {
let mut recipe_list = Vec::new(); self.store
for recipe_key in self.get_recipe_keys().await {
let key = to_value(&recipe_key).expect("Failed to serialize key");
let entry = self
.store
.ro_transaction(&[js_lib::RECIPE_STORE_NAME], |trx| async move { .ro_transaction(&[js_lib::RECIPE_STORE_NAME], |trx| async move {
let mut recipe_list = Vec::new();
let object_store = trx let object_store = trx
.object_store(js_lib::RECIPE_STORE_NAME) .object_store(js_lib::RECIPE_STORE_NAME)
.expect("Failed to get object store"); .expect("Failed to get object store");
let entry: Option<RecipeEntry> = match object_store let mut c = object_store
.get(&key) .cursor()
.open()
.await .await
.expect("Failed to get recipe from key") .expect("Failed to open recipe cursor");
{ while let Some(value) = c.value() {
Some(v) => from_value(v).expect("Failed to deserialize entry"), recipe_list.push(from_value(value).expect("Failed to deserialize entry"));
None => None, c.advance(1).await.expect("Failed to advance cursor for recipes");
};
Ok(entry)
})
.await
.expect("Failed to get recipes");
if let Some(entry) = entry {
recipe_list.push(entry);
}
} }
if recipe_list.is_empty() { if recipe_list.is_empty() {
return None; return Ok(None);
} }
Some(recipe_list) Ok(Some(recipe_list))
})
.await
.expect("Failed to get recipes")
} }
pub async fn get_recipe_entry(&self, id: &str) -> Option<RecipeEntry> { pub async fn get_recipe_entry(&self, id: &str) -> Option<RecipeEntry> {
@ -347,7 +340,8 @@ impl LocalStore {
let entry = entry.clone(); let entry = entry.clone();
let key = let key =
to_value(&recipe_key(entry.recipe_id())).expect("Failed to serialize recipe key"); to_value(&recipe_key(entry.recipe_id())).expect("Failed to serialize recipe key");
self.store.rw_transaction(&[js_lib::RECIPE_STORE_NAME], |trx| async move { self.store
.rw_transaction(&[js_lib::RECIPE_STORE_NAME], |trx| async move {
let object_store = trx let object_store = trx
.object_store(js_lib::RECIPE_STORE_NAME) .object_store(js_lib::RECIPE_STORE_NAME)
.expect("Failed to get object store"); .expect("Failed to get object store");
@ -359,7 +353,9 @@ impl LocalStore {
.await .await
.expect("Failed to store recipe_entry"); .expect("Failed to store recipe_entry");
Ok(()) Ok(())
}).await.expect("Failed to store recipe entry"); })
.await
.expect("Failed to store recipe entry");
//self.set_recipe_entry(entry).await; //self.set_recipe_entry(entry).await;
} }
} }
@ -368,7 +364,8 @@ impl LocalStore {
pub async fn set_recipe_entry(&self, entry: &RecipeEntry) { pub async fn set_recipe_entry(&self, entry: &RecipeEntry) {
let entry = entry.clone(); let entry = entry.clone();
let key = to_value(&recipe_key(entry.recipe_id())).expect("Failed to serialize recipe key"); let key = to_value(&recipe_key(entry.recipe_id())).expect("Failed to serialize recipe key");
self.store.rw_transaction(&[js_lib::RECIPE_STORE_NAME], |trx| async move { self.store
.rw_transaction(&[js_lib::RECIPE_STORE_NAME], |trx| async move {
let object_store = trx let object_store = trx
.object_store(js_lib::RECIPE_STORE_NAME) .object_store(js_lib::RECIPE_STORE_NAME)
.expect("Failed to get object store"); .expect("Failed to get object store");
@ -380,7 +377,9 @@ impl LocalStore {
.await .await
.expect("Failed to store recipe_entry"); .expect("Failed to store recipe_entry");
Ok(()) Ok(())
}).await.expect("Failed to store recipe entry"); })
.await
.expect("Failed to store recipe entry");
// FIXME(zaphar): Migration from local storage to indexed db // FIXME(zaphar): Migration from local storage to indexed db
//self.store //self.store
// .set( // .set(