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

test(perf): trim telegram webhook artificial delay windows

Browse Source
This commit is contained in:
Peter Steinberger
2026-03-02 17:48:36 +00:00
parent 54382a66b4
commit 8ae8056622
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/telegram/webhook.test.ts
View File

@@ -412,7 +412,7 @@ describe("startTelegramWebhook", () => {
it("keeps webhook payload readable when callback delays body read", async () => { it("keeps webhook payload readable when callback delays body read", async () => {
handlerSpy.mockImplementationOnce(async (...args: unknown[]) => { handlerSpy.mockImplementationOnce(async (...args: unknown[]) => {
const [update, reply] = args as [unknown, (json: string) => Promise<void>]; const [update, reply] = args as [unknown, (json: string) => Promise<void>];
await sleep(50); await sleep(10);
await reply(JSON.stringify(update)); await reply(JSON.stringify(update));
}); });
@@ -439,7 +439,7 @@ describe("startTelegramWebhook", () => {
const seenPayloads: string[] = []; const seenPayloads: string[] = [];
const delayedHandler = async (...args: unknown[]) => { const delayedHandler = async (...args: unknown[]) => {
const [update, reply] = args as [unknown, (json: string) => Promise<void>]; const [update, reply] = args as [unknown, (json: string) => Promise<void>];
await sleep(50); await sleep(10);
seenPayloads.push(JSON.stringify(update)); seenPayloads.push(JSON.stringify(update));
await reply("ok"); await reply("ok");
}; };
@@ -483,7 +483,7 @@ describe("startTelegramWebhook", () => {
) => { ) => {
seenUpdates.push(update); seenUpdates.push(update);
void (async () => { void (async () => {
await sleep(50); await sleep(10);
await reply("ok"); await reply("ok");
})(); })();
}, },
@@ -597,9 +597,7 @@ describe("startTelegramWebhook", () => {
}); });
abort.abort(); abort.abort();
await sleep(25); await vi.waitFor(() => expect(deleteWebhookSpy).toHaveBeenCalledTimes(1));
expect(deleteWebhookSpy).toHaveBeenCalledTimes(1);
expect(deleteWebhookSpy).toHaveBeenCalledWith({ drop_pending_updates: false }); expect(deleteWebhookSpy).toHaveBeenCalledWith({ drop_pending_updates: false });
}); });
}); });