1import { sleep } from '../../sharedF/sleepF.mts'
2import { reachabilityFor } from './ctxF/klusterReachabilityAI.mts'
3
4const transientMsgRe = /ETIMEDOUT|ECONNRESET|ECONNREFUSED|ENOTFOUND|socket hang up|timeout|terminated|429|500|502|503|504/
5
6export const isTransientKubeErr = (err: any): boolean => {
7  if (err?.name === 'AbortError') return true
8  const msg = String(err?.message || err?.body || err)
9  return transientMsgRe.test(msg)
10}
11
12export const withKubeRetry = async <T,>(fn: () => Promise<T>, cluster_name: string): Promise<T> => {
13  if (typeof reachabilityFor(cluster_name) !== 'number') return fn()
14  const maxRetries = 2, baseDelayMs = 1000
15  for (let attempt = 0; ; attempt++) {
16    try {
17      return await fn()
18    } catch (err) {
19      if (!isTransientKubeErr(err) || attempt >= maxRetries) throw err
20      await sleep(baseDelayMs * 2 ** attempt)
21    }
22  }
23}
24