commit fdd3f9cade086e35371064b1f8e78bb828b56336
Author: Hermes Agent <Hermes@Hermes.Hermes>
Date:   Thu May 28 20:26:44 2026 +0800

    ui: simplify configuration forms

diff --git a/.dockerignore b/.dockerignore
new file mode 100644
index 0000000..5916548
--- /dev/null
+++ b/.dockerignore
@@ -0,0 +1,8 @@
+__pycache__/
+*.pyc
+.DS_Store
+.git/
+data/
+config.json
+*.db
+*.log
diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..9eefaad
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,12 @@
+config.json
+.env
+*.env
+.env.*
+data/
+*.db
+*.sqlite
+*.sqlite3
+*.log
+__pycache__/
+*.pyc
+.DS_Store
diff --git a/Dockerfile b/Dockerfile
new file mode 100644
index 0000000..f265399
--- /dev/null
+++ b/Dockerfile
@@ -0,0 +1,19 @@
+FROM python:3.11-alpine
+
+ENV PYTHONUNBUFFERED=1 \
+    SOCKS5_MONITOR_CONFIG=/app/config.json
+
+WORKDIR /app
+COPY app.py config.example.json README.md ./
+COPY static ./static
+
+RUN mkdir -p /app/data && \
+    cp /app/config.example.json /app/config.json
+
+EXPOSE 8787
+VOLUME ["/app/data"]
+
+HEALTHCHECK --interval=30s --timeout=5s --start-period=10s --retries=3 \
+  CMD python3 -c "import urllib.request; urllib.request.urlopen('http://127.0.0.1:8787/api/status', timeout=3).read()" || exit 1
+
+CMD ["python3", "/app/app.py", "--host", "0.0.0.0", "--port", "8787", "--config", "/app/config.json"]
diff --git a/README.md b/README.md
new file mode 100644
index 0000000..b17c933
--- /dev/null
+++ b/README.md
@@ -0,0 +1,128 @@
+# SOCKS5 Monitor
+
+一个轻量的 SOCKS5 代理健康监控面板，支持节点检测、状态记录和通知告警。
+
+## 功能
+
+- SOCKS5 连通性检测：协商、认证并 CONNECT 到目标地址
+- 全局默认检测目标与节点级覆盖
+- 检测间隔、超时、失败/恢复阈值可配置
+- 通知渠道：Bark、PushPlus、Autman、Webhook
+- SQLite 保存检测记录、事件和通知日志
+- Docker / Docker Compose 部署
+
+## 快速启动
+
+```bash
+cp config.example.json config.json
+docker compose up -d
+```
+
+访问：
+
+```text
+http://127.0.0.1:8787
+```
+
+## 本地运行
+
+```bash
+python3 app.py --host 0.0.0.0 --port 8787 --config config.json
+```
+
+## 配置
+
+默认配置见 `config.example.json`。实际运行配置写入 `config.json`，不要提交真实账号、密码、Token 或私有地址。
+
+### 全局检测设置
+
+```json
+{
+  "target_host": "www.baidu.com",
+  "target_port": 443,
+  "interval_seconds": 300,
+  "timeout_seconds": 8,
+  "fail_threshold": 3,
+  "recover_threshold": 1
+}
+```
+
+### 节点配置
+
+```json
+{
+  "id": "proxy-1",
+  "name": "Example Proxy",
+  "host": "127.0.0.1",
+  "port": 1080,
+  "username": "",
+  "password": "",
+  "target_host": "www.baidu.com",
+  "target_port": 443,
+  "timeout_seconds": 8,
+  "interval_seconds": 300,
+  "fail_threshold": 3,
+  "recover_threshold": 1,
+  "enabled": false
+}
+```
+
+### Autman 通知
+
+Autman 通道适配 `/m/push1` 消息推送插件，发送 JSON：
+
+```json
+{
+  "message": "标题:...\n内容:...",
+  "access_token": "..."
+}
+```
+
+配置示例：
+
+```json
+{
+  "type": "autman",
+  "enabled": false,
+  "config": {
+    "url": "http://example.com/m/push1",
+    "access_token": ""
+  }
+}
+```
+
+## API
+
+```text
+GET    /api/status
+PUT    /api/settings
+POST   /api/check/<id>
+POST   /api/notify/test
+GET    /api/proxies
+POST   /api/proxies
+PUT    /api/proxies/<id>
+DELETE /api/proxies/<id>
+GET    /api/channels
+POST   /api/channels
+PUT    /api/channels/<id>
+DELETE /api/channels/<id>
+POST   /api/channels/<id>/test
+```
+
+## Docker 镜像
+
+```text
+192.168.2.66:80/hermes/socks5-monitor:latest
+```
+
+## 数据目录
+
+```text
+data/monitor.db
+```
+
+## 安全
+
+- `config.json`、`data/`、日志和缓存不应提交到源码仓库
+- 镜像构建只包含 `config.example.json`，不包含真实运行配置
+- 公开仓库中只保留占位配置
diff --git a/app.py b/app.py
new file mode 100644
index 0000000..4e87445
--- /dev/null
+++ b/app.py
@@ -0,0 +1,684 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+from __future__ import annotations
+
+import argparse
+import asyncio
+import contextlib
+import dataclasses
+import json
+import re
+import socket
+import sqlite3
+import struct
+import time
+import traceback
+import urllib.error
+import urllib.parse
+import urllib.request
+import uuid
+from datetime import datetime
+from pathlib import Path
+from typing import Any
+
+APP_DIR = Path(__file__).resolve().parent
+DEFAULT_CONFIG = APP_DIR / "config.json"
+DEFAULT_DB = APP_DIR / "data" / "monitor.db"
+
+
+def now_ts() -> int:
+    return int(time.time())
+
+
+def iso(ts: int | None = None) -> str:
+    return datetime.fromtimestamp(ts or now_ts()).strftime("%Y-%m-%d %H:%M:%S")
+
+
+def load_json(path: Path) -> dict[str, Any]:
+    if not path.exists():
+        return {}
+    return json.loads(path.read_text(encoding="utf-8"))
+
+
+def save_json(path: Path, data: dict[str, Any]) -> None:
+    path.parent.mkdir(parents=True, exist_ok=True)
+    tmp = path.with_suffix(path.suffix + ".tmp")
+    tmp.write_text(json.dumps(data, ensure_ascii=False, indent=2) + "\n", encoding="utf-8")
+    tmp.replace(path)
+
+
+def deep_copy(obj: Any) -> Any:
+    return json.loads(json.dumps(obj, ensure_ascii=False))
+
+
+def default_config() -> dict[str, Any]:
+    return {
+        "interval_seconds": 300,
+        "timeout_seconds": 8,
+        "target_host": "www.baidu.com",
+        "target_port": 443,
+        "fail_threshold": 3,
+        "recover_threshold": 1,
+        "db_path": str(DEFAULT_DB),
+        "proxies": [],
+        "notifications": {"enabled": True, "timeout_seconds": 10, "channels": []},
+    }
+
+
+def merge_defaults(cfg: dict[str, Any]) -> dict[str, Any]:
+    base = default_config()
+    base.update(cfg or {})
+    notifications = base.get("notifications") or {}
+    base["notifications"] = {"enabled": True, "timeout_seconds": 10, "channels": [], **notifications}
+    if base.get("target_host") in (None, "", "1.1.1.1", "8.8.8.8", "google.com"):
+        base["target_host"] = "www.baidu.com"
+    base["target_port"] = int(base.get("target_port") or 443)
+    base["interval_seconds"] = int(base.get("interval_seconds") or 300)
+    base.setdefault("proxies", [])
+    for proxy in base["proxies"]:
+        if proxy.get("target_host") in (None, "", "1.1.1.1", "8.8.8.8", "google.com"):
+            proxy["target_host"] = base["target_host"]
+        proxy["target_port"] = int(proxy.get("target_port") or base["target_port"])
+        proxy["interval_seconds"] = int(proxy.get("interval_seconds") or base["interval_seconds"])
+    base["notifications"].setdefault("channels", [])
+    base["notifications"]["channels"] = [normalize_channel(c) for c in base["notifications"].get("channels", [])]
+    return base
+
+
+def public_proxy(proxy: dict[str, Any]) -> dict[str, Any]:
+    p = deep_copy(proxy)
+    if p.get("password"):
+        p["password_masked"] = "********"
+        p["password"] = ""
+    return p
+
+
+def normalize_channel(channel: dict[str, Any]) -> dict[str, Any]:
+    """Return canonical notification channel shape: common fields + type-specific config.
+
+    Backward compatible with the old flat schema, but output never mixes fields
+    across Bark / PushPlus / Autman / Webhook.
+    """
+    c = dict(channel or {})
+    typ = c.get("type") or "webhook"
+    cfg = dict(c.get("config") or {})
+    if typ == "bark":
+        cfg = {
+            "server": cfg.get("server") or c.get("server") or "https://api.day.app",
+            "key": cfg.get("key") or c.get("key") or "",
+            "group": cfg.get("group") or c.get("group") or "SOCKS5监控",
+        }
+    elif typ == "pushplus":
+        cfg = {
+            "token": cfg.get("token") or c.get("token") or c.get("key") or "",
+            "template": cfg.get("template") or c.get("template") or "txt",
+            "topic": cfg.get("topic") or c.get("topic") or c.get("group") or "",
+        }
+    elif typ == "autman":
+        cfg = {
+            "url": cfg.get("url") or c.get("url") or c.get("webhook") or "",
+            "access_token": cfg.get("access_token") or cfg.get("token") or c.get("access_token") or c.get("token") or "",
+        }
+    elif typ == "webhook":
+        cfg = {
+            "url": cfg.get("url") or c.get("url") or "",
+            "headers": cfg.get("headers") if isinstance(cfg.get("headers"), dict) else (c.get("headers") if isinstance(c.get("headers"), dict) else {}),
+            "payload": cfg.get("payload") if isinstance(cfg.get("payload"), dict) else (c.get("payload") if isinstance(c.get("payload"), dict) else {}),
+        }
+    return {
+        "id": c.get("id") or f"ch-{uuid.uuid4().hex[:8]}",
+        "type": typ,
+        "name": c.get("name") or typ,
+        "enabled": bool(c.get("enabled", True)),
+        "config": cfg,
+    }
+
+
+class Store:
+    def __init__(self, path: Path):
+        self.path = path
+        self.path.parent.mkdir(parents=True, exist_ok=True)
+        self.conn = sqlite3.connect(self.path, check_same_thread=False)
+        self.conn.row_factory = sqlite3.Row
+        self.lock = asyncio.Lock()
+        self.init()
+
+    def init(self) -> None:
+        self.conn.executescript(
+            """
+            create table if not exists checks(
+              id integer primary key autoincrement,
+              proxy_id text not null,
+              ts integer not null,
+              ok integer not null,
+              latency_ms integer,
+              error text,
+              exit_ip text
+            );
+            create index if not exists idx_checks_proxy_ts on checks(proxy_id, ts desc);
+            create table if not exists events(
+              id integer primary key autoincrement,
+              proxy_id text not null,
+              ts integer not null,
+              old_status text,
+              new_status text,
+              message text
+            );
+            create index if not exists idx_events_ts on events(ts desc);
+            create table if not exists notification_logs(
+              id integer primary key autoincrement,
+              ts integer not null,
+              channel_id text,
+              channel_name text,
+              ok integer not null,
+              title text,
+              message text,
+              result text
+            );
+            create index if not exists idx_notification_logs_ts on notification_logs(ts desc);
+            """
+        )
+        self.conn.commit()
+
+    async def add_check(self, proxy_id: str, ok: bool, latency_ms: int | None, error: str | None, exit_ip: str | None) -> None:
+        async with self.lock:
+            self.conn.execute(
+                "insert into checks(proxy_id,ts,ok,latency_ms,error,exit_ip) values(?,?,?,?,?,?)",
+                (proxy_id, now_ts(), 1 if ok else 0, latency_ms, error, exit_ip),
+            )
+            self.conn.commit()
+
+    async def add_event(self, proxy_id: str, old_status: str | None, new_status: str, message: str) -> None:
+        async with self.lock:
+            self.conn.execute(
+                "insert into events(proxy_id,ts,old_status,new_status,message) values(?,?,?,?,?)",
+                (proxy_id, now_ts(), old_status, new_status, message),
+            )
+            self.conn.commit()
+
+    async def add_notification(self, channel: dict[str, Any], ok: bool, title: str, message: str, result: str) -> None:
+        async with self.lock:
+            self.conn.execute(
+                "insert into notification_logs(ts,channel_id,channel_name,ok,title,message,result) values(?,?,?,?,?,?,?)",
+                (now_ts(), channel.get("id"), channel.get("name") or channel.get("type"), 1 if ok else 0, title, message, result),
+            )
+            self.conn.commit()
+
+    def recent_checks(self, proxy_id: str, limit: int = 50) -> list[dict[str, Any]]:
+        rows = self.conn.execute("select * from checks where proxy_id=? order by ts desc limit ?", (proxy_id, limit)).fetchall()
+        return [dict(r) for r in rows]
+
+    def recent_events(self, limit: int = 50) -> list[dict[str, Any]]:
+        rows = self.conn.execute("select * from events order by ts desc limit ?", (limit,)).fetchall()
+        return [dict(r) for r in rows]
+
+    def recent_notifications(self, limit: int = 50) -> list[dict[str, Any]]:
+        rows = self.conn.execute("select * from notification_logs order by ts desc limit ?", (limit,)).fetchall()
+        return [dict(r) for r in rows]
+
+
+@dataclasses.dataclass
+class RuntimeState:
+    status: str = "unknown"
+    last_ok: bool | None = None
+    last_ts: int | None = None
+    latency_ms: int | None = None
+    error: str | None = None
+    exit_ip: str | None = None
+    fail_count: int = 0
+    ok_count: int = 0
+    notified_down: bool = False
+
+
+class Notifier:
+    def __init__(self, cfg: dict[str, Any], store: Store | None = None):
+        self.cfg = cfg or {}
+        self.store = store
+        self.timeout = int(self.cfg.get("timeout_seconds", 10))
+
+    async def send_all(self, title: str, body: str) -> list[dict[str, Any]]:
+        if not self.cfg.get("enabled", True):
+            return [{"channel": "all", "ok": False, "error": "notifications disabled"}]
+        channels = [c for c in self.cfg.get("channels", []) if c.get("enabled", True)]
+        return await self.send_channels(channels, title, body)
+
+    async def send_channel_id(self, channel_id: str, title: str, body: str) -> dict[str, Any]:
+        ch = next((c for c in self.cfg.get("channels", []) if c.get("id") == channel_id), None)
+        if not ch:
+            return {"channel": channel_id, "ok": False, "error": "channel not found"}
+        # 单通道测试应可验证配置本身，即使该渠道平时处于停用状态。
+        test_ch = dict(ch)
+        test_ch["enabled"] = True
+        res = await self.send_channels([test_ch], title, body)
+        return res[0] if res else {"channel": channel_id, "ok": False, "error": "not sent"}
+
+    async def send_channels(self, channels: list[dict[str, Any]], title: str, body: str) -> list[dict[str, Any]]:
+        results = []
+        for ch in channels:
+            res = await asyncio.to_thread(self._send_one, ch, title, body)
+            results.append(res)
+            if self.store:
+                await self.store.add_notification(ch, bool(res.get("ok")), title, body, json.dumps(res, ensure_ascii=False))
+        return results
+
+    def _http_get(self, url: str) -> tuple[bool, str]:
+        try:
+            with urllib.request.urlopen(url, timeout=self.timeout) as r:
+                text = r.read(4096).decode("utf-8", "replace")
+                return 200 <= r.status < 300, f"HTTP {r.status} {text[:300]}"
+        except Exception as e:
+            return False, repr(e)
+
+    def _http_post_json(self, url: str, payload: dict[str, Any], headers: dict[str, str] | None = None) -> tuple[bool, str]:
+        data = json.dumps(payload, ensure_ascii=False).encode("utf-8")
+        req = urllib.request.Request(url, data=data, headers={"Content-Type": "application/json", **(headers or {})}, method="POST")
+        try:
+            with urllib.request.urlopen(req, timeout=self.timeout) as r:
+                text = r.read(4096).decode("utf-8", "replace")
+                return 200 <= r.status < 300, f"HTTP {r.status} {text[:300]}"
+        except Exception as e:
+            return False, repr(e)
+
+    def _send_one(self, ch: dict[str, Any], title: str, body: str) -> dict[str, Any]:
+        ch = normalize_channel(ch)
+        typ = ch.get("type")
+        cfg = ch.get("config") or {}
+        name = ch.get("name") or typ
+        if not ch.get("enabled", True):
+            return {"channel": name, "ok": False, "error": "disabled"}
+        try:
+            if typ == "bark":
+                base = (cfg.get("server") or "https://api.day.app").rstrip("/")
+                key = cfg.get("key") or ""
+                group = cfg.get("group") or "SOCKS5监控"
+                if not key:
+                    return {"channel": name, "ok": False, "error": "missing Bark key"}
+                url = f"{base}/{urllib.parse.quote(key)}/{urllib.parse.quote(title)}/{urllib.parse.quote(body)}?group={urllib.parse.quote(group)}"
+                ok, msg = self._http_get(url)
+            elif typ == "pushplus":
+                token = cfg.get("token") or ""
+                if not token:
+                    return {"channel": name, "ok": False, "error": "missing PushPlus token"}
+                payload = {"token": token, "title": title, "content": body, "template": cfg.get("template", "txt")}
+                if cfg.get("topic"):
+                    payload["topic"] = cfg.get("topic")
+                ok, msg = self._http_post_json("https://www.pushplus.plus/send", payload)
+            elif typ == "autman":
+                url = cfg.get("url") or ""
+                if not url:
+                    return {"channel": name, "ok": False, "error": "missing autman url"}
+                message = f"标题:{title}\n内容:{body}"
+                payload = {"message": message, "access_token": cfg.get("access_token") or ""}
+                ok, msg = self._http_post_json(url, payload, {})
+            elif typ == "webhook":
+                url = cfg.get("url") or ""
+                if not url:
+                    return {"channel": name, "ok": False, "error": "missing webhook url"}
+                payload = dict(cfg.get("payload", {}) if isinstance(cfg.get("payload"), dict) else {})
+                payload.update({"title": title, "content": body, "ts": now_ts()})
+                ok, msg = self._http_post_json(url, payload, cfg.get("headers") or {})
+            else:
+                return {"channel": name, "ok": False, "error": f"unknown type {typ}"}
+            return {"channel": name, "ok": ok, "message": msg}
+        except Exception as e:
+            return {"channel": name, "ok": False, "error": repr(e)}
+
+
+async def socks5_connect(proxy: dict[str, Any], timeout: float) -> None:
+    host = proxy["host"]
+    port = int(proxy["port"])
+    username = proxy.get("username") or ""
+    password = proxy.get("password") or ""
+    target_host = proxy.get("target_host", "1.1.1.1")
+    target_port = int(proxy.get("target_port", 443))
+    reader, writer = await asyncio.wait_for(asyncio.open_connection(host, port), timeout=timeout)
+    try:
+        methods = [0x00]
+        if username or password:
+            methods.append(0x02)
+        writer.write(bytes([0x05, len(methods), *methods])); await writer.drain()
+        resp = await asyncio.wait_for(reader.readexactly(2), timeout=timeout)
+        if resp[0] != 0x05: raise RuntimeError(f"invalid socks version {resp[0]}")
+        method = resp[1]
+        if method == 0xFF: raise RuntimeError("socks auth method rejected")
+        if method == 0x02:
+            ub, pb = username.encode(), password.encode()
+            writer.write(bytes([0x01, len(ub)]) + ub + bytes([len(pb)]) + pb); await writer.drain()
+            auth = await asyncio.wait_for(reader.readexactly(2), timeout=timeout)
+            if auth[1] != 0x00: raise RuntimeError("socks username/password auth failed")
+        elif method != 0x00:
+            raise RuntimeError(f"unsupported socks method {method}")
+        try:
+            addr = socket.inet_aton(target_host); atyp = 0x01; body = addr
+        except OSError:
+            hb = target_host.encode(); atyp = 0x03; body = bytes([len(hb)]) + hb
+        writer.write(bytes([0x05, 0x01, 0x00, atyp]) + body + struct.pack("!H", target_port)); await writer.drain()
+        head = await asyncio.wait_for(reader.readexactly(4), timeout=timeout)
+        if head[1] != 0x00: raise RuntimeError(f"socks connect failed rep=0x{head[1]:02x}")
+        atyp = head[3]
+        if atyp == 0x01: await reader.readexactly(4)
+        elif atyp == 0x03: await reader.readexactly((await reader.readexactly(1))[0])
+        elif atyp == 0x04: await reader.readexactly(16)
+        await reader.readexactly(2)
+    finally:
+        writer.close()
+        with contextlib.suppress(Exception): await writer.wait_closed()
+
+
+async def check_proxy(proxy: dict[str, Any]) -> tuple[bool, int | None, str | None, str | None]:
+    timeout = float(proxy.get("timeout_seconds", 8))
+    start = time.perf_counter()
+    try:
+        await socks5_connect(proxy, timeout)
+        return True, int((time.perf_counter() - start) * 1000), None, None
+    except Exception as e:
+        return False, int((time.perf_counter() - start) * 1000), str(e), None
+
+
+class App:
+    def __init__(self, config_path: Path):
+        self.config_path = config_path
+        self.config = merge_defaults(load_json(config_path))
+        if not config_path.exists(): save_json(config_path, self.config)
+        self.store = Store(Path(self.config.get("db_path") or DEFAULT_DB))
+        self.notifier = Notifier(self.config.get("notifications") or {}, self.store)
+        self.states: dict[str, RuntimeState] = {}
+        self.monitor_tasks: dict[str, asyncio.Task] = {}
+        self.config_lock = asyncio.Lock()
+
+    @property
+    def proxies(self) -> list[dict[str, Any]]:
+        return self.config.setdefault("proxies", [])
+
+    @property
+    def channels(self) -> list[dict[str, Any]]:
+        return self.config.setdefault("notifications", {}).setdefault("channels", [])
+
+    def state_for(self, proxy_id: str) -> RuntimeState:
+        return self.states.setdefault(proxy_id, RuntimeState())
+
+    async def save_config(self) -> None:
+        async with self.config_lock:
+            save_json(self.config_path, self.config)
+            self.notifier = Notifier(self.config.get("notifications") or {}, self.store)
+
+    def get_proxy(self, proxy_id: str) -> dict[str, Any] | None:
+        return next((p for p in self.proxies if p.get("id") == proxy_id), None)
+
+    def get_channel(self, channel_id: str) -> dict[str, Any] | None:
+        return next((c for c in self.channels if c.get("id") == channel_id), None)
+
+    def validate_proxy(self, data: dict[str, Any], existing: dict[str, Any] | None = None) -> dict[str, Any]:
+        p = dict(existing or {})
+        p.update(data)
+        p.setdefault("id", re.sub(r"[^a-zA-Z0-9_-]+", "-", (p.get("name") or "proxy").strip()).strip("-") or f"proxy-{uuid.uuid4().hex[:8]}")
+        p.setdefault("name", p["id"])
+        if not p.get("host"): raise ValueError("host required")
+        p["port"] = int(p.get("port") or 1080)
+        p["target_host"] = p.get("target_host") or self.config.get("target_host") or "www.baidu.com"
+        p["target_port"] = int(p.get("target_port") or self.config.get("target_port") or 443)
+        p["timeout_seconds"] = int(p.get("timeout_seconds") or self.config.get("timeout_seconds") or 8)
+        p["interval_seconds"] = max(5, int(p.get("interval_seconds") or self.config.get("interval_seconds") or 300))
+        p["fail_threshold"] = int(p.get("fail_threshold") or self.config.get("fail_threshold") or 3)
+        p["recover_threshold"] = int(p.get("recover_threshold") or self.config.get("recover_threshold") or 1)
+        p["enabled"] = bool(p.get("enabled", True))
+        return p
+
+    def validate_channel(self, data: dict[str, Any], existing: dict[str, Any] | None = None) -> dict[str, Any]:
+        incoming = normalize_channel(data or {})
+        if existing:
+            incoming["id"] = existing.get("id")
+        typ = incoming.get("type")
+        if typ not in {"bark", "pushplus", "autman", "webhook"}:
+            raise ValueError("type must be bark/pushplus/autman/webhook")
+        incoming.setdefault("name", typ)
+        incoming["enabled"] = bool(incoming.get("enabled", True))
+        cfg = incoming["config"]
+        if typ == "bark" and not cfg.get("server"):
+            cfg["server"] = "https://api.day.app"
+        if typ == "pushplus" and not cfg.get("template"):
+            cfg["template"] = "txt"
+        return incoming
+
+    def validate_settings(self, data: dict[str, Any]) -> dict[str, Any]:
+        out = {}
+        if "interval_seconds" in data:
+            out["interval_seconds"] = max(5, int(data.get("interval_seconds") or 300))
+        if "timeout_seconds" in data:
+            out["timeout_seconds"] = max(1, int(data.get("timeout_seconds") or 8))
+        if "target_host" in data:
+            host = str(data.get("target_host") or "").strip()
+            if not host:
+                raise ValueError("target_host required")
+            out["target_host"] = host
+        if "target_port" in data:
+            port = int(data.get("target_port") or 443)
+            if port < 1 or port > 65535:
+                raise ValueError("target_port must be 1..65535")
+            out["target_port"] = port
+        if "fail_threshold" in data:
+            out["fail_threshold"] = max(1, int(data.get("fail_threshold") or 3))
+        if "recover_threshold" in data:
+            out["recover_threshold"] = max(1, int(data.get("recover_threshold") or 1))
+        return out
+
+    async def update_settings(self, data: dict[str, Any]) -> dict[str, Any]:
+        settings = self.validate_settings(data)
+        self.config.update(settings)
+        # Apply changed global defaults to nodes that were still using old built-in defaults.
+        for p in self.proxies:
+            if settings.get("target_host") and p.get("target_host") in (None, "", "1.1.1.1", "8.8.8.8", "google.com"):
+                p["target_host"] = settings["target_host"]
+            if settings.get("target_port") and not p.get("target_port"):
+                p["target_port"] = settings["target_port"]
+            if settings.get("interval_seconds") and not p.get("interval_seconds"):
+                p["interval_seconds"] = settings["interval_seconds"]
+        await self.save_config()
+        for p in list(self.proxies):
+            await self.restart_proxy_task(p["id"])
+        return {k: self.config.get(k) for k in ["interval_seconds", "timeout_seconds", "target_host", "target_port", "fail_threshold", "recover_threshold"]}
+
+    async def upsert_proxy(self, data: dict[str, Any], proxy_id: str | None = None) -> dict[str, Any]:
+        existing = self.get_proxy(proxy_id) if proxy_id else None
+        p = self.validate_proxy(data, existing)
+        if proxy_id and existing:
+            idx = self.proxies.index(existing); self.proxies[idx] = p
+        else:
+            if self.get_proxy(p["id"]): raise ValueError("proxy id already exists")
+            self.proxies.append(p)
+        await self.save_config(); await self.restart_proxy_task(p["id"])
+        return public_proxy(p)
+
+    async def delete_proxy(self, proxy_id: str) -> bool:
+        p = self.get_proxy(proxy_id)
+        if not p: return False
+        self.proxies.remove(p)
+        task = self.monitor_tasks.pop(proxy_id, None)
+        if task: task.cancel()
+        self.states.pop(proxy_id, None)
+        await self.save_config()
+        return True
+
+    async def upsert_channel(self, data: dict[str, Any], channel_id: str | None = None) -> dict[str, Any]:
+        existing = self.get_channel(channel_id) if channel_id else None
+        c = self.validate_channel(data, existing)
+        if channel_id and existing:
+            idx = self.channels.index(existing); self.channels[idx] = c
+        else:
+            if self.get_channel(c["id"]): raise ValueError("channel id already exists")
+            self.channels.append(c)
+        await self.save_config()
+        return c
+
+    async def delete_channel(self, channel_id: str) -> bool:
+        c = self.get_channel(channel_id)
+        if not c: return False
+        self.channels.remove(c)
+        await self.save_config()
+        return True
+
+    async def run_once(self, proxy: dict[str, Any]) -> None:
+        if not proxy.get("enabled", True): return
+        proxy_id = proxy["id"]
+        st = self.state_for(proxy_id)
+        ok, latency, err, exit_ip = await check_proxy(proxy)
+        await self.store.add_check(proxy_id, ok, latency, err, exit_ip)
+        st.last_ts = now_ts(); st.last_ok = ok; st.latency_ms = latency; st.error = err; st.exit_ip = exit_ip
+        fail_threshold = int(proxy.get("fail_threshold", self.config.get("fail_threshold", 3)))
+        recover_threshold = int(proxy.get("recover_threshold", self.config.get("recover_threshold", 1)))
+        old = st.status
+        if ok:
+            st.ok_count += 1; st.fail_count = 0
+            if st.status == "down" and st.ok_count >= recover_threshold:
+                st.status = "up"; st.notified_down = False
+                msg = f"{proxy.get('name', proxy_id)} 已恢复。延迟 {latency}ms，时间 {iso()}"
+                await self.store.add_event(proxy_id, old, st.status, msg)
+                await self.notifier.send_all(f"SOCKS5恢复：{proxy.get('name', proxy_id)}", msg)
+            elif st.status == "unknown":
+                st.status = "up"
+                await self.store.add_event(proxy_id, old, st.status, f"{proxy.get('name', proxy_id)} 首次检测正常")
+        else:
+            st.fail_count += 1; st.ok_count = 0
+            if st.fail_count >= fail_threshold:
+                st.status = "down"
+                if not st.notified_down:
+                    msg = f"{proxy.get('name', proxy_id)} 不通，连续失败 {st.fail_count} 次。错误：{err}。时间 {iso()}"
+                    await self.store.add_event(proxy_id, old, st.status, msg)
+                    await self.notifier.send_all(f"SOCKS5故障：{proxy.get('name', proxy_id)}", msg)
+                    st.notified_down = True
+
+    async def monitor_loop(self, proxy_id: str) -> None:
+        while True:
+            proxy = self.get_proxy(proxy_id)
+            if not proxy: return
+            if proxy.get("enabled", True):
+                await self.run_once(proxy)
+            await asyncio.sleep(int(proxy.get("interval_seconds", self.config.get("interval_seconds", 60))))
+
+    async def restart_proxy_task(self, proxy_id: str) -> None:
+        old = self.monitor_tasks.pop(proxy_id, None)
+        if old: old.cancel()
+        if self.get_proxy(proxy_id):
+            self.monitor_tasks[proxy_id] = asyncio.create_task(self.monitor_loop(proxy_id))
+
+    async def start_tasks(self) -> None:
+        for p in self.proxies:
+            await self.restart_proxy_task(p["id"])
+
+    def status_payload(self) -> dict[str, Any]:
+        items = []
+        for p in self.proxies:
+            sid = p["id"]; st = self.state_for(sid)
+            items.append({"proxy": public_proxy(p), "state": dataclasses.asdict(st), "recent": self.store.recent_checks(sid, 20)})
+        return {
+            "ok": True, "now": now_ts(), "now_text": iso(),
+            "settings": {k: self.config.get(k) for k in ["interval_seconds", "timeout_seconds", "target_host", "target_port", "fail_threshold", "recover_threshold"]},
+            "proxies": items,
+            "notifications": self.config.get("notifications", {}),
+            "events": self.store.recent_events(50),
+            "notification_logs": self.store.recent_notifications(30),
+        }
+
+
+def get_index_html() -> str:
+    static_index = APP_DIR / "static" / "index.html"
+    if static_index.exists():
+        return static_index.read_text(encoding="utf-8")
+    return "<h1>SOCKS5 Sentinel</h1><p>static/index.html missing</p>"
+
+
+
+def json_response(obj: Any, status: int = 200) -> tuple[int, str, bytes]:
+    return status, "application/json; charset=utf-8", json.dumps(obj, ensure_ascii=False).encode("utf-8")
+
+
+async def read_request(reader: asyncio.StreamReader) -> tuple[str, str, dict[str, str], bytes]:
+    head = await reader.readuntil(b"\r\n\r\n")
+    text = head.decode("iso-8859-1")
+    lines = text.split("\r\n")
+    method, path, _ = lines[0].split(" ", 2)
+    headers = {}
+    for line in lines[1:]:
+        if ":" in line:
+            k, v = line.split(":", 1); headers[k.lower()] = v.strip()
+    length = int(headers.get("content-length") or "0")
+    body = await reader.readexactly(length) if length else b""
+    return method, path, headers, body
+
+
+async def handle_http(reader: asyncio.StreamReader, writer: asyncio.StreamWriter, app: App) -> None:
+    try:
+        method, path, headers, body = await read_request(reader)
+        parsed = urllib.parse.urlparse(path); p = parsed.path
+        status, ctype, resp = 200, "text/plain; charset=utf-8", b""
+        data = json.loads(body.decode("utf-8")) if body else {}
+        if method == "GET" and p == "/":
+            ctype = "text/html; charset=utf-8"; resp = get_index_html().encode("utf-8")
+        elif method == "GET" and p == "/api/status":
+            status, ctype, resp = json_response(app.status_payload())
+        elif method == "PUT" and p == "/api/settings":
+            status, ctype, resp = json_response({"ok": True, "settings": await app.update_settings(data)})
+        elif method == "POST" and p == "/api/proxies":
+            status, ctype, resp = json_response({"ok": True, "proxy": await app.upsert_proxy(data)}, 201)
+        elif method == "PUT" and p.startswith("/api/proxies/"):
+            pid = urllib.parse.unquote(p.rsplit("/", 1)[-1])
+            status, ctype, resp = json_response({"ok": True, "proxy": await app.upsert_proxy(data, pid)})
+        elif method == "DELETE" and p.startswith("/api/proxies/"):
+            pid = urllib.parse.unquote(p.rsplit("/", 1)[-1])
+            status, ctype, resp = json_response({"ok": await app.delete_proxy(pid)})
+        elif method == "POST" and p.startswith("/api/check/"):
+            pid = urllib.parse.unquote(p.rsplit("/", 1)[-1]); proxy = app.get_proxy(pid)
+            if not proxy: status, ctype, resp = json_response({"ok": False, "error": "proxy not found"}, 404)
+            else:
+                await app.run_once(proxy)
+                status, ctype, resp = json_response({"ok": True, "state": dataclasses.asdict(app.state_for(pid))})
+        elif method == "POST" and p == "/api/channels":
+            status, ctype, resp = json_response({"ok": True, "channel": await app.upsert_channel(data)}, 201)
+        elif method == "PUT" and p.startswith("/api/channels/"):
+            cid = urllib.parse.unquote(p.rsplit("/", 1)[-1])
+            status, ctype, resp = json_response({"ok": True, "channel": await app.upsert_channel(data, cid)})
+        elif method == "DELETE" and p.startswith("/api/channels/"):
+            cid = urllib.parse.unquote(p.rsplit("/", 1)[-1])
+            status, ctype, resp = json_response({"ok": await app.delete_channel(cid)})
+        elif method == "POST" and p.startswith("/api/channels/") and p.endswith("/test"):
+            cid = urllib.parse.unquote(p.split("/")[-2])
+            res = await app.notifier.send_channel_id(cid, "SOCKS5监控测试", f"测试通知 {iso()}")
+            status, ctype, resp = json_response({"ok": bool(res.get("ok")), "result": res})
+        elif method == "POST" and p == "/api/notify/test":
+            res = await app.notifier.send_all("SOCKS5监控测试", f"测试通知 {iso()}")
+            status, ctype, resp = json_response({"ok": True, "results": res})
+        else:
+            status, ctype, resp = json_response({"ok": False, "error": "not found"}, 404)
+    except Exception as e:
+        traceback.print_exc()
+        status, ctype, resp = json_response({"ok": False, "error": str(e)}, 500)
+    try:
+        reason = {200:"OK",201:"Created",400:"Bad Request",404:"Not Found",500:"Internal Server Error"}.get(status,"OK")
+        writer.write(f"HTTP/1.1 {status} {reason}\r\nContent-Type: {ctype}\r\nContent-Length: {len(resp)}\r\nConnection: close\r\n\r\n".encode()+resp)
+        await writer.drain()
+    finally:
+        writer.close()
+        with contextlib.suppress(Exception): await writer.wait_closed()
+
+
+async def main_async(args: argparse.Namespace) -> None:
+    app = App(Path(args.config))
+    await app.start_tasks()
+    server = await asyncio.start_server(lambda r,w: handle_http(r,w,app), args.host, args.port)
+    print(f"SOCKS5 monitor panel: http://{args.host}:{args.port}", flush=True)
+    print(f"Config: {args.config}", flush=True)
+    async with server:
+        await server.serve_forever()
+
+
+def main() -> None:
+    ap = argparse.ArgumentParser()
+    ap.add_argument("--config", default=str(DEFAULT_CONFIG))
+    ap.add_argument("--host", default="0.0.0.0")
+    ap.add_argument("--port", type=int, default=8787)
+    args = ap.parse_args()
+    asyncio.run(main_async(args))
+
+
+if __name__ == "__main__":
+    main()
diff --git a/config.example.json b/config.example.json
new file mode 100644
index 0000000..bdfef25
--- /dev/null
+++ b/config.example.json
@@ -0,0 +1,64 @@
+{
+  "interval_seconds": 300,
+  "timeout_seconds": 8,
+  "target_host": "www.baidu.com",
+  "target_port": 443,
+  "fail_threshold": 3,
+  "recover_threshold": 1,
+  "db_path": "/app/data/monitor.db",
+  "proxies": [
+    {
+      "id": "example-local",
+      "name": "示例 SOCKS5（默认停用）",
+      "host": "127.0.0.1",
+      "port": 1080,
+      "username": "",
+      "password": "",
+      "target_host": "www.baidu.com",
+      "target_port": 443,
+      "timeout_seconds": 8,
+      "interval_seconds": 300,
+      "fail_threshold": 3,
+      "recover_threshold": 1,
+      "enabled": false
+    }
+  ],
+  "notifications": {
+    "enabled": true,
+    "timeout_seconds": 10,
+    "channels": [
+      {
+        "id": "ch-bark",
+        "type": "bark",
+        "name": "Bark",
+        "enabled": false,
+        "config": {
+          "server": "https://api.day.app",
+          "key": "填你的BarkKey",
+          "group": "SOCKS5监控"
+        }
+      },
+      {
+        "id": "ch-pushplus",
+        "type": "pushplus",
+        "name": "PushPlus",
+        "enabled": false,
+        "config": {
+          "token": "填你的PushPlusToken",
+          "template": "txt",
+          "topic": ""
+        }
+      },
+      {
+        "id": "ch-autman",
+        "type": "autman",
+        "name": "Autman",
+        "enabled": false,
+        "config": {
+          "url": "http://ip:port/m/push1",
+          "access_token": "填你的Autman鉴权token"
+        }
+      }
+    ]
+  }
+}
diff --git a/docker-compose.yml b/docker-compose.yml
new file mode 100644
index 0000000..30c6a34
--- /dev/null
+++ b/docker-compose.yml
@@ -0,0 +1,10 @@
+services:
+  socks5-monitor:
+    image: 192.168.2.66:80/hermes/socks5-monitor:latest
+    container_name: socks5-monitor
+    restart: unless-stopped
+    ports:
+      - "8787:8787"
+    volumes:
+      - ./config.json:/app/config.json
+      - ./data:/app/data
diff --git a/static/index.html b/static/index.html
new file mode 100644
index 0000000..e54f50e
--- /dev/null
+++ b/static/index.html
@@ -0,0 +1,35 @@
+<!doctype html>
+<html lang="zh-CN">
+<head>
+<meta charset="utf-8" />
+<meta name="viewport" content="width=device-width,initial-scale=1" />
+<title>SOCKS5 Island Monitor</title>
+<link rel="icon" href="data:image/svg+xml,%3Csvg xmlns='http://www.w3.org/2000/svg' viewBox='0 0 64 64'%3E%3Crect width='64' height='64' rx='18' fill='%2319c8b9'/%3E%3Ccircle cx='19' cy='23' r='8' fill='%23f7cd67'/%3E%3Ccircle cx='43' cy='22' r='9' fill='%2386d67a'/%3E%3Cpath d='M10 47c8-15 20-19 31-12 6 4 10 8 13 12H10z' fill='%23f8f8f0'/%3E%3Cpath d='M24 44c3-8 9-13 17-16' stroke='%23725d42' stroke-width='4' stroke-linecap='round' fill='none'/%3E%3Ctext x='32' y='55' text-anchor='middle' font-size='14' font-family='Arial' fill='%23725d42'%3ES5%3C/text%3E%3C/svg%3E">
+<link rel="apple-touch-icon" href="data:image/svg+xml,%3Csvg xmlns='http://www.w3.org/2000/svg' viewBox='0 0 64 64'%3E%3Crect width='64' height='64' rx='18' fill='%2319c8b9'/%3E%3Ccircle cx='19' cy='23' r='8' fill='%23f7cd67'/%3E%3Ccircle cx='43' cy='22' r='9' fill='%2386d67a'/%3E%3Cpath d='M10 47c8-15 20-19 31-12 6 4 10 8 13 12H10z' fill='%23f8f8f0'/%3E%3Cpath d='M24 44c3-8 9-13 17-16' stroke='%23725d42' stroke-width='4' stroke-linecap='round' fill='none'/%3E%3Ctext x='32' y='55' text-anchor='middle' font-size='14' font-family='Arial' fill='%23725d42'%3ES5%3C/text%3E%3C/svg%3E">
+<link href="https://fonts.googleapis.com/css2?family=Nunito:wght@400;500;600;700;800;900&family=Noto+Sans+SC:wght@400;500;700&family=Zen+Maru+Gothic:wght@400;500;700&display=swap" rel="stylesheet">
+<style>
+:root{--bg:#f8f8f0;--card:rgb(247,243,223);--text:#725d42;--head:#794f27;--muted:#9f927d;--soft:#c4b89e;--line:#9f927d;--mint:#19c8b9;--mint2:#e6f9f6;--green:#6fba2c;--red:#e05a5a;--yellow:#f5c31c;--blue:#889df0;--pink:#f8a6b2;--purple:#b77dee;--orange:#e59266;--teal:#82d5bb;--shadow:#bdaea0}*{box-sizing:border-box}body{margin:0;min-height:100vh;background:radial-gradient(circle at 12% 18%,rgba(130,213,187,.35),transparent 22%),radial-gradient(circle at 88% 8%,rgba(247,205,103,.36),transparent 21%),linear-gradient(180deg,#a7dec0 0,#f8f8f0 42%);color:var(--text);font-family:Nunito,'Noto Sans SC','Zen Maru Gothic',-apple-system,'PingFang SC',sans-serif;font-weight:500;letter-spacing:.01em}.wrap{max-width:1420px;margin:0 auto;padding:26px}.island{background:rgba(248,248,240,.76);border:3px solid rgba(159,146,125,.45);border-radius:42px 36px 48px 34px/36px 44px 34px 46px;padding:22px;box-shadow:0 12px 0 rgba(114,93,66,.12)}.nav{display:flex;align-items:center;justify-content:space-between;gap:18px;margin-bottom:22px}.brand{display:flex;align-items:center;gap:14px}.logo{width:58px;height:58px;border-radius:22px;background:linear-gradient(145deg,var(--mint),#86d67a);border:3px solid var(--line);box-shadow:0 5px 0 var(--shadow);display:grid;place-items:center;font-size:30px}.brand h1{margin:0;color:var(--head);font-size:34px;font-weight:900;letter-spacing:.02em}.muted{color:var(--muted)}.tabs{display:flex;gap:10px;flex-wrap:wrap}.tab,.btn{border:2.5px solid var(--line);background:var(--card);color:var(--text);border-radius:50px;height:44px;padding:0 18px;font-weight:800;cursor:pointer;box-shadow:0 5px 0 var(--shadow);transition:all .22s cubic-bezier(.4,0,.2,1)}.tab:hover,.btn:hover{transform:translateY(-1px);box-shadow:0 6px 0 var(--shadow)}.tab:active,.btn:active{transform:translateY(2px);box-shadow:0 1px 0 var(--shadow)}.tab.active,.btn.primary{background:var(--mint);color:white;border-color:#11a89b;box-shadow:0 5px 0 #0f8f85}.btn.danger{background:#fff1ef;color:var(--red);border-color:var(--red);box-shadow:0 5px 0 #c94444}.btn.small{height:34px;padding:0 13px;font-size:12px;border-radius:18px}.grid{display:grid;grid-template-columns:repeat(auto-fit,minmax(360px,1fr));gap:18px}.hero{display:grid;grid-template-columns:1.2fr .8fr;gap:18px;margin-bottom:18px}.card{background:var(--card);border:3px solid rgba(159,146,125,.88);border-radius:28px 24px 32px 23px/25px 32px 24px 30px;padding:18px;box-shadow:0 4px 10px rgba(107,92,67,.42);transition:all .22s}.card:hover{transform:translateY(-2px)}.card.blue{background:#eef2ff}.card.green{background:#eef9e8}.card.yellow{background:#fff5cf}.card.pink{background:#fff0f3}.row{display:flex;align-items:center;justify-content:space-between;gap:12px}.metric{display:grid;grid-template-columns:repeat(4,1fr);gap:14px;margin-top:16px}.metric .box{background:linear-gradient(180deg,#fff,var(--bg));border:2.5px solid #d4cfc3;border-radius:20px;padding:14px;box-shadow:0 3px 0 #d4c9b4}.num{font-size:34px;font-weight:900;color:#8b7355}.section{display:none}.section.active{display:block}h2,h3{color:var(--head)}.pill{display:inline-flex;align-items:center;gap:7px;border:2px solid var(--line);border-radius:999px;padding:5px 10px;background:#fff;font-size:12px;font-weight:900}.dot{width:9px;height:9px;border-radius:50%;background:var(--yellow)}.up{color:var(--green)}.up .dot{background:var(--green)}.down{color:var(--red)}.down .dot{background:var(--red)}.unknown{color:#dba90e}.unknown .dot{background:var(--yellow)}.mono{font-family:'Zen Maru Gothic',ui-monospace,monospace}.kv{display:grid;grid-template-columns:110px 1fr;gap:7px;margin:14px 0;font-size:13px}.toolbar{display:flex;gap:9px;flex-wrap:wrap}table{width:100%;border-collapse:separate;border-spacing:0 7px;font-size:13px}td,th{text-align:left;padding:8px 10px}th{color:var(--muted);font-weight:900}tbody tr{background:rgba(255,255,255,.55)}tbody td:first-child{border-radius:14px 0 0 14px}tbody td:last-child{border-radius:0 14px 14px 0}.err{max-width:420px;white-space:nowrap;overflow:hidden;text-overflow:ellipsis}.drawer{position:fixed;right:18px;top:18px;bottom:18px;width:min(620px,calc(100vw - 36px));background:var(--card);border:3px solid var(--line);border-radius:40px 35px 45px 38px/38px 45px 35px 40px;padding:24px;box-shadow:0 18px 0 rgba(114,93,66,.22),0 30px 80px rgba(107,92,67,.38);transform:translateX(120%);transition:.25s;z-index:10;overflow:auto}.drawer.open{transform:none}.overlay{position:fixed;inset:0;background:rgba(80,60,40,.38);display:none;z-index:9}.overlay.open{display:block}.form{display:grid;grid-template-columns:repeat(2,minmax(0,1fr));gap:12px}.form .full{grid-column:1/-1}label{font-size:12px;color:var(--muted);font-weight:900;display:block;margin:8px 0 5px}input,select,textarea{width:100%;height:42px;background:#fff;color:var(--text);border:2.5px solid #c4b89e;border-radius:50px;padding:0 16px;box-shadow:0 3px 0 #d4c9b4;outline:none;font-weight:700}textarea{height:94px;border-radius:20px;padding:12px 16px}input:focus,select:focus,textarea:focus{border-color:#ffcc00;box-shadow:0 3px 0 #e0b800,0 0 0 3px rgba(255,204,0,.15)}.type-fields{background:rgba(255,255,255,.48);border:2px dashed #c4b89e;border-radius:22px;padding:12px}.channel{display:grid;grid-template-columns:1fr auto;align-items:center;gap:12px}.toast{position:fixed;left:50%;bottom:24px;transform:translateX(-50%);background:var(--mint);color:#fff;border:3px solid #11a89b;border-radius:50px;padding:12px 18px;box-shadow:0 5px 0 #0f8f85;font-weight:900;display:none;z-index:20}.toast.show{display:block}.sea{height:60px;margin-top:18px;border-radius:0 0 34px 34px;background:repeating-linear-gradient(135deg,#82d5bb 0 18px,#19c8b9 18px 36px);opacity:.45}@media(max-width:900px){.hero{grid-template-columns:1fr}.metric{grid-template-columns:repeat(2,1fr)}.form{grid-template-columns:1fr}.nav{align-items:flex-start;flex-direction:column}.wrap{padding:12px}}
+</style></head><body><div class="wrap"><div class="island"><div class="nav"><div class="brand"><div class="logo">🏝️</div><div><h1>SOCKS5 Island</h1><div class="muted">代理健康监控面板</div></div></div><div class="tabs"><button class="tab active" data-tab="dashboard">仪表盘</button><button class="tab" data-tab="proxies">节点管理</button><button class="tab" data-tab="notify">通知渠道</button><button class="tab" data-tab="settings">设置</button><button class="tab" data-tab="logs">日志</button></div></div><div class="hero"><div class="card yellow"><div class="row"><div><h2 style="margin:0 0 8px">运行概览</h2><div class="muted" id="now">加载中...</div></div><button class="btn" onclick="refresh()">刷新</button></div><div class="metric"><div class="box"><div class="muted">节点</div><div class="num" id="mTotal">0</div></div><div class="box"><div class="muted">正常</div><div class="num up" id="mUp">0</div></div><div class="box"><div class="muted">故障</div><div class="num down" id="mDown">0</div></div><div class="box"><div class="muted">通知</div><div class="num" id="mChan">0</div></div></div></div><div class="card green"><h2 style="margin-top:0">快速操作</h2><div class="toolbar"><button class="btn primary" onclick="openProxy()">新增节点</button><button class="btn" onclick="openChannel()">新增通知</button><button class="btn" onclick="openSettings()">检测设置</button><button class="btn" onclick="testAllNotify()">测试全部通知</button></div><p class="muted">管理节点和通知渠道。</p></div></div><section id="dashboard" class="section active"><div id="proxyCards" class="grid"></div></section><section id="proxies" class="section"><div class="card"><div class="row"><h2>SOCKS5 节点</h2><button class="btn primary" onclick="openProxy()">新增节点</button></div><div id="proxyList"></div></div></section><section id="notify" class="section"><div class="card"><div class="row"><h2>通知渠道</h2><button class="btn primary" onclick="openChannel()">新增渠道</button></div><div id="channelList"></div></div></section><section id="settings" class="section"><div class="card"><div class="row"><div><h2>检测设置</h2><p class="muted">配置全局检测目标、间隔、超时和状态阈值。</p></div><button class="btn primary" onclick="openSettings()">编辑全局设置</button></div><div class="metric"><div class="box"><div class="muted">默认检测目标</div><div class="mono" id="sTarget">-</div></div><div class="box"><div class="muted">默认间隔</div><div class="num" id="sInterval">-</div></div><div class="box"><div class="muted">默认超时</div><div class="num" id="sTimeout">-</div></div><div class="box"><div class="muted">阈值</div><div class="mono" id="sThreshold">-</div></div></div></div></section><section id="logs" class="section"><div class="grid"><div class="card"><h2>事件</h2><table><thead><tr><th>时间</th><th>节点</th><th>状态</th><th>消息</th></tr></thead><tbody id="events"></tbody></table></div><div class="card"><h2>通知记录</h2><table><thead><tr><th>时间</th><th>渠道</th><th>结果</th><th>标题</th></tr></thead><tbody id="notifLogs"></tbody></table></div></div></section><div class="sea"></div></div></div><div id="overlay" class="overlay" onclick="closeDrawer()"></div><div id="drawer" class="drawer"></div><div id="toast" class="toast"></div>
+<script>
+let DATA=null, editingProxy=null, editingChannel=null; const $=id=>document.getElementById(id); function esc(s){return String(s??'').replace(/[&<>"']/g,c=>({'&':'&amp;','<':'&lt;','>':'&gt;','"':'&quot;',"'":'&#39;'}[c]))} function ts(t){return t?new Date(t*1000).toLocaleString():'-'} function toast(s){$('toast').textContent=s;$('toast').classList.add('show');setTimeout(()=>$('toast').classList.remove('show'),2400)} async function api(url,opt={}){let r=await fetch(url,{headers:{'Content-Type':'application/json'},...opt});let j=await r.json(); if(!r.ok||j.ok===false) throw new Error(j.error||'请求失败'); return j} function cfg(c){return c.config||{}}
+document.querySelectorAll('.tab').forEach(b=>b.onclick=()=>{closeDrawer();document.querySelectorAll('.tab,.section').forEach(x=>x.classList.remove('active'));b.classList.add('active');$(b.dataset.tab).classList.add('active')})
+function statusPill(s){let c=s||'unknown';return `<span class="pill ${c}"><span class="dot"></span>${esc(c)}</span>`}
+async function refresh(){DATA=await api('/api/status'); $('now').textContent='当前时间：'+DATA.now_text; let ps=DATA.proxies, up=ps.filter(x=>x.state.status==='up').length, down=ps.filter(x=>x.state.status==='down').length; $('mTotal').textContent=ps.length;$('mUp').textContent=up;$('mDown').textContent=down;$('mChan').textContent=(DATA.notifications.channels||[]).length; renderSettings(); renderProxies(); renderChannels(); renderLogs()}
+function renderProxies(){let cards='', list=''; for(const it of DATA.proxies){let p=it.proxy,s=it.state; let recent=(it.recent||[]).slice(0,5).map(r=>`<tr><td>${ts(r.ts)}</td><td class="${r.ok?'up':'down'}">${r.ok?'OK':'FAIL'}</td><td>${r.latency_ms??'-'}ms</td><td class="err">${esc(r.error||'')}</td></tr>`).join(''); let color=s.status==='up'?'green':s.status==='down'?'pink':'blue'; let block=`<div class="card ${color}"><div class="row"><div><h2 style="margin:.1em 0">${esc(p.name||p.id)}</h2><div class="muted mono">${esc(p.host)}:${esc(p.port)} → ${esc(p.target_host)}:${esc(p.target_port)} · ${esc(p.interval_seconds||DATA.settings.interval_seconds)}s</div></div>${statusPill(s.status)}</div><div class="kv"><div class="muted">最后检测</div><div>${ts(s.last_ts)}</div><div class="muted">延迟</div><div>${s.latency_ms??'-'} ms</div><div class="muted">失败/成功</div><div>${s.fail_count} / ${s.ok_count}</div><div class="muted">错误</div><div class="err">${esc(s.error||'-')}</div></div><div class="toolbar"><button class="btn small" onclick="checkProxy('${esc(p.id)}')">立即检测</button><button class="btn small" onclick="openProxy('${esc(p.id)}')">编辑</button><button class="btn small danger" onclick="delProxy('${esc(p.id)}')">删除</button></div><table style="margin-top:12px"><thead><tr><th>时间</th><th>结果</th><th>延迟</th><th>错误</th></tr></thead><tbody>${recent}</tbody></table></div>`; cards+=block; list+=block } $('proxyCards').innerHTML=cards||'<div class="card muted">还没有节点，点击新增节点。</div>'; $('proxyList').innerHTML=list||'<p class="muted">暂无节点</p>'}
+function channelSummary(c){let x=cfg(c); if(c.type==='bark')return x.server||'https://api.day.app'; if(c.type==='pushplus')return 'template='+(x.template||'txt')+(x.topic?' · topic='+x.topic:''); if(c.type==='autman')return (x.url||'') + (x.access_token?' · token已配置':' · token未配置'); return x.url||''}
+function renderSettings(){let s=DATA.settings||{}; if($('sTarget')){$('sTarget').textContent=(s.target_host||'-')+':'+(s.target_port||'-');$('sInterval').textContent=s.interval_seconds||'-';$('sTimeout').textContent=s.timeout_seconds||'-';$('sThreshold').textContent='失败 '+(s.fail_threshold||'-')+' / 恢复 '+(s.recover_threshold||'-')}}
+function renderChannels(){let html=''; for(const c of DATA.notifications.channels||[]){html+=`<div class="card channel"><div><div class="row" style="justify-content:flex-start"><h3 style="margin:0">${esc(c.name)}</h3><span class="pill">${esc(c.type)}</span><span class="pill ${c.enabled?'up':'unknown'}"><span class="dot"></span>${c.enabled?'启用':'停用'}</span></div><div class="muted mono">${esc(channelSummary(c))}</div></div><div class="toolbar"><button class="btn small" onclick="testChannel('${esc(c.id)}')">测试</button><button class="btn small" onclick="openChannel('${esc(c.id)}')">编辑</button><button class="btn small danger" onclick="delChannel('${esc(c.id)}')">删除</button></div></div>`} $('channelList').innerHTML=html||'<p class="muted">暂无通知渠道</p>'}
+function renderLogs(){ $('events').innerHTML=(DATA.events||[]).map(e=>`<tr><td>${ts(e.ts)}</td><td>${esc(e.proxy_id)}</td><td>${esc(e.old_status)} → ${esc(e.new_status)}</td><td>${esc(e.message)}</td></tr>`).join(''); $('notifLogs').innerHTML=(DATA.notification_logs||[]).map(n=>`<tr><td>${ts(n.ts)}</td><td>${esc(n.channel_name)}</td><td class="${n.ok?'up':'down'}">${n.ok?'OK':'FAIL'}</td><td>${esc(n.title)}</td></tr>`).join('')}
+function closeDrawer(){ $('drawer').classList.remove('open');$('overlay').classList.remove('open')} function draw(html){$('drawer').innerHTML=html;$('drawer').classList.add('open');$('overlay').classList.add('open')}
+function openProxy(id){let d=(DATA&&DATA.settings)||{};let p=id?DATA.proxies.find(x=>x.proxy.id===id).proxy:{enabled:true,port:1080,target_host:d.target_host||'www.baidu.com',target_port:d.target_port||443,timeout_seconds:d.timeout_seconds||8,interval_seconds:d.interval_seconds||300,fail_threshold:d.fail_threshold||3,recover_threshold:d.recover_threshold||1}; editingProxy=id||null; draw(`<h2>${id?'编辑':'新增'} SOCKS5 节点</h2><form id="pf" class="form"><div><label>名称</label><input name="name" value="${esc(p.name||'')}"></div><div><label>Host</label><input name="host" value="${esc(p.host||'')}"></div><div><label>Port</label><input name="port" type="number" value="${esc(p.port||1080)}"></div><div><label>用户名</label><input name="username" value="${esc(p.username||'')}"></div><div><label>密码（留空保持原值）</label><input name="password" type="password" value=""></div><details class="full"><summary>高级检测设置</summary><div class="form" style="margin-top:12px"><div><label>测试目标 Host</label><input name="target_host" value="${esc(p.target_host||((DATA.settings||{}).target_host)||'www.baidu.com')}"></div><div><label>测试目标 Port</label><input name="target_port" type="number" value="${esc(p.target_port||443)}"></div><div><label>超时秒</label><input name="timeout_seconds" type="number" value="${esc(p.timeout_seconds||8)}"></div><div><label>检测间隔秒</label><input name="interval_seconds" type="number" min="5" value="${esc(p.interval_seconds||((DATA.settings||{}).interval_seconds)||300)}"></div><div><label>失败阈值</label><input name="fail_threshold" type="number" value="${esc(p.fail_threshold||3)}"></div><div><label>恢复阈值</label><input name="recover_threshold" type="number" value="${esc(p.recover_threshold||1)}"></div></div></details><div class="full"><label><input style="width:auto;height:auto" name="enabled" type="checkbox" ${p.enabled!==false?'checked':''}> 启用监控</label></div><div class="full toolbar"><button class="btn primary" type="submit">保存</button><button class="btn" type="button" onclick="closeDrawer()">取消</button></div></form>`); $('pf').onsubmit=saveProxy}
+async function saveProxy(e){e.preventDefault();let fd=new FormData(e.target), o=Object.fromEntries(fd.entries()); ['port','target_port','timeout_seconds','interval_seconds','fail_threshold','recover_threshold'].forEach(k=>o[k]=Number(o[k])); o.enabled=fd.get('enabled')==='on'; if(!o.password) delete o.password; await api(editingProxy?'/api/proxies/'+encodeURIComponent(editingProxy):'/api/proxies',{method:editingProxy?'PUT':'POST',body:JSON.stringify(o)}); closeDrawer(); toast('节点已保存'); await refresh()}
+
+function openSettings(){let s=(DATA&&DATA.settings)||{}; draw(`<h2>全局检测设置</h2><form id="sf" class="form"><div><label>默认检测目标 Host</label><input name="target_host" value="${esc(s.target_host||'www.baidu.com')}"><p class="muted">可填公网、内网或业务目标。</p></div><div><label>默认检测目标 Port</label><input name="target_port" type="number" min="1" max="65535" value="${esc(s.target_port||443)}"></div><div><label>默认检测间隔秒</label><input name="interval_seconds" type="number" min="5" value="${esc(s.interval_seconds||300)}"><p class="muted">新增节点默认使用此值。</p></div><div><label>默认超时秒</label><input name="timeout_seconds" type="number" min="1" value="${esc(s.timeout_seconds||8)}"></div><div><label>默认失败阈值</label><input name="fail_threshold" type="number" min="1" value="${esc(s.fail_threshold||3)}"></div><div><label>默认恢复阈值</label><input name="recover_threshold" type="number" min="1" value="${esc(s.recover_threshold||1)}"></div><div class="full toolbar"><button class="btn primary" type="submit">保存设置</button><button class="btn" type="button" onclick="closeDrawer()">取消</button></div></form>`); $('sf').onsubmit=saveSettings}
+async function saveSettings(e){e.preventDefault();let fd=new FormData(e.target), o=Object.fromEntries(fd.entries()); ['target_port','interval_seconds','timeout_seconds','fail_threshold','recover_threshold'].forEach(k=>o[k]=Number(o[k])); await api('/api/settings',{method:'PUT',body:JSON.stringify(o)}); closeDrawer(); toast('检测设置已保存'); await refresh()}
+async function delProxy(id){if(confirm('删除节点 '+id+' ?')){await api('/api/proxies/'+encodeURIComponent(id),{method:'DELETE'});toast('已删除');refresh()}} async function checkProxy(id){await api('/api/check/'+encodeURIComponent(id),{method:'POST'});toast('检测完成');refresh()}
+function channelFields(type,c={}){let x=cfg(c); if(type==='bark')return `<div class="type-fields full"><h3>Bark 配置</h3><label>Server</label><input name="server" value="${esc(x.server||'https://api.day.app')}"><label>Bark Key</label><input name="key" value="${esc(x.key||'')}"><label>Group</label><input name="group" value="${esc(x.group||'SOCKS5监控')}"></div>`; if(type==='pushplus')return `<div class="type-fields full"><h3>PushPlus 配置</h3><label>Token</label><input name="token" value="${esc(x.token||'')}"></div>`; if(type==='autman')return `<div class="type-fields full"><h3>Autman 配置</h3><p class="muted">发送到 Autman。</p><label>API URL</label><input name="url" placeholder="http://ip:port/m/push1" value="${esc(x.url||'')}"><label>Access Token</label><input name="access_token" value="${esc(x.access_token||'')}"></div>`; return `<div class="type-fields full"><h3>Webhook 配置</h3><label>Webhook URL</label><input name="url" value="${esc(x.url||'')}"><details><summary>高级 Webhook 设置</summary><label>Headers JSON</label><textarea name="headers">${esc(JSON.stringify(x.headers||{},null,2))}</textarea><label>Payload JSON</label><textarea name="payload">${esc(JSON.stringify(x.payload||{},null,2))}</textarea></details></div>`}
+function openChannel(id){let c=id?(DATA.notifications.channels||[]).find(x=>x.id===id):{type:'bark',enabled:true,config:{server:'https://api.day.app',group:'SOCKS5监控'}}; editingChannel=id||null; draw(`<h2>${id?'编辑':'新增'}通知渠道</h2><form id="cf" class="form"><div><label>名称</label><input name="name" value="${esc(c.name||'')}"></div><div><label>类型</label><select id="channelType" name="type"><option value="bark">Bark</option><option value="pushplus">PushPlus</option><option value="autman">Autman</option><option value="webhook">Webhook</option></select></div><div><label>状态</label><select name="enabled"><option value="true">启用</option><option value="false">停用</option></select></div><div id="channelFields" class="full"></div><div class="full toolbar"><button class="btn primary" type="submit">保存</button><button class="btn" type="button" onclick="closeDrawer()">取消</button></div></form>`); $('channelType').value=c.type||'bark'; document.querySelector('[name=enabled]').value=String(c.enabled!==false); $('channelFields').outerHTML=channelFields($('channelType').value,c); $('channelType').onchange=()=>{document.querySelector('.type-fields').outerHTML=channelFields($('channelType').value,{type:$('channelType').value,config:{}})}; $('cf').onsubmit=saveChannel}
+async function saveChannel(e){e.preventDefault();let fd=new FormData(e.target), type=fd.get('type'); let o={name:fd.get('name')||type,type,enabled:fd.get('enabled')==='true',config:{}}; if(type==='bark') o.config={server:fd.get('server')||'https://api.day.app',key:fd.get('key')||'',group:fd.get('group')||'SOCKS5监控'}; else if(type==='pushplus') o.config={token:fd.get('token')||'',template:'txt',topic:''}; else if(type==='autman') o.config={url:fd.get('url')||'',access_token:fd.get('access_token')||''}; else {try{o.config={url:fd.get('url')||'',headers:JSON.parse(fd.get('headers')||'{}'),payload:JSON.parse(fd.get('payload')||'{}')}}catch(e){toast('JSON 格式错误');return}} await api(editingChannel?'/api/channels/'+encodeURIComponent(editingChannel):'/api/channels',{method:editingChannel?'PUT':'POST',body:JSON.stringify(o)}); closeDrawer(); toast('渠道已保存'); refresh()}
+async function delChannel(id){if(confirm('删除通知渠道 '+id+' ?')){await api('/api/channels/'+encodeURIComponent(id),{method:'DELETE'});toast('已删除');refresh()}} async function testChannel(id){let r=await api('/api/channels/'+encodeURIComponent(id)+'/test',{method:'POST'});toast('测试结果：'+(r.result.ok?'OK':'FAIL'))} async function testAllNotify(){await api('/api/notify/test',{method:'POST'});toast('已触发全部通知测试')}
+refresh(); setInterval(refresh,10000)
+</script></body></html>