make fmt-rust

oguzkocer · oguzkocer · commit fe7435c9f74b · 2025-12-18T10:48:37.000-05:00
diff --git a/wp_mobile/src/collection/mod.rs b/wp_mobile/src/collection/mod.rs
@@ -8,7 +8,9 @@ mod stateless_collection;
 pub use collection_error::CollectionError;
 pub use fetch_error::FetchError;
 pub use fetch_result::FetchResult;
-pub use post_metadata_collection::{PostMetadataCollectionItem, PostMetadataCollectionWithEditContext};
+pub use post_metadata_collection::{
+    PostMetadataCollectionItem, PostMetadataCollectionWithEditContext,
+};
 pub use stateless_collection::StatelessCollection;
 
 /// Macro to create UniFFI-compatible post collection wrappers
diff --git a/wp_mobile/src/service/metadata.rs b/wp_mobile/src/service/metadata.rs
@@ -5,8 +5,8 @@ use wp_mobile_cache::{
     db_types::db_site::DbSite,
     list_metadata::ListState,
     repository::list_metadata::{
-        FetchNextPageInfo, ListMetadataHeaderUpdate, ListMetadataItemInput,
-        ListMetadataRepository, RefreshInfo,
+        FetchNextPageInfo, ListMetadataHeaderUpdate, ListMetadataItemInput, ListMetadataRepository,
+        RefreshInfo,
     },
 };
 
@@ -101,10 +101,7 @@ impl MetadataService {
     /// Get pagination info for a list.
     ///
     /// Returns None if the list doesn't exist.
-    pub fn get_pagination(
-        &self,
-        key: &str,
-    ) -> Result<Option<ListPaginationInfo>, WpServiceError> {
+    pub fn get_pagination(&self, key: &str) -> Result<Option<ListPaginationInfo>, WpServiceError> {
         self.cache.execute(|conn| {
             let header = self.repo.get_header(conn, &self.db_site, key)?;
             Ok(header.map(|h| ListPaginationInfo {
@@ -147,7 +144,10 @@ impl MetadataService {
     /// Check if the current version matches expected (for stale detection).
     pub fn check_version(&self, key: &str, expected_version: i64) -> Result<bool, WpServiceError> {
         self.cache
-            .execute(|conn| self.repo.check_version(conn, &self.db_site, key, expected_version))
+            .execute(|conn| {
+                self.repo
+                    .check_version(conn, &self.db_site, key, expected_version)
+            })
             .map_err(Into::into)
     }
 
@@ -415,8 +415,7 @@ mod tests {
     use rstest::*;
     use rusqlite::Connection;
     use wp_mobile_cache::{
-        MigrationManager, WpApiCache,
-        db_types::self_hosted_site::SelfHostedSite,
+        MigrationManager, WpApiCache, db_types::self_hosted_site::SelfHostedSite,
         repository::sites::SiteRepository,
     };
 
@@ -485,12 +484,18 @@ mod tests {
 
         test_ctx
             .service
-            .set_items(key, &[EntityMetadata::new(1, None), EntityMetadata::new(2, None)])
+            .set_items(
+                key,
+                &[EntityMetadata::new(1, None), EntityMetadata::new(2, None)],
+            )
             .unwrap();
 
         test_ctx
             .service
-            .set_items(key, &[EntityMetadata::new(10, None), EntityMetadata::new(20, None)])
+            .set_items(
+                key,
+                &[EntityMetadata::new(10, None), EntityMetadata::new(20, None)],
+            )
             .unwrap();
 
         let ids = test_ctx.service.get_entity_ids(key).unwrap();
@@ -508,7 +513,10 @@ mod tests {
 
         test_ctx
             .service
-            .append_items(key, &[EntityMetadata::new(2, None), EntityMetadata::new(3, None)])
+            .append_items(
+                key,
+                &[EntityMetadata::new(2, None), EntityMetadata::new(3, None)],
+            )
             .unwrap();
 
         let ids = test_ctx.service.get_entity_ids(key).unwrap();
@@ -555,15 +563,24 @@ mod tests {
         let key = "edit:posts:publish";
 
         // No pages loaded yet
-        test_ctx.service.update_pagination(key, Some(3), None, 0, 20).unwrap();
+        test_ctx
+            .service
+            .update_pagination(key, Some(3), None, 0, 20)
+            .unwrap();
         assert!(test_ctx.service.has_more_pages(key).unwrap());
 
         // Page 1 of 3 loaded
-        test_ctx.service.update_pagination(key, Some(3), None, 1, 20).unwrap();
+        test_ctx
+            .service
+            .update_pagination(key, Some(3), None, 1, 20)
+            .unwrap();
         assert!(test_ctx.service.has_more_pages(key).unwrap());
 
         // Page 3 of 3 loaded (no more)
-        test_ctx.service.update_pagination(key, Some(3), None, 3, 20).unwrap();
+        test_ctx
+            .service
+            .update_pagination(key, Some(3), None, 3, 20)
+            .unwrap();
         assert!(!test_ctx.service.has_more_pages(key).unwrap());
     }
 
@@ -598,7 +615,10 @@ mod tests {
 
         // Set up: page 1 of 3 loaded
         test_ctx.service.begin_refresh(key).unwrap();
-        test_ctx.service.update_pagination(key, Some(3), None, 1, 20).unwrap();
+        test_ctx
+            .service
+            .update_pagination(key, Some(3), None, 1, 20)
+            .unwrap();
         test_ctx.service.complete_sync(key).unwrap();
 
         let result = test_ctx.service.begin_fetch_next_page(key).unwrap();
@@ -615,7 +635,10 @@ mod tests {
             .service
             .set_items(key, &[EntityMetadata::new(1, None)])
             .unwrap();
-        test_ctx.service.update_pagination(key, Some(1), None, 1, 20).unwrap();
+        test_ctx
+            .service
+            .update_pagination(key, Some(1), None, 1, 20)
+            .unwrap();
 
         test_ctx.service.delete_list(key).unwrap();
 
@@ -626,7 +649,10 @@ mod tests {
     #[rstest]
     fn test_list_metadata_reader_trait(test_ctx: TestContext) {
         let key = "edit:posts:publish";
-        let metadata = vec![EntityMetadata::new(100, None), EntityMetadata::new(200, None)];
+        let metadata = vec![
+            EntityMetadata::new(100, None),
+            EntityMetadata::new(200, None),
+        ];
 
         test_ctx.service.set_items(key, &metadata).unwrap();
 
diff --git a/wp_mobile/src/service/posts.rs b/wp_mobile/src/service/posts.rs
@@ -225,7 +225,11 @@ impl PostService {
 
         // Helper to print log on early return
         let print_log = |log: &[String], status: &str| {
-            println!("[PostService] fetch_metadata_persistent:\n  {} | {}", log.join(" -> "), status);
+            println!(
+                "[PostService] fetch_metadata_persistent:\n  {} | {}",
+                log.join(" -> "),
+                status
+            );
         };
 
         // Update state to fetching (this creates the list if needed)
@@ -421,7 +425,9 @@ impl PostService {
         self.metadata_service
             .set_state(key, state, None)
             .map_err(|e| match e {
-                WpServiceError::DatabaseError { err_message } => FetchError::Database { err_message },
+                WpServiceError::DatabaseError { err_message } => {
+                    FetchError::Database { err_message }
+                }
                 WpServiceError::SiteNotFound => FetchError::Database {
                     err_message: "Site not found".to_string(),
                 },
@@ -441,13 +447,17 @@ impl PostService {
 
         // 3. Store metadata in database
         let store_result = if is_refresh {
-            self.metadata_service.set_items(key, &metadata_result.metadata)
+            self.metadata_service
+                .set_items(key, &metadata_result.metadata)
         } else {
-            self.metadata_service.append_items(key, &metadata_result.metadata)
+            self.metadata_service
+                .append_items(key, &metadata_result.metadata)
         };
 
         if let Err(e) = store_result {
-            let _ = self.metadata_service.complete_sync_with_error(key, &e.to_string());
+            let _ = self
+                .metadata_service
+                .complete_sync_with_error(key, &e.to_string());
             return Err(FetchError::Database {
                 err_message: e.to_string(),
             });
@@ -550,14 +560,17 @@ impl PostService {
 
         // Convert to raw IDs and filter out already-fetching
         let raw_ids: Vec<i64> = ids.iter().map(|id| id.0).collect();
-        let fetchable = self.state_store_with_edit_context.filter_fetchable(&raw_ids);
+        let fetchable = self
+            .state_store_with_edit_context
+            .filter_fetchable(&raw_ids);
 
         if fetchable.is_empty() {
             return Ok(Vec::new());
         }
 
         // Mark as fetching
-        self.state_store_with_edit_context.set_batch(&fetchable, EntityState::Fetching);
+        self.state_store_with_edit_context
+            .set_batch(&fetchable, EntityState::Fetching);
 
         // Convert back to PostId for the API call
         let post_ids: Vec<PostId> = fetchable.iter().map(|&id| PostId(id)).collect();
@@ -593,10 +606,11 @@ impl PostService {
                         .data
                         .iter()
                         .map(|post| {
-                            repo.upsert(conn, &self.db_site, post)
-                                .map_err(|e| FetchError::Database {
+                            repo.upsert(conn, &self.db_site, post).map_err(|e| {
+                                FetchError::Database {
                                     err_message: e.to_string(),
-                                })
+                                }
+                            })
                         })
                         .collect::<Result<Vec<_>, _>>()
                 })?;
diff --git a/wp_mobile/src/sync/metadata_collection.rs b/wp_mobile/src/sync/metadata_collection.rs
@@ -288,7 +288,9 @@ where
             .unwrap_or_else(|| "?".to_string());
         println!(
             "[MetadataCollection] Fetched metadata: page {} of {}, {} items",
-            next_page, total_pages_str, result.metadata.len()
+            next_page,
+            total_pages_str,
+            result.metadata.len()
         );
 
         {
diff --git a/wp_mobile/src/sync/sync_result.rs b/wp_mobile/src/sync/sync_result.rs
@@ -41,7 +41,12 @@ impl SyncResult {
     }
 
     /// Create a result indicating no sync was needed.
-    pub fn no_op(total_items: usize, has_more_pages: bool, current_page: u32, total_pages: Option<u32>) -> Self {
+    pub fn no_op(
+        total_items: usize,
+        has_more_pages: bool,
+        current_page: u32,
+        total_pages: Option<u32>,
+    ) -> Self {
         Self {
             total_items: total_items as u64,
             fetched_count: 0,
diff --git a/wp_mobile_cache/src/repository/list_metadata.rs b/wp_mobile_cache/src/repository/list_metadata.rs
