github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-09 12:57:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(web): stabilize processMessage inbound contract cleanup

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-15 00:15:49 +00:00
parent ef91cd8479
commit a6fda4ae8e
1 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/web/auto-reply/monitor/process-message.inbound-contract.test.ts
View File

@@ -8,6 +8,7 @@ let capturedCtx: unknown;
let capturedDispatchParams: unknown; let capturedDispatchParams: unknown;
let sessionDir: string | undefined; let sessionDir: string | undefined;
let sessionStorePath: string; let sessionStorePath: string;
let backgroundTasks: Set<Promise<unknown>>;
vi.mock("../../../auto-reply/reply/provider-dispatcher.js", () => ({ vi.mock("../../../auto-reply/reply/provider-dispatcher.js", () => ({
// oxlint-disable-next-line typescript/no-explicit-any // oxlint-disable-next-line typescript/no-explicit-any
@@ -19,7 +20,12 @@ vi.mock("../../../auto-reply/reply/provider-dispatcher.js", () => ({
})); }));
vi.mock("./last-route.js", () => ({ vi.mock("./last-route.js", () => ({
trackBackgroundTask: () => undefined, trackBackgroundTask: (tasks: Set<Promise<unknown>>, task: Promise<unknown>) => {
tasks.add(task);
task.finally(() => {
tasks.delete(task);
});
},
updateLastRouteInBackground: vi.fn(), updateLastRouteInBackground: vi.fn(),
})); }));
@@ -29,11 +35,13 @@ describe("web processMessage inbound contract", () => {
beforeEach(async () => { beforeEach(async () => {
capturedCtx = undefined; capturedCtx = undefined;
capturedDispatchParams = undefined; capturedDispatchParams = undefined;
backgroundTasks = new Set();
sessionDir = await fs.mkdtemp(path.join(os.tmpdir(), "openclaw-process-message-")); sessionDir = await fs.mkdtemp(path.join(os.tmpdir(), "openclaw-process-message-"));
sessionStorePath = path.join(sessionDir, "sessions.json"); sessionStorePath = path.join(sessionDir, "sessions.json");
}); });
afterEach(async () => { afterEach(async () => {
await Promise.allSettled(Array.from(backgroundTasks));
if (sessionDir) { if (sessionDir) {
await fs.rm(sessionDir, { recursive: true, force: true }); await fs.rm(sessionDir, { recursive: true, force: true });
sessionDir = undefined; sessionDir = undefined;
@@ -73,7 +81,7 @@ describe("web processMessage inbound contract", () => {
replyResolver: (async () => undefined) as any, replyResolver: (async () => undefined) as any,
// oxlint-disable-next-line typescript/no-explicit-any // oxlint-disable-next-line typescript/no-explicit-any
replyLogger: { info: () => {}, warn: () => {}, error: () => {}, debug: () => {} } as any, replyLogger: { info: () => {}, warn: () => {}, error: () => {}, debug: () => {} } as any,
backgroundTasks: new Set(), backgroundTasks,
rememberSentText: (_text: string | undefined, _opts: unknown) => {}, rememberSentText: (_text: string | undefined, _opts: unknown) => {},
echoHas: () => false, echoHas: () => false,
echoForget: () => {}, echoForget: () => {},
@@ -119,7 +127,7 @@ describe("web processMessage inbound contract", () => {
replyResolver: (async () => undefined) as any, replyResolver: (async () => undefined) as any,
// oxlint-disable-next-line typescript/no-explicit-any // oxlint-disable-next-line typescript/no-explicit-any
replyLogger: { info: () => {}, warn: () => {}, error: () => {}, debug: () => {} } as any, replyLogger: { info: () => {}, warn: () => {}, error: () => {}, debug: () => {} } as any,
backgroundTasks: new Set(), backgroundTasks,
rememberSentText: (_text: string | undefined, _opts: unknown) => {}, rememberSentText: (_text: string | undefined, _opts: unknown) => {},
echoHas: () => false, echoHas: () => false,
echoForget: () => {}, echoForget: () => {},
@@ -181,7 +189,7 @@ describe("web processMessage inbound contract", () => {
replyResolver: (async () => undefined) as any, replyResolver: (async () => undefined) as any,
// oxlint-disable-next-line typescript/no-explicit-any // oxlint-disable-next-line typescript/no-explicit-any
replyLogger: { info: () => {}, warn: () => {}, error: () => {}, debug: () => {} } as any, replyLogger: { info: () => {}, warn: () => {}, error: () => {}, debug: () => {} } as any,
backgroundTasks: new Set(), backgroundTasks,
rememberSentText: (_text: string | undefined, _opts: unknown) => {}, rememberSentText: (_text: string | undefined, _opts: unknown) => {},
echoHas: () => false, echoHas: () => false,
echoForget: () => {}, echoForget: () => {},
@@ -246,7 +254,7 @@ describe("web processMessage inbound contract", () => {
replyResolver: (async () => undefined) as any, replyResolver: (async () => undefined) as any,
// oxlint-disable-next-line typescript/no-explicit-any // oxlint-disable-next-line typescript/no-explicit-any
replyLogger: { info: () => {}, warn: () => {}, error: () => {}, debug: () => {} } as any, replyLogger: { info: () => {}, warn: () => {}, error: () => {}, debug: () => {} } as any,
backgroundTasks: new Set(), backgroundTasks,
rememberSentText: (_text: string | undefined, _opts: unknown) => {}, rememberSentText: (_text: string | undefined, _opts: unknown) => {},
echoHas: () => false, echoHas: () => false,
echoForget: () => {}, echoForget: () => {},