From 3943075a9b2fd0e7e0b3a03b711d4f4873010959 Mon Sep 17 00:00:00 2001
From: Accusys <accusys@momentry.dev>
Date: Thu, 2 Jul 2026 17:08:50 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20ASRX=20pre=5Fchunks=20=E4=BD=BF=E7=94=A8?=
 =?UTF-8?q?=E6=AD=A3=E7=A2=BA=E7=9A=84=20start=5Fframe?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- pipeline/mod.rs: 使用 segment.start_frame 取代 i (sequential index)
- data JSON 加入 end_time, start_frame, end_frame 供 rule1_ingest 使用
- 確保 ASRX pre_chunks 有正確的 frame 資訊
---
 src/core/pipeline/mod.rs | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/core/pipeline/mod.rs b/src/core/pipeline/mod.rs
index ef71cd0..36d5384 100644
--- a/src/core/pipeline/mod.rs
+++ b/src/core/pipeline/mod.rs
@@ -29,8 +29,11 @@ pub async fn store_asrx_chunks(db: &PostgresDb, uuid: &str) -> Result<()> {
             "text": segment.text,
             "speaker_id": segment.speaker_id,
             "timestamp": segment.start_time,
+            "end_time": segment.end_time,
+            "start_frame": segment.start_frame,
+            "end_frame": segment.end_frame,
         });
-        pre_chunks.push((i as i64, Some(segment.start_time), data, None, None));
+        pre_chunks.push((segment.start_frame as i64, Some(segment.start_time), data, None, None));
         speaker_detections.push((
             segment.speaker_id.clone().unwrap_or_default(),
             segment.start_time,