fix(telegram): treat ENETDOWN as transient network failure (#86762) · openclaw/openclaw@1fd8de8

Recent Commits to openclaw:main

TurboTheTurt · 2026-05-27 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -1101,6 +1101,23 @@ describe("resolveTelegramFetch", () => {`
`1101`	`1101`	`expect(undiciFetch).toHaveBeenCalledTimes(1);`
`1102`	`1102`	`});`
`1103`	`1103`
	`1104`	`+it("retries sticky fallback when the local network is down during connect", async () => {`
	`1105`	`+undiciFetch`
	`1106`	`+.mockRejectedValueOnce(buildFetchFallbackError("ENETDOWN"))`
	`1107`	`+.mockResolvedValueOnce({ ok: true } as Response);`
	`1108`	`+`
	`1109`	`+const resolved = resolveTelegramFetchOrThrow(undefined, {`
	`1110`	`+network: {`
	`1111`	`+autoSelectFamily: true,`
	`1112`	`+},`
	`1113`	`+});`
	`1114`	`+`
	`1115`	`+await resolved("https://api.telegram.org/botx/getUpdates");`
	`1116`	`+`
	`1117`	`+expect(undiciFetch).toHaveBeenCalledTimes(2);`
	`1118`	`+expect(getDispatcherFromUndiciCall(1)).not.toBe(getDispatcherFromUndiciCall(2));`
	`1119`	`+});`
	`1120`	`+`
`1104`	`1121`	`it("keeps per-resolver transport policy isolated across multiple accounts", async () => {`
`1105`	`1122`	`undiciFetch.mockResolvedValue({ ok: true } as Response);`
`1106`	`1123`

Original file line number	Diff line number	Diff line change
`@@ -113,6 +113,7 @@ type LookupFunction = (`
`113`	`113`
`114`	`114`	`const FALLBACK_RETRY_ERROR_CODES = [`
`115`	`115`	`"ETIMEDOUT",`
	`116`	`+"ENETDOWN",`
`116`	`117`	`"ENETUNREACH",`
`117`	`118`	`"EHOSTUNREACH",`
`118`	`119`	`"UND_ERR_CONNECT_TIMEOUT",`

Original file line number	Diff line number	Diff line change
`@@ -83,6 +83,7 @@ describe("isRecoverableTelegramNetworkError", () => {`
`83`	`83`
`84`	`84`	`it.each([`
`85`	`85`	`["ETIMEDOUT", "timeout"],`
	`86`	`+["ENETDOWN", "network down"],`
`86`	`87`	`["ECONNABORTED", "aborted"],`
`87`	`88`	`["ERR_NETWORK", "network"],`
`88`	`89`	`])("detects recoverable error code %s", (code, message) => {`
`@@ -218,6 +219,7 @@ describe("isSafeToRetrySendError", () => {`
`218`	`219`	`["ECONNREFUSED", "connect ECONNREFUSED", true],`
`219`	`220`	`["ENOTFOUND", "getaddrinfo ENOTFOUND", true],`
`220`	`221`	`["EAI_AGAIN", "getaddrinfo EAI_AGAIN", true],`
	`222`	`+["ENETDOWN", "connect ENETDOWN", true],`
`221`	`223`	`["ENETUNREACH", "connect ENETUNREACH", true],`
`222`	`224`	`["EHOSTUNREACH", "connect EHOSTUNREACH", true],`
`223`	`225`	`["ECONNRESET", "read ECONNRESET", false],`

Original file line number	Diff line number	Diff line change
`@@ -12,6 +12,7 @@ const RECOVERABLE_ERROR_CODES = new Set([`
`12`	`12`	`"ECONNRESET",`
`13`	`13`	`"ECONNREFUSED",`
`14`	`14`	`"EPIPE",`
	`15`	`+"ENETDOWN",`
`15`	`16`	`"ETIMEDOUT",`
`16`	`17`	`"ESOCKETTIMEDOUT",`
`17`	`18`	`"ENETUNREACH",`
`@@ -41,6 +42,7 @@ const PRE_CONNECT_ERROR_CODES = new Set([`
`41`	`42`	`"ECONNREFUSED", // Server actively refused the connection (never reached Telegram)`
`42`	`43`	`"ENOTFOUND", // DNS resolution failed (never sent)`
`43`	`44`	`"EAI_AGAIN", // Transient DNS failure (never sent)`
	`45`	`+"ENETDOWN", // Local network interface is down before connect completes (never sent)`
`44`	`46`	`"ENETUNREACH", // No route to host (never sent)`
`45`	`47`	`"EHOSTUNREACH", // Host unreachable (never sent)`
`46`	`48`	`]);`

Original file line number	Diff line number	Diff line change
`@@ -16,6 +16,7 @@ describe("resolveCronExecutionRetryHint", () => {`
`16`	`16`	`it("treats common network error codes as network when retryOn only includes network", () => {`
`17`	`17`	`for (const code of [`
`18`	`18`	`"EAI_AGAIN",`
	`19`	`+"ENETDOWN",`
`19`	`20`	`"EHOSTUNREACH",`
`20`	`21`	`"EHOSTDOWN",`
`21`	`22`	`"ENETRESET",`

Original file line number	Diff line number	Diff line change
`@@ -11,7 +11,7 @@ const TRANSIENT_PATTERNS: Record<CronRetryOn, RegExp> = {`
`11`	`11`	`overloaded:`
`12`	`12`	`/\b529\b\|\boverloaded(?:_error)?\b\|high demand\|temporar(?:ily\|y) overloaded\|capacity exceeded/i,`
`13`	`13`	`network:`
`14`		`-/(network\|fetch failed\|socket\|econnreset\|econnrefused\|eai_again\|ehostunreach\|ehostdown\|enetreset\|enetunreach\|epipe)/i,`
	`14`	`+/(network\|fetch failed\|socket\|econnreset\|econnrefused\|eai_again\|enetdown\|ehostunreach\|ehostdown\|enetreset\|enetunreach\|epipe)/i,`
`15`	`15`	`timeout: /(timeout\|etimedout)/i,`
`16`	`16`	`server_error: /\b5\d{2}\b/,`
`17`	`17`	`};`

Original file line number	Diff line number	Diff line change
`@@ -150,6 +150,9 @@ describe("installUnhandledRejectionHandler - fatal detection", () => {`
`150`	`150`	`cause: { code: "UND_ERR_CONNECT_TIMEOUT", syscall: "connect" },`
`151`	`151`	`}),`
`152`	`152`	`Object.assign(new Error("DNS resolve failed"), { code: "UND_ERR_DNS_RESOLVE_FAILED" }),`
	`153`	`+Object.assign(new Error("connect ENETDOWN 149.154.167.220:443"), {`
	`154`	`+code: "ENETDOWN",`
	`155`	`+}),`
`153`	`156`	`Object.assign(new Error("Connection reset"), { code: "ECONNRESET" }),`
`154`	`157`	`Object.assign(new Error("Timeout"), { code: "ETIMEDOUT" }),`
`155`	`158`	`Object.assign(`

Original file line number	Diff line number	Diff line change
`@@ -60,6 +60,7 @@ describe("isTransientNetworkError", () => {`
`60`	`60`	`"ESOCKETTIMEDOUT",`
`61`	`61`	`"ECONNABORTED",`
`62`	`62`	`"EPIPE",`
	`63`	`+"ENETDOWN",`
`63`	`64`	`"EHOSTUNREACH",`
`64`	`65`	`"ENETUNREACH",`
`65`	`66`	`"EADDRNOTAVAIL",`
`@@ -375,6 +376,12 @@ describe("isTransientUnhandledRejectionError", () => {`
`375`	`376`	`const epipe = Object.assign(new Error("write EPIPE"), { code: "EPIPE" });`
`376`	`377`	`const sqlite = Object.assign(new Error("database is locked"), { code: "SQLITE_BUSY" });`
`377`	`378`	`const network = Object.assign(new Error("connection reset"), { code: "ECONNRESET" });`
	`379`	`+const networkDown = Object.assign(new Error("connect ENETDOWN"), {`
	`380`	`+code: "ENETDOWN",`
	`381`	`+});`
	`382`	`+const rawNetworkDown = new Error(`
	`383`	`+"connect ENETDOWN 149.154.167.220:443 - Local (10.0.10.40:50017)",`
	`384`	`+);`
`378`	`385`	`const hostUnreachable = Object.assign(new Error("connect EHOSTUNREACH"), {`
`379`	`386`	`code: "EHOSTUNREACH",`
`380`	`387`	`});`
`@@ -398,6 +405,8 @@ describe("isTransientUnhandledRejectionError", () => {`
`398`	`405`	`expect(isBenignUncaughtExceptionError(epipe)).toBe(true);`
`399`	`406`	`expect(isBenignUncaughtExceptionError(sqlite)).toBe(false);`
`400`	`407`	`expect(isBenignUncaughtExceptionError(network)).toBe(false);`
	`408`	`+expect(isBenignUncaughtExceptionError(networkDown)).toBe(true);`
	`409`	`+expect(isBenignUncaughtExceptionError(rawNetworkDown)).toBe(true);`
`401`	`410`	`expect(isBenignUncaughtExceptionError(hostUnreachable)).toBe(true);`
`402`	`411`	`expect(isBenignUncaughtExceptionError(rawHostUnreachable)).toBe(true);`
`403`	`412`	`expect(isBenignUncaughtExceptionError(addressUnavailable)).toBe(true);`

Original file line number	Diff line number	Diff line change
`@@ -57,6 +57,7 @@ const TRANSIENT_NETWORK_CODES = new Set([`
`57`	`57`	`"ESOCKETTIMEDOUT",`
`58`	`58`	`"ECONNABORTED",`
`59`	`59`	`"EPIPE",`
	`60`	`+"ENETDOWN",`
`60`	`61`	`"EHOSTUNREACH",`
`61`	`62`	`"ENETUNREACH",`
`62`	`63`	`"EADDRNOTAVAIL",`
`@@ -93,6 +94,7 @@ const TRANSIENT_SQLITE_ERRCODES = new Set([5, 6, 10, 14]);`
`93`	`94`	`const BENIGN_UNCAUGHT_EXCEPTION_CODES = new Set(["EPIPE", "EIO"]);`
`94`	`95`	`const BENIGN_UNCAUGHT_EXCEPTION_NETWORK_CODES = new Set([`
`95`	`96`	`"ECONNREFUSED",`
	`97`	`+"ENETDOWN",`
`96`	`98`	`"EHOSTUNREACH",`
`97`	`99`	`"ENETUNREACH",`
`98`	`100`	`"EADDRNOTAVAIL",`
`@@ -106,9 +108,9 @@ const BENIGN_UNCAUGHT_EXCEPTION_NETWORK_CODES = new Set([`
`106`	`108`	`]);`
`107`	`109`
`108`	`110`	`const TRANSIENT_NETWORK_MESSAGE_CODE_RE =`
`109`		`-/\b(ECONNRESET\|ECONNREFUSED\|ENOTFOUND\|ETIMEDOUT\|ESOCKETTIMEDOUT\|ECONNABORTED\|EPIPE\|EHOSTUNREACH\|ENETUNREACH\|EADDRNOTAVAIL\|EAI_AGAIN\|EPROTO\|UND_ERR_CONNECT_TIMEOUT\|UND_ERR_DNS_RESOLVE_FAILED\|UND_ERR_CONNECT\|UND_ERR_SOCKET\|UND_ERR_HEADERS_TIMEOUT\|UND_ERR_BODY_TIMEOUT\|ERR_HTTP2_INVALID_SESSION)\b/i;`
	`111`	`+/\b(ECONNRESET\|ECONNREFUSED\|ENOTFOUND\|ETIMEDOUT\|ESOCKETTIMEDOUT\|ECONNABORTED\|EPIPE\|ENETDOWN\|EHOSTUNREACH\|ENETUNREACH\|EADDRNOTAVAIL\|EAI_AGAIN\|EPROTO\|UND_ERR_CONNECT_TIMEOUT\|UND_ERR_DNS_RESOLVE_FAILED\|UND_ERR_CONNECT\|UND_ERR_SOCKET\|UND_ERR_HEADERS_TIMEOUT\|UND_ERR_BODY_TIMEOUT\|ERR_HTTP2_INVALID_SESSION)\b/i;`
`110`	`112`	`const BENIGN_UNCAUGHT_EXCEPTION_NETWORK_MESSAGE_CODE_RE =`
`111`		`-/\b(ECONNREFUSED\|EHOSTUNREACH\|ENETUNREACH\|EADDRNOTAVAIL\|EAI_AGAIN\|ENOTFOUND\|ETIMEDOUT\|UND_ERR_CONNECT_TIMEOUT\|UND_ERR_DNS_RESOLVE_FAILED\|UND_ERR_CONNECT\|ERR_HTTP2_INVALID_SESSION)\b/i;`
	`113`	`+/\b(ECONNREFUSED\|ENETDOWN\|EHOSTUNREACH\|ENETUNREACH\|EADDRNOTAVAIL\|EAI_AGAIN\|ENOTFOUND\|ETIMEDOUT\|UND_ERR_CONNECT_TIMEOUT\|UND_ERR_DNS_RESOLVE_FAILED\|UND_ERR_CONNECT\|ERR_HTTP2_INVALID_SESSION)\b/i;`
`112`	`114`
`113`	`115`	`const TRANSIENT_SQLITE_MESSAGE_CODE_RE =`
`114`	`116`	`/\b(SQLITE_BUSY\|SQLITE_CANTOPEN\|SQLITE_IOERR\|SQLITE_LOCKED)\b/i;`

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。原文来自 — 版权归原作者所有。

推荐订阅源

Recent Commits to openclaw:main