Function generateStreamingResponseClient

lib/client-api.ts:112–187

(conversationHistory: Message[], abortSignal?: AbortSignal)

// 流式响应生成函数
export async function generateStreamingResponseClient(conversationHistory: Message[], abortSignal?: AbortSignal) {
  if (!conversationHistory || !Array.isArray(conversationHistory) || conversationHistory.length === 0) {
    throw new Error("对话历史无效");
  }

  try {
    // 从 localStorage 获取模型设置
    const settingsStr = localStorage.getItem("model_settings")
    
    if (!settingsStr) {
      const legacyApiKey = localStorage.getItem("openai_api_key")
      if (!legacyApiKey) {
        throw new Error("缺少模型设置。请先配置您的 AI 模型。");
      }
      
      // 使用旧版 API 密钥（兼容性支持）
      const response = await fetch("/api/stream", {
        method: "POST",
        headers: {
          "Content-Type": "application/json",
          "x-api-key": legacyApiKey,
        },
        body: JSON.stringify({ conversationHistory }),
        signal: abortSignal,
      })
      
      if (!response.ok || !response.body) {
        throw new Error(`流式响应失败: ${response.status} ${response.statusText}`);
      }
      
      return streamAsyncIterable(response.body, abortSignal);
    }
    
    // 解析模型设置
    const settings: ModelSettings = JSON.parse(settingsStr)
    const provider = settings.provider
    const providerSettings = settings.providerSettings?.[provider] || {
      baseURL: "",
      model: "",
      apiKey: ""
    }
    
    // 发送请求到流式 API 路由
    const response = await fetch("/api/stream", {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
      },
      body: JSON.stringify({ 
        conversationHistory,
        settings: {
          provider: provider,
          baseURL: providerSettings.baseURL,
          model: providerSettings.model,
          apiKey: providerSettings.apiKey,
          temperature: settings.temperature
        }
      }),