构建内容生产工作流

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

const stages = [
  "汇总品牌规范、受众和渠道目标",
  "生成选题、内容大纲和素材清单",
  "并行生产文案、图片、音频或视频",
  "执行事实、版权和品牌一致性审核",
  "排期发布并回收表现数据优化模板"
];
const selectedTools = [
  "Hugging Face",
  "LangChain.js"
];

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