github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-09 01:38:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf: honor low timeout budgets in health telegram probes

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-13 19:22:20 +00:00
parent a3574bbde4
commit 08725270e2
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/commands/health.ts
View File

@@ -412,7 +412,7 @@ export async function getHealthSnapshot(params?: {
buildSessionSummary(resolveStorePath(cfg.session?.store, { agentId: defaultAgentId })); buildSessionSummary(resolveStorePath(cfg.session?.store, { agentId: defaultAgentId }));
const start = Date.now(); const start = Date.now();
const cappedTimeout = Math.max(1000, timeoutMs ?? DEFAULT_TIMEOUT_MS); const cappedTimeout = timeoutMs === undefined ? DEFAULT_TIMEOUT_MS : Math.max(50, timeoutMs);
const doProbe = params?.probe !== false; const doProbe = params?.probe !== false;
const channels: Record<string, ChannelHealthSummary> = {}; const channels: Record<string, ChannelHealthSummary> = {};
const channelOrder = listChannelPlugins().map((plugin) => plugin.id); const channelOrder = listChannelPlugins().map((plugin) => plugin.id);

3
src/telegram/probe.ts
View File

@@ -26,6 +26,7 @@ export async function probeTelegram(
const started = Date.now(); const started = Date.now();
const fetcher = proxyUrl ? makeProxyFetch(proxyUrl) : fetch; const fetcher = proxyUrl ? makeProxyFetch(proxyUrl) : fetch;
const base = `${TELEGRAM_API_BASE}/bot${token}`; const base = `${TELEGRAM_API_BASE}/bot${token}`;
const retryDelayMs = Math.max(50, Math.min(1000, timeoutMs));
const result: TelegramProbe = { const result: TelegramProbe = {
ok: false, ok: false,
@@ -46,7 +47,7 @@ export async function probeTelegram(
} catch (err) { } catch (err) {
fetchError = err; fetchError = err;
if (i < 2) { if (i < 2) {
await new Promise((resolve) => setTimeout(resolve, 1000)); await new Promise((resolve) => setTimeout(resolve, retryDelayMs));
} }
} }
} }