fix: saveToDB 改为同步写,防止进程被杀时消息丢失
This commit is contained in:
@@ -67,9 +67,9 @@ func (cs *ConversationStore) AddMessage(sessionID string, msg model.LLMMessage)
|
|||||||
}
|
}
|
||||||
cs.messages[sessionID] = msgs
|
cs.messages[sessionID] = msgs
|
||||||
|
|
||||||
// 异步写 DB 确保重启后上下文不丢失
|
// 同步写 DB 确保进程被杀前消息已持久化
|
||||||
if cs.databaseURL != "" {
|
if cs.databaseURL != "" {
|
||||||
go cs.saveToDB(sessionID, msg)
|
cs.saveToDB(sessionID, msg)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user