refactor: add transcript runtime identity contract (#89201) · openclaw/openclaw@efa9a61

Recent Commits to openclaw:main

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

Original file line number	Diff line number	Diff line change
`@@ -25,6 +25,10 @@ const legacyWholeStoreAccessNames = new Set([`
`25`	`25`	`]);`
`26`	`26`
`27`	`27`	`export const migratedSessionAccessorFiles = new Set([`
	`28`	`+"src/agents/embedded-agent-runner/compaction-successor-transcript.ts",`
	`29`	`+"src/agents/embedded-agent-runner/tool-result-truncation.ts",`
	`30`	`+"src/agents/embedded-agent-runner/transcript-rewrite.ts",`
	`31`	`+"src/agents/embedded-agent-runner/transcript-runtime-state.ts",`
`28`	`32`	`"src/commands/export-trajectory.ts",`
`29`	`33`	`"src/commands/health.ts",`
`30`	`34`	`"src/commands/sandbox-explain.ts",`
`@@ -35,6 +39,7 @@ export const migratedSessionAccessorFiles = new Set([`
`35`	`39`	`"src/config/sessions/combined-store-gateway.ts",`
`36`	`40`	`"src/cron/isolated-agent/delivery-target.ts",`
`37`	`41`	`"src/cron/service/timer.ts",`
	`42`	`+"src/gateway/session-compaction-checkpoints.ts",`
`38`	`43`	`"src/gateway/session-utils.ts",`
`39`	`44`	`"src/gateway/sessions-resolve.ts",`
`40`	`45`	`"src/gateway/server-methods/sessions.ts",`
`@@ -161,6 +166,7 @@ export async function main() {`
`161`	`166`	`const sourceRoots = resolveSourceRoots(repoRoot, [`
`162`	`167`	`"extensions/discord/src/monitor",`
`163`	`168`	`"extensions/telegram/src",`
	`169`	`+"src/agents/embedded-agent-runner",`
`164`	`170`	`"src/commands",`
`165`	`171`	`"src/config/sessions",`
`166`	`172`	`"src/cron",`

Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,7 @@ import { SessionManager } from "openclaw/plugin-sdk/agent-sessions";`
`6`	`6`	`import { afterEach, describe, expect, it, vi } from "vitest";`
`7`	`7`	`import { makeAgentAssistantMessage } from "../test-helpers/agent-message-fixtures.js";`
`8`	`8`	`import {`
	`9`	`+rotateRuntimeTranscriptAfterCompaction,`
`9`	`10`	`rotateTranscriptAfterCompaction,`
`10`	`11`	`rotateTranscriptFileAfterCompaction,`
`11`	`12`	`shouldRotateCompactionTranscript,`
`@@ -117,6 +118,24 @@ function createCompactedSession(sessionDir: string): {`
`117`	`118`	`}`
`118`	`119`
`119`	`120`	`describe("rotateTranscriptAfterCompaction", () => {`
	`121`	`+it("does not create session metadata for missing runtime transcripts", async () => {`
	`122`	`+const dir = await createTmpDir();`
	`123`	`+const storePath = path.join(dir, "sessions.json");`
	`124`	`+await fs.writeFile(storePath, "{}\n", "utf8");`
	`125`	`+`
	`126`	`+const result = await rotateRuntimeTranscriptAfterCompaction({`
	`127`	`+scope: {`
	`128`	`+agentId: "main",`
	`129`	`+sessionId: "missing-session",`
	`130`	`+sessionKey: "agent:main:missing",`
	`131`	`+ storePath,`
	`132`	`+},`
	`133`	`+});`
	`134`	`+`
	`135`	`+expect(result.rotated).toBe(false);`
	`136`	`+expect(await fs.readFile(storePath, "utf8")).toBe("{}\n");`
	`137`	`+});`
	`138`	`+`
`120`	`139`	`it("can rotate a persisted transcript without opening a manager", async () => {`
`121`	`140`	`const dir = await createTmpDir();`
`122`	`141`	`const { sessionFile } = createCompactedSession(dir);`

Original file line number	Diff line number	Diff line change
`@@ -14,6 +14,10 @@ import {`
`14`	`14`	`TranscriptFileState,`
`15`	`15`	`writeTranscriptFileAtomic,`
`16`	`16`	`} from "./transcript-file-state.js";`
	`17`	`+import {`
	`18`	`+resolveRuntimeTranscriptReadTarget,`
	`19`	`+type RuntimeTranscriptScope,`
	`20`	`+} from "./transcript-runtime-state.js";`
`17`	`21`
`18`	`22`	`type ReadonlySessionManagerForRotation = Pick<`
`19`	`23`	`TranscriptFileState,`
`@@ -99,6 +103,33 @@ export async function rotateTranscriptFileAfterCompaction(params: {`
`99`	`103`	`});`
`100`	`104`	`}`
`101`	`105`
	`106`	`+/**`
	`107`	`+ * Rotates a runtime transcript after compaction using agent/session identity.`
	`108`	`+ */`
	`109`	`+export async function rotateRuntimeTranscriptAfterCompaction(params: {`
	`110`	`+sessionManager?: ReadonlySessionManagerForRotation;`
	`111`	`+scope: RuntimeTranscriptScope;`
	`112`	`+now?: () => Date;`
	`113`	`+}): Promise<CompactionTranscriptRotation> {`
	`114`	`+const target = await resolveRuntimeTranscriptReadTarget(params.scope);`
	`115`	`+let sessionManager = params.sessionManager;`
	`116`	`+if (!sessionManager) {`
	`117`	`+try {`
	`118`	`+sessionManager = await readTranscriptFileState(target.sessionFile);`
	`119`	`+} catch (err) {`
	`120`	`+if ((err as NodeJS.ErrnoException).code === "ENOENT") {`
	`121`	`+return { rotated: false, reason: "missing session file" };`
	`122`	`+}`
	`123`	`+throw err;`
	`124`	`+}`
	`125`	`+}`
	`126`	`+return await rotateTranscriptAfterCompaction({`
	`127`	`+ sessionManager,`
	`128`	`+sessionFile: target.sessionFile,`
	`129`	`+ ...(params.now ? { now: params.now } : {}),`
	`130`	`+});`
	`131`	`+}`
	`132`	`+`
`102`	`133`	`function findLatestCompactionIndex(entries: SessionEntry[]): number {`
`103`	`134`	`for (let index = entries.length - 1; index >= 0; index -= 1) {`
`104`	`135`	`if (entries[index]?.type === "compaction") {`

Original file line number	Diff line number	Diff line change
`@@ -17,6 +17,7 @@ let calculateMaxToolResultCharsWithCap: typeof import("./tool-result-truncation.`
`17`	`17`	`let resolveAutoLiveToolResultMaxChars: typeof import("./tool-result-truncation.js").resolveAutoLiveToolResultMaxChars;`
`18`	`18`	`let getToolResultTextLength: typeof import("./tool-result-truncation.js").getToolResultTextLength;`
`19`	`19`	`let truncateOversizedToolResultsInMessages: typeof import("./tool-result-truncation.js").truncateOversizedToolResultsInMessages;`
	`20`	`+let truncateOversizedToolResultsInRuntimeTranscript: typeof import("./tool-result-truncation.js").truncateOversizedToolResultsInRuntimeTranscript;`
`20`	`21`	`let truncateOversizedToolResultsInSession: typeof import("./tool-result-truncation.js").truncateOversizedToolResultsInSession;`
`21`	`22`	`let isOversizedToolResult: typeof import("./tool-result-truncation.js").isOversizedToolResult;`
`22`	`23`	`let sessionLikelyHasOversizedToolResults: typeof import("./tool-result-truncation.js").sessionLikelyHasOversizedToolResults;`
`@@ -36,6 +37,7 @@ async function loadFreshToolResultTruncationModuleForTest() {`
`36`	`37`	`resolveAutoLiveToolResultMaxChars,`
`37`	`38`	`getToolResultTextLength,`
`38`	`39`	`truncateOversizedToolResultsInMessages,`
	`40`	`+ truncateOversizedToolResultsInRuntimeTranscript,`
`39`	`41`	`truncateOversizedToolResultsInSession,`
`40`	`42`	`isOversizedToolResult,`
`41`	`43`	`sessionLikelyHasOversizedToolResults,`
`@@ -464,6 +466,25 @@ describe("truncateOversizedToolResultsInMessages", () => {`
`464`	`466`	`});`
`465`	`467`
`466`	`468`	`describe("truncateOversizedToolResultsInSession", () => {`
	`469`	`+it("does not create session metadata for missing runtime transcripts", async () => {`
	`470`	`+const dir = await createTmpDir();`
	`471`	`+const storePath = path.join(dir, "sessions.json");`
	`472`	`+await fs.writeFile(storePath, "{}\n", "utf8");`
	`473`	`+`
	`474`	`+const result = await truncateOversizedToolResultsInRuntimeTranscript({`
	`475`	`+scope: {`
	`476`	`+agentId: "main",`
	`477`	`+sessionId: "missing-session",`
	`478`	`+sessionKey: "agent:main:missing",`
	`479`	`+ storePath,`
	`480`	`+},`
	`481`	`+contextWindowTokens: 100,`
	`482`	`+});`
	`483`	`+`
	`484`	`+expect(result.truncated).toBe(false);`
	`485`	`+expect(await fs.readFile(storePath, "utf8")).toBe("{}\n");`
	`486`	`+});`
	`487`	`+`
`467`	`488`	`it("readably truncates aggregate medium tool results in a session file", async () => {`
`468`	`489`	`// Persisted truncation rewrites JSONL directly and emits the transcript`
`469`	`490`	`// update event instead of reopening through SessionManager internals.`

Original file line number	Diff line number	Diff line change
`@@ -25,6 +25,10 @@ import {`
`25`	`25`	`rewriteTranscriptEntriesInSessionManager,`
`26`	`26`	`rewriteTranscriptEntriesInState,`
`27`	`27`	`} from "./transcript-rewrite.js";`
	`28`	`+import {`
	`29`	`+resolveRuntimeTranscriptReadTarget,`
	`30`	`+type RuntimeTranscriptScope,`
	`31`	`+} from "./transcript-runtime-state.js";`
`28`	`32`
`29`	`33`	`/**`
`30`	`34`	`* Maximum share of the context window a single tool result should occupy.`
`@@ -818,6 +822,49 @@ export function truncateOversizedToolResultsInSessionManager(params: {`
`818`	`822`	`}`
`819`	`823`	`}`
`820`	`824`
	`825`	`+/**`
	`826`	`+ * Truncates oversized tool results for a runtime transcript scope.`
	`827`	`+ */`
	`828`	`+export async function truncateOversizedToolResultsInRuntimeTranscript(params: {`
	`829`	`+scope: RuntimeTranscriptScope;`
	`830`	`+contextWindowTokens: number;`
	`831`	`+maxCharsOverride?: number;`
	`832`	`+aggregateMaxCharsOverride?: number;`
	`833`	`+config?: SessionWriteLockAcquireTimeoutConfig;`
	`834`	`+}): Promise<{ truncated: boolean; truncatedCount: number; reason?: string }> {`
	`835`	`+let sessionLock: Awaited<ReturnType<typeof acquireSessionWriteLock>> \| undefined;`
	`836`	`+`
	`837`	`+try {`
	`838`	`+const target = await resolveRuntimeTranscriptReadTarget(params.scope);`
	`839`	`+sessionLock = await acquireSessionWriteLock({`
	`840`	`+sessionFile: target.sessionFile,`
	`841`	`+ ...resolveSessionWriteLockOptions(params.config),`
	`842`	`+});`
	`843`	`+const state = await readTranscriptFileState(target.sessionFile);`
	`844`	`+return await truncateOversizedToolResultsInTranscriptState({`
	`845`	`+ state,`
	`846`	`+contextWindowTokens: params.contextWindowTokens,`
	`847`	`+maxCharsOverride: params.maxCharsOverride,`
	`848`	`+aggregateMaxCharsOverride: params.aggregateMaxCharsOverride,`
	`849`	`+sessionFile: target.sessionFile,`
	`850`	`+sessionId: target.sessionId,`
	`851`	`+sessionKey: target.sessionKey,`
	`852`	`+agentId: target.agentId,`
	`853`	`+config: params.config,`
	`854`	`+});`
	`855`	`+} catch (err) {`
	`856`	`+const errMsg = formatErrorMessage(err);`
	`857`	+log.warn(`[tool-result-truncation] Failed to truncate: ${errMsg}`);
	`858`	`+return { truncated: false, truncatedCount: 0, reason: errMsg };`
	`859`	`+} finally {`
	`860`	`+await sessionLock?.release();`
	`861`	`+}`
	`862`	`+}`
	`863`	`+`
	`864`	`+/**`
	`865`	`+ * Truncates a named transcript file artifact. Runtime callers should prefer`
	`866`	`+ * truncateOversizedToolResultsInRuntimeTranscript with agent/session scope.`
	`867`	`+ */`
`821`	`868`	`export async function truncateOversizedToolResultsInSession(params: {`
`822`	`869`	`sessionFile: string;`
`823`	`870`	`contextWindowTokens: number;`

Original file line number	Diff line number	Diff line change
`@@ -22,6 +22,7 @@ vi.mock("../session-write-lock.js", () =>`
`22`	`22`
`23`	`23`	`let rewriteTranscriptEntriesInSessionFile: typeof import("./transcript-rewrite.js").rewriteTranscriptEntriesInSessionFile;`
`24`	`24`	`let rewriteTranscriptEntriesInSessionManager: typeof import("./transcript-rewrite.js").rewriteTranscriptEntriesInSessionManager;`
	`25`	`+let rewriteTranscriptEntriesInRuntimeTranscript: typeof import("./transcript-rewrite.js").rewriteTranscriptEntriesInRuntimeTranscript;`
`25`	`26`	`let onSessionTranscriptUpdate: typeof import("../../sessions/transcript-events.js").onSessionTranscriptUpdate;`
`26`	`27`	`let installSessionToolResultGuard: typeof import("../session-tool-result-guard.js").installSessionToolResultGuard;`
`27`	`28`
`@@ -159,8 +160,11 @@ function requireString(value: string \| undefined, label: string): string {`
`159`	`160`	`beforeAll(async () => {`
`160`	`161`	`({ onSessionTranscriptUpdate } = await import("../../sessions/transcript-events.js"));`
`161`	`162`	`({ installSessionToolResultGuard } = await import("../session-tool-result-guard.js"));`
`162`		`-({ rewriteTranscriptEntriesInSessionFile, rewriteTranscriptEntriesInSessionManager } =`
`163`		`-await import("./transcript-rewrite.js"));`
	`163`	`+({`
	`164`	`+ rewriteTranscriptEntriesInRuntimeTranscript,`
	`165`	`+ rewriteTranscriptEntriesInSessionFile,`
	`166`	`+ rewriteTranscriptEntriesInSessionManager,`
	`167`	`+} = await import("./transcript-rewrite.js"));`
`164`	`168`	`});`
`165`	`169`
`166`	`170`	`beforeEach(() => {`
`@@ -306,6 +310,25 @@ describe("rewriteTranscriptEntriesInSessionManager", () => {`
`306`	`310`	`});`
`307`	`311`
`308`	`312`	`describe("rewriteTranscriptEntriesInSessionFile", () => {`
	`313`	`+it("does not create session metadata for missing runtime transcripts", async () => {`
	`314`	`+const dir = await fs.mkdtemp(path.join(os.tmpdir(), "openclaw-transcript-rewrite-runtime-"));`
	`315`	`+const storePath = path.join(dir, "sessions.json");`
	`316`	`+await fs.writeFile(storePath, "{}\n", "utf8");`
	`317`	`+`
	`318`	`+const result = await rewriteTranscriptEntriesInRuntimeTranscript({`
	`319`	`+scope: {`
	`320`	`+agentId: "main",`
	`321`	`+sessionId: "missing-session",`
	`322`	`+sessionKey: "agent:main:missing",`
	`323`	`+ storePath,`
	`324`	`+},`
	`325`	`+request: { replacements: [] },`
	`326`	`+});`
	`327`	`+`
	`328`	`+expect(result.changed).toBe(false);`
	`329`	`+expect(await fs.readFile(storePath, "utf8")).toBe("{}\n");`
	`330`	`+});`
	`331`	`+`
`309`	`332`	`it("aborts under the write lock when the active suffix contains an unexpected entry", async () => {`
`310`	`333`	`const dir = await fs.mkdtemp(path.join(os.tmpdir(), "openclaw-transcript-rewrite-guard-"));`
`311`	`334`	`const sessionManager = SessionManager.create(dir, dir);`

Original file line number	Diff line number	Diff line change
`@@ -22,6 +22,11 @@ import {`
`22`	`22`	`readTranscriptFileState,`
`23`	`23`	`type TranscriptFileState,`
`24`	`24`	`} from "./transcript-file-state.js";`
	`25`	`+import {`
	`26`	`+persistRuntimeTranscriptStateMutation,`
	`27`	`+resolveRuntimeTranscriptReadTarget,`
	`28`	`+type RuntimeTranscriptScope,`
	`29`	`+} from "./transcript-runtime-state.js";`
`25`	`30`
`26`	`31`	`type SessionManagerLike = ReturnType<typeof SessionManager.open>;`
`27`	`32`	`type SessionBranchEntry = ReturnType<SessionManagerLike["getBranch"]>[number];`
`@@ -372,8 +377,65 @@ export function rewriteTranscriptEntriesInState(params: {`
`372`	`377`	`}`
`373`	`378`
`374`	`379`	`/**`
`375`		`- * Open a transcript file, rewrite message entries on the active branch, and`
`376`		`- * emit a transcript update when the active branch changed.`
	`380`	`+ * Rewrites message entries for a runtime transcript without using the`
	`381`	`+ * file-backed path as caller identity.`
	`382`	`+ */`
	`383`	`+export async function rewriteTranscriptEntriesInRuntimeTranscript(params: {`
	`384`	`+scope: RuntimeTranscriptScope;`
	`385`	`+request: TranscriptRewriteRequest;`
	`386`	`+config?: SessionWriteLockAcquireTimeoutConfig;`
	`387`	`+}): Promise<TranscriptRewriteResult> {`
	`388`	`+let sessionLock: Awaited<ReturnType<typeof acquireSessionWriteLock>> \| undefined;`
	`389`	`+try {`
	`390`	`+const target = await resolveRuntimeTranscriptReadTarget(params.scope);`
	`391`	`+sessionLock = await acquireSessionWriteLock({`
	`392`	`+sessionFile: target.sessionFile,`
	`393`	`+ ...resolveSessionWriteLockOptions(params.config),`
	`394`	`+});`
	`395`	`+const state = await readTranscriptFileState(target.sessionFile);`
	`396`	`+const result = rewriteTranscriptEntriesInState({`
	`397`	`+ state,`
	`398`	`+replacements: params.request.replacements,`
	`399`	`+ ...(params.request.allowedRewriteSuffixEntryIds`
	`400`	`+ ? { allowedRewriteSuffixEntryIds: params.request.allowedRewriteSuffixEntryIds }`
	`401`	`+ : {}),`
	`402`	`+});`
	`403`	`+if (result.changed) {`
	`404`	`+await persistRuntimeTranscriptStateMutation({`
	`405`	`+ target,`
	`406`	`+ state,`
	`407`	`+appendedEntries: result.appendedEntries,`
	`408`	`+});`
	`409`	`+emitSessionTranscriptUpdate({`
	`410`	`+sessionFile: target.sessionFile,`
	`411`	`+sessionKey: target.sessionKey,`
	`412`	`+agentId: target.agentId,`
	`413`	`+});`
	`414`	`+log.info(`
	`415`	+`[transcript-rewrite] rewrote ${result.rewrittenEntries} entr` +
	`416`	+`${result.rewrittenEntries === 1 ? "y" : "ies"} ` +
	`417`	+`bytesFreed=${result.bytesFreed} ` +
	`418`	+`sessionKey=${target.sessionKey}`,
	`419`	`+);`
	`420`	`+}`
	`421`	`+return result;`
	`422`	`+} catch (err) {`
	`423`	`+const reason = formatErrorMessage(err);`
	`424`	+log.warn(`[transcript-rewrite] failed: ${reason}`);
	`425`	`+return {`
	`426`	`+changed: false,`
	`427`	`+bytesFreed: 0,`
	`428`	`+rewrittenEntries: 0,`
	`429`	`+ reason,`
	`430`	`+};`
	`431`	`+} finally {`
	`432`	`+await sessionLock?.release();`
	`433`	`+}`
	`434`	`+}`
	`435`	`+`
	`436`	`+/**`
	`437`	`+ * Rewrites a named transcript file artifact. Runtime callers should prefer`
	`438`	`+ * rewriteTranscriptEntriesInRuntimeTranscript with agent/session scope.`
`377`	`439`	`*/`
`378`	`440`	`export async function rewriteTranscriptEntriesInSessionFile(params: {`
`379`	`441`	`sessionFile: string;`

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

推荐订阅源

Recent Commits to openclaw:main