homeio

1import "server-only";
2
3import { getDueTasks, runScheduledTask } from "./service";
4
5const POLL_INTERVAL_MS = 60_000;
6const MAX_CONCURRENT_TASKS = 3;
7
8let started = false;
9
10export function startScheduledTaskRunner() {
11  if (started) return;
12  started = true;
13
14  const tick = async () => {
15    try {
16      const dueTasks = await getDueTasks();
17
18      // Run at most MAX_CONCURRENT_TASKS tasks simultaneously
19      for (let i = 0; i < dueTasks.length; i += MAX_CONCURRENT_TASKS) {
20        const batch = dueTasks.slice(i, i + MAX_CONCURRENT_TASKS);
21        await Promise.allSettled(batch.map((task) => runScheduledTask(task.id)));
22      }
23    } catch {
24      // don't crash the runner
25    }
26  };
27
28  // Run immediately on startup, then every minute
29  tick();
30  setInterval(tick, POLL_INTERVAL_MS);
31}
32