diff --git a/src-tauri/src/commands/ai/agentic/mod.rs b/src-tauri/src/commands/ai/agentic/mod.rs index 25292ae..d3c8ee0 100644 --- a/src-tauri/src/commands/ai/agentic/mod.rs +++ b/src-tauri/src/commands/ai/agentic/mod.rs @@ -1722,13 +1722,22 @@ async fn count_recent_failures( .unwrap_or((0u32, String::new())) } -// ── is_failure_content: 失败判定(禁止/跳过重试/失败/Error 关键词) ── +// ── is_failure_content: 纯结构化判定(只读字段,绝不解析内容文本) ── +// 原理:工具成败是执行层的结构化事实(exit_code / status),断路器只读字段。内容文本(无论含 +// error/失败/任何词)绝不参与判定 —— 这样读含 error 字样的代码、搜"失败"的结果等成功工具内容 +// 永远不会被判失败(根除 conv 09e7abfa 的误熔断)。 +// 失败 content 由 audit/mod.rs 包成 JSON envelope {"status":"failed","error":...}; +// 成功 content 是 result JSON(run_command 含 exit_code,其他工具无 status 字段即成功)或 namespace:// 占位符。 +// 非 JSON(namespace 占位符 / 重试 guard skip 纯文本)→ 无结构化失败信号 → 不判(false)。 fn is_failure_content(content: &str) -> bool { - content.starts_with("禁止") - || content.starts_with("已跳过重试") - || content.contains("失败") - || content.contains("Error") - || content.contains("error") + let Ok(v) = serde_json::from_str::(content) else { + return false; // namespace:// 占位符 / 重试 guard skip 等 → 无结构化失败信号,不判 + }; + if let Some(exit) = v.get("exit_code").and_then(|x| x.as_i64()) { + return exit != 0; // run_command 等:非零退出 = 真失败 + } + matches!(v.get("status").and_then(|s| s.as_str()), Some("failed") | Some("error")) + || v.get("error").is_some() } // ── summarize_tool_results: tool_result view-only 摘要压缩(扁平抽自原嵌套 map 块) ── diff --git a/src-tauri/src/commands/ai/audit/mod.rs b/src-tauri/src/commands/ai/audit/mod.rs index 9c185ff..8e84d80 100644 --- a/src-tauri/src/commands/ai/audit/mod.rs +++ b/src-tauri/src/commands/ai/audit/mod.rs @@ -503,7 +503,12 @@ pub(crate) async fn process_tool_calls( { let mut session = session_arc.lock().await; // T2: 大工具结果进 namespace - let msg_content = if df_ai::namespace_store::should_use_namespace(&content, &draft.name) { + // 失败包结构化 envelope {"status":"failed","error":...}:让断路器按 status 判 + // (不解析内容文本,理论可靠)。emit 给前端的 result 与 audit 仍用原 err_msg 纯文本 + // (前端卡片/审计可读,与断路器信号解耦)。 + let msg_content = if status == "failed" { + serde_json::json!({"status":"failed","error":&content}).to_string() + } else if df_ai::namespace_store::should_use_namespace(&content, &draft.name) { session.namespace_store.store(&draft.name, &content) } else { content.clone() @@ -622,7 +627,12 @@ pub(crate) async fn process_tool_calls( { let mut session = session_arc.lock().await; // T2: 大工具结果进 namespace,主队列只留引用 - let msg_content = if df_ai::namespace_store::should_use_namespace(&content, &draft.name) { + // 失败包结构化 envelope {"status":"failed","error":...}:让断路器按 status 判 + // (不解析内容文本,理论可靠)。emit 给前端的 result 与 audit 仍用原 err_msg 纯文本 + // (前端卡片/审计可读,与断路器信号解耦)。 + let msg_content = if status == "failed" { + serde_json::json!({"status":"failed","error":&content}).to_string() + } else if df_ai::namespace_store::should_use_namespace(&content, &draft.name) { session.namespace_store.store(&draft.name, &content) } else { content.clone()