LLM/moltbot
1
0
Fork 0
mirror of https://github.com/moltbot/moltbot.git synced 2026-05-21 21:56:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: seed codex run history in sqlite

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-08 15:31:04 +01:00
parent 2c4aecb9c3
commit a9e16c0674
1 changed files with 27 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
extensions/codex/src/app-server/run-attempt.test.ts
View File

@@ -2,7 +2,6 @@ import fs from "node:fs/promises";
import os from "node:os";
import path from "node:path";
import { abortAgentHarnessRun } from "openclaw/plugin-sdk/agent-harness";
import { SessionManager } from "openclaw/plugin-sdk/agent-harness-runtime";
import {
embeddedAgentLog,
nativeHookRelayTesting,
@@ -183,6 +182,26 @@ function userMessage(text: string, timestamp: number) {
};
}
function seedSessionHistory(
sessionFile: string,
messages: Array<ReturnType<typeof assistantMessage> | ReturnType<typeof userMessage>>,
) {
replaceSqliteSessionTranscriptEvents({
agentId: "main",
sessionId: "session-1",
transcriptPath: sessionFile,
events: [
{ type: "session", version: 1, id: "session-1" },
...messages.map((message, index) => ({
type: "message",
id: `history-${index + 1}`,
parentId: index === 0 ? null : `history-${index}`,
message,
})),
],
});
}
function createAppServerHarness(
requestImpl: (method: string, params: unknown) => Promise<unknown>,
options: {
@@ -1438,8 +1457,7 @@ describe("runCodexAppServerAttempt", () => {
);
const sessionFile = path.join(tempDir, "session.jsonl");
const workspaceDir = path.join(tempDir, "workspace");
const sessionManager = SessionManager.open(sessionFile);
sessionManager.appendMessage(assistantMessage("previous turn", Date.now()));
seedSessionHistory(sessionFile, [assistantMessage("previous turn", Date.now())]);
const harness = createStartedThreadHarness();
const run = runCodexAppServerAttempt(createParams(sessionFile, workspaceDir));
@@ -1479,9 +1497,10 @@ describe("runCodexAppServerAttempt", () => {
it("projects mirrored history when starting Codex without a native thread binding", async () => {
const sessionFile = path.join(tempDir, "session.jsonl");
const workspaceDir = path.join(tempDir, "workspace");
const sessionManager = SessionManager.open(sessionFile);
sessionManager.appendMessage(userMessage("we are fixing the Opik default project", Date.now()));
sessionManager.appendMessage(assistantMessage("Opik default project context", Date.now() + 1));
seedSessionHistory(sessionFile, [
userMessage("we are fixing the Opik default project", Date.now()),
assistantMessage("Opik default project context", Date.now() + 1),
]);
const harness = createStartedThreadHarness();
const params = createParams(sessionFile, workspaceDir);
params.prompt = "make the default webpage openclaw";
@@ -1549,8 +1568,7 @@ describe("runCodexAppServerAttempt", () => {
);
const sessionFile = path.join(tempDir, "session.jsonl");
const workspaceDir = path.join(tempDir, "workspace");
const sessionManager = SessionManager.open(sessionFile);
sessionManager.appendMessage(assistantMessage("existing context", Date.now()));
seedSessionHistory(sessionFile, [assistantMessage("existing context", Date.now())]);
const harness = createStartedThreadHarness();
const params = createParams(sessionFile, workspaceDir);
@@ -2240,9 +2258,7 @@ describe("runCodexAppServerAttempt", () => {
);
const sessionFile = path.join(tempDir, "session.jsonl");
const workspaceDir = path.join(tempDir, "workspace");
SessionManager.open(sessionFile).appendMessage(
assistantMessage("existing context", Date.now()),
);
seedSessionHistory(sessionFile, [assistantMessage("existing context", Date.now())]);
createStartedThreadHarness(async (method) => {
if (method === "turn/start") {
throw new Error("turn start exploded");