github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-19 11:18:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: share session transcript store setup

Browse Source
This commit is contained in:
Peter Steinberger
2026-03-13 21:24:14 +00:00
parent eca22c0cc7
commit d3f46fa7fa
1 changed files with 19 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
src/config/sessions/sessions.test.ts
View File

@@ -283,18 +283,25 @@ describe("session store lock (Promise chain mutex)", () => {
describe("appendAssistantMessageToSessionTranscript", () => { describe("appendAssistantMessageToSessionTranscript", () => {
const fixture = useTempSessionsFixture("transcript-test-"); const fixture = useTempSessionsFixture("transcript-test-");
const sessionId = "test-session-id";
const sessionKey = "test-session";
function writeTranscriptStore() {
fs.writeFileSync(
fixture.storePath(),
JSON.stringify({
[sessionKey]: {
sessionId,
chatType: "direct",
channel: "discord",
},
}),
"utf-8",
);
}
it("creates transcript file and appends message for valid session", async () => { it("creates transcript file and appends message for valid session", async () => {
const sessionId = "test-session-id"; writeTranscriptStore();
const sessionKey = "test-session";
const store = {
[sessionKey]: {
sessionId,
chatType: "direct",
channel: "discord",
},
};
fs.writeFileSync(fixture.storePath(), JSON.stringify(store), "utf-8");
const result = await appendAssistantMessageToSessionTranscript({ const result = await appendAssistantMessageToSessionTranscript({
sessionKey, sessionKey,
@@ -326,16 +333,7 @@ describe("appendAssistantMessageToSessionTranscript", () => {
}); });
it("does not append a duplicate delivery mirror for the same idempotency key", async () => { it("does not append a duplicate delivery mirror for the same idempotency key", async () => {
const sessionId = "test-session-id"; writeTranscriptStore();
const sessionKey = "test-session";
const store = {
[sessionKey]: {
sessionId,
chatType: "direct",
channel: "discord",
},
};
fs.writeFileSync(fixture.storePath(), JSON.stringify(store), "utf-8");
await appendAssistantMessageToSessionTranscript({ await appendAssistantMessageToSessionTranscript({
sessionKey, sessionKey,
@@ -360,16 +358,7 @@ describe("appendAssistantMessageToSessionTranscript", () => {
}); });
it("ignores malformed transcript lines when checking mirror idempotency", async () => { it("ignores malformed transcript lines when checking mirror idempotency", async () => {
const sessionId = "test-session-id"; writeTranscriptStore();
const sessionKey = "test-session";
const store = {
[sessionKey]: {
sessionId,
chatType: "direct",
channel: "discord",
},
};
fs.writeFileSync(fixture.storePath(), JSON.stringify(store), "utf-8");
const sessionFile = resolveSessionTranscriptPathInDir(sessionId, fixture.sessionsDir()); const sessionFile = resolveSessionTranscriptPathInDir(sessionId, fixture.sessionsDir());
fs.writeFileSync( fs.writeFileSync(