Function runSpeedtest

speedtest/speedtest.ts:637–790

(serverId?: number, retryCount: number = 0, useSystem: boolean = false)

}

async function runSpeedtest(serverId?: number, retryCount: number = 0, useSystem: boolean = false): Promise<SpeedtestResult> {
  const MAX_RETRIES = 1; // 最多重试1次，避免无限循环

  try {
    // 如果要求使用系统 speedtest，则尝试系统可执行文件
    if (useSystem) {
      return await runSystemSpeedtest(serverId, retryCount);
    }

    // 检查并诊断内置可执行文件
    if (!fs.existsSync(SPEEDTEST_PATH)) {
      console.log("Speedtest executable not found, downloading...");
      await downloadCli();
    }

    // 只在第一次尝试时进行诊断，避免重复诊断
    if (retryCount === 0) {
      const diagnosis = await diagnoseSpeedtestExecutable();
      if (!diagnosis.canRun) {
        console.log(`Speedtest executable issue detected: ${diagnosis.error}`);
        if (diagnosis.needsReinstall) {
          console.log("Attempting auto-fix...");
          await autoFixSpeedtest();
        }
      }
    }

    const serverArg = serverId ? ` -s ${serverId}` : "";
    const command = `"${SPEEDTEST_PATH}" --accept-license --accept-gdpr -f json${serverArg}`;

    const { stdout, stderr } = await execAsync(command, {
      timeout: 120000 // 120秒超时
    });

    if (stderr) {
      console.log("Speedtest stderr:", stderr);
      if (stderr.includes("NoServersException")) {
        // 如果指定服务器不可用，尝试自动选择
        if (serverId) {
          console.log(`Server ${serverId} not available, trying auto selection...`);
          return await runSpeedtest(undefined, retryCount, useSystem); // 递归调用，不指定服务器ID，保持重试计数
        }
        throw new Error("指定的服务器不可用，请尝试其他服务器或使用自动选择");
      }
      if (stderr.includes("Timeout occurred")) {
        throw new Error("网络连接超时，请检查网络状况或稍后重试");
      }
      if (stderr.includes("Cannot read from socket")) {
        throw new Error("网络连接中断，可能是网络不稳定或防火墙阻止");
      }
    }

    // 尝试解析JSON结果，处理可能的部分失败情况
    let result: any;
    try {
      result = JSON.parse(stdout);

      // 检查JSON中是否包含错误信息