feat(live-session): 暂停边沿收敛与漏边沿补偿（no-rescore 断句+合成事件对+边界切断）

Author: Aparencia

app/src-tauri/src/commands_live.rs

@@ -28,6 +28,9 @@ pub struct LiveSessionStatus {
     /// 2026-08 修复：是否处于暂停（挂载拉取恢复右侧面板状态机用——
     /// recording 事件只发一次，刷新/重进页面后需靠此字段还原 phase）
     pub paused: bool,
+    /// 批 2a：暂停来源（kebab-case：manual/media/foreground；paused=false 恒
+    /// None——前端据此显示暂停原因与恢复语义，自动暂停可提示"视频仍暂停"）
+    pub paused_reason: Option<String>,
     /// v0.9.0 M2（REQ-189）：当前生效画面档（kebab-case；None=未定档——
     /// 前端面板挂载拉取兑底，tier-changed 事件可能早于监听注册）
     pub tier: Option<String>,
@@ -199,6 +202,8 @@ pub fn live_session_status(state: State<'_, AppState>) -> LiveSessionStatus {
             crate::live_session_prepare::PrepareStatus::Ready
         ),
         paused: state.live_session.is_paused(),
+        // 批 2a：暂停来源（None=未暂停）
+        paused_reason: state.live_session.paused_reason(),
         // v0.9.0 M2（REQ-189）：当前生效画面档（None=未定档/未激活）
         tier: state.live_session.applied_tier().map(|t| t.as_str().to_string()),
     }
@@ -258,17 +263,19 @@ pub fn release_live_prepare(state: State<'_, AppState>) -> Result<(), String> {
     state.live_session.release_prepare().map_err(|e| e.to_string())
 }
 
-/// 暂停实时会话（2026-08 A1 硬暂停：完全停采，时间轴冻结）。
+/// 暂停实时会话（2026-08 A1 硬暂停：完全停采，时间轴冻结；批 2a 经 request
+/// API 锁存 Manual 来源——reason=manual）。
 ///
-/// @ai-context: 只置共享标志——实际暂停由捕获线程边沿检测执行（WASAPI 端点
-///              Stop + 暂停时长累计），会话线程发出 live:paused 事件与落库；
-///              无活动会话/已暂停 → 明确报错（幂等拒绝）。
+/// @ai-context: request 只落共享状态——实际暂停由捕获线程边沿检测执行（WASAPI
+///              端点 Stop + 暂停时长累计），会话线程发出 live:paused 事件与落库
+///              （载荷带 reason）；无活动会话/已暂停 → 明确报错（幂等拒绝）。
 #[tauri::command]
 pub fn pause_live_session(state: State<'_, AppState>) -> Result<(), String> {
     state.live_session.pause().map_err(|e| e.to_string())
 }
 
-/// 恢复暂停的实时会话（2026-08 A1；未暂停 → 明确报错）。
+/// 恢复暂停的实时会话（2026-08 A1；批 2a Release(Manual)——manual 解除瞬间
+/// 重评估 auto 条件仍真则对应源自动重暂停；未暂停 → 明确报错）。
 #[tauri::command]
 pub fn resume_live_session(state: State<'_, AppState>) -> Result<(), String> {
     state.live_session.resume().map_err(|e| e.to_string())

app/src-tauri/src/lib.rs

@@ -372,6 +372,8 @@ mod live_session_lifecycle;
 #[cfg(target_os = "windows")]
 mod pause_state;
 #[cfg(target_os = "windows")]
+mod live_session_pause;
+#[cfg(target_os = "windows")]
 mod live_keyframes;
 mod load_monitor;
 // v0.7.0 M1（REQ-106，TRUST-4）：诊断日志脱敏（OCR 文本/会话标题等敏感内容过滤）

app/src-tauri/src/live_session_loop.rs

@@ -73,7 +73,7 @@ pub(crate) struct LiveLoopCtx<'a> {
 pub(crate) fn run_audio_loop(
     rx: mpsc::Receiver<AudioChunk>,
     mut audio: crate::capture::AudioLoopbackCapture,
-    ctx: LiveLoopCtx<'_>,
+    mut ctx: LiveLoopCtx<'_>,
     data_dir: &std::path::Path,
 ) {
     let mut asr_health = crate::asr_health::AsrHealthMonitor::new();
@@ -124,70 +124,28 @@ pub(crate) fn run_audio_loop(
     // deadline 早已过期，宽限从未生效；改为 draining 置位时才起算（Option<Instant>）
     let mut drain_deadline: Option<Instant> = None;
     let mut draining = false;
-    // 2026-08 A1：暂停边沿跟踪（false→true 断句隔离；暂停期捕获线程停采，
-    // channel 空 → recv_timeout 空转，无需显式消费处理）
-    let mut loop_paused = ctx.pause.paused.load(Ordering::SeqCst);
+    // 批 2a：暂停边沿收敛域（live_session_pause.rs）——可见边沿 flush_no_rescore
+    // 断句 + seq 漏边沿代数补偿 + 合成事件对；本循环只留编排调用。
+    // @ai-context: 暂停期捕获线程停采 → channel 空 → recv_timeout 空转，无需显式消费
+    let mut pause_view = crate::live_session_pause::PauseEdgeView::new(ctx.pause);
     loop {
-        // ── 暂停边沿（2026-08 A1）──
+        // ── 暂停边沿（批 2a：检测+应用收敛于 live_session_pause.rs）──
         // @ai-context: 时间戳 = 会话时间（epoch - 已补偿暂停时长）——暂停开始
         //              时补偿尚未累计（正确，时间轴冻结点）；恢复时补偿已更新
         //              （时间戳回到冻结点附近，时间轴无缝衔接）。
-        let paused_now = ctx.pause.paused.load(Ordering::SeqCst);
-        if paused_now != loop_paused {
-            let now_ms = ctx.epoch.elapsed().as_millis() as u64
-                - ctx.pause.total_paused_ms.load(Ordering::SeqCst);
-            if paused_now {
-                // 进入暂停（P2 增强：替代"喂 100ms 静音"方案——静音块不足以触发
-                // sherpa 端点规则（rule1 需 2.4s 尾静音），句无法断开；flush 尾句
-                // 落库 + reset 重建流才能保证暂停前后的语音不连句，恢复后干净开始）
-                // REQ-154（v0.7.2 S-1）：动态合并阈值先算（借用释放后再构造 ctx）
-                let merge_gap_ms = crate::asr_merge::adaptive_merge_gap(
-                    pause_history.iter().copied(),
-                );
-                flush_tail_and_persist(
-                    FinalEventCtx {
-                        app: ctx.app,
-                        db: ctx.db,
-                        session_id: ctx.session_id,
-                        asr_segments: ctx.asr_segments,
-                        sentence_start_ms: &mut sentence_start_ms,
-                        last_speech_ms: &mut last_speech_ms,
-                        last_final_clean: &mut last_final_clean,
-                        pending_merge: &mut pending_merge,
-                        last_segment_end: &mut last_segment_end,
-                        // REQ-154（v0.7.2 S-1/S-2）：停顿历史/动态阈值/语速基准
-                        pause_history: &mut pause_history,
-                        merge_gap_ms,
-                        last_speech_rate: &mut last_speech_rate,
-                    },
-                    ctx.asr_engine,
-                    now_ms,
-                    &mut sentence_rms_sum,
-                    &mut sentence_rms_count,
-                );
-                // 重建流（reset 预留给复用场景：清句音频/状态，热词重读）
-                ctx.asr_engine.reset();
-                // REQ-154（v0.7.2 S-2）：暂停边沿重置语速基准——恢复后首段与
-                // 暂停前比较会跨暂停区间误判语速骤变（暂停时长不计入段间）
-                last_speech_rate = None;
-                let _ = ctx.db.add_event(&crate::session_events::NewSessionEvent::simple(
-                    ctx.session_id,
-                    crate::session_events::EventKind::Pause,
-                    now_ms,
-                ));
-                let _ = ctx.app.emit("live:paused", ());
-                eprintln!("[LiveSession] 会话 {} 暂停 @{}ms", ctx.session_id, now_ms);
-            } else {
-                let _ = ctx.db.add_event(&crate::session_events::NewSessionEvent::simple(
-                    ctx.session_id,
-                    crate::session_events::EventKind::Resume,
-                    now_ms,
-                ));
-                let _ = ctx.app.emit("live:resumed", ());
-                eprintln!("[LiveSession] 会话 {} 恢复 @{}ms", ctx.session_id, now_ms);
-            }
-            loop_paused = paused_now;
-        }
+        crate::live_session_pause::detect_and_apply_pause_edges(
+            &mut pause_view,
+            &mut ctx,
+            &mut sentence_start_ms,
+            &mut last_speech_ms,
+            &mut last_final_clean,
+            &mut pending_merge,
+            &mut last_segment_end,
+            &mut pause_history,
+            &mut last_speech_rate,
+            &mut sentence_rms_sum,
+            &mut sentence_rms_count,
+        );
         // H1 修复：deadline 在 draining 置位时才起算（见声明处注释），此处
         // 仅在已置位的情况下判定到期；None 表示尚未进入 drain 阶段
         if draining
@@ -423,6 +381,8 @@ pub(crate) fn run_audio_loop(
         stop_now_ms,
         &mut sentence_rms_sum,
         &mut sentence_rms_count,
+        // 停止路径保留 SenseVoice 重打分（与端点同质量兜底；暂停边沿才跳过）
+        true,
     );
     audio.stop();
 

app/src-tauri/src/live_session_manager.rs

@@ -39,6 +39,11 @@ impl LiveSessionManager {
         self.pause.paused.load(Ordering::SeqCst)
     }
 
+    /// 暂停来源（批 2a：status 查询下发——paused=false 恒 None）。
+    pub fn paused_reason(&self) -> Option<String> {
+        self.pause.paused_reason().map(|s| s.as_str().to_string())
+    }
+
     /// 画面档降档确认共享状态句柄（command 层组装 LiveSessionParams 时获取；
     /// v0.9.0 M2 REQ-189——前端确认降档后写入，worker 消费）。
     pub fn tier_override(&self) -> std::sync::Arc<std::sync::Mutex<Option<crate::video_profile_spec::VisualTier>>> {
@@ -99,33 +104,57 @@ impl LiveSessionManager {
         self.applied_profile.clone()
     }
 
-    /// 暂停活动会话（2026-08 A1 硬暂停：完全停采）。
+    /// 暂停活动会话（2026-08 A1 硬暂停：完全停采；批 2a 改经 request API——
+    /// Manual 来源锁存，reason 由此推导）。
     ///
-    /// @ai-context: 只置共享标志——实际暂停由捕获线程边沿检测执行
+    /// @ai-context: request 只落共享状态——实际暂停由捕获线程边沿检测执行
     ///              （WASAPI 端点 Stop）并累计补偿时长；事件/落库由会话
     ///              线程边沿检测发出（保证与真实暂停时序一致）。
-    /// @ai-context: 无活动会话/已暂停 → 明确报错（幂等拒绝）。
+    /// @ai-context: 守卫（文案与锁纪律不变）：无活动会话/已暂停 → 明确报错
+    ///              （幂等拒绝；自动暂停期按已暂停拒绝——手动接管留 2b UI
+    ///              层按 paused_reason 决策）。
     pub fn pause(&self) -> Result<()> {
         let guard = self.active.lock().expect("live session lock poisoned");
         if guard.is_none() {
             return Err(AppError::Io("无活动实时会话".to_string()));
         }
-        if self.pause.paused.swap(true, Ordering::SeqCst) {
+        if self.is_paused() {
+            // 先查后请求：Err 路径不得锁存 Manual（幂等拒绝，与旧 swap 语义一致）
             return Err(AppError::Io("会话已处于暂停".to_string()));
         }
-        Ok(())
+        use crate::pause_state::{PauseOutcome, PauseRequest, PauseSource};
+        match self.pause.request(PauseRequest::Pause(PauseSource::Manual)) {
+            PauseOutcome::Paused => Ok(()),
+            // 理论不可达（先查未暂停）——防御：不静默
+            _ => Err(AppError::Io("会话已处于暂停".to_string())),
+        }
     }
 
-    /// 恢复暂停的会话（2026-08 A1；未暂停 → 明确报错）。
+    /// 恢复暂停的会话（2026-08 A1；批 2a 改经 request API——Release(Manual)）。
+    ///
+    /// @ai-context: 单状态机语义：manual 解除瞬间重评估 auto 条件（媒体/前台
+    ///              锁存仍真 → 对应源自动重暂停——pause_state 模块头真值表）；
+    ///              自动暂停期按手动恢复请求：无 manual 锁存可释放 → Ok 但
+    ///              paused 保持（物理无变化，条件由 worker 检测器自行解除），
+    ///              前端以 paused_reason 感知。
     pub fn resume(&self) -> Result<()> {
         let guard = self.active.lock().expect("live session lock poisoned");
         if guard.is_none() {
             return Err(AppError::Io("无活动实时会话".to_string()));
         }
-        if !self.pause.paused.swap(false, Ordering::SeqCst) {
-            return Err(AppError::Io("会话未处于暂停".to_string()));
+        use crate::pause_state::{PauseOutcome, PauseRequest, PauseSource};
+        match self.pause.request(PauseRequest::Release(PauseSource::Manual)) {
+            PauseOutcome::Resumed => Ok(()),
+            PauseOutcome::StillHeld => {
+                // auto 条件仍持暂停（manual 解除瞬间重评估）——如实记录可观测
+                eprintln!("[LiveSession] 手动恢复但自动暂停条件仍持（reason={:?}）", self.pause.reason());
+                Ok(())
+            }
+            PauseOutcome::NotPaused => Err(AppError::Io("会话未处于暂停".to_string())),
+            PauseOutcome::Paused | PauseOutcome::AlreadyPaused => {
+                Err(AppError::Io("会话未处于暂停".to_string()))
+            }
         }
-        Ok(())
     }
 
     /// 停止活动会话（有界等待线程退出，返回其会话 id）。