diff --git a/src/agents/transcript/session-manager.ts b/src/agents/transcript/session-manager.ts index e50b7eb9c00..0aa327a2ceb 100644 --- a/src/agents/transcript/session-manager.ts +++ b/src/agents/transcript/session-manager.ts @@ -260,7 +260,7 @@ function listSqliteTranscriptRecords(): SqliteTranscriptRecord[] { agentId: entry.agentId, sessionId: entry.sessionId, path: - entry.path ?? + entry.locator ?? createSqliteSessionTranscriptLocator({ agentId: entry.agentId, sessionId: entry.sessionId, diff --git a/src/auto-reply/reply/agent-runner-memory.ts b/src/auto-reply/reply/agent-runner-memory.ts index 18a7be93b44..c96d705541a 100644 --- a/src/auto-reply/reply/agent-runner-memory.ts +++ b/src/auto-reply/reply/agent-runner-memory.ts @@ -241,12 +241,12 @@ function resolveSqliteSessionTranscriptPath(params: { } const explicit = normalizeOptionalString(params.sessionEntry?.sessionFile); if (explicit) { - const matched = candidates.find((entry) => entry.path === explicit); + const matched = candidates.find((entry) => entry.locator === explicit); if (matched) { - return matched.path; + return matched.locator; } } - return candidates[0]?.path; + return candidates[0]?.locator; } function deriveTranscriptUsageSnapshot( diff --git a/src/config/sessions/transcript-store.sqlite.test.ts b/src/config/sessions/transcript-store.sqlite.test.ts index 79aa1df4989..cb4aef3f59e 100644 --- a/src/config/sessions/transcript-store.sqlite.test.ts +++ b/src/config/sessions/transcript-store.sqlite.test.ts @@ -196,7 +196,10 @@ describe("SQLite session transcript store", () => { { agentId: "main", sessionId: "session-1", - path: createSqliteSessionTranscriptLocator({ agentId: "main", sessionId: "session-1" }), + locator: createSqliteSessionTranscriptLocator({ + agentId: "main", + sessionId: "session-1", + }), updatedAt: 200, eventCount: 2, }, diff --git a/src/config/sessions/transcript-store.sqlite.ts b/src/config/sessions/transcript-store.sqlite.ts index be16107496b..51966f1c8bc 100644 --- a/src/config/sessions/transcript-store.sqlite.ts +++ b/src/config/sessions/transcript-store.sqlite.ts @@ -58,12 +58,12 @@ export type SqliteSessionTranscriptScope = { }; export type SqliteSessionTranscriptLocator = SqliteSessionTranscriptScope & { - path: string; + locator: string; updatedAt: number; }; export type SqliteSessionTranscript = SqliteSessionTranscriptScope & { - path?: string; + locator?: string; updatedAt: number; eventCount: number; }; @@ -277,8 +277,8 @@ export function listSqliteSessionTranscriptLocators( return listSqliteSessionTranscripts(options).map((transcript) => ({ agentId: transcript.agentId, sessionId: transcript.sessionId, - path: - transcript.path ?? + locator: + transcript.locator ?? createSqliteSessionTranscriptLocator({ agentId: transcript.agentId, sessionId: transcript.sessionId, @@ -335,7 +335,7 @@ export function listSqliteSessionTranscripts( { agentId: agentDatabase.agentId, sessionId: normalizeSessionId(record.session_id), - path: createSqliteSessionTranscriptLocator({ + locator: createSqliteSessionTranscriptLocator({ agentId: agentDatabase.agentId, sessionId: normalizeSessionId(record.session_id), }), diff --git a/src/infra/session-cost-usage.ts b/src/infra/session-cost-usage.ts index ab6b84aea72..d2c78d684bf 100644 --- a/src/infra/session-cost-usage.ts +++ b/src/infra/session-cost-usage.ts @@ -265,7 +265,7 @@ const applyCostTotal = (totals: CostUsageTotals, costTotal: number | undefined) function getRememberedTranscriptPath(agentId: string, sessionId: string): string | undefined { return listSqliteSessionTranscriptLocators().find( (entry) => entry.agentId === agentId && entry.sessionId === sessionId, - )?.path; + )?.locator; } function resolveSyntheticSessionFile(params: { @@ -590,7 +590,7 @@ export async function discoverAllSessions(params?: { sessionFile: resolveSyntheticSessionFile({ agentId: transcript.agentId, sessionId: transcript.sessionId, - rememberedPath: transcript.path, + rememberedPath: transcript.locator, }), mtime: transcript.updatedAt, firstUserMessage,