File size: 3,406 Bytes
fc93158 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 | import { afterEach, describe, expect, it, vi } from "vitest";
const readFileSyncMock = vi.hoisted(() => vi.fn());
const listCatalogMock = vi.hoisted(() => vi.fn());
const listPluginsMock = vi.hoisted(() => vi.fn());
const ensurePluginRegistryLoadedMock = vi.hoisted(() => vi.fn());
vi.mock("node:fs", async () => {
const actual = await vi.importActual<typeof import("node:fs")>("node:fs");
const base = ("default" in actual ? actual.default : actual) as Record<string, unknown>;
return {
...actual,
default: {
...base,
readFileSync: readFileSyncMock,
},
readFileSync: readFileSyncMock,
};
});
vi.mock("../channels/registry.js", () => ({
CHAT_CHANNEL_ORDER: ["telegram", "discord"],
}));
vi.mock("../channels/plugins/catalog.js", () => ({
listChannelPluginCatalogEntries: listCatalogMock,
}));
vi.mock("../channels/plugins/index.js", () => ({
listChannelPlugins: listPluginsMock,
}));
vi.mock("./plugin-registry.js", () => ({
ensurePluginRegistryLoaded: ensurePluginRegistryLoadedMock,
}));
async function loadModule() {
return await import("./channel-options.js");
}
describe("resolveCliChannelOptions", () => {
afterEach(() => {
delete process.env.OPENCLAW_EAGER_CHANNEL_OPTIONS;
vi.resetModules();
vi.clearAllMocks();
});
it("uses precomputed startup metadata when available", async () => {
readFileSyncMock.mockReturnValue(
JSON.stringify({ channelOptions: ["cached", "telegram", "cached"] }),
);
listCatalogMock.mockReturnValue([{ id: "catalog-only" }]);
const mod = await loadModule();
expect(mod.resolveCliChannelOptions()).toEqual(["cached", "telegram", "catalog-only"]);
expect(listCatalogMock).toHaveBeenCalledOnce();
});
it("falls back to dynamic catalog resolution when metadata is missing", async () => {
readFileSyncMock.mockImplementation(() => {
throw new Error("ENOENT");
});
listCatalogMock.mockReturnValue([{ id: "feishu" }, { id: "telegram" }]);
const mod = await loadModule();
expect(mod.resolveCliChannelOptions()).toEqual(["telegram", "discord", "feishu"]);
expect(listCatalogMock).toHaveBeenCalledOnce();
});
it("respects eager mode and includes loaded plugin ids", async () => {
process.env.OPENCLAW_EAGER_CHANNEL_OPTIONS = "1";
readFileSyncMock.mockReturnValue(JSON.stringify({ channelOptions: ["cached"] }));
listCatalogMock.mockReturnValue([{ id: "zalo" }]);
listPluginsMock.mockReturnValue([{ id: "custom-a" }, { id: "custom-b" }]);
const mod = await loadModule();
expect(mod.resolveCliChannelOptions()).toEqual([
"telegram",
"discord",
"zalo",
"custom-a",
"custom-b",
]);
expect(ensurePluginRegistryLoadedMock).toHaveBeenCalledOnce();
expect(listPluginsMock).toHaveBeenCalledOnce();
});
it("keeps dynamic catalog resolution when external catalog env is set", async () => {
process.env.OPENCLAW_PLUGIN_CATALOG_PATHS = "/tmp/plugins-catalog.json";
readFileSyncMock.mockReturnValue(JSON.stringify({ channelOptions: ["cached", "telegram"] }));
listCatalogMock.mockReturnValue([{ id: "custom-catalog" }]);
const mod = await loadModule();
expect(mod.resolveCliChannelOptions()).toEqual(["cached", "telegram", "custom-catalog"]);
expect(listCatalogMock).toHaveBeenCalledOnce();
delete process.env.OPENCLAW_PLUGIN_CATALOG_PATHS;
});
});
|