API 请求条件式重试机制：实现与优化

const axios = require("axios");
const qs = require("qs");

// 假设 apiKey 已定义
const apiKey = "YOUR_API_KEY"; 

let data = qs.stringify({
  document_key: "038A2E0792CE72020E9BB88380D002EB582A6B3AE5883C34DE53C9F17D415D99",
});

let config = {
  method: "post",
  maxBodyLength: Infinity,
  url: "https://api-free.deepl.com/v2/document/95BA71197AC66EE4745FF5269CF4399D",
  headers: {
    Authorization: apiKey,
    "Content-Type": "application/x-www-form-urlencoded",
  },
  data: data,
};

function retryUntilSuccess(requestConfig, callback) {
  axios
    .request(requestConfig)
    .then((response) => {
      // 检查特定条件
      if (response.data.status === "done") {
        console.log("任务完成:", response.data.status);
        callback(null, response.data); // 任务完成，返回结果
      } else {
        console.log("任务进行中，继续重试:", response.data.status);
        // 未完成，继续重试
        retryUntilSuccess(requestConfig, callback);
      }
    })
    .catch((error) => {
      console.error("请求失败，继续重试:", error.message);
      // 请求失败，直接重试
      retryUntilSuccess(requestConfig, callback);
    });
}

// 调用重试函数
// retryUntilSuccess(config, function(err, result) {
//   if (err) {
//     console.error("最终失败:", err);
//   } else {
//     console.log("最终成功结果:", result);
//   }
// });

const axios = require("axios");
const qs = require("qs");

// 假设 apiKey 已定义
const apiKey = "YOUR_API_KEY"; 

let data = qs.stringify({
  document_key: "038A2E0792CE72020E9BB88380D002EB582A6B3AE5883C34DE53C9F17D415D99",
});

let config = {
  method: "post",
  maxBodyLength: Infinity,
  url: "https://api-free.deepl.com/v2/document/95BA71197AC66EE4745FF5269CF4399D",
  headers: {
    Authorization: apiKey,
    "Content-Type": "application/x-www-form-urlencoded",
  },
  data: data,
};

/**
 * 异步延迟函数
 * @param {number} ms - 延迟毫秒数
 */
const delay = (ms) => new Promise((resolve) => setTimeout(resolve, ms));

/**
 * 执行带重试机制的 API 请求
 * @param {object} requestConfig - axios 请求配置
 * @param {function} conditionFn - 判断是否成功的函数，接收响应数据作为参数，返回布尔值
 * @param {object} options - 重试选项
 * @param {number} [options.maxRetries=5] - 最大重试次数
 * @param {number} [options.initialDelayMs=1000] - 初始重试延迟（毫秒）
 * @param {number} [options.backoffFactor=2] - 延迟因子，用于指数退避
 * @returns {Promise<object>} - 成功时的响应数据
 * @throws {Error} - 达到最大重试次数或遇到不可恢复错误时抛出
 */
async function retryApiRequest(requestConfig, conditionFn, options = {}) {
  const { maxRetries = 5, initialDelayMs = 1000, backoffFactor = 2 } = options;
  let currentDelay = initialDelayMs;

  for (let attempt = 1; attempt <= maxRetries; attempt++) {
    try {
      console.log(`尝试请求 (第 ${attempt} 次)...`);
      const response = await axios.request(requestConfig);

      // 检查业务逻辑条件
      if (conditionFn(response.data)) {
        console.log(`请求成功，条件满足！状态: ${response.data.status}`);
        return response.data; // 条件满足，返回结果
      } else {
        console.log(`条件未满足，状态: ${response.data.status}，将在 ${currentDelay}ms 后重试。`);
      }
    } catch (error) {
      console.error(`请求失败 (第 ${attempt} 次): ${error.message}`);
      // 判断是否为可重试错误（例如网络错误、5xx 服务器错误）
      // 这里的判断可以更细致，例如根据 error.response.status
      if (attempt === maxRetries || !axios.isAxiosError(error) || (error.response && error.response.status < 500)) {
        // 如果是最后一次尝试，或者是非 axios 错误，或者客户端错误（4xx），则不再重试
        throw new Error(`API 请求最终失败或条件未满足，已达最大重试次数 ${maxRetries} 次。`);
      }
    }

    // 等待一段时间后重试
    await delay(currentDelay);
    // 指数退避：每次重试延迟时间翻倍
    currentDelay *= backoffFactor;
  }

  // 如果循环结束仍未成功，则抛出错误
  throw new Error(`API 请求最终失败或条件未满足，已达最大重试次数 ${maxRetries} 次。`);
}

// 定义成功条件函数
const isStatusDone = (data) => data && data.status === "done";

// 使用示例
(async () => {
  try {
    const result = await retryApiRequest(config, isStatusDone, {
      maxRetries: 10,
      initialDelayMs: 500, // 初始延迟 0.5 秒
      backoffFactor: 1.5, // 每次延迟增加 1.5 倍
    });
    console.log("最终成功结果:", result);
  } catch (error) {
    console.error("教程最终失败:", error.message);
  }
})();