ooodc/PicoBot
1
0
Fork 0
Code Pull Requests Activity

fix: 优先使用 topic_id 更新 todo 列表，确保与工具内存状态一致

Browse Source
This commit is contained in:
oudecheng 2026-06-12 17:25:50 +08:00
parent 4866ea9538
commit ec5ddf644a
2 changed files with 24 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/gateway/session.rs
View File

@ -131,7 +131,15 @@ impl BusToolCallEmitter {
}; };
let session_id = crate::storage::persistent_session_id(&self.channel_name, &self.chat_id); let session_id = crate::storage::persistent_session_id(&self.channel_name, &self.chat_id);
let scope_key = &session_id; // 优先用 topic_id（与 list_todos handler 和 tool 内存状态保持一致）
let scope_key = self
.metadata
.get("topic_id")
.filter(|t| !t.is_empty())
.cloned()
.unwrap_or_else(|| session_id.clone());
let topic_id = self.metadata.get("topic_id").filter(|t| !t.is_empty()).cloned();
let records: Vec<crate::storage::TodoRecord> = todos_array let records: Vec<crate::storage::TodoRecord> = todos_array
.iter() .iter()
@ -140,7 +148,7 @@ impl BusToolCallEmitter {
id: item.get("id")?.as_str()?.to_string(), id: item.get("id")?.as_str()?.to_string(),
scope_key: scope_key.clone(), scope_key: scope_key.clone(),
session_id: session_id.clone(), session_id: session_id.clone(),
topic_id: None, topic_id: topic_id.clone(),
content: item.get("content")?.as_str()?.to_string(), content: item.get("content")?.as_str()?.to_string(),
status: item.get("status")?.as_str()?.to_string(), status: item.get("status")?.as_str()?.to_string(),
priority: item.get("priority")?.as_str()?.to_string(), priority: item.get("priority")?.as_str()?.to_string(),
@ -156,7 +164,7 @@ impl BusToolCallEmitter {
"BusToolCallEmitter: persisting todo_write result" "BusToolCallEmitter: persisting todo_write result"
); );
if let Err(e) = self.store.replace_todos(scope_key, &records) { if let Err(e) = self.store.replace_todos(&scope_key, &records) {
tracing::warn!(error = %e, %scope_key, "Failed to persist todo list from BusToolCallEmitter"); tracing::warn!(error = %e, %scope_key, "Failed to persist todo list from BusToolCallEmitter");
} }
} }

17
web/src/App.tsx
View File

@ -332,11 +332,20 @@ function App() {
const skillCmd = requestSkillList() const skillCmd = requestSkillList()
handleCommand(skillCmd) handleCommand(skillCmd)
sendMessage({ type: 'command', payload: JSON.stringify(skillCmd) }) sendMessage({ type: 'command', payload: JSON.stringify(skillCmd) })
const todoCmd = requestTodoList()
handleCommand(todoCmd)
sendMessage({ type: 'command', payload: JSON.stringify(todoCmd) })
} }
}, [status, handleCommand, sendMessage, requestMemoryList, requestSkillList, requestTodoList]) }, [status, handleCommand, sendMessage, requestMemoryList, requestSkillList])
// 连接就绪、切换 topic、或进出子代理视图时刷新 todo 列表
const prevTodoTriggerRef = useRef<string>('')
useEffect(() => {
if (status !== 'connected') return
const key = `${selectedTopic ?? ''}|${subAgentView?.taskId ?? ''}`
if (key === prevTodoTriggerRef.current) return
prevTodoTriggerRef.current = key
const todoCmd = requestTodoList()
handleCommand(todoCmd)
sendMessage({ type: 'command', payload: JSON.stringify(todoCmd) })
}, [status, selectedTopic, subAgentView, handleCommand, sendMessage, requestTodoList])
const handleRefreshMemories = useCallback(() => { const handleRefreshMemories = useCallback(() => {
const cmd = requestMemoryList() const cmd = requestMemoryList()