vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 06:30:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: share session conversation fallback fixtures

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-20 19:27:04 +01:00
parent 263a190fc9
commit 434e3d81f3
1 changed files with 36 additions and 69 deletions
Download Patch File Download Diff File Expand all files Collapse all files

105
src/channels/plugins/session-conversation.bundled-fallback.test.ts
View File

@@ -32,6 +32,37 @@ vi.mock("../../plugin-sdk/facade-runtime.js", async () => {
import { resolveSessionConversationRef, resolveSessionThreadInfo } from "./session-conversation.js";
type ResolveSessionConversation = NonNullable<typeof fallbackState.resolveSessionConversation>;
function enableBundledFallback(
dirName: string,
resolveSessionConversation: ResolveSessionConversation,
) {
fallbackState.activeDirName = dirName;
fallbackState.resolveSessionConversation = resolveSessionConversation;
setRuntimeConfigSnapshot({
plugins: {
entries: {
[dirName]: {
enabled: true,
},
},
},
});
}
function enableThreadedFallback() {
enableBundledFallback("mock-threaded", ({ rawId }) => {
const [conversationId, threadId] = rawId.split(":topic:");
return {
id: conversationId,
threadId,
baseConversationId: conversationId,
parentConversationCandidates: [conversationId],
};
});
}
describe("session conversation bundled fallback", () => {
beforeEach(() => {
fallbackState.activeDirName = null;
@@ -45,25 +76,7 @@ describe("session conversation bundled fallback", () => {
});
it("delegates pre-bootstrap thread parsing to the active bundled channel plugin", () => {
fallbackState.activeDirName = "mock-threaded";
fallbackState.resolveSessionConversation = ({ rawId }) => {
const [conversationId, threadId] = rawId.split(":topic:");
return {
id: conversationId,
threadId,
baseConversationId: conversationId,
parentConversationCandidates: [conversationId],
};
};
setRuntimeConfigSnapshot({
plugins: {
entries: {
"mock-threaded": {
enabled: true,
},
},
},
});
enableThreadedFallback();
expect(resolveSessionConversationRef("agent:main:mock-threaded:group:room:topic:42")).toEqual({
channel: "mock-threaded",
@@ -78,25 +91,7 @@ describe("session conversation bundled fallback", () => {
});
it("can skip bundled fallback probing for hot generic-only callers", () => {
fallbackState.activeDirName = "mock-threaded";
fallbackState.resolveSessionConversation = ({ rawId }) => {
const [conversationId, threadId] = rawId.split(":topic:");
return {
id: conversationId,
threadId,
baseConversationId: conversationId,
parentConversationCandidates: [conversationId],
};
};
setRuntimeConfigSnapshot({
plugins: {
entries: {
"mock-threaded": {
enabled: true,
},
},
},
});
enableThreadedFallback();
expect(
resolveSessionConversationRef("agent:main:mock-threaded:group:room:topic:42", {
@@ -123,21 +118,11 @@ describe("session conversation bundled fallback", () => {
});
it("uses explicit bundled parent candidates before registry bootstrap", () => {
fallbackState.activeDirName = "mock-parent";
fallbackState.resolveSessionConversation = ({ rawId }) => ({
enableBundledFallback("mock-parent", ({ rawId }) => ({
id: rawId,
baseConversationId: "room",
parentConversationCandidates: ["room:topic:root", "room"],
});
setRuntimeConfigSnapshot({
plugins: {
entries: {
"mock-parent": {
enabled: true,
},
},
},
});
}));
expect(
resolveSessionConversationRef("agent:main:mock-parent:group:room:topic:root:sender:user"),
@@ -154,25 +139,7 @@ describe("session conversation bundled fallback", () => {
});
it("reuses the bundled fallback loader result across repeated calls", () => {
fallbackState.activeDirName = "mock-threaded";
fallbackState.resolveSessionConversation = ({ rawId }) => {
const [conversationId, threadId] = rawId.split(":topic:");
return {
id: conversationId,
threadId,
baseConversationId: conversationId,
parentConversationCandidates: [conversationId],
};
};
setRuntimeConfigSnapshot({
plugins: {
entries: {
"mock-threaded": {
enabled: true,
},
},
},
});
enableThreadedFallback();
expect(resolveSessionConversationRef("agent:main:mock-threaded:group:room:topic:42")).toEqual(
expect.objectContaining({