import handler from "./.open-next/worker.js";
import {
  runCurate,
  runTriage,
  runPrReview,
  runStale,
  runDupes,
  runDigest,
  type AgentEnv,
} from "./lib/community-agent-tasks";
import { runFactsDrift } from "./lib/facts-drift";
import { runLinkCheck, runSemanticDrift } from "./lib/content-watch";

export default {
  fetch: handler.fetch,
  async scheduled(event: ScheduledEvent, env: Record<string, unknown>, ctx: ExecutionContext) {
    const expr = event.cron;
    ctx.waitUntil((async () => {
      const agentEnv = env as unknown as AgentEnv;
      if (expr === "0 */6 * * *") {
        await runCurate(agentEnv);
        await runFactsDrift(agentEnv);
      }
      else if (expr === "*/30 * * * *") {
        await runTriage(agentEnv);
        await runPrReview(agentEnv);
      }
      else if (expr === "0 0 * * *") {
        await runStale(agentEnv);
        await runDupes(agentEnv);
        await runLinkCheck(agentEnv);
        await runSemanticDrift(agentEnv);
      }
      else if (expr === "0 9 * * 1") await runDigest(agentEnv);
    })());
  },
} satisfies ExportedHandler;