feat(sync): add --chat filter to sync msgs

Author: dgrr

src/app/sync.rs

@@ -40,6 +40,8 @@ pub struct SyncOptions {
     pub incremental: bool,
     pub messages_per_chat: usize,
     pub concurrency: usize,
+    /// If set, only sync this specific chat
+    pub chat_filter: Option<i64>,
 }
 
 /// Get media type string and file extension from grammers Media enum
@@ -603,9 +605,16 @@ impl App {
         let all_chats = self.store.list_chats_with_checkpoint().await?;
 
         // Filter chats to process
+        let chat_filter = opts.chat_filter;
         let chats_to_sync: Vec<_> = all_chats
             .into_iter()
             .filter(|chat| {
+                // If chat_filter is set, only include that specific chat
+                if let Some(filter_id) = chat_filter {
+                    if chat.id != filter_id {
+                        return false;
+                    }
+                }
                 if ignore_set.contains(&chat.id) {
                     return false;
                 }

src/cmd/daemon.rs

@@ -214,6 +214,7 @@ pub async fn run(cli: &Cli, args: &DaemonArgs) -> Result<()> {
                 incremental: true,
                 messages_per_chat: 50,
                 concurrency: 4,
+                chat_filter: None,
             };
 
             let result = backfill_app.sync(opts).await;

src/cmd/sync.rs

@@ -59,6 +59,10 @@ pub enum SyncCommand {
     Msgs {
         #[command(flatten)]
         common: CommonSyncArgs,
+
+        /// Sync only this specific chat (by chat ID)
+        #[arg(long, value_name = "CHAT_ID")]
+        chat: Option<i64>,
     },
 }
 
@@ -97,6 +101,7 @@ fn build_sync_options(common: &CommonSyncArgs) -> crate::app::sync::SyncOptions
         incremental: true, // Always incremental
         messages_per_chat: common.messages_per_chat,
         concurrency: common.concurrency,
+        chat_filter: None,
     }
 }
 
@@ -188,10 +193,11 @@ pub async fn run(cli: &Cli, args: &SyncArgs) -> Result<()> {
             let result = app.sync_chats(opts).await?;
             print_sync_result(common, &result, "chats-only");
         }
-        Some(SyncCommand::Msgs { common }) => {
+        Some(SyncCommand::Msgs { common, chat }) => {
             // Sync messages only from local chats (uses stored access_hash, no iter_dialogs)
             let mut app = App::new(cli).await?;
-            let opts = build_sync_options(common);
+            let mut opts = build_sync_options(common);
+            opts.chat_filter = *chat;
             let result = app.sync_msgs(opts).await?;
             print_sync_result(common, &result, "msgs-only");
         }