pname.js_old

/**
 * 日期：2023-08-06 12:15:05 仅支持Surge、Loon
 * 注意: Surge 必须使用带 有参数 [ability=http-client-policy] 走指定节点功能的substore否则脚本无效 
 * 用法：Sub-Store 脚本操作里添加 此脚本链接 https://github.com/Keywos/rule/raw/main/pname.js#timeout=1000&bs=30
 * 作者：@Key
 * 功能：去除无效节点
 *
 * 参数：
 * [bs=]       批处理节点数
 * [timeout=]  超时时间 单位 ms
 * [flag]      加国旗
 * [px]        根据 [Https Ping cloudflare] 延时排序
 */

const $ = $substore;
const iar = $arguments;
let timeout = iar.timeout || 2000,
  flag = iar.flag,
  debug = iar.debug,
  Sort = iar.px,
  bs = iar.bs || 20;
const { isLoon: isLoon, isSurge: isSurge } = $substore.env,
  target = isLoon ? "Loon" : isSurge ? "Surge" : undefined;    
async function operator(e = [], targetPlatform, env) {
  let tzname = "", subcoll = "", x = false, xy = false;
  if (env?.source?.[e?.[0]?.subName]) x = true;
  if (env?.source?._collection?.name) xy = true;
  if (x && xy) {
    tzname =
      env.source._collection.name + ": [" + env.source._collection.subscriptions + "]";
    subcoll = "组合订阅内单条订阅加了脚本, 输出组合订阅";
  } else if (x) {
    tzname = env.source[e[0].subName].name;
    subcoll = "单条订阅脚本";
  } else {
    tzname = env.source._collection.name;
    subcoll = "组合订阅脚本";
  }

  const startTime = new Date();
  const support = isLoon || isSurge;
  if (!support) {
    $.notify("No Loon or Surge")
    $.error(`No Loon or Surge`);
    return e;
  }
  if (e.length < 1) {
    $notification.post("PNAME:"+subcoll+tzname, "订阅无节点", "");
    return e;
  }
  function klog(...arg) {
    console.log("[PNAME] "+subcoll+tzname+ " " + arg);
  }
  const ein = e.length;
  klog(`开始处理节点: ${ein} 个`);
  klog(`批处理节点数: ${bs} 个`);
  let i = 0, newnode = [];
  while (i < e.length) {
    const batch = e.slice(i, i + bs);
    await Promise.all(
      batch.map(async (pk) => {
        try {
          const OUTK = await OUTIA(pk);
          const qcip = pk.server + OUTK.ip;
          flag && (pk.name = getflag(OUTK.loc) + " " + pk.name);
          newnode.push(OUTK.ip)
          pk.Key = OUTK;
          pk.qc = qcip
        } catch (err) {
          delog(err.message)
        }
      })
    );
    i += bs;
  }
  e = removels(e);
  let eout = e.length;
  if (eout > 2 && isSurge){
    delog(newnode)
    const allsame = newnode.every((value, index, arr) => value === arr[0]);
    if(allsame){
        klog(`未使用带指定节点功能的 SubStore`);
        $notification.post('PNAME：点击以安装对应版本'+subcoll+tzname,'未使用带指定节点功能的 SubStore，或所有节点落地IP相同','',{url: "https://raw.githubusercontent.com/sub-store-org/Sub-Store/master/config/Surge-ability.sgmodule",})
        return e;
    }
  }
  Sort && (e.sort((a, b) => a.Key.tk - b.Key.tk));
  const endTime = new Date();
  const timeDiff = endTime.getTime() - startTime.getTime();
  klog(`处理完后剩余: ${eout} 个`);
  klog(`此方法总用时: ${zhTime(timeDiff)}`);
  return e;
}

function getflag(e) {
  const t = e
    .toUpperCase()
    .split("")
    .map((e) => 127397 + e.charCodeAt());
  return String.fromCodePoint(...t).replace(/🇹🇼/g, "🇨🇳");
}
function sleep(e) {
  return new Promise((t) => setTimeout(t, e));
}

let apiRead = 0, apiw = 0;
async function OUTIA(e) {
  const maxRE = 2;
  //https://cloudflare.com/cdn-cgi/trace
  const url = `https://cloudflare.com/cdn-cgi/trace`;
  const getHttp = async (reTry) => {
    try {
      let r = ProxyUtils.produce([e], target);
      let time = Date.now();
      const response = await Promise.race([
        $.http.get({ url: url, node: r, "policy-descriptor": r }),
        new Promise((_, reject) =>
          setTimeout(() => reject(new Error("timeout")), timeout)
        ),
      ]);
      const data = response.body;
      if (data.length > 0) {
        let endtime = Date.now() - time;
        let lines = data.split("\n");
        let key = lines.reduce((acc, line) => {
          const [name, value] = line.split("=").map((item) => item.trim());
          if (["ip", "loc", "warp"].includes(name)) {
            acc[name] = value;
            acc["tk"] = endtime;
          }
          return acc;
        }, {});
        return key;
      } else {
        throw new Error(resdata.message);
      }
    } catch (error) {
      if (reTry < maxRE) {
        await sleep(getRandom());
        delog(e.name + "-> [OUTKApi超时查询次数] " + reTry);
        return getHttp(reTry + 1);
      } else {
        throw error;
      }
    }
  };
  const resGet = new Promise((resolve, reject) => {
    getHttp(1)
      .then((data) => {
        apiw++;
        resolve(data);
      })
      .catch(reject);
  });
  return resGet;
}

function getRandom() {
  return Math.floor(Math.random() * (200 - 20 + 1) + 20);
}

function delog(...arg) {
  if (debug) {
    console.log("[PNAME] " + arg);
  }
}


function removels(e) {
  const t = new Set();
  const n = [];
  for (const s of e) {
    if (s.qc && !t.has(s.qc)) {
      t.add(s.qc);
      n.push(s);
    }
  }
  return n;
}

function zhTime(e) {
  e = e.toString().replace(/-/g, "");
  if (e < 1e3) {
    return `${Math.round(e)}毫秒`;
  } else if (e < 6e4) {
    return `${Math.round(e / 1e3)}秒`;
  } else if (e < 36e5) {
    return `${Math.round(e / 6e4)}分钟`;
  } else if (e >= 36e5) {
    return `${Math.round(e / 36e5)}小时`;
  }
}
function getid(e) {
  let t = "ld";
  return `${t}-${e.server}-${e.port}`;
}