github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-10 20:34:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(test): table telegram heartbeat account cases

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-14 22:33:25 +00:00
parent 8217d77ece
commit 937e1c21f2
1 changed files with 36 additions and 101 deletions
Download Patch File Download Diff File Expand all files Collapse all files

137
src/infra/heartbeat-runner.respects-ackmaxchars-heartbeat-acks.test.ts
View File

@@ -461,16 +461,20 @@ describe("resolveHeartbeatIntervalMs", () => {
} }
}); });
it("passes through accountId for telegram heartbeats", async () => { async function expectTelegramHeartbeatAccountId(params: {
heartbeat: Record<string, unknown>;
telegram: Record<string, unknown>;
expectedAccountId: string | undefined;
}): Promise<void> {
await withTempTelegramHeartbeatSandbox(async ({ tmpDir, storePath, replySpy }) => { await withTempTelegramHeartbeatSandbox(async ({ tmpDir, storePath, replySpy }) => {
const cfg: OpenClawConfig = { const cfg: OpenClawConfig = {
agents: { agents: {
defaults: { defaults: {
workspace: tmpDir, workspace: tmpDir,
heartbeat: { every: "5m", target: "telegram" }, heartbeat: params.heartbeat as never,
}, },
}, },
channels: { telegram: { botToken: "test-bot-token-123" } }, channels: { telegram: params.telegram as never },
session: { store: storePath }, session: { store: storePath },
}; };
const sessionKey = resolveMainSessionKey(cfg); const sessionKey = resolveMainSessionKey(cfg);
@@ -500,108 +504,39 @@ describe("resolveHeartbeatIntervalMs", () => {
expect(sendTelegram).toHaveBeenCalledWith( expect(sendTelegram).toHaveBeenCalledWith(
"123456", "123456",
"Hello from heartbeat", "Hello from heartbeat",
expect.objectContaining({ accountId: undefined, verbose: false }), expect.objectContaining({ accountId: params.expectedAccountId, verbose: false }),
); );
}); });
}); }
it("uses explicit heartbeat accountId for telegram delivery", async () => { it.each([
await withTempTelegramHeartbeatSandbox(async ({ tmpDir, storePath, replySpy }) => { {
const cfg: OpenClawConfig = { title: "passes through accountId for telegram heartbeats",
agents: { heartbeat: { every: "5m", target: "telegram" },
defaults: { telegram: { botToken: "test-bot-token-123" },
workspace: tmpDir, expectedAccountId: undefined,
heartbeat: { every: "5m", target: "telegram", accountId: "work" }, },
}, {
title: "does not pre-resolve telegram accountId (allows config-only account tokens)",
heartbeat: { every: "5m", target: "telegram" },
telegram: {
accounts: {
work: { botToken: "test-bot-token-123" },
}, },
channels: { },
telegram: { expectedAccountId: undefined,
accounts: { },
work: { botToken: "test-bot-token-123" }, {
}, title: "uses explicit heartbeat accountId for telegram delivery",
}, heartbeat: { every: "5m", target: "telegram", accountId: "work" },
telegram: {
accounts: {
work: { botToken: "test-bot-token-123" },
}, },
session: { store: storePath }, },
}; expectedAccountId: "work",
const sessionKey = resolveMainSessionKey(cfg); },
])("$title", async ({ heartbeat, telegram, expectedAccountId }) => {
await seedSessionStore(storePath, sessionKey, { await expectTelegramHeartbeatAccountId({ heartbeat, telegram, expectedAccountId });
lastChannel: "telegram",
lastProvider: "telegram",
lastTo: "123456",
});
replySpy.mockResolvedValue({ text: "Hello from heartbeat" });
const sendTelegram = vi.fn().mockResolvedValue({
messageId: "m1",
chatId: "123456",
});
await runHeartbeatOnce({
cfg,
deps: {
sendTelegram,
getQueueSize: () => 0,
nowMs: () => 0,
},
});
expect(sendTelegram).toHaveBeenCalledTimes(1);
expect(sendTelegram).toHaveBeenCalledWith(
"123456",
"Hello from heartbeat",
expect.objectContaining({ accountId: "work", verbose: false }),
);
});
});
it("does not pre-resolve telegram accountId (allows config-only account tokens)", async () => {
await withTempTelegramHeartbeatSandbox(async ({ tmpDir, storePath, replySpy }) => {
const cfg: OpenClawConfig = {
agents: {
defaults: {
workspace: tmpDir,
heartbeat: { every: "5m", target: "telegram" },
},
},
channels: {
telegram: {
accounts: {
work: { botToken: "test-bot-token-123" },
},
},
},
session: { store: storePath },
};
const sessionKey = resolveMainSessionKey(cfg);
await seedSessionStore(storePath, sessionKey, {
lastChannel: "telegram",
lastProvider: "telegram",
lastTo: "123456",
});
replySpy.mockResolvedValue({ text: "Hello from heartbeat" });
const sendTelegram = vi.fn().mockResolvedValue({
messageId: "m1",
chatId: "123456",
});
await runHeartbeatOnce({
cfg,
deps: {
sendTelegram,
getQueueSize: () => 0,
nowMs: () => 0,
},
});
expect(sendTelegram).toHaveBeenCalledTimes(1);
expect(sendTelegram).toHaveBeenCalledWith(
"123456",
"Hello from heartbeat",
expect.objectContaining({ accountId: undefined, verbose: false }),
);
});
}); });
}); });