自动化调研与情报

type WorkflowInput = { request: string; userId: string };
type StageAdapter = (context: unknown) => Promise<unknown>;

const stages = [
  "把研究问题拆成关键词、实体与时间范围",
  "并行搜索公开网页、新闻与专业数据源",
  "抽取正文、日期、作者与原始链接",
  "交叉核验关键事实并标注证据强度",
  "生成带引用的结论、风险和行动建议"
];
const selectedTools = [
  "NASA Open APIs",
  "Open Library",
  "REST Countries",
  "Nominatim"
];

export async function runWorkflow(input: WorkflowInput, adapters: Record<string, StageAdapter>) {
  let context: unknown = { ...input, selectedTools };

  for (const stage of stages) {
    const adapter = adapters[stage];
    if (!adapter) throw new Error(`Missing adapter: ${stage}`);
    context = await adapter(context);
  }

  return context;
}