Function startCheckHostsTask

src/controllers/BookmarkHostCheck.controller.ts:380–409

(input: {
  getRunningTask: () => Promise<CheckHostsTaskValue | null>
  getHostKeys: () => Promise<Array<{ hostKey: string | null }>>
  saveTask: SaveCheckHostsTask
})

}

async function startCheckHostsTask(input: {
  getRunningTask: () => Promise<CheckHostsTaskValue | null>
  getHostKeys: () => Promise<Array<{ hostKey: string | null }>>
  saveTask: SaveCheckHostsTask
}) {
  const runningTask = await input.getRunningTask()
  if (runningTask && runningTask.finishedAt === null) return runningTask

  const rows = await input.getHostKeys()
  const hostKeys = await filterPendingHostKeys(rows.map((item) => item.hostKey))
  const now = new Date().toISOString()
  const initialTask: CheckHostsTaskValue = {
    startedAt: now,
    finishedAt: hostKeys.length ? null : now,
    total: hostKeys.length,
    checked: 0,
    errorMessage: null,
  }

  await input.saveTask(initialTask)
  if (hostKeys.length) {
    void executeCheckHostsTask({
      hostKeys,
      initialTask,
      saveTask: input.saveTask,
    })
  }

  return initialTask
}

const BookmarkHostCheckController = {
  async checkHost(hostKey: string, opts: { timeout?: number; proxyUrl?: string } = {}) {