Function getNodeInfo

subinfo/subinfo.ts:139–210

(url: string)

// 尝试解析节点信息 (节点数, 类型, 地区分布)
async function getNodeInfo(url: string): Promise<{ node_count: number | string, type_count: Record<string, number>, regions: Record<string, number> } | null> {
  try {
    const res = await axios.get(url, { timeout: 10000, responseType: 'text' });
    
    // 1. 尝试解析 YAML (Clash/Surge)
    try {
      const config = yaml.load(res.data);
      if (config && (config as any).proxies) {
        const proxies = (config as any).proxies;
        const typeCount: Record<string, number> = {};
        const regions: Record<string, number> = {};
        let totalNodes = proxies.length;
        let identified = 0;
        for (const proxy of proxies) {
          const type = proxy.type?.toLowerCase();
          typeCount[type] = (typeCount[type] || 0) + 1;
          const nameLow = proxy.name?.toLowerCase() || '';
          for (const [region, keys] of REGION_RULES) {
            if (keys.some(k => nameLow.includes(k.toLowerCase()))) {
              regions[region] = (regions[region] || 0) + 1;
              identified++;
              break;
            }
          }
        }
        if (totalNodes - identified > 0) regions['其他'] = totalNodes - identified;
        return {
          node_count: totalNodes,
          type_count: Object.fromEntries(Object.entries(typeCount).filter(([, v]) => v > 0)),
          regions: Object.fromEntries(Object.entries(regions).filter(([, v]) => v > 0))
        };
      }
    } catch { /* 忽略 YAML 解析错误 */ }
    
    // 2. 尝试解析 Base64 (V2Ray/Shadowsocks 原始链接)
    try {
      const decoded = Buffer.from(res.data, 'base64').toString();
      const typeCount: Record<string, number> = {};
      const regions: Record<string, number> = {};
      let nodeCount = 0;
      let identified = 0;
      const protocols = ['vmess://', 'trojan://', 'ss://', 'ssr://', 'vless://', 'hy2://', 'hysteria://', 'hy://', 'tuic://', 'wireguard://', 'socks5://', 'http://', 'https://', 'shadowtls://', 'naive://'];
      
      decoded.split('\n').forEach((line: string) => {
        if (!line.trim()) return;
        for (const pattern of protocols) {
          if (line.startsWith(pattern)) {
            let t = pattern.replace('://', '');
            typeCount[t] = (typeCount[t] || 0) + 1;
            nodeCount++;
            let lLow = line.toLowerCase();
            for (const [region, keys] of REGION_RULES) {
              if (keys.some(k => lLow.includes(k.toLowerCase()))) {
                regions[region] = (regions[region] || 0) + 1;
                identified++;
                break;
              }
            }