vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-28 06:29:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(telegram): wait for polling watchdog deterministically

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-22 19:50:45 +01:00
parent 0241a6e7ae
commit 7c9127c94d
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
extensions/telegram/src/polling-session.test.ts
View File

@@ -95,6 +95,8 @@ type WorkerMessageListener = (message: TelegramIngressWorkerMessage) => void;
type AsyncVoidFn = () => Promise<void>;
type MockCallSource = { mock: { calls: Array<Array<unknown>> } };
const POLLING_TEST_WATCHDOG_INTERVAL_MS = 30_000;
function mockObjectArg(
source: MockCallSource,
label: string,
@@ -155,8 +157,10 @@ function makeBot() {
function installPollingStallWatchdogHarness(dateNowSequence: readonly number[] = [0, 0]) {
let watchdog: (() => void) | undefined;
const setIntervalSpy = vi.spyOn(globalThis, "setInterval").mockImplementation((fn) => {
watchdog = fn as () => void;
const setIntervalSpy = vi.spyOn(globalThis, "setInterval").mockImplementation((fn, delay) => {
if (delay === POLLING_TEST_WATCHDOG_INTERVAL_MS) {
watchdog = fn as () => void;
}
return 1 as unknown as ReturnType<typeof setInterval>;
});
const clearIntervalSpy = vi.spyOn(globalThis, "clearInterval").mockImplementation(() => {});
@@ -173,7 +177,7 @@ function installPollingStallWatchdogHarness(dateNowSequence: readonly number[] =
return {
async waitForWatchdog() {
for (let attempt = 0; attempt < 20; attempt += 1) {
for (let attempt = 0; attempt < 200; attempt += 1) {
if (watchdog) {
break;
}