From a4b2b9a292bbb44847d857bc69d470d8906becf4 Mon Sep 17 00:00:00 2001
From: iamdoubz <>
Date: Sat, 11 Jul 2026 08:42:25 -0500
Subject: [PATCH] feat(transcription): drive live worker with StreamTuning;
 store only committed segments

---
 src-tauri/src/commands.rs | 19 ++++++++++++++++---
 1 file changed, 16 insertions(+), 3 deletions(-)

diff --git a/src-tauri/src/commands.rs b/src-tauri/src/commands.rs
index 977a35f..119ab03 100644
--- a/src-tauri/src/commands.rs
+++ b/src-tauri/src/commands.rs
@@ -430,6 +430,9 @@ pub async fn start_recording(
     let language_for_worker = language.clone();
     let app_for_worker = app.clone();
     let meeting_id_for_worker = meeting_id.clone();
+    // Live-transcript cadence; the low-overhead preset trades a touch of
+    // immediacy for half the decode load (see StreamTuning).
+    let stream_tuning = crate::transcription::StreamTuning::new(settings.low_overhead);
     let transcription_worker = std::thread::Builder::new()
         .name("wa-transcription".into())
         .spawn(move || {
@@ -460,9 +463,19 @@ pub async fn start_recording(
             if let Ok(mut lang) = language_state_for_worker.lock() {
                 *lang = transcriber.effective_language();
             }
-            run_streaming_worker(transcriber.as_ref(), frame_rx, |segment| {
-                if let Ok(mut buf) = segments_for_worker.lock() {
-                    buf.push(segment.clone());
+            run_streaming_worker(transcriber.as_ref(), frame_rx, stream_tuning, |segment| {
+                // Only committed lines are the real transcript; interim updates
+                // are live-UI only (emitted below). Storing interims would push
+                // a duplicate row per refresh into the buffer stop_recording and
+                // the live-diarization preview both read. A committed line's id
+                // is stable, so replace-in-place guards against any re-commit.
+                if !segment.interim {
+                    if let Ok(mut buf) = segments_for_worker.lock() {
+                        match buf.iter_mut().find(|s| s.id == segment.id) {
+                            Some(existing) => *existing = segment.clone(),
+                            None => buf.push(segment.clone()),
+                        }
+                    }
                 }
                 let _ = app_for_worker.emit(
                     "transcript://segment",