Dima/matrix-rust-sdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(indexeddb): add transaction fn for getting max key in range

Browse Source 
Signed-off-by: Michael Goldenberg <m@mgoldenberg.net>
This commit is contained in:
Michael Goldenberg
2025-10-14 10:25:58 -04:00
committed by Damir Jelić
parent dfb3713f1e
commit 4e8ddde2f2
1 changed files with 34 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/matrix-sdk-indexeddb/src/transaction/mod.rs
+34 -23
View File
@@ -237,30 +237,10 @@ impl<'a> Transaction<'a> {
T: Indexed,
T::IndexedType: DeserializeOwned,
T::Error: AsyncErrorDeps,
K: IndexedKey<T> + Serialize,
K: IndexedKey<T> + Serialize + DeserializeOwned,
{
let range = self.serializer.encode_key_range::<T, K>(range);
let direction = CursorDirection::Prev;
let object_store = self.transaction.object_store(T::OBJECT_STORE)?;
if let Some(index) = K::INDEX {
let index = object_store.index(index)?;
if let Some(mut cursor) =
index.open_cursor().with_query(range).with_direction(direction).serde()?.await?
{
if let Some(record) = cursor.next_record_ser().await? {
return T::from_indexed(record, self.serializer.inner())
.map(Some)
.map_err(|e| TransactionError::Serialization(Box::new(e)));
}
}
} else if let Some(mut cursor) =
object_store.open_cursor().with_query(range).with_direction(direction).serde()?.await?
{
if let Some(record) = cursor.next_record_ser().await? {
return T::from_indexed(record, self.serializer.inner())
.map(Some)
.map_err(|e| TransactionError::Serialization(Box::new(e)));
}
if let Some(key) = self.get_max_key::<T, K>(range).await? {
return self.get_item_by_key::<T, K>(key).await;
}
Ok(None)
}
@@ -289,6 +269,37 @@ impl<'a> Transaction<'a> {
Ok(Vec::new())
}
/// Query IndexedDB for the maximum key in the given range.
pub async fn get_max_key<T, K>(
&self,
range: impl Into<IndexedKeyRange<K>>,
) -> Result<Option<K>, TransactionError>
where
T: Indexed,
K: IndexedKey<T> + Serialize + DeserializeOwned,
{
let range = self.serializer.encode_key_range::<T, K>(range);
let direction = CursorDirection::Prev;
let object_store = self.transaction.object_store(T::OBJECT_STORE)?;
if let Some(index) = K::INDEX {
let index = object_store.index(index)?;
if let Some(mut cursor) =
index.open_key_cursor().with_query(range).with_direction(direction).serde()?.await?
{
return cursor.next_key_ser().await.map_err(Into::into);
}
} else if let Some(mut cursor) = object_store
.open_key_cursor()
.with_query(range)
.with_direction(direction)
.serde()?
.await?
{
return cursor.next_key_ser().await.map_err(Into::into);
}
Ok(None)
}
/// Query IndexedDB for keys that match the given key range. Iterate over
/// the keys in the given [`direction`](CursorDirection) using a cursor and
/// fold them into an accumulator while the given function `f` returns