Ayuriel/openclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: integrate Cortex local memory into OpenClaw

Browse Source
This commit is contained in:
Marc J Saint-jour 2026-03-12 18:41:06 -04:00
parent 0a161b96fe
commit 93f09f7d02
1 changed files with 69 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

73
src/auto-reply/reply/agent-runner.ts
View File

@ -1,5 +1,11 @@
import fs from "node:fs";
import { lookupContextTokens } from "../../agents/context.js";
import {
ingestAgentCortexMemoryCandidate,
resolveAgentCortexConflictNotice,
resolveAgentCortexModeStatus,
resolveCortexChannelTarget,
} from "../../agents/cortex.js";
import { DEFAULT_CONTEXT_TOKENS } from "../../agents/defaults.js";
import { resolveModelAuthMode } from "../../agents/model-auth.js";
import { isCliProvider } from "../../agents/model-selection.js";
@ -278,10 +284,6 @@ export async function runReplyAgent(params: {
updatedAt: Date.now(),
systemSent: false,
abortedLastRun: false,
modelProvider: undefined,
model: undefined,
contextTokens: undefined,
systemPromptReport: undefined,
fallbackNoticeSelectedModel: undefined,
fallbackNoticeActiveModel: undefined,
fallbackNoticeReason: undefined,
@ -693,6 +695,69 @@ export async function runReplyAgent(params: {
verboseNotices.push({ text: `🧹 Auto-compaction complete${suffix}.` });
}
}
const cortexAgentId =
followupRun.run.agentId ?? (sessionKey ? resolveAgentIdFromSessionKey(sessionKey) : "main");
const cortexChannelId = resolveCortexChannelTarget({
channel: followupRun.run.messageProvider,
originatingChannel: String(sessionCtx.OriginatingChannel ?? ""),
originatingTo: sessionCtx.OriginatingTo,
nativeChannelId: sessionCtx.NativeChannelId,
to: sessionCtx.To,
from: sessionCtx.From,
});
const cortexModeStatus =
verboseEnabled && cfg
? await resolveAgentCortexModeStatus({
cfg,
agentId: cortexAgentId,
sessionId: followupRun.run.sessionId,
channelId: cortexChannelId,
})
: null;
const cortexMemoryCapture = cfg
? await ingestAgentCortexMemoryCandidate({
cfg,
agentId: cortexAgentId,
workspaceDir: followupRun.run.workspaceDir,
commandBody,
sessionId: followupRun.run.sessionId,
channelId: cortexChannelId,
provider: followupRun.run.messageProvider,
})
: null;
const cortexConflictNotice = cfg
? await resolveAgentCortexConflictNotice({
cfg,
agentId: cortexAgentId,
workspaceDir: followupRun.run.workspaceDir,
sessionId: followupRun.run.sessionId,
channelId: cortexChannelId,
})
: null;
if (verboseEnabled && cortexModeStatus) {
const sourceLabel =
cortexModeStatus.source === "session-override"
? "session override"
: cortexModeStatus.source === "channel-override"
? "channel override"
: "agent config";
verboseNotices.push({
text: `🧠 Cortex: ${cortexModeStatus.mode} (${sourceLabel})`,
});
}
if (verboseEnabled && cortexMemoryCapture?.captured) {
verboseNotices.push({
text: `🧠 Cortex memory updated (${cortexMemoryCapture.reason}, score ${cortexMemoryCapture.score.toFixed(2)})`,
});
}
if (verboseEnabled && cortexMemoryCapture?.syncedCodingContext) {
verboseNotices.push({
text: `🧠 Cortex coding sync updated (${(cortexMemoryCapture.syncPlatforms ?? []).join(", ")})`,
});
}
if (cortexConflictNotice) {
finalPayloads = [{ text: cortexConflictNotice.text }, ...finalPayloads];
}
if (verboseNotices.length > 0) {
finalPayloads = [...verboseNotices, ...finalPayloads];
}