企业文档知识库

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

const stages = [
  "同步网盘、Wiki、PDF 与业务文档",
  "解析、去重、分块并保留访问权限",
  "建立可增量更新的检索索引",
  "回答问题并展示命中的原文引用",
  "监控过期内容、无答案问题和使用反馈"
];
const selectedTools = [
  "Open Library",
  "LangChain.js",
  "Context7",
  "Hugging Face"
];

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;
}