Function startComponentWatchdog

src/controller/main.ts:253–334

()

}

function startComponentWatchdog() {
  componentWatchdogStopping = false
  if (componentWatchdogTimer) {
    clearInterval(componentWatchdogTimer)
    componentWatchdogTimer = undefined
  }

  let running = false
  let rcloneFailCount = 0
  let openlistFailCount = 0
  let rcloneCooldownUntil = 0
  let openlistCooldownUntil = 0

  const COOLDOWN_MS = 60_000
  const INTERVAL_MS = 10_000
  const FAIL_THRESHOLD = 3

  componentWatchdogTimer = window.setInterval(async () => {
    if (componentWatchdogStopping) return
    if (!nmConfig.settings.autoRecoverComponents) return
    if (running) return
    running = true

    try {
      const now = Date.now()

      if (rcloneInfo.process.child) {
        const ok = await rclone_api_noop()
        rcloneFailCount = ok ? 0 : rcloneFailCount + 1
        if (!ok && rcloneFailCount >= FAIL_THRESHOLD && now >= rcloneCooldownUntil) {
          rcloneCooldownUntil = now + COOLDOWN_MS
          rcloneFailCount = 0
          Notification.warning({
            id: 'rclone_auto_recover',
            title: t('transmit'),
            content: t('rclone_restarting'),
          })
          try {
            await restartRclone()
            Notification.success({
              id: 'rclone_auto_recover_ok',
              title: t('success'),
              content: t('rclone_restarted'),
            })
          } catch (e) {
            console.error('restartRclone failed:', e)
          }
        }
      } else {
        rcloneFailCount = 0
      }

      if (openlistInfo.process.child) {
        const ok = await openlist_api_ping()
        openlistFailCount = ok ? 0 : openlistFailCount + 1
        if (!ok && openlistFailCount >= FAIL_THRESHOLD && now >= openlistCooldownUntil) {
          openlistCooldownUntil = now + COOLDOWN_MS
          openlistFailCount = 0