错误处理

async function safeChat(message, options = {}) {
  const maxRetries = 3;
  let lastError = null;

  for (let attempt = 0; attempt < maxRetries; attempt++) {
    try {
      const response = await fetch("https://huajune.duliday.com/api/v1/chat", {
        method: "POST",
        headers: {
          Authorization: `Bearer ${apiKey}`,
          "Content-Type": "application/json",
        },
        body: JSON.stringify({
          model: "anthropic/claude-3-7-sonnet-20250219",
          messages: [{ role: "user", content: message }],
          ...options,
        }),
      });

      // 429 处理（当前不会触发，为未来兼容性保留）
      if (response.status === 429) {
        const retryAfter = parseInt(response.headers.get("Retry-After") || "5");
        console.log(`Rate limited, retrying after ${retryAfter}s`);
        await new Promise((resolve) => setTimeout(resolve, retryAfter * 1000));
        continue;
      }

      const data = await response.json();

      // 获取 correlationId：优先从响应体，失败则从响应头
      const correlationId =
        data.correlationId || response.headers.get("X-Correlation-Id");

      if (!response.ok) {
        console.error(`Error (${correlationId}):`, data.message);
        throw new Error(data.message);
      }

      return data;
    } catch (error) {
      lastError = error;

      if (attempt < maxRetries - 1) {
        const delay = Math.pow(2, attempt) * 1000;
        console.log(`Attempt ${attempt + 1} failed, retrying in ${delay}ms`);
        await new Promise((resolve) => setTimeout(resolve, delay));
      }
    }
  }

  throw lastError;
}

// 使用
try {
  const result = await safeChat("你好");
  console.log(result.data.messages[0].parts[0].text);
} catch (error) {
  console.error("聊天失败:", error.message);
}