alex/LocalAGI
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Save conversations also at the end

Browse Source
This commit is contained in:
Ettore Di Giacinto
2025-03-01 22:31:49 +01:00
parent 042c1ee65c
commit e696c5ae31
1 changed files with 32 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
core/agent/agent.go
View File

@@ -168,6 +168,36 @@ func (a *Agent) askLLM(ctx context.Context, conversation []openai.ChatCompletion
return resp.Choices[0].Message, nil return resp.Choices[0].Message, nil
} }
func (a *Agent) saveCurrentConversationInMemory() {
if !a.options.enableLongTermMemory {
return
}
xlog.Info("Saving conversation", "agent", a.Character.Name, "conversation size", len(a.currentConversation))
if a.options.enableSummaryMemory && len(a.currentConversation) > 0 {
msg, err := a.askLLM(a.context.Context, []openai.ChatCompletionMessage{{
Role: "user",
Content: "Summarize the conversation below, keep the highlights as a bullet list:\n" + Messages(a.currentConversation).String(),
}})
if err != nil {
xlog.Error("Error summarizing conversation", "error", err)
}
if err := a.options.ragdb.Store(msg.Content); err != nil {
xlog.Error("Error storing into memory", "error", err)
}
} else {
for _, message := range a.currentConversation {
if message.Role == "user" {
if err := a.options.ragdb.Store(message.Content); err != nil {
xlog.Error("Error storing into memory", "error", err)
}
}
}
}
}
func (a *Agent) ResetConversation() { func (a *Agent) ResetConversation() {
a.Lock() a.Lock()
defer a.Unlock() defer a.Unlock()
@@ -177,33 +207,7 @@ func (a *Agent) ResetConversation() {
// store into memory the conversation before pruning it // store into memory the conversation before pruning it
// TODO: Shall we summarize the conversation into a bullet list of highlights // TODO: Shall we summarize the conversation into a bullet list of highlights
// using the LLM instead? // using the LLM instead?
if a.options.enableLongTermMemory { a.saveCurrentConversationInMemory()
xlog.Info("Saving conversation", "agent", a.Character.Name, "conversation size", len(a.currentConversation))
if a.options.enableSummaryMemory && len(a.currentConversation) > 0 {
msg, err := a.askLLM(a.context.Context, []openai.ChatCompletionMessage{{
Role: "user",
Content: "Summarize the conversation below, keep the highlights as a bullet list:\n" + Messages(a.currentConversation).String(),
}})
if err != nil {
xlog.Error("Error summarizing conversation", "error", err)
}
if err := a.options.ragdb.Store(msg.Content); err != nil {
xlog.Error("Error storing into memory", "error", err)
}
} else {
for _, message := range a.currentConversation {
if message.Role == "user" {
if err := a.options.ragdb.Store(message.Content); err != nil {
xlog.Error("Error storing into memory", "error", err)
}
}
}
}
}
a.currentConversation = []openai.ChatCompletionMessage{} a.currentConversation = []openai.ChatCompletionMessage{}
} }
@@ -702,6 +706,7 @@ func (a *Agent) consumeJob(job *Job, role string) {
job.Result.SetResponse(msg.Content) job.Result.SetResponse(msg.Content)
xlog.Info("Response from LLM", "response", msg.Content, "agent", a.Character.Name) xlog.Info("Response from LLM", "response", msg.Content, "agent", a.Character.Name)
job.Result.Conversation = a.currentConversation job.Result.Conversation = a.currentConversation
a.saveCurrentConversationInMemory()
job.Result.Finish(nil) job.Result.Finish(nil)
} }