fix: resolve Telegram outbound fetch failure on Node 22 (#25676)

lairtonlelis · lairtonlelis · commit 2621873253eb · 2026-02-24T15:09:58.000-03:00
Node 22's built-in globalThis.fetch uses undici's internal Agent whose
connect options are frozen at construction time. Calling
net.setDefaultAutoSelectFamily(true) after the agent is already created
has no effect on it, causing outbound Telegram API calls to fail with
`TypeError: fetch failed` on networks with broken IPv6 routing.

Fix: replace the global undici dispatcher with a new Agent that has
autoSelectFamily: true and autoSelectFamilyAttemptTimeout: 300 set
explicitly in its connect options. This ensures all subsequent
globalThis.fetch calls use IPv4 fallback via Happy Eyeballs.

Inbound polling was unaffected because grammyjs/runner re-creates
connections on each poll cycle, while outbound send calls hit the
stale internal dispatcher.
diff --git a/src/telegram/fetch.test.ts b/src/telegram/fetch.test.ts
@@ -4,6 +4,12 @@ import { resetTelegramFetchStateForTests, resolveTelegramFetch } from "./fetch.j
 
 const setDefaultAutoSelectFamily = vi.hoisted(() => vi.fn());
 const setDefaultResultOrder = vi.hoisted(() => vi.fn());
+const setGlobalDispatcher = vi.hoisted(() => vi.fn());
+const AgentCtor = vi.hoisted(() =>
+  vi.fn(function MockAgent(this: { options: unknown }, options: unknown) {
+    this.options = options;
+  }),
+);
 
 vi.mock("node:net", async () => {
   const actual = await vi.importActual<typeof import("node:net")>("node:net");
@@ -21,12 +27,19 @@ vi.mock("node:dns", async () => {
   };
 });
 
+vi.mock("undici", () => ({
+  Agent: AgentCtor,
+  setGlobalDispatcher,
+}));
+
 const originalFetch = globalThis.fetch;
 
 afterEach(() => {
   resetTelegramFetchStateForTests();
   setDefaultAutoSelectFamily.mockReset();
   setDefaultResultOrder.mockReset();
+  setGlobalDispatcher.mockReset();
+  AgentCtor.mockClear();
   vi.unstubAllEnvs();
   vi.clearAllMocks();
   if (originalFetch) {
@@ -133,4 +146,23 @@ describe("resolveTelegramFetch", () => {
 
     expect(setDefaultResultOrder).toHaveBeenCalledTimes(2);
   });
+
+  it("replaces global undici dispatcher with autoSelectFamily-enabled agent", async () => {
+    globalThis.fetch = vi.fn(async () => ({})) as unknown as typeof fetch;
+    resolveTelegramFetch();
+    expect(setGlobalDispatcher).toHaveBeenCalledTimes(1);
+    expect(AgentCtor).toHaveBeenCalledWith({
+      connect: {
+        autoSelectFamily: true,
+        autoSelectFamilyAttemptTimeout: 300,
+      },
+    });
+  });
+
+  it("sets global dispatcher only once across multiple calls", async () => {
+    globalThis.fetch = vi.fn(async () => ({})) as unknown as typeof fetch;
+    resolveTelegramFetch();
+    resolveTelegramFetch();
+    expect(setGlobalDispatcher).toHaveBeenCalledTimes(1);
+  });
 });
diff --git a/src/telegram/fetch.ts b/src/telegram/fetch.ts
@@ -1,5 +1,6 @@
 import * as dns from "node:dns";
 import * as net from "node:net";
+import { Agent, setGlobalDispatcher } from "undici";
 import type { TelegramNetworkConfig } from "../config/types.telegram.js";
 import { resolveFetch } from "../infra/fetch.js";
 import { createSubsystemLogger } from "../logging/subsystem.js";
@@ -10,6 +11,7 @@ import {
 
 let appliedAutoSelectFamily: boolean | null = null;
 let appliedDnsResultOrder: string | null = null;
+let appliedGlobalDispatcher = false;
 const log = createSubsystemLogger("telegram/network");
 
 // Node 22 workaround: enable autoSelectFamily to allow IPv4 fallback on broken IPv6 networks.
@@ -29,6 +31,30 @@ function applyTelegramNetworkWorkarounds(network?: TelegramNetworkConfig): void
         // ignore if unsupported by the runtime
       }
     }
+
+    // Node 22's built-in globalThis.fetch uses undici's internal Agent whose
+    // connect options are frozen at construction time.  Calling
+    // net.setDefaultAutoSelectFamily() after that agent is created has no
+    // effect on it.  Replace the global dispatcher with one that carries the
+    // correct autoSelectFamily setting so every subsequent globalThis.fetch
+    // call inherits it.
+    // See: https://github.com/openclaw/openclaw/issues/25676
+    if (autoSelectDecision.value !== null && !appliedGlobalDispatcher) {
+      try {
+        setGlobalDispatcher(
+          new Agent({
+            connect: {
+              autoSelectFamily: autoSelectDecision.value,
+              autoSelectFamilyAttemptTimeout: 300,
+            },
+          }),
+        );
+        appliedGlobalDispatcher = true;
+        log.info("global undici dispatcher updated for autoSelectFamily");
+      } catch {
+        // ignore if setGlobalDispatcher is unavailable
+      }
+    }
   }
 
   // Apply DNS result order workaround for IPv4/IPv6 issues.
@@ -68,4 +94,5 @@ export function resolveTelegramFetch(
 export function resetTelegramFetchStateForTests(): void {
   appliedAutoSelectFamily = null;
   appliedDnsResultOrder = null;
+  appliedGlobalDispatcher = false;
 }
