fix(telegram): 排除 EADDRNOTAVAIL 误触发 Telegram 传输回退

lzyyzznl · claude · lzyyzznl · commit 3164733b7443 · 2026-06-20T15:45:33.000+08:00
EADDRNOTAVAIL 是本地 socket 分配失败，切换远程 Telegram IP 无效。 collectErrorCodes() 增加数值 errno 提取，shouldUseTelegramTransportFallback() 在 EADDRNOTAVAIL 时返回 false 避免无效回退和误导性日志。 Fixes #94620 Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
diff --git a/extensions/telegram/src/fetch.test.ts b/extensions/telegram/src/fetch.test.ts
@@ -113,6 +113,7 @@ vi.mock("openclaw/plugin-sdk/runtime-env", () => ({
 let resolveTelegramFetch: typeof import("./fetch.js").resolveTelegramFetch;
 let resolveTelegramApiBase: typeof import("./fetch.js").resolveTelegramApiBase;
 let resolveTelegramTransport: typeof import("./fetch.js").resolveTelegramTransport;
+let shouldRetryTelegramTransportFallback: typeof import("./fetch.js").shouldRetryTelegramTransportFallback;
 const tempDirs: string[] = [];
 
 type TelegramDispatcherPolicy = NonNullable<
@@ -125,8 +126,12 @@ type ExplicitProxyTelegramDispatcherPolicy = Extract<
 >;
 
 beforeAll(async () => {
-  ({ resolveTelegramApiBase, resolveTelegramFetch, resolveTelegramTransport } =
-    await import("./fetch.js"));
+  ({
+    resolveTelegramApiBase,
+    resolveTelegramFetch,
+    resolveTelegramTransport,
+    shouldRetryTelegramTransportFallback,
+  } = await import("./fetch.js"));
 });
 
 beforeEach(() => {
@@ -1327,4 +1332,24 @@ describe("resolveTelegramFetch", () => {
       await expect(transport.close()).resolves.toBeUndefined();
     });
   });
+
+  describe("shouldRetryTelegramTransportFallback", () => {
+    it("returns false for EADDRNOTAVAIL code string", () => {
+      const err = buildFetchFallbackError("EADDRNOTAVAIL");
+      expect(shouldRetryTelegramTransportFallback(err)).toBe(false);
+    });
+
+    it("returns false for EADDRNOTAVAIL numeric errno", () => {
+      const connectErr = Object.assign(new Error("connect EADDRNOTAVAIL api.telegram.org:443"), {
+        errno: 99,
+      });
+      const err = Object.assign(new TypeError("fetch failed"), { cause: connectErr });
+      expect(shouldRetryTelegramTransportFallback(err)).toBe(false);
+    });
+
+    it("returns true for other network errors", () => {
+      const err = buildFetchFallbackError("ENETUNREACH");
+      expect(shouldRetryTelegramTransportFallback(err)).toBe(true);
+    });
+  });
 });
diff --git a/extensions/telegram/src/fetch.ts b/extensions/telegram/src/fetch.ts
@@ -431,6 +431,10 @@ function collectErrorCodes(err: unknown): Set<string> {
       if (typeof code === "string" && code.trim()) {
         codes.add(code.trim().toUpperCase());
       }
+      const errno = (current as { errno?: unknown }).errno;
+      if (typeof errno === "number") {
+        codes.add(String(errno));
+      }
       const cause = (current as { cause?: unknown }).cause;
       if (cause && !seen.has(cause)) {
         queue.push(cause);
@@ -473,6 +477,10 @@ function shouldUseTelegramTransportFallback(err: unknown): boolean {
         : "",
     codes: collectErrorCodes(err),
   };
+  // EADDRNOTAVAIL 是本地 socket 分配失败，换远程 IP 无效
+  if (ctx.codes.has("EADDRNOTAVAIL") || ctx.codes.has("99")) {
+    return false;
+  }
   const hasFetchFailedEnvelope = ctx.message.includes("fetch failed");
   const hasKnownNetworkCode = FALLBACK_RETRY_ERROR_CODES.some((code) => ctx.codes.has(code));
   return hasKnownNetworkCode || (hasFetchFailedEnvelope && ctx.codes.size === 0);
