test(telegram): wait for startup probe slots

steipete · steipete · commit 0a8af67c11bb · 2026-05-24T11:21:15.000+01:00
diff --git a/extensions/telegram/src/channel.gateway.test.ts b/extensions/telegram/src/channel.gateway.test.ts
@@ -145,12 +145,13 @@ function sendMessageOptionsAt(index: number): Record<string, unknown> {
   return options;
 }
 
-async function waitForCondition(check: () => boolean, message: string, attempts = 100) {
-  for (let i = 0; i < attempts; i += 1) {
+async function waitForCondition(check: () => boolean, message: string, timeoutMs = 5_000) {
+  const deadline = Date.now() + timeoutMs;
+  while (Date.now() < deadline) {
     if (check()) {
       return;
     }
-    await new Promise((resolve) => setImmediate(resolve));
+    await new Promise((resolve) => setTimeout(resolve, 1));
   }
   throw new Error(message);
 }

Original file line number	Diff line number	Diff line change
`@@ -145,12 +145,13 @@ function sendMessageOptionsAt(index: number): Record<string, unknown> {`
`145`	`145`	`return options;`
`146`	`146`	`}`
`147`	`147`
`148`		`-async function waitForCondition(check: () => boolean, message: string, attempts = 100) {`
`149`		`- for (let i = 0; i < attempts; i += 1) {`
	`148`	`+async function waitForCondition(check: () => boolean, message: string, timeoutMs = 5_000) {`
	`149`	`+ const deadline = Date.now() + timeoutMs;`
	`150`	`+ while (Date.now() < deadline) {`
`150`	`151`	`if (check()) {`
`151`	`152`	`return;`
`152`	`153`	`}`
`153`		`- await new Promise((resolve) => setImmediate(resolve));`
	`154`	`+ await new Promise((resolve) => setTimeout(resolve, 1));`
`154`	`155`	`}`
`155`	`156`	`throw new Error(message);`
`156`	`157`	`}`