Function runSpeedtest

speedtest/speedtest.ts:637–790

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

    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中是否包含错误信息
      if (result.error) {
        if (result.error.includes("Cannot read")) {
          throw new Error(`网络连接错误: ${result.error}\n\n这是网络环境问题，不是程序问题。建议：\n1. 检查网络连接稳定性\n2. 尝试其他测试服务器\n3. 稍后重试`);
        }
        throw new Error(`测试失败: ${result.error}`);
      }
    } catch (parseError) {