让 AI 连接业务数据

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

const stages = [
  "统一数据库、文档和业务接口的只读访问",
  "按用户身份注入行列级权限",
  "把问题转换为受约束的查询或工具调用",
  "返回带数据来源和计算口径的答案",
  "审计敏感访问、失败查询与导出行为"
];
const selectedTools = [
  "LangChain.js",
  "Hugging Face",
  "REST Countries"
];

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