File size: 2,344 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 | import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
const { startGmailWatcherMock } = vi.hoisted(() => ({
startGmailWatcherMock: vi.fn(),
}));
vi.mock("./gmail-watcher.js", () => ({
startGmailWatcher: startGmailWatcherMock,
}));
import { startGmailWatcherWithLogs } from "./gmail-watcher-lifecycle.js";
describe("startGmailWatcherWithLogs", () => {
const log = {
info: vi.fn(),
warn: vi.fn(),
error: vi.fn(),
};
beforeEach(() => {
startGmailWatcherMock.mockClear();
log.info.mockClear();
log.warn.mockClear();
log.error.mockClear();
delete process.env.OPENCLAW_SKIP_GMAIL_WATCHER;
});
afterEach(() => {
delete process.env.OPENCLAW_SKIP_GMAIL_WATCHER;
});
it("logs startup success", async () => {
startGmailWatcherMock.mockResolvedValue({ started: true, reason: undefined });
await startGmailWatcherWithLogs({
cfg: {},
log,
});
expect(log.info).toHaveBeenCalledWith("gmail watcher started");
expect(log.warn).not.toHaveBeenCalled();
expect(log.error).not.toHaveBeenCalled();
});
it("logs actionable non-start reason", async () => {
startGmailWatcherMock.mockResolvedValue({ started: false, reason: "auth failed" });
await startGmailWatcherWithLogs({
cfg: {},
log,
});
expect(log.warn).toHaveBeenCalledWith("gmail watcher not started: auth failed");
});
it("suppresses expected non-start reasons", async () => {
startGmailWatcherMock.mockResolvedValue({
started: false,
reason: "hooks not enabled",
});
await startGmailWatcherWithLogs({
cfg: {},
log,
});
expect(log.warn).not.toHaveBeenCalled();
});
it("supports skip callback when watcher is disabled", async () => {
process.env.OPENCLAW_SKIP_GMAIL_WATCHER = "1";
const onSkipped = vi.fn();
await startGmailWatcherWithLogs({
cfg: {},
log,
onSkipped,
});
expect(startGmailWatcherMock).not.toHaveBeenCalled();
expect(onSkipped).toHaveBeenCalledTimes(1);
});
it("logs startup errors", async () => {
startGmailWatcherMock.mockRejectedValue(new Error("boom"));
await startGmailWatcherWithLogs({
cfg: {},
log,
});
expect(log.error).toHaveBeenCalledWith("gmail watcher failed to start: Error: boom");
});
});
|