| 物理位置 | 运营主体 / ISP | IP 类型 | -操作 | +操作 | @@ -2780,6 +2821,7 @@ INDEX_HTML = r""" + @@ -3118,6 +3160,9 @@ function getFilteredNodes() { if (selectedStatus === "unavailable" && (n.probe_status !== "unavailable" || n.active)) { return false; } + if (selectedStatus === "favorites" && (!state.favorite_node_ids || !state.favorite_node_ids.includes(n.id))) { + return false; + } const searchStr = [ n.country || "", n.country_short || "", n.ip || "", n.remote_host || "", n.proto || "", translateQuality(n.quality), translateIpType(n.ip_type), n.location || "", n.owner || "", n.as_name || "" @@ -3277,6 +3322,10 @@ function render(){ } } + const isFavoritesFilter = $("status_filter").value === "favorites"; + const banner = $("favorites_banner"); + if (banner) banner.style.display = isFavoritesFilter ? "block" : "none"; + // Pagination calculation const totalPages = Math.ceil(shown.length / pageSize) || 1; if (currentPage > totalPages) currentPage = totalPages; @@ -3306,12 +3355,18 @@ function render(){ const testBtnText = isTesting ? `${testSpinner}检测中` : '检测'; const testBtn = ``; + // Connect button is disabled if probe status is "unavailable" and not already active, or if we are already connecting // Connect button is disabled if probe status is "unavailable" and not already active, or if we are already connecting const isUnavailable = n.probe_status === "unavailable"; const connectBtn = isCurrentlyActive ? `` : ``; + const isFav = state.favorite_node_ids && state.favorite_node_ids.includes(n.id); + const favBtn = isFav + ? `` + : ``; + return `
|---|---|
| ${badgeText} | @@ -3320,6 +3375,7 @@ function render(){
+ ${favBtn}
${connectBtn}
|
@@ -3380,6 +3436,24 @@ async function testNode(btn, id, event){
}
}
+async function toggleFavorite(id, event) {
+ if (event) event.stopPropagation();
+ try {
+ const response = await fetch("./api/toggle_favorite", {
+ method: "POST",
+ headers: { "Content-Type": "application/json" },
+ body: JSON.stringify({ id })
+ });
+ const result = await response.json();
+ if (result.ok) {
+ state.favorite_node_ids = result.favorite_node_ids || [];
+ render();
+ }
+ } catch (e) {
+ console.error("切换收藏失败", e);
+ }
+}
+
let pollInterval = null;
function startConnectionPolling() {
@@ -3578,6 +3652,12 @@ function handleRoutingModeChange(mode) {
warningDiv.style.background = "rgba(245, 158, 11, 0.1)";
warningDiv.style.border = "1px solid rgba(245, 158, 11, 0.2)";
warningDiv.innerHTML = `⚠️ 固定地区：限制仅连接选定国家的节点，且后台仅并发测速该国家的节点。如果该国的所有可用节点都失效，会造成代理中断且绝不自动切换到其他国家的节点。`;
+ } else if (mode === "favorites") {
+ countryGroup.style.display = "none";
+ warningDiv.style.color = "var(--warning)";
+ warningDiv.style.background = "rgba(245, 158, 11, 0.1)";
+ warningDiv.style.border = "1px solid rgba(245, 158, 11, 0.2)";
+ warningDiv.innerHTML = `⚠️ 仅用收藏：只连接和切换您收藏的节点。如果所有收藏的节点均失效，系统不会自动切换到未收藏的节点。请确保收藏列表中有足够多且可用的节点。`;
} else if (mode === "fixed_ip") {
countryGroup.style.display = "none";
warningDiv.style.color = "var(--warning)";
@@ -4589,7 +4669,7 @@ class Handler(BaseHTTPRequestHandler):
self.send_json({"ok": False, "error": "安全后缀仅能由英文字母和数字组成"}, HTTPStatus.BAD_REQUEST)
return
- if routing_mode not in ("auto", "fixed_ip", "fixed_region"):
+ if (routing_mode not in ("auto", "fixed_ip", "fixed_region", "favorites")):
self.send_json({"ok": False, "error": "无效的路由配置模式"}, HTTPStatus.BAD_REQUEST)
return
if routing_ip_type not in ("all", "residential", "hosting"):
@@ -4637,7 +4717,7 @@ class Handler(BaseHTTPRequestHandler):
force_country = str(payload.get("force_country") or "").strip()
routing_ip_type = str(payload.get("routing_ip_type") or "all").strip()
- if routing_mode not in ("auto", "fixed_ip", "fixed_region"):
+ if routing_mode not in ("auto", "fixed_ip", "fixed_region", "favorites"):
self.send_json({"ok": False, "error": "无效的路由配置模式"}, HTTPStatus.BAD_REQUEST)
return
if routing_ip_type not in ("all", "residential", "hosting"):
@@ -4660,6 +4740,33 @@ class Handler(BaseHTTPRequestHandler):
self.send_json({"ok": False, "error": str(exc)}, HTTPStatus.INTERNAL_SERVER_ERROR)
return
+ elif effective_path == "/api/toggle_favorite":
+ try:
+ length = parse_int(self.headers.get("Content-Length"))
+ payload = json.loads(self.rfile.read(length).decode("utf-8") or "{}")
+ node_id = str(payload.get("id") or "").strip()
+
+ ui_cfg = load_ui_config()
+ fav_ids = ui_cfg.get("favorite_node_ids", [])
+ if not isinstance(fav_ids, list):
+ fav_ids = []
+
+ if node_id in fav_ids:
+ fav_ids.remove(node_id)
+ else:
+ fav_ids.append(node_id)
+
+ ui_cfg["favorite_node_ids"] = fav_ids
+ auth_file = DATA_DIR / "ui_auth.json"
+ with lock:
+ DATA_DIR.mkdir(exist_ok=True, parents=True)
+ auth_file.write_text(json.dumps(ui_cfg, ensure_ascii=False, indent=2), encoding="utf-8")
+
+ self.send_json({"ok": True, "favorite_node_ids": fav_ids})
+ except Exception as exc:
+ self.send_json({"ok": False, "error": str(exc)}, HTTPStatus.INTERNAL_SERVER_ERROR)
+ return
+
if effective_path == "/api/check":
try:
self.send_json({"ok": True, "message": maintain_valid_nodes(force=True)})