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

test(telegram): update monitor test for #69787 transport rebuild on 409

Browse Source 
Sibling test in monitor.test.ts asserted the pre-fix behavior (single
transport reused across cycles on 409). My #69787 change rebuilds the
transport on 409 so Telegram sees a fresh TCP socket — update the
assertion to match.

Two transports are now expected: the initial one plus the rebuild
after the conflict.
This commit is contained in:
HCL
2026-04-22 17:18:08 +08:00
committed by Peter Steinberger
parent 83a906c95c
commit 3a11435c7d
1 changed files with 18 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
extensions/telegram/src/monitor.test.ts
View File

@@ -787,16 +787,25 @@ describe("monitorTelegramProvider (grammY)", () => {
await expectOffsetConfirmationSkipped(Number.MAX_SAFE_INTEGER);
});
it("resets webhookCleared latch on 409 conflict so deleteWebhook re-runs", async () => {
it("resets webhookCleared latch on 409 conflict so deleteWebhook re-runs, and rebuilds transport for a fresh TCP socket (#69787)", async () => {
const abort = new AbortController();
api.deleteWebhook.mockReset();
api.deleteWebhook.mockResolvedValue(true);
const telegramTransport = {
const telegramTransport1 = {
fetch: globalThis.fetch,
sourceFetch: globalThis.fetch,
close: vi.fn(async () => undefined),
};
resolveTelegramTransportSpy.mockReturnValueOnce(telegramTransport);
const telegramTransport2 = {
fetch: globalThis.fetch,
sourceFetch: globalThis.fetch,
close: vi.fn(async () => undefined),
};
// First call is the initial cycle; second call is the post-409 rebuild
// that forces a fresh TCP connection (see #69787 polling-session fix).
resolveTelegramTransportSpy
.mockReturnValueOnce(telegramTransport1)
.mockReturnValueOnce(telegramTransport2);
const conflictError = Object.assign(
new Error("Conflict: terminated by other getUpdates request"),
@@ -829,9 +838,12 @@ describe("monitorTelegramProvider (grammY)", () => {
expect(api.deleteWebhook).toHaveBeenCalledTimes(2);
expect(pollingCycle).toBe(2);
expect(runSpy).toHaveBeenCalledTimes(2);
expect(resolveTelegramTransportSpy).toHaveBeenCalledTimes(1);
expect(createTelegramBotCalls[0]?.telegramTransport).toBe(telegramTransport);
expect(createTelegramBotCalls[1]?.telegramTransport).toBe(telegramTransport);
// Transport is rebuilt on 409 conflict — the second cycle gets a fresh
// transport so Telegram sees a new TCP socket instead of reusing the
// keep-alive connection it already terminated.
expect(resolveTelegramTransportSpy).toHaveBeenCalledTimes(2);
expect(createTelegramBotCalls[0]?.telegramTransport).toBe(telegramTransport1);
expect(createTelegramBotCalls[1]?.telegramTransport).toBe(telegramTransport2);
});
it("falls back to configured webhookSecret when not passed explicitly", async () => {