Function executeCheckHostsTask

src/controllers/BookmarkHostCheck.controller.ts:343–378

(input: {
  hostKeys: string[]
  initialTask: CheckHostsTaskValue
  saveTask: SaveCheckHostsTask
})

}

async function executeCheckHostsTask(input: {
  hostKeys: string[]
  initialTask: CheckHostsTaskValue
  saveTask: SaveCheckHostsTask
}) {
  const { hostKeys, initialTask, saveTask } = input
  let checked = initialTask.checked
  const proxyUrl = await SiteSettingController.getProxyUrl()

  try {
    await runConcurrent(hostKeys, CHECK_HOST_CONCURRENCY, async (hostKey) => {
      try {
        await BookmarkHostCheckController.checkHost(hostKey, { timeout: CHECK_HOST_TIMEOUT, proxyUrl })
      } catch {
        // 单个 Host 的异常不应让整批任务卡住；可解析 Host 的网络失败会在 checkHost 内落库。
      }
      checked += 1
      await saveTask({
        ...initialTask,
        checked,
      })
    })
    await saveTask({
      ...initialTask,
      checked,
      finishedAt: new Date().toISOString(),
    })
  } catch (error) {
    await saveTask({
      ...initialTask,
      checked,
      finishedAt: new Date().toISOString(),
      errorMessage: error instanceof Error ? error.message : '检测任务执行失败',
    })
  }
}

async function startCheckHostsTask(input: {
  getRunningTask: () => Promise<CheckHostsTaskValue | null>