sync: Add aligned stream progress display

Replace timestamped stderr progress lines with aligned per-stream indicatif
rows for concurrent sync visibility. Keep the reporter contract sync-owned and
generic, provide a no-op JSON path, support non-TTY and NO_COLOR output, and finalize successful runs explicitly. Remove repository and source-instance
identifiers from sync payloads and update documentation and tests.

Co-authored-by: SCE <sce@crocoder.dev>

Author: stefanskoricdev

cli/Cargo.lock

@@ -34,6 +34,7 @@ clap_complete = "4"
 dirs = "6"
 hmac = "0.13"
 inquire = "0.9"
+indicatif = "0.18"
 jsonschema = "0.46"
 keyring-core = "1"
 owo-colors = { version = "4", features = ["supports-colors"] }

cli/Cargo.toml

@@ -46,6 +46,10 @@ where
     style_if(text, supports_color_stderr(), f)
 }
 
+pub(crate) fn success_with_stderr_color_policy(text: &str, color_enabled: bool) -> String {
+    style_if(text, color_enabled, |s| s.green().bold().to_string())
+}
+
 #[must_use]
 pub fn heading(text: &str) -> String {
     heading_with_color_policy(text, supports_color())

cli/src/services/style.rs

@@ -2,10 +2,13 @@ use std::io::Write;
 
 use crate::app::ContextWithRepoRoot;
 use crate::services::error::ClassifiedError;
+use crate::services::sync::progress::{
+    IndicatifProgressReporter, NoopProgressReporter, ProgressReporter,
+};
 use crate::services::sync::render_sync;
 use crate::services::sync::sync::{
-    run_current_sync_with_progress_and_clock, NoopSyncProgressSink, SyncProgressClock,
-    SyncProgressEvent, SyncProgressSink, SystemSyncProgressClock, TraceSyncError,
+    run_current_sync_with_progress_and_clock, SyncProgressClock, SystemSyncProgressClock,
+    TraceSyncError,
 };
 use crate::services::sync::SyncRequest;
 
@@ -31,61 +34,6 @@ fn classify_sync_error(err: TraceSyncError) -> ClassifiedError {
     ClassifiedError::runtime(format!("{err}"))
 }
 
-struct StderrSyncProgressReporter<'a, W> {
-    writer: &'a mut W,
-}
-
-impl<'a, W> StderrSyncProgressReporter<'a, W> {
-    fn new(writer: &'a mut W) -> Self {
-        Self { writer }
-    }
-}
-
-impl<W> SyncProgressSink for StderrSyncProgressReporter<'_, W>
-where
-    W: Write,
-{
-    fn report(&mut self, event: SyncProgressEvent) {
-        let _ = writeln!(self.writer, "{}", format_progress_event(&event));
-        let _ = self.writer.flush();
-    }
-}
-
-fn format_progress_event(event: &SyncProgressEvent) -> String {
-    match event {
-        SyncProgressEvent::Started { timestamp } => {
-            format!("Starting Agent Trace sync at {timestamp}...")
-        }
-        SyncProgressEvent::BatchAccepted {
-            stream,
-            batch_rows,
-            uploaded,
-            cursor,
-        } => format!(
-            "{stream}: uploaded batch of {batch_rows} rows ({uploaded} total, cursor {cursor})"
-        ),
-        SyncProgressEvent::StreamCompleted {
-            stream,
-            uploaded,
-            cursor,
-            batches,
-        } if *batches == 0 => {
-            format!("{stream}: complete - no new rows uploaded (cursor {cursor})")
-        }
-        SyncProgressEvent::StreamCompleted {
-            stream,
-            uploaded,
-            cursor,
-            batches,
-        } => format!(
-            "{stream}: complete - {uploaded} rows uploaded in {batches} batches (cursor {cursor})"
-        ),
-        SyncProgressEvent::Finished { timestamp } => {
-            format!("Agent Trace sync finished at {timestamp}.")
-        }
-    }
-}
-
 impl SyncCommand {
     #[allow(dead_code)]
     pub fn execute<C>(&self, context: &C) -> Result<String, ClassifiedError>
@@ -124,11 +72,16 @@ impl SyncCommand {
 
         let report = match self.request.format {
             crate::services::output_format::OutputFormat::Text => {
-                let mut progress = StderrSyncProgressReporter::new(stderr);
-                run_current_sync_with_progress_and_clock(&repo_root, &mut progress, clock)
+                let mut progress = IndicatifProgressReporter::new(stderr);
+                let result =
+                    run_current_sync_with_progress_and_clock(&repo_root, &mut progress, clock);
+                if result.is_ok() {
+                    progress.finish_successfully();
+                }
+                result
             }
             crate::services::output_format::OutputFormat::Json => {
-                let mut progress = NoopSyncProgressSink;
+                let mut progress = NoopProgressReporter;
                 run_current_sync_with_progress_and_clock(&repo_root, &mut progress, clock)
             }
         }
@@ -138,38 +91,3 @@ impl SyncCommand {
             .map_err(|error| ClassifiedError::runtime(format!("{error:#}")))
     }
 }
-
-#[cfg(test)]
-mod tests {
-    use super::*;
-
-    #[test]
-    fn progress_reporter_writes_deterministic_text_lines_and_flushes_each_event() {
-        let mut output = Vec::new();
-        let mut reporter = StderrSyncProgressReporter::new(&mut output);
-
-        reporter.report(SyncProgressEvent::Started {
-            timestamp: "2026-01-02T03:04:05Z".to_string(),
-        });
-        reporter.report(SyncProgressEvent::BatchAccepted {
-            stream: "messages",
-            batch_rows: 500,
-            uploaded: 500,
-            cursor: 500,
-        });
-        reporter.report(SyncProgressEvent::StreamCompleted {
-            stream: "parts",
-            uploaded: 0,
-            cursor: 12,
-            batches: 0,
-        });
-        reporter.report(SyncProgressEvent::Finished {
-            timestamp: "2026-01-02T03:04:06Z".to_string(),
-        });
-
-        assert_eq!(
-            String::from_utf8(output).expect("progress output should be UTF-8"),
-            "Starting Agent Trace sync at 2026-01-02T03:04:05Z...\nmessages: uploaded batch of 500 rows (500 total, cursor 500)\nparts: complete - no new rows uploaded (cursor 12)\nAgent Trace sync finished at 2026-01-02T03:04:06Z.\n"
-        );
-    }
-}

cli/src/services/sync/command.rs

@@ -1,7 +1,9 @@
 //! Top-level `sce sync` command and Agent Trace synchronization service.
 
 pub mod command;
+pub mod progress;
 pub mod render_sync;
+#[allow(clippy::module_inception)]
 pub mod sync;
 
 pub const NAME: &str = "sync";