diff --git a/extensions/msteams/src/monitor.conversation-allowlist.lifecycle.test.ts b/extensions/msteams/src/monitor.conversation-allowlist.lifecycle.test.ts index 2b6d5ee8891f..d9a33ac46462 100644 --- a/extensions/msteams/src/monitor.conversation-allowlist.lifecycle.test.ts +++ b/extensions/msteams/src/monitor.conversation-allowlist.lifecycle.test.ts @@ -45,30 +45,12 @@ const keepHttpServerTaskAliveMock = vi.hoisted(() => }), ); -vi.mock("../runtime-api.js", async () => { - const { normalizeOptionalString } = await import("openclaw/plugin-sdk/string-coerce-runtime"); +vi.mock("../runtime-api.js", async (importOriginal) => { + const actual = await importOriginal(); return { - DEFAULT_WEBHOOK_MAX_BODY_BYTES: 1024 * 1024, + ...actual, isDangerousNameMatchingEnabled, - normalizeSecretInputString: normalizeOptionalString, - hasConfiguredSecretInput: (value: unknown) => - typeof value === "string" && value.trim().length > 0, - normalizeResolvedSecretInputString: (params: { value?: unknown }) => - typeof params?.value === "string" && params.value.trim() ? params.value.trim() : undefined, keepHttpServerTaskAlive: keepHttpServerTaskAliveMock, - mergeAllowlist: (params: { existing?: string[]; additions: string[] }) => - Array.from(new Set([...(params.existing ?? []), ...params.additions])), - resolveChannelMediaMaxBytes: (params: { - cfg: OpenClawConfig; - resolveChannelLimitMb: (context: { cfg: OpenClawConfig }) => number | undefined; - }) => { - const mediaMaxMb = - params.resolveChannelLimitMb({ cfg: params.cfg }) ?? - params.cfg.agents?.defaults?.mediaMaxMb; - return typeof mediaMaxMb === "number" && mediaMaxMb > 0 - ? Math.floor(mediaMaxMb * 1024 * 1024) - : undefined; - }, summarizeMapping: vi.fn(), }; }); diff --git a/extensions/slack/src/monitor/provider.reconnect.test.ts b/extensions/slack/src/monitor/provider.reconnect.test.ts index e246187f186d..520ff878b43f 100644 --- a/extensions/slack/src/monitor/provider.reconnect.test.ts +++ b/extensions/slack/src/monitor/provider.reconnect.test.ts @@ -231,18 +231,6 @@ describe("slack socket reconnect helpers", () => { await expect(waiter).resolves.toEqual({ event: "disconnect" }); }); - it("leaves transient socket errors to the native reconnect lifecycle", async () => { - const client = new FakeEmitter(); - const app = { receiver: { client } }; - const err = new Error("dns down"); - - const waiter = waitForSlackSocketDisconnect(app as never); - client.emit("error", err); - client.emit("disconnected"); - - await expect(waiter).resolves.toEqual({ event: "disconnect" }); - }); - it("installs the disconnect waiter before socket start completes", async () => { const client = new FakeEmitter(); const app = {