mirror of
https://github.com/openclaw/openclaw.git
synced 2026-05-08 04:01:23 +00:00
refactor(test): reuse web auto-reply harness
This commit is contained in:
Peter Steinberger
@@ -1,109 +1,20 @@
|
|||||||
import "./test-helpers.js";
|
|
||||||
import fs from "node:fs/promises";
|
import fs from "node:fs/promises";
|
||||||
import os from "node:os";
|
import os from "node:os";
|
||||||
import path from "node:path";
|
import path from "node:path";
|
||||||
import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
|
import { describe, expect, it, vi } from "vitest";
|
||||||
|
|
||||||
vi.mock("../agents/pi-embedded.js", () => ({
|
|
||||||
abortEmbeddedPiRun: vi.fn().mockReturnValue(false),
|
|
||||||
isEmbeddedPiRunActive: vi.fn().mockReturnValue(false),
|
|
||||||
isEmbeddedPiRunStreaming: vi.fn().mockReturnValue(false),
|
|
||||||
runEmbeddedPiAgent: vi.fn(),
|
|
||||||
queueEmbeddedPiMessage: vi.fn().mockReturnValue(false),
|
|
||||||
resolveEmbeddedSessionLane: (key: string) => `session:${key.trim() || "main"}`,
|
|
||||||
}));
|
|
||||||
|
|
||||||
import { resetInboundDedupe } from "../auto-reply/reply/inbound-dedupe.js";
|
|
||||||
import { resetLogger, setLoggerOverride } from "../logging.js";
|
|
||||||
import { monitorWebChannel } from "./auto-reply.js";
|
import { monitorWebChannel } from "./auto-reply.js";
|
||||||
import { resetBaileysMocks, resetLoadConfigMock, setLoadConfigMock } from "./test-helpers.js";
|
import {
|
||||||
|
installWebAutoReplyTestHomeHooks,
|
||||||
|
installWebAutoReplyUnitTestHooks,
|
||||||
|
resetLoadConfigMock,
|
||||||
|
rmDirWithRetries,
|
||||||
|
setLoadConfigMock,
|
||||||
|
} from "./auto-reply.test-harness.js";
|
||||||
|
|
||||||
let previousHome: string | undefined;
|
installWebAutoReplyTestHomeHooks();
|
||||||
let tempHome: string | undefined;
|
|
||||||
|
|
||||||
const rmDirWithRetries = async (dir: string): Promise<void> => {
|
|
||||||
// Some tests can leave async session-store writes in-flight; recursive deletion can race and throw ENOTEMPTY.
|
|
||||||
for (let attempt = 0; attempt < 10; attempt += 1) {
|
|
||||||
try {
|
|
||||||
await fs.rm(dir, { recursive: true, force: true });
|
|
||||||
return;
|
|
||||||
} catch (err) {
|
|
||||||
const code =
|
|
||||||
err && typeof err === "object" && "code" in err
|
|
||||||
? String((err as { code?: unknown }).code)
|
|
||||||
: null;
|
|
||||||
if (code === "ENOTEMPTY" || code === "EBUSY" || code === "EPERM") {
|
|
||||||
await new Promise((resolve) => setTimeout(resolve, 5));
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
throw err;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
await fs.rm(dir, { recursive: true, force: true });
|
|
||||||
};
|
|
||||||
|
|
||||||
beforeEach(async () => {
|
|
||||||
resetInboundDedupe();
|
|
||||||
previousHome = process.env.HOME;
|
|
||||||
tempHome = await fs.mkdtemp(path.join(os.tmpdir(), "openclaw-web-home-"));
|
|
||||||
process.env.HOME = tempHome;
|
|
||||||
});
|
|
||||||
|
|
||||||
afterEach(async () => {
|
|
||||||
process.env.HOME = previousHome;
|
|
||||||
if (tempHome) {
|
|
||||||
await rmDirWithRetries(tempHome);
|
|
||||||
tempHome = undefined;
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
const _makeSessionStore = async (
|
|
||||||
entries: Record<string, unknown> = {},
|
|
||||||
): Promise<{ storePath: string; cleanup: () => Promise<void> }> => {
|
|
||||||
const dir = await fs.mkdtemp(path.join(os.tmpdir(), "openclaw-session-"));
|
|
||||||
const storePath = path.join(dir, "sessions.json");
|
|
||||||
await fs.writeFile(storePath, JSON.stringify(entries));
|
|
||||||
const cleanup = async () => {
|
|
||||||
// Session store writes can be in-flight when the test finishes (e.g. updateLastRoute
|
|
||||||
// after a message flush). `fs.rm({ recursive })` can race and throw ENOTEMPTY.
|
|
||||||
for (let attempt = 0; attempt < 10; attempt += 1) {
|
|
||||||
try {
|
|
||||||
await fs.rm(dir, { recursive: true, force: true });
|
|
||||||
return;
|
|
||||||
} catch (err) {
|
|
||||||
const code =
|
|
||||||
err && typeof err === "object" && "code" in err
|
|
||||||
? String((err as { code?: unknown }).code)
|
|
||||||
: null;
|
|
||||||
if (code === "ENOTEMPTY" || code === "EBUSY" || code === "EPERM") {
|
|
||||||
await new Promise((resolve) => setTimeout(resolve, 5));
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
throw err;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
await fs.rm(dir, { recursive: true, force: true });
|
|
||||||
};
|
|
||||||
return {
|
|
||||||
storePath,
|
|
||||||
cleanup,
|
|
||||||
};
|
|
||||||
};
|
|
||||||
|
|
||||||
describe("web auto-reply", () => {
|
describe("web auto-reply", () => {
|
||||||
beforeEach(() => {
|
installWebAutoReplyUnitTestHooks();
|
||||||
vi.clearAllMocks();
|
|
||||||
resetBaileysMocks();
|
|
||||||
resetLoadConfigMock();
|
|
||||||
});
|
|
||||||
|
|
||||||
afterEach(() => {
|
|
||||||
resetLogger();
|
|
||||||
setLoggerOverride(null);
|
|
||||||
vi.useRealTimers();
|
|
||||||
});
|
|
||||||
|
|
||||||
it("requires mention in group chats and injects history when replying", async () => {
|
it("requires mention in group chats and injects history when replying", async () => {
|
||||||
const sendMedia = vi.fn();
|
const sendMedia = vi.fn();
|
||||||
|
|||||||
@@ -1,110 +1,16 @@
|
|||||||
import "./test-helpers.js";
|
import { describe, expect, it, vi } from "vitest";
|
||||||
import fs from "node:fs/promises";
|
|
||||||
import os from "node:os";
|
|
||||||
import path from "node:path";
|
|
||||||
import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
|
|
||||||
|
|
||||||
vi.mock("../agents/pi-embedded.js", () => ({
|
|
||||||
abortEmbeddedPiRun: vi.fn().mockReturnValue(false),
|
|
||||||
isEmbeddedPiRunActive: vi.fn().mockReturnValue(false),
|
|
||||||
isEmbeddedPiRunStreaming: vi.fn().mockReturnValue(false),
|
|
||||||
runEmbeddedPiAgent: vi.fn(),
|
|
||||||
queueEmbeddedPiMessage: vi.fn().mockReturnValue(false),
|
|
||||||
resolveEmbeddedSessionLane: (key: string) => `session:${key.trim() || "main"}`,
|
|
||||||
}));
|
|
||||||
|
|
||||||
import { resetInboundDedupe } from "../auto-reply/reply/inbound-dedupe.js";
|
|
||||||
import { resetLogger, setLoggerOverride } from "../logging.js";
|
|
||||||
import { sleep } from "../utils.js";
|
|
||||||
import { monitorWebChannel } from "./auto-reply.js";
|
import { monitorWebChannel } from "./auto-reply.js";
|
||||||
import { resetBaileysMocks, resetLoadConfigMock, setLoadConfigMock } from "./test-helpers.js";
|
import {
|
||||||
|
installWebAutoReplyTestHomeHooks,
|
||||||
|
installWebAutoReplyUnitTestHooks,
|
||||||
|
resetLoadConfigMock,
|
||||||
|
setLoadConfigMock,
|
||||||
|
} from "./auto-reply.test-harness.js";
|
||||||
|
|
||||||
let previousHome: string | undefined;
|
installWebAutoReplyTestHomeHooks();
|
||||||
let tempHome: string | undefined;
|
|
||||||
|
|
||||||
const rmDirWithRetries = async (dir: string): Promise<void> => {
|
|
||||||
// Some tests can leave async session-store writes in-flight; recursive deletion can race and throw ENOTEMPTY.
|
|
||||||
for (let attempt = 0; attempt < 10; attempt += 1) {
|
|
||||||
try {
|
|
||||||
await fs.rm(dir, { recursive: true, force: true });
|
|
||||||
return;
|
|
||||||
} catch (err) {
|
|
||||||
const code =
|
|
||||||
err && typeof err === "object" && "code" in err
|
|
||||||
? String((err as { code?: unknown }).code)
|
|
||||||
: null;
|
|
||||||
if (code === "ENOTEMPTY" || code === "EBUSY" || code === "EPERM") {
|
|
||||||
await sleep(25);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
throw err;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
await fs.rm(dir, { recursive: true, force: true });
|
|
||||||
};
|
|
||||||
|
|
||||||
beforeEach(async () => {
|
|
||||||
resetInboundDedupe();
|
|
||||||
previousHome = process.env.HOME;
|
|
||||||
tempHome = await fs.mkdtemp(path.join(os.tmpdir(), "openclaw-web-home-"));
|
|
||||||
process.env.HOME = tempHome;
|
|
||||||
});
|
|
||||||
|
|
||||||
afterEach(async () => {
|
|
||||||
process.env.HOME = previousHome;
|
|
||||||
if (tempHome) {
|
|
||||||
await rmDirWithRetries(tempHome);
|
|
||||||
tempHome = undefined;
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
const _makeSessionStore = async (
|
|
||||||
entries: Record<string, unknown> = {},
|
|
||||||
): Promise<{ storePath: string; cleanup: () => Promise<void> }> => {
|
|
||||||
const dir = await fs.mkdtemp(path.join(os.tmpdir(), "openclaw-session-"));
|
|
||||||
const storePath = path.join(dir, "sessions.json");
|
|
||||||
await fs.writeFile(storePath, JSON.stringify(entries));
|
|
||||||
const cleanup = async () => {
|
|
||||||
// Session store writes can be in-flight when the test finishes (e.g. updateLastRoute
|
|
||||||
// after a message flush). `fs.rm({ recursive })` can race and throw ENOTEMPTY.
|
|
||||||
for (let attempt = 0; attempt < 10; attempt += 1) {
|
|
||||||
try {
|
|
||||||
await fs.rm(dir, { recursive: true, force: true });
|
|
||||||
return;
|
|
||||||
} catch (err) {
|
|
||||||
const code =
|
|
||||||
err && typeof err === "object" && "code" in err
|
|
||||||
? String((err as { code?: unknown }).code)
|
|
||||||
: null;
|
|
||||||
if (code === "ENOTEMPTY" || code === "EBUSY" || code === "EPERM") {
|
|
||||||
await new Promise((resolve) => setTimeout(resolve, 5));
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
throw err;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
await fs.rm(dir, { recursive: true, force: true });
|
|
||||||
};
|
|
||||||
return {
|
|
||||||
storePath,
|
|
||||||
cleanup,
|
|
||||||
};
|
|
||||||
};
|
|
||||||
|
|
||||||
describe("web auto-reply", () => {
|
describe("web auto-reply", () => {
|
||||||
beforeEach(() => {
|
installWebAutoReplyUnitTestHooks();
|
||||||
vi.clearAllMocks();
|
|
||||||
resetBaileysMocks();
|
|
||||||
resetLoadConfigMock();
|
|
||||||
});
|
|
||||||
|
|
||||||
afterEach(() => {
|
|
||||||
resetLogger();
|
|
||||||
setLoggerOverride(null);
|
|
||||||
vi.useRealTimers();
|
|
||||||
});
|
|
||||||
|
|
||||||
it("uses per-agent mention patterns for group gating", async () => {
|
it("uses per-agent mention patterns for group gating", async () => {
|
||||||
const sendMedia = vi.fn();
|
const sendMedia = vi.fn();
|
||||||
|
|||||||
Reference in New Issue
Block a user