Function prepareShadowrocketNodeSwitch

src/server.js:3810–3843

(target)

}

async function prepareShadowrocketNodeSwitch(target) {
  const resolved = await runCommand(shadowrocketNodeControlPath, ["resolve", target], { timeout: 8000, allowFailure: true });
  if (resolved.status !== 0) {
    return {
      ok: false,
      summary: "Shadowrocket node resolve failed",
      reply: trimIMessageCommandOutput(`没找到这个节点：${target}\n${resolved.output.trim()}`)
    };
  }
  const node = JSON.parse(resolved.output.trim());
  const probe = await runCommand(shadowrocketNodeControlPath, ["probe-target", String(node.index || node.uuid)], { timeout: 8000, allowFailure: true });
  state.proxy.pendingAction = {
    action: "switch-node",
    target: String(node.index || node.uuid),
    node,
    createdAt: Date.now()
  };
  return {
    ok: true,
    summary: "Shadowrocket node switch confirmation required",
    reply: trimIMessageCommandOutput([
      "准备切换 Shadowrocket 节点。",
      `目标：${node.index}. ${node.title}`,
      `类型：${node.type || "未知"}，小火箭 ping：${node.ping ?? "未知"}`,
      `入口：${node.host || "未知"}:${node.port || "未知"}`,
      "",
      "准备阶段入口测速：",
      probe.output.trim() || "入口测速没有输出。",
      "",
      "注意：这里只测目标入口 TCP，不代表目标节点一定能访问 OpenAI/X/YouTube。",
      "确认切换请在 3 分钟内发送 /确认；不切换就发送 /取消。"
    ].join("\n"))
  };
}

function trimIMessageCommandOutput(text, limit = 1600) {
  const value = String(text || "").trim();