fix(codex): log app-server compaction completion (#93463) · openclaw/openclaw@7e9b942

Recent Commits to openclaw:main

goutamadwant · 2026-06-16 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,8 @@ import { LiveSessionModelSwitchError } from "../../agents/live-model-switch-erro`
`7`	`7`	`import { MissingProviderAuthError } from "../../agents/model-auth.js";`
`8`	`8`	`import type { SessionEntry } from "../../config/sessions.js";`
`9`	`9`	`import type { ModelDefinitionConfig } from "../../config/types.models.js";`
	`10`	`+import { resetLogger, setLoggerOverride } from "../../logging/logger.js";`
	`11`	`+import { loggingState } from "../../logging/state.js";`
`10`	`12`	`import { CommandLaneClearedError, GatewayDrainingError } from "../../process/command-queue.js";`
`11`	`13`	`import {`
`12`	`14`	`createUserTurnTranscriptRecorder,`
`@@ -5142,6 +5144,69 @@ describe("runAgentTurnWithFallback", () => {`
`5142`	`5144`	`expect(onBlockReply).not.toHaveBeenCalled();`
`5143`	`5145`	`});`
`5144`	`5146`
	`5147`	`+it("logs Codex app-server compaction completion while notices stay silent by default", async () => {`
	`5148`	`+const onBlockReply = vi.fn();`
	`5149`	`+const consoleLog = vi.fn();`
	`5150`	`+setLoggerOverride({ level: "silent", consoleLevel: "info", consoleStyle: "compact" });`
	`5151`	`+loggingState.rawConsole = {`
	`5152`	`+log: consoleLog,`
	`5153`	`+info: vi.fn(),`
	`5154`	`+warn: vi.fn(),`
	`5155`	`+error: vi.fn(),`
	`5156`	`+};`
	`5157`	`+try {`
	`5158`	`+state.runWithModelFallbackMock.mockImplementationOnce(`
	`5159`	`+async (params: FallbackRunnerParams) => ({`
	`5160`	`+result: await params.run("openai", "gpt-5.5"),`
	`5161`	`+provider: "openai",`
	`5162`	`+model: "gpt-5.5",`
	`5163`	`+attempts: [{ provider: "anthropic", model: "claude", error: "rate limit" }],`
	`5164`	`+}),`
	`5165`	`+);`
	`5166`	`+state.runEmbeddedAgentMock.mockImplementationOnce(async (params: EmbeddedAgentParams) => {`
	`5167`	`+await params.onAgentEvent?.({`
	`5168`	`+stream: "compaction",`
	`5169`	`+data: {`
	`5170`	`+phase: "start",`
	`5171`	`+backend: "codex-app-server",`
	`5172`	`+threadId: "thread-1",`
	`5173`	`+turnId: "turn-1",`
	`5174`	`+itemId: "compaction-1",`
	`5175`	`+},`
	`5176`	`+});`
	`5177`	`+await params.onAgentEvent?.({`
	`5178`	`+stream: "compaction",`
	`5179`	`+data: {`
	`5180`	`+phase: "end",`
	`5181`	`+completed: true,`
	`5182`	`+backend: "codex-app-server",`
	`5183`	`+threadId: "thread-1",`
	`5184`	`+turnId: "turn-1",`
	`5185`	`+itemId: "compaction-1",`
	`5186`	`+},`
	`5187`	`+});`
	`5188`	`+return { payloads: [{ text: "final" }], meta: {} };`
	`5189`	`+});`
	`5190`	`+`
	`5191`	`+const runAgentTurnWithFallback = await getRunAgentTurnWithFallback();`
	`5192`	`+const result = await runAgentTurnWithFallback({`
	`5193`	`+ ...createMinimalRunAgentTurnParams({`
	`5194`	`+opts: { onBlockReply },`
	`5195`	`+}),`
	`5196`	`+});`
	`5197`	`+`
	`5198`	`+expect(result.kind).toBe("success");`
	`5199`	`+expect(onBlockReply).not.toHaveBeenCalled();`
	`5200`	`+expect(consoleLog.mock.calls.map(([line]) => String(line)).join("\n")).toContain(`
	`5201`	`+"codex app-server auto-compaction succeeded for openai/gpt-5.5; refreshed session context",`
	`5202`	`+);`
	`5203`	`+} finally {`
	`5204`	`+loggingState.rawConsole = null;`
	`5205`	`+setLoggerOverride(null);`
	`5206`	`+resetLogger();`
	`5207`	`+}`
	`5208`	`+});`
	`5209`	`+`
`5145`	`5210`	`it("emits a compaction start notice when notifyUser is enabled", async () => {`
`5146`	`5211`	`const onBlockReply = vi.fn();`
`5147`	`5212`	`state.runEmbeddedAgentMock.mockImplementationOnce(async (params: EmbeddedAgentParams) => {`

Original file line number	Diff line number	Diff line change
`@@ -163,9 +163,26 @@ type AgentTurnTimingSummary = {`
`163`	`163`	`};`
`164`	`164`
`165`	`165`	`const agentTurnTimingLog = createSubsystemLogger("auto-reply/agent-turn-timing");`
	`166`	`+const agentCompactionLog = createSubsystemLogger("auto-reply/compaction");`
	`167`	`+const CODEX_APP_SERVER_COMPACTION_BACKEND = "codex-app-server";`
`166`	`168`	`const AGENT_TURN_TIMING_WARN_TOTAL_MS = 1_000;`
`167`	`169`	`const AGENT_TURN_TIMING_WARN_STAGE_MS = 500;`
`168`	`170`
	`171`	`+function formatCompactionModelRef(provider?: string, model?: string): string {`
	`172`	`+const normalizedProvider = normalizeOptionalString(provider);`
	`173`	`+const normalizedModel = normalizeOptionalString(model);`
	`174`	`+if (normalizedProvider && normalizedModel) {`
	`175`	+return `${sanitizeForLog(normalizedProvider)}/${sanitizeForLog(normalizedModel)}`;
	`176`	`+}`
	`177`	`+if (normalizedProvider) {`
	`178`	`+return sanitizeForLog(normalizedProvider);`
	`179`	`+}`
	`180`	`+if (normalizedModel) {`
	`181`	`+return sanitizeForLog(normalizedModel);`
	`182`	`+}`
	`183`	`+return "unknown model";`
	`184`	`+}`
	`185`	`+`
`169`	`186`	`function createAgentTurnTimingTracker(options: { profilerEnabled?: boolean } = {}): {`
`170`	`187`	`measure: <T>(name: string, run: () => Promise<T> \| T) => Promise<T>;`
`171`	`188`	`measureSync: <T>(name: string, run: () => T) => T;`
`@@ -2710,6 +2727,7 @@ export async function runAgentTurnWithFallback(params: {`
`2710`	`2727`	`}`
`2711`	`2728`	`if (evt.stream === "compaction") {`
`2712`	`2729`	`const phase = readStringValue(evt.data.phase) ?? "";`
	`2730`	`+const backend = readStringValue(evt.data.backend);`
`2713`	`2731`	`const hookMessages = readCompactionHookMessages(evt.data.messages);`
`2714`	`2732`	`const sendCompactionUserNotices = async (`
`2715`	`2733`	`noticePhase: "start" \| "end" \| "incomplete",`
`@@ -2731,6 +2749,28 @@ export async function runAgentTurnWithFallback(params: {`
`2731`	`2749`	`const completed = evt.data?.completed === true;`
`2732`	`2750`	`if (completed) {`
`2733`	`2751`	`attemptCompactionCount += 1;`
	`2752`	`+if (backend === CODEX_APP_SERVER_COMPACTION_BACKEND) {`
	`2753`	`+const modelRef = formatCompactionModelRef(provider, model);`
	`2754`	`+const consoleMessage =`
	`2755`	+`codex app-server auto-compaction succeeded for ${modelRef}; ` +
	`2756`	`+"refreshed session context";`
	`2757`	`+agentCompactionLog.info(`
	`2758`	`+"codex app-server auto-compaction succeeded",`
	`2759`	`+{`
	`2760`	`+event: "codex_app_server_compaction_succeeded",`
	`2761`	`+ backend,`
	`2762`	`+ provider,`
	`2763`	`+ model,`
	`2764`	`+sessionKey: params.sessionKey,`
	`2765`	`+sessionId: effectiveRun.sessionId,`
	`2766`	`+threadId: readStringValue(evt.data.threadId),`
	`2767`	`+turnId: readStringValue(evt.data.turnId),`
	`2768`	`+itemId: readStringValue(evt.data.itemId),`
	`2769`	`+compactionCount: attemptCompactionCount,`
	`2770`	`+ consoleMessage,`
	`2771`	`+},`
	`2772`	`+);`
	`2773`	`+}`
`2734`	`2774`	`if (params.opts?.onCompactionEnd) {`
`2735`	`2775`	`await params.opts.onCompactionEnd();`
`2736`	`2776`	`}`

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。原文来自 — 版权归原作者所有。

推荐订阅源

Recent Commits to openclaw:main