Function connectWithRetry

packages/mcp-server/src/cli.ts:97–121

(timeout: number)

}

async function connectWithRetry(timeout: number): Promise<Socket> {
  const startTime = Date.now()
  let delay = CONNECT_RETRY_DELAY
  while (Date.now() - startTime < timeout) {
    try {
      return await connectHub()
    } catch (err: unknown) {
      if (
        err &&
        typeof err === 'object' &&
        'code' in err &&
        (err.code === 'ENOENT' || err.code === 'ECONNREFUSED')
      ) {
        const remainingTime = timeout - (Date.now() - startTime)
        const waitTime = Math.min(delay, remainingTime)
        if (waitTime <= 0) break
        await new Promise((r) => setTimeout(r, waitTime))
        delay = Math.min(delay * 1.5, 1000)
      } else {
        throw err
      }
    }
  }
  throw new Error(`Failed to connect to Hub within ${timeout}ms.`)
}

function startHub(): ChildProcess {
  log.info('Spawning new Hub process...')