vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-03-12 07:20:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(retry): simplify telegram shouldRetry composition

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

21
src/infra/retry-policy.ts
View File

@@ -22,6 +22,20 @@ export const TELEGRAM_RETRY_DEFAULTS = {
const TELEGRAM_RETRY_RE = /429|timeout|connect|reset|closed|unavailable|temporarily/i;
const log = createSubsystemLogger("retry-policy");
function resolveTelegramShouldRetry(params: {
shouldRetry?: (err: unknown) => boolean;
strictShouldRetry?: boolean;
}) {
if (!params.shouldRetry) {
return (err: unknown) => TELEGRAM_RETRY_RE.test(formatErrorMessage(err));
}
if (params.strictShouldRetry) {
return params.shouldRetry;
}
return (err: unknown) =>
params.shouldRetry?.(err) || TELEGRAM_RETRY_RE.test(formatErrorMessage(err));
}
function getTelegramRetryAfterMs(err: unknown): number | undefined {
if (!err || typeof err !== "object") {
return undefined;
@@ -88,12 +102,7 @@ export function createTelegramRetryRunner(params: {
...params.configRetry,
...params.retry,
});
const shouldRetry = params.shouldRetry
? params.strictShouldRetry
? params.shouldRetry
: (err: unknown) =>
params.shouldRetry?.(err) || TELEGRAM_RETRY_RE.test(formatErrorMessage(err))
: (err: unknown) => TELEGRAM_RETRY_RE.test(formatErrorMessage(err));
const shouldRetry = resolveTelegramShouldRetry(params);
return <T>(fn: () => Promise<T>, label?: string) =>
retryAsync(fn, {