perf(gateway): skip lifecycle session cache clone · openc...

Recent Commits to openclaw:main

steipete · 2026-05-27 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -20,6 +20,7 @@ import {`
`20`	`20`	`readSessionUpdatedAt,`
`21`	`21`	`saveSessionStore,`
`22`	`22`	`updateSessionStore,`
	`23`	`+updateSessionStoreEntry,`
`23`	`24`	`} from "./sessions/store.js";`
`24`	`25`	`import type { SessionEntry } from "./sessions/types.js";`
`25`	`26`
`@@ -579,6 +580,24 @@ describe("Session Store Cache", () => {`
`579`	`580`	`expect(cached["session:1"].displayName).toBe("Writer owned");`
`580`	`581`	`});`
`581`	`582`
	`583`	`+it("can publish writer-owned entry patches directly into the object cache", async () => {`
	`584`	`+await saveSessionStore(storePath, createSingleSessionStore());`
	`585`	`+`
	`586`	`+const persisted = await updateSessionStoreEntry({`
	`587`	`+ storePath,`
	`588`	`+sessionKey: "session:1",`
	`589`	`+takeCacheOwnership: true,`
	`590`	`+update: async () => ({`
	`591`	`+displayName: "Entry writer owned",`
	`592`	`+updatedAt: Date.now() + 1,`
	`593`	`+}),`
	`594`	`+});`
	`595`	`+`
	`596`	`+const cached = loadSessionStore(storePath, { clone: false });`
	`597`	`+expect(cached["session:1"]).toBe(persisted);`
	`598`	`+expect(cached["session:1"].displayName).toBe("Entry writer owned");`
	`599`	`+});`
	`600`	`+`
`582`	`601`	`it("builds immutable session snapshots lazily after writes", async () => {`
`583`	`602`	`await saveSessionStore(storePath, createSingleSessionStore());`
`584`	`603`

Original file line number	Diff line number	Diff line change
`@@ -633,13 +633,15 @@ async function persistResolvedSessionEntry(params: {`
`633`	`633`	`store: Record<string, SessionEntry>;`
`634`	`634`	`resolved: ReturnType<typeof resolveSessionStoreEntry>;`
`635`	`635`	`next: SessionEntry;`
	`636`	`+takeCacheOwnership?: boolean;`
`636`	`637`	`}): Promise<SessionEntry> {`
`637`	`638`	`params.store[params.resolved.normalizedKey] = params.next;`
`638`	`639`	`for (const legacyKey of params.resolved.legacyKeys) {`
`639`	`640`	`delete params.store[legacyKey];`
`640`	`641`	`}`
`641`	`642`	`await saveSessionStoreUnlocked(params.storePath, params.store, {`
`642`	`643`	`activeSessionKey: params.resolved.normalizedKey,`
	`644`	`+takeCacheOwnership: params.takeCacheOwnership,`
`643`	`645`	`});`
`644`	`646`	`return params.next;`
`645`	`647`	`}`
`@@ -648,6 +650,7 @@ export async function updateSessionStoreEntry(params: {`
`648`	`650`	`storePath: string;`
`649`	`651`	`sessionKey: string;`
`650`	`652`	`update: (entry: SessionEntry) => Promise<Partial<SessionEntry> \| null>;`
	`653`	`+takeCacheOwnership?: boolean;`
`651`	`654`	`}): Promise<SessionEntry \| null> {`
`652`	`655`	`const { storePath, sessionKey, update } = params;`
`653`	`656`	`return await runExclusiveSessionStoreWrite(storePath, async () => {`
`@@ -667,6 +670,7 @@ export async function updateSessionStoreEntry(params: {`
`667`	`670`	`store,`
`668`	`671`	`resolved,`
`669`	`672`	`next,`
	`673`	`+takeCacheOwnership: params.takeCacheOwnership,`
`670`	`674`	`});`
`671`	`675`	`});`
`672`	`676`	`}`

Original file line number	Diff line number	Diff line change
`@@ -160,6 +160,7 @@ export async function persistGatewaySessionLifecycleEvent(params: {`
`160`	`160`	`await updateSessionStoreEntry({`
`161`	`161`	`storePath: sessionEntry.storePath,`
`162`	`162`	`sessionKey: sessionEntry.canonicalKey,`
	`163`	`+takeCacheOwnership: true,`
`163`	`164`	`update: async (entry) =>`
`164`	`165`	`derivePersistedSessionLifecyclePatch({`
`165`	`166`	`entry,`

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