From a22529344a5a8f299b9d23d0effb3c6dc2ecb736 Mon Sep 17 00:00:00 2001 From: Jonas Platte Date: Wed, 8 Feb 2023 14:25:27 +0100 Subject: [PATCH] refactor(sqlite): Inline inherent methods that duplicate trait methods --- crates/matrix-sdk-sqlite/src/crypto_store.rs | 49 ++++++++------------ 1 file changed, 19 insertions(+), 30 deletions(-) diff --git a/crates/matrix-sdk-sqlite/src/crypto_store.rs b/crates/matrix-sdk-sqlite/src/crypto_store.rs index 9092084a2..e850a6143 100644 --- a/crates/matrix-sdk-sqlite/src/crypto_store.rs +++ b/crates/matrix-sdk-sqlite/src/crypto_store.rs @@ -177,33 +177,6 @@ impl SqliteCryptoStore { async fn acquire(&self) -> Result { Ok(self.pool.get().await?) } - - async fn load_tracked_users(&self) -> Result> { - self.acquire() - .await? - .get_tracked_users() - .await? - .iter() - .map(|value| Ok(self.deserialize_value(value)?)) - .collect() - } - - async fn save_tracked_users( - &self, - tracked_users: &[(&UserId, bool)], - ) -> Result<(), CryptoStoreError> { - let users: Vec<(Key, Vec)> = tracked_users - .iter() - .map(|(u, d)| { - let user_id = self.encode_key("tracked_users", u.as_bytes()); - let data = - self.serialize_value(&TrackedUser { user_id: (*u).into(), dirty: *d })?; - Ok((user_id, data)) - }) - .collect::>()?; - - Ok(self.acquire().await?.add_tracked_users(users).await?) - } } const DATABASE_VERSION: u8 = 1; @@ -859,11 +832,27 @@ impl CryptoStore for SqliteCryptoStore { } async fn load_tracked_users(&self) -> StoreResult> { - Ok(self.load_tracked_users().await?) + self.acquire() + .await? + .get_tracked_users() + .await? + .iter() + .map(|value| self.deserialize_value(value)) + .collect() } - async fn save_tracked_users(&self, users: &[(&UserId, bool)]) -> StoreResult<()> { - self.save_tracked_users(users).await + async fn save_tracked_users(&self, tracked_users: &[(&UserId, bool)]) -> StoreResult<()> { + let users: Vec<(Key, Vec)> = tracked_users + .iter() + .map(|(u, d)| { + let user_id = self.encode_key("tracked_users", u.as_bytes()); + let data = + self.serialize_value(&TrackedUser { user_id: (*u).into(), dirty: *d })?; + Ok((user_id, data)) + }) + .collect::>()?; + + Ok(self.acquire().await?.add_tracked_users(users).await?) } async fn get_device(