社交舆情监测

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

const stages = [
  "配置品牌、产品、人物和竞品关键词",
  "采集新闻、论坛、社交与搜索趋势",
  "去重并识别语言、情绪、主题和传播者",
  "按声量变化和风险规则触发预警",
  "生成事件摘要、证据链接和响应建议"
];
const selectedTools = [];

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