import { Hono } from 'hono';

import { KIMI_CODE_HOME } from '../config';
import type { CronTask } from '../lib/agent-record-types';
import { readSessionDetail } from '../lib/session-store';
import { listCronTasks } from '../lib/cron-store';

export function cronRoute(home: string = KIMI_CODE_HOME): Hono {
  const r = new Hono();
  r.get('/:id/cron', async (c) => {
    const id = c.req.param('id');
    const detail = await readSessionDetail(home, id);
    if (!detail) {
      return c.json({ error: 'session not found', code: 'NOT_FOUND' }, 404);
    }
    // Cron state is per-agent (wire records in each agent's `wire.jsonl`,
    // plus legacy `<homedir>/cron/*.json` files), not the session root.
    // Aggregate across agents; sub agents simply contribute nothing.
    const cron: CronTask[] = [];
    const seen = new Set<string>();
    for (const agent of detail.agents) {
      for (const job of await listCronTasks(agent.homedir)) {
        if (seen.has(job.id)) continue;
        seen.add(job.id);
        cron.push(job);
      }
    }
    cron.sort((a, b) => a.createdAt - b.createdAt);
    return c.json({ sessionId: id, cron });
  });
  return r;
}