DBT/clawgo
1
0
Fork 0
mirror of https://github.com/YspCoder/clawgo.git synced 2026-05-06 16:57:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

memory: append daily work summary entries after each completed response

Browse Source
This commit is contained in:
DBT
2026-02-27 06:01:50 +00:00
parent 5f1588450c
commit 7bb2ad86ec
1 changed files with 28 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
pkg/agent/loop.go
View File

@@ -742,9 +742,37 @@ func (al *AgentLoop) processMessage(ctx context.Context, msg bus.InboundMessage)
"user_length": len(userContent), "user_length": len(userContent),
}) })
al.appendDailySummaryLog(msg, userContent)
return userContent, nil return userContent, nil
} }
func (al *AgentLoop) appendDailySummaryLog(msg bus.InboundMessage, response string) {
if strings.TrimSpace(al.workspace) == "" {
return
}
userText := strings.TrimSpace(msg.Content)
respText := strings.TrimSpace(response)
if userText == "" && respText == "" {
return
}
// Avoid noisy heartbeat/system boilerplate.
lc := strings.ToLower(userText)
if strings.Contains(lc, "heartbeat") && strings.Contains(strings.ToLower(respText), "heartbeat_ok") {
return
}
ms := NewMemoryStore(al.workspace)
line := fmt.Sprintf("- [%s] channel=%s session=%s\n - user: %s\n - result: %s",
time.Now().Format("15:04"),
strings.TrimSpace(msg.Channel),
strings.TrimSpace(msg.SessionKey),
truncate(strings.ReplaceAll(userText, "\n", " "), 180),
truncate(strings.ReplaceAll(respText, "\n", " "), 220),
)
if err := ms.AppendToday(line); err != nil {
logger.WarnCF("agent", "append daily summary log failed", map[string]interface{}{logger.FieldError: err.Error()})
}
}
func (al *AgentLoop) updateIntentHint(sessionKey, content string) { func (al *AgentLoop) updateIntentHint(sessionKey, content string) {
content = strings.TrimSpace(content) content = strings.TrimSpace(content)
if sessionKey == "" || content == "" { if sessionKey == "" || content == "" {