From c02b0be46efacfacb506aaf708e77e532e2de2e6 Mon Sep 17 00:00:00 2001 From: Peter Steinberger Date: Sat, 9 May 2026 05:34:04 +0100 Subject: [PATCH] test: use sqlite locators in gateway chat history --- src/gateway/server.chat.gateway-server-chat-b.test.ts | 10 +++++----- src/gateway/server.chat.gateway-server-chat.test.ts | 10 +++++----- 2 files changed, 10 insertions(+), 10 deletions(-) diff --git a/src/gateway/server.chat.gateway-server-chat-b.test.ts b/src/gateway/server.chat.gateway-server-chat-b.test.ts index b707f0190f5..dd2aa2b4972 100644 --- a/src/gateway/server.chat.gateway-server-chat-b.test.ts +++ b/src/gateway/server.chat.gateway-server-chat-b.test.ts @@ -4,7 +4,7 @@ import path from "node:path"; import { afterAll, beforeAll, describe, expect, test, vi } from "vitest"; import type { GetReplyOptions } from "../auto-reply/get-reply-options.types.js"; import { clearConfigCache } from "../config/config.js"; -import { getSessionEntry } from "../config/sessions.js"; +import { createSqliteSessionTranscriptLocator, getSessionEntry } from "../config/sessions.js"; import { replaceSqliteSessionTranscriptEvents } from "../config/sessions/transcript-store.sqlite.js"; import { GATEWAY_CLIENT_MODES, GATEWAY_CLIENT_NAMES } from "../utils/message-channel.js"; import { __setMaxChatHistoryMessagesBytesForTest } from "./server-constants.js"; @@ -65,8 +65,8 @@ function createDeferred() { return { promise, resolve, reject }; } -function resolveMainTranscriptPath(root: string): string { - return path.join(root, "agents", "main", "sessions", "sess-main.jsonl"); +function resolveMainTranscriptPath(): string { + return createSqliteSessionTranscriptLocator({ agentId: "main", sessionId: "sess-main" }); } async function withGatewayChatHarness( @@ -112,11 +112,11 @@ async function writeGatewayConfig(config: Record) { clearConfigCache(); } -async function writeMainSessionTranscript(sessionDir: string, lines: string[]) { +async function writeMainSessionTranscript(_sessionDir: string, lines: string[]) { replaceSqliteSessionTranscriptEvents({ agentId: "main", sessionId: "sess-main", - transcriptPath: resolveMainTranscriptPath(sessionDir), + transcriptPath: resolveMainTranscriptPath(), events: lines.map((line) => JSON.parse(line) as unknown), }); } diff --git a/src/gateway/server.chat.gateway-server-chat.test.ts b/src/gateway/server.chat.gateway-server-chat.test.ts index bf9daacfec1..0c52350a18c 100644 --- a/src/gateway/server.chat.gateway-server-chat.test.ts +++ b/src/gateway/server.chat.gateway-server-chat.test.ts @@ -3,7 +3,7 @@ import os from "node:os"; import path from "node:path"; import { beforeEach, describe, expect, test, vi } from "vitest"; import { WebSocket } from "ws"; -import { getSessionEntry } from "../config/sessions.js"; +import { createSqliteSessionTranscriptLocator, getSessionEntry } from "../config/sessions.js"; import { replaceSqliteSessionTranscriptEvents } from "../config/sessions/transcript-store.sqlite.js"; import { emitAgentEvent, registerAgentRunContext } from "../infra/agent-events.js"; import { extractFirstTextBlock } from "../shared/chat-message-content.js"; @@ -30,8 +30,8 @@ const CHAT_RESPONSE_TIMEOUT_MS = 10_000; let ws: WebSocket; let port: number; -function resolveMainTranscriptPath(root: string): string { - return path.join(root, "agents", "main", "sessions", "sess-main.jsonl"); +function resolveMainTranscriptPath(): string { + return createSqliteSessionTranscriptLocator({ agentId: "main", sessionId: "sess-main" }); } installConnectedControlUiServerSuite((started) => { @@ -130,11 +130,11 @@ describe("gateway server chat", () => { } }; - const writeMainSessionTranscript = (dir: string, events: unknown[]): void => { + const writeMainSessionTranscript = (_dir: string, events: unknown[]): void => { replaceSqliteSessionTranscriptEvents({ agentId: "main", sessionId: "sess-main", - transcriptPath: resolveMainTranscriptPath(dir), + transcriptPath: resolveMainTranscriptPath(), events, }); };