github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-18 18:07:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(telegram): share error graph traversal helper

Browse Source
This commit is contained in:
Peter Steinberger
2026-03-08 01:10:00 +00:00
parent f866e57de3
commit 7b9a34939a
1 changed files with 15 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/telegram/network-errors.ts
View File

@@ -65,6 +65,19 @@ const RECOVERABLE_MESSAGE_SNIPPETS = [
"timed out", // grammY getUpdates returns "timed out after X seconds" (not matched by "timeout")
];
function collectTelegramErrorCandidates(err: unknown) {
return collectErrorGraphCandidates(err, (current) => {
const nested: Array<unknown> = [current.cause, current.reason];
if (Array.isArray(current.errors)) {
nested.push(...current.errors);
}
if (readErrorName(current) === "HttpError") {
nested.push(current.error);
}
return nested;
});
}
function normalizeCode(code?: string): string {
return code?.trim().toUpperCase() ?? "";
}
@@ -101,16 +114,7 @@ export function isSafeToRetrySendError(err: unknown): boolean {
if (!err) {
return false;
}
for (const candidate of collectErrorGraphCandidates(err, (current) => {
const nested: Array<unknown> = [current.cause, current.reason];
if (Array.isArray(current.errors)) {
nested.push(...current.errors);
}
if (readErrorName(current) === "HttpError") {
nested.push(current.error);
}
return nested;
})) {
for (const candidate of collectTelegramErrorCandidates(err)) {
const code = normalizeCode(getErrorCode(candidate));
if (code && PRE_CONNECT_ERROR_CODES.has(code)) {
return true;
@@ -131,17 +135,7 @@ export function isRecoverableTelegramNetworkError(
? options.allowMessageMatch
: options.context !== "send";
for (const candidate of collectErrorGraphCandidates(err, (current) => {
const nested: Array<unknown> = [current.cause, current.reason];
if (Array.isArray(current.errors)) {
nested.push(...current.errors);
}
// Grammy's HttpError wraps the underlying error in .error (not .cause).
if (readErrorName(current) === "HttpError") {
nested.push(current.error);
}
return nested;
})) {
for (const candidate of collectTelegramErrorCandidates(err)) {
const code = normalizeCode(getErrorCode(candidate));
if (code && RECOVERABLE_ERROR_CODES.has(code)) {
return true;