From d9f1376beb1593a73fd096175de7f01de1cda372 Mon Sep 17 00:00:00 2001
From: Linghong <ink29535@proton.me>
Date: Sun, 13 Sep 2026 07:34:12 +0000
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=BC=BA=E7=AD=96=E5=88=92Agent?=
 =?UTF-8?q?=E6=B5=81=E5=BC=8F=E8=B0=83=E8=AF=95=E8=AE=B0=E5=BD=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

记录流式事件时间、序号、增量与累计文本长度及结束原因

扩大异步调试队列容量，保持调试写入不阻塞正常运行
---
 .../src-tauri/src/agent/design_runtime.rs     | 20 ++++++++++++++++++-
 1 file changed, 19 insertions(+), 1 deletion(-)

diff --git a/apps/ai-game-creator-shell/src-tauri/src/agent/design_runtime.rs b/apps/ai-game-creator-shell/src-tauri/src/agent/design_runtime.rs
index a8bb580e9..959081636 100644
--- a/apps/ai-game-creator-shell/src-tauri/src/agent/design_runtime.rs
+++ b/apps/ai-game-creator-shell/src-tauri/src/agent/design_runtime.rs
@@ -473,7 +473,7 @@ fn design_debug(root: &Path, kind: &str, data: Value) {
     type Entry = (PathBuf, Value);
     static QUEUE: OnceLock<std::sync::mpsc::SyncSender<Entry>> = OnceLock::new();
     let sender = QUEUE.get_or_init(|| {
-        let (sender, receiver) = std::sync::mpsc::sync_channel::<Entry>(16);
+        let (sender, receiver) = std::sync::mpsc::sync_channel::<Entry>(256);
         let _ = std::thread::Builder::new()
             .name("design-debug".into())
             .spawn(move || {
@@ -546,8 +546,26 @@ async fn request_design_provider(
             None,
         ));
         let result = if llm.stream {
+            let mut stream_sequence = 0_u64;
             client
                 .stream_run(request.clone(), |delta| {
+                    stream_sequence = stream_sequence.saturating_add(1);
+                    design_debug(
+                        root,
+                        "stream",
+                        json!({
+                            "turnId": turn_id,
+                            "requestIndex": session.turn.as_ref().map(|turn| turn.request_index),
+                            "attempt": attempt,
+                            "sequence": stream_sequence,
+                            "occurredAtUnixNanos": unix_timestamp_nanos().to_string(),
+                            "model": llm.model,
+                            "deltaChars": delta.delta_text.chars().count(),
+                            "accumulatedChars": delta.accumulated_text.chars().count(),
+                            "deltaText": delta.delta_text,
+                            "finishReason": delta.finish_reason,
+                        }),
+                    );
                     emit(design_event(
                         root,
                         &turn_id,