h3-console 加 Bearer token 鉴权，comfyui.wudaima.com 补 HTTP Basic Auth

公网审计发现 qwen.wudaima.com/console 无鉴权可直调（已知问题一直没排上），以及 comfyui.wudaima.com 也在裸奔（raylight 上线后 8188 常驻监听，旧的"隧道空挂"假设已经过期，没人重新审计过）。两处都已实测确认修复生效：console 的 /v1/* 全部接口要求 Authorization: Bearer <token>（H3_CONSOLE_AUTH_TOKEN 环境变量），ComfyUI 隧道用 frp 原生的 http_user/http_pwd 加了基本认证。 Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01SURs92UuTkFxDF4RXsEFJi

h3-console 加 Bearer token 鉴权，comfyui.wudaima.com 补 HTTP Basic Auth
公网审计发现 qwen.wudaima.com/console 无鉴权可直调（已知问题一直没排上），以及 comfyui.wudaima.com 也在裸奔（raylight 上线后 8188 常驻监听，旧的"隧道空挂"假设已经过期，没人重新审计过）。两处都已实测确认修复生效：console 的 /v1/* 全部接口要求 Authorization: Bearer <token>（H3_CONSOLE_AUTH_TOKEN 环境变量），ComfyUI 隧道用 frp 原生的 http_user/http_pwd 加了基本认证。 Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01SURs92UuTkFxDF4RXsEFJi
yibo
1 parent 5a7632a3
Showing 7 changed files with 113 additions and 19 deletions
CHANGELOG.md
h3-console/README.md
h3-console/server.py
h3-console/static/index.html
h3-console/systemd/h3-console-lan.service
h3-console/systemd/h3-console-public.service
llm-setup.md
 # 变更记录
  
+## 2026-08-29 — h3-console 加 Bearer token 鉴权，comfyui.wudaima.com 补基本认证
+
+**背景**：审计公网暴露面时发现两个真实问题，都是**实测确认**，不是猜测：
+1. `qwen.wudaima.com/console`（h3-console 公网实例）无鉴权，`curl` 直接能拿到所有历史任务
+   （包括别人的 prompt 内容）、能提交新任务消耗4卡GPU。这是已知问题（`DESIGN.md` 问题3，
+   一直"跑通了再加"没排上）。
+2. **新发现**：`comfyui.wudaima.com` 也是活的、且完全无鉴权——`raylight/README.md` 里"8188
+   仅内部调用，不对外"这个假设已经过期。根因：`comfyui.frpc.ini` 这条 frp 隧道很早就配了，
+   当时 ComfyUI(8188) 没监听，隧道空挂无害；2026-08-22 raylight 上线后 ComfyUI 常驻监听
+   `0.0.0.0:8188`，隧道悄悄变成活的，没人重新审计过。`curl http://comfyui.wudaima.com/
+   system_stats`/`/queue` 直接返回真实数据。ComfyUI 原生 API 能提交任意 workflow 图，风险面
+   比 console 的受限 `/v1/videos` 接口大得多。
+
+**修复**：
+- `h3-console/server.py`：`/v1/*` 全部接口挂到独立的 `api` router，加 `Depends(_require_token)`，
+  校验 `Authorization: Bearer <token>`（token 走 `H3_CONSOLE_AUTH_TOKEN` 环境变量，未设则不校验，
+  局域网/本地开发不受影响）。页面路由（`/`、`/newtask.html`、`/task.html/{tid}`）和 `/assets/*`
+  静态文件不校验——前者是鸡生蛋蛋生鸡，后者是 GPU worker 要能反向拉取上传的参考图。
+  `<video src>`/下载链接是浏览器原生请求加不上 header，改成同时认 `?token=` 查询参数。
+  `static/index.html` 首次调用 API 时 `prompt()` 弹一次令牌存 `localStorage`，401 清空重弹。
+  两个 systemd 实例（8080/8081）都配了同一个 token，已重启验证：无 token/错 token 返回 401，
+  正确 token 返回 200，公网 `qwen.wudaima.com/console` 和局域网 8080 都测过。
+- `comfyui.frpc.ini`：加 `http_user`/`http_pwd`（frp ini 原生字段，`frpc http -h` 确认存在，
+  不用改 ComfyUI 一行代码），`pm2 restart frpc-comfyui-client` 生效。公网实测：无凭证 401，
+  错误凭证 401，正确凭证 200。
+- 顺手把 `llm-setup.md` FRP 那张表里"8188 无监听，隧道空挂"这条过期结论改成实际状态，
+  同步回了服务器 `/home/admin/llm-setup.md`。
+
+**被推翻的假设**：`raylight/README.md`/`llm-setup.md` 里"ComfyUI(8188) 只在内部调用、不对外"
+这个假设一直没被验证过，实际上从 2026-08-22 起就已经在公网裸奔了一周，直到这次审计才发现。
+以后改动任何监听端口的服务，得顺手查一下有没有同名/旧的 frp 隧道配置早就指向它。
+
 ## 2026-08-25（晚）— 服务器意外重启后 raylight/h3-console 全灭，补上 systemd 开机自启
  
 **背景**：用户反馈 `http://192.168.110.67:8080/newtask.html` 打不开。排查发现机器在当天
@@ -166,8 +166,14 @@ console 譛ｬ霄ｫ譏ｯ迢ｬ遶玖ｿ帷ｨ具ｼ悟髣ｮ鬚倡峩謗･ `kill` console 霑帷ｨ句叉蜿ｯ御ｸ
  
 ## 蟾ｲ遏･髯仙宛
  
-- 驩ｴ譚ｼ壽嘯譛ｪ蜉DESIGN.md` 髣ｮ鬚3瑚ｷ鷹壻ｺ蜉峨るΚ鄂ｲ蛻ｰ蜈ｬ鄂大燕蠢｡ｻ陦･悟凄蛻吝柱邇ｰ譛画恪蜉｡荳譬ｷ譏ｯ
-  譌驩ｴ譚庄逶ｴ隹ｼ碁｣朱勦譖ｴ鬮倪披把onsole 螟壻ｺ譁ｻｶ井ｸ贋ｼ臥噪閭ｽ蜉帙
+- 驩ｴ譚ｼ**2026-08-29 蟾ｲ蜉**縲ＡH3_CONSOLE_AUTH_TOKEN` 邇ｯ蠅序驥剰ｮｾ莠燕譬｡鬪鯉ｼ井ｸ､荳ｪ systemd 螳樔ｾ
+  驛ｽ蟾ｲ驟咲ｽｮ蜷御ｸ荳ｪ token会ｼ形/v1/*` 蜈ｨ驛ｨ謗･蜿｣隕∵ｱ `Authorization: Bearer <token>`幃｡ｵ髱｢譛ｬ霄ｫ
+  /`縲〜/newtask.html`縲〜/task.html/{tid}`牙柱 `/assets/*` 髱呎∵枚莉ｶ荳肴｡鬪娯披泌燕閠弍鮑｡逕溯寞
+  陋狗函鮑｡域ｲ｡蜉霓ｽ蜃ｺ鬘ｵ髱｢譌莉手ｾ灘token会ｼ悟錘閠弍蝗荳ｺ譛榊苅蝎ｨ荳顔噪 GPU worker 隕∬蜿榊髄諡牙叙荳贋ｼ逧
+  蜿り崟/蜿りｧ｢托ｼ御ｸ泌ｮｻｬ譛ｬ霄ｫ謨乗─蠎ｦ菴弱Ａ<video src>`/荳玖ｽｽ `<a href>` 譏ｯ豬剰ｧ亥勣蜴溽函隸ｷ豎ょ刈荳堺ｸ
+  螟ｴ梧隼謌占ｮ､ `?token=` 譟･隸｢蜿よ焚瑚ｷ header 襍ｰ蜷御ｸ莉ｽ譬｡鬪鯉ｼserver.py` 逧 `_require_token`峨
+  蜑咲ｫｯ `static/index.html` 鬥匁ｬ｡隹畑 API 譌ｶ `prompt()` 蠑ｹ荳谺｡莉､迚悟ｭ `localStorage`401 莨壽ｸｩｺ
+  驥榊ｼｹ縲
 - 莉ｻ蜉｡謖∽ｹ喧譏ｯ console 閾ｪ蟾ｱ逧 sqlite悟柱 `api.py` 蜀ｭ俶∽ｹ矩龍譛芽ｽｮ隸｢髣ｴ髫皮噪遏ｭ證ゆｸ堺ｸ閾ｴ亥遘堤ｺｧ会ｼ
   荳崎ｿｽ豎ょｼｺ荳閾ｴ縲
 - 逎∫尨啻/` 蜿ｪ蜑ｩ 29G形/data` 83% 貊｡御ｸ贋ｼ謗･蜿｣逶ｮ蜑榊宵蛛壼黒譁ｻｶ 20MB 荳企剞譬｡鬪鯉ｼ梧ｲ｡蛛夂｣∫尨菴咎譽譟･
@@ -14,8 +14,9 @@ import os, re, sqlite3, time, uuid, json, asyncio, subprocess
 from pathlib import Path
 from typing import Optional
  
+import hmac
 import httpx
-from fastapi import APIRouter, FastAPI, HTTPException, UploadFile, File, Request
+from fastapi import APIRouter, Depends, FastAPI, HTTPException, UploadFile, File, Request
 from fastapi.responses import StreamingResponse, FileResponse, HTMLResponse
 from fastapi.staticfiles import StaticFiles
 from PIL import Image
@@ -34,6 +35,22 @@ ENABLE_SUPERVISOR = os.environ.get(&quot;H3_ENABLE_SUPERVISOR&quot;) == &quot;1&quot;
 # 部署在共享域名的子路径下时设这个（比如挂在 qwen.wudaima.com/console 而不是独立域名），
 # 见 README「子路径部署」。留空就是原来的行为，挂在根路径，本地/局域网直连不受影响。
 BASE_PATH = os.environ.get("H3_CONSOLE_BASE_PATH", "").rstrip("/")
+# 公网直接可达（qwen.wudaima.com/console 无需登录就能提交任务/看到所有历史任务），设了这个
+# 才校验 /v1/* 接口；留空等于原来的行为（局域网/本地开发不用配）。`<video src>`/下载链接是
+# 浏览器原生请求，加不上 Authorization 头，所以顺带认 `?token=` 查询参数——跟 header 校验
+# 走同一份比较逻辑，不是单独开了个后门。
+AUTH_TOKEN = os.environ.get("H3_CONSOLE_AUTH_TOKEN", "")
+
+
+def _require_token(request: Request):
+    if not AUTH_TOKEN:
+        return
+    got = request.query_params.get("token", "")
+    auth = request.headers.get("authorization", "")
+    if auth.startswith("Bearer "):
+        got = auth[len("Bearer "):]
+    if not hmac.compare_digest(got, AUTH_TOKEN):
+        raise HTTPException(401, "缺少或错误的访问令牌（Authorization: Bearer <token> 或 ?token=）")
  
 # GPU/端口映射，对应服务器上 start-all.sh 写死的分配。仅 supervisor 用得到。
 BACKEND_TOPOLOGY = [
@@ -66,7 +83,9 @@ def _check_not_resetting():
 # 所有 /v1/* 接口挂在这个 router 上而不是直接挂在 app 上，是为了能整体套一层 BASE_PATH
 # 前缀（app.include_router(router, prefix=BASE_PATH)，见文件末尾）——BASE_PATH 留空时
 # 前缀是空字符串，行为和直接挂在 app 上完全一样。
-router = APIRouter()
+router = APIRouter()  # 页面路由（/、/newtask.html、/task.html/{tid}）——不校验token，
+# 不然连页面壳子都加载不出来，无从输入token
+api = APIRouter(dependencies=[Depends(_require_token)])  # 所有 /v1/* 接口
  
  
 def db():
@@ -110,7 +129,7 @@ VIDEO_EXTS = (&quot;.mp4&quot;, &quot;.mov&quot;, &quot;.webm&quot;, &quot;.mkv&quot;)
 AUDIO_EXTS = (".mp3", ".wav", ".m4a", ".ogg", ".flac")
  
  
-@router.post("/v1/assets")
+@api.post("/v1/assets")
 async def upload_asset(file: UploadFile = File(...)):
     ext = Path(file.filename or "").suffix.lower()
     # 2026-08-23：原来只收图片，现在参考视频/独立音频参考也走这个接口——按扩展名分流到
@@ -332,7 +351,7 @@ async def _discover_from_gateway():
             )
  
  
-@router.post("/v1/videos", status_code=202)
+@api.post("/v1/videos", status_code=202)
 async def create_video(req: dict):
     _check_not_resetting()
     partition = _partition_of(req)
@@ -351,7 +370,7 @@ async def create_video(req: dict):
     return _row_view(row)
  
  
-@router.post("/v1/videos/{jid}/cancel")
+@api.post("/v1/videos/{jid}/cancel")
 async def cancel_video(jid: str):
     with db() as con:
         row = con.execute("SELECT * FROM jobs WHERE id=?", (jid,)).fetchone()
@@ -389,7 +408,7 @@ async def cancel_video(jid: str):
     return _row_view(row)
  
  
-@router.get("/v1/videos/{jid}")
+@api.get("/v1/videos/{jid}")
 async def get_video(jid: str):
     with db() as con:
         row = con.execute("SELECT * FROM jobs WHERE id=?", (jid,)).fetchone()
@@ -404,7 +423,7 @@ async def get_video(jid: str):
     return _row_view(row)
  
  
-@router.get("/v1/videos/{jid}/file")
+@api.get("/v1/videos/{jid}/file")
 async def download_video(jid: str, request: Request):
     with db() as con:
         row = con.execute(
@@ -464,7 +483,7 @@ async def download_video(jid: str, request: Request):
     return StreamingResponse(stream(), status_code=upstream.status_code, headers=passthrough)
  
  
-@router.get("/v1/videos")
+@api.get("/v1/videos")
 async def list_videos(limit: int = 50, trash: bool = False, q: str = "", status: str = "",
                        kind: str = "", sort: str = "desc"):
     # console 自己的 sqlite 是任务列表的唯一真相来源（本地排队中的任务，gateway 根本不知道它存在，
@@ -498,7 +517,7 @@ async def list_videos(limit: int = 50, trash: bool = False, q: str = &quot;&quot;, status:
     return {"jobs": [_row_view(r) for r in rows]}
  
  
-@router.delete("/v1/videos/{jid}")
+@api.delete("/v1/videos/{jid}")
 async def delete_video(jid: str):
     """软删除：只挪出主列表，不碰 gateway/api.py 上的任务本身（可能还在跑），不删磁盘文件。"""
     with db() as con:
@@ -508,7 +527,7 @@ async def delete_video(jid: str):
     return {"id": jid, "deleted": True}
  
  
-@router.post("/v1/videos/{jid}/restore")
+@api.post("/v1/videos/{jid}/restore")
 async def restore_video(jid: str):
     with db() as con:
         cur = con.execute("UPDATE jobs SET deleted_at=NULL WHERE id=? AND deleted_at IS NOT NULL", (jid,))
@@ -517,14 +536,14 @@ async def restore_video(jid: str):
     return {"id": jid, "deleted": False}
  
  
-@router.get("/v1/backends")
+@api.get("/v1/backends")
 async def backends():
     resp = await client.get(f"{GATEWAY_URL}/health")
     resp.raise_for_status()
     return resp.json()
  
  
-@router.post("/v1/admin/reset-gpu")
+@api.post("/v1/admin/reset-gpu")
 async def reset_gpu():
     # 通用重置入口，不挂在具体任务上——应对Raylight actor崩溃/OOM后不自愈、显存卡在接近
     # 满载但JOBS里没有running任务的情况（这时候"停止"按钮不会出现，需要这个兜底）。
@@ -538,7 +557,7 @@ async def reset_gpu():
     return resp.json()
  
  
-@router.get("/v1/models")
+@api.get("/v1/models")
 def models():
     # 静态信息，对应服务器上 api.py 里的 PARTITIONS 常量。只读展示，不做运行时切换。
     return {
@@ -717,3 +736,4 @@ async def newtask_page():
 # 直接用 @app.xxx 一模一样；非空时（比如 "/console"）整体套一层前缀，一次性生效，
 # 不用每个路由自己拼。
 app.include_router(router, prefix=BASE_PATH)
+app.include_router(api, prefix=BASE_PATH)
@@ -257,6 +257,40 @@
 // 否则子路径部署时请求会打到域名根路径，而不是我们这个子路径。
 const H3_BASE = "__H3_BASE_PATH__";
  
+// 服务器加了 H3_CONSOLE_AUTH_TOKEN 时，/v1/* 接口要求 Authorization: Bearer <token>。
+// 没设这个环境变量时 server.py 直接放行，这段代码在本地/局域网(没配token)环境下是空转，
+// h3Token() 第一次调用才会真正弹 prompt。
+function h3Token() {
+  let t = localStorage.getItem('h3_console_token');
+  if (t === null) {
+    t = window.prompt('请输入 H3 访问令牌 (Access Token)') || '';
+    localStorage.setItem('h3_console_token', t);
+  }
+  return t;
+}
+function h3FileUrl(path) {
+  // <video src>/<a href download> 是浏览器原生请求，加不上 Authorization 头，
+  // 只能把 token 拼进查询串——server.py 的 _require_token 两种都认。
+  const t = h3Token();
+  return t ? `${path}${path.includes('?') ? '&' : '?'}token=${encodeURIComponent(t)}` : path;
+}
+(function () {
+  const origFetch = window.fetch.bind(window);
+  window.fetch = async (input, opts = {}) => {
+    const url = typeof input === 'string' ? input : input.url;
+    if (url.startsWith(H3_BASE + '/v1/')) {
+      const t = h3Token();
+      if (t) opts = { ...opts, headers: { ...(opts.headers || {}), 'Authorization': 'Bearer ' + t } };
+    }
+    const r = await origFetch(input, opts);
+    if (r.status === 401) {
+      localStorage.removeItem('h3_console_token');
+      alert('访问令牌无效，请刷新页面重新输入');
+    }
+    return r;
+  };
+})();
+
 const uploaded = { 'fl2va-first': null, 'fl2va-last': null, 'ref2va-refs': [], 'ref2va-videos': [], 'ref2va-audios': [] };
 let jobsCache = [];
 let trashCache = [];
@@ -894,8 +928,8 @@ async function refreshDetail() {
  
     let resultHtml = '';
     if (j.status === 'done') {
-      resultHtml = `<video controls src="${H3_BASE}/v1/videos/${j.id}/file"></video>
-        <a class="download" href="${H3_BASE}/v1/videos/${j.id}/file" download>下载 mp4${j.size_bytes ? ' ('+(j.size_bytes/1024/1024).toFixed(1)+'MB)' : ''}</a>`;
+      resultHtml = `<video controls src="${h3FileUrl(H3_BASE + '/v1/videos/' + j.id + '/file')}"></video>
+        <a class="download" href="${h3FileUrl(H3_BASE + '/v1/videos/' + j.id + '/file')}" download>下载 mp4${j.size_bytes ? ' ('+(j.size_bytes/1024/1024).toFixed(1)+'MB)' : ''}</a>`;
     } else if (j.status === 'failed') {
       resultHtml = `<div class="err">${(j.error || '未知错误').replace(/</g,'&lt;')}</div>`;
     } else if (j.status === 'running') {
@@ -8,6 +8,7 @@ User=admin
 WorkingDirectory=/data/models/minimax-h3/console
 Environment=H3_GATEWAY_URL=http://127.0.0.1:8100
 Environment=H3_CONSOLE_PUBLIC_BASE=http://192.168.110.67:8080
+Environment=H3_CONSOLE_AUTH_TOKEN=a470f4dc154c2b9a927c8dad76666a0e0cff3266c5ded42e
 Environment=PORT=8080
 ExecStart=/data/models/minimax-h3/console/run.sh
 StandardOutput=append:/data/models/minimax-h3/console/console-8080.log
@@ -9,6 +9,7 @@ WorkingDirectory=/data/models/minimax-h3/console
 Environment=H3_GATEWAY_URL=http://127.0.0.1:8100
 Environment=H3_CONSOLE_PUBLIC_BASE=http://192.168.110.67:8080
 Environment=H3_CONSOLE_BASE_PATH=/console
+Environment=H3_CONSOLE_AUTH_TOKEN=a470f4dc154c2b9a927c8dad76666a0e0cff3266c5ded42e
 Environment=PORT=8081
 ExecStart=/data/models/minimax-h3/console/run.sh
 StandardOutput=append:/data/models/minimax-h3/console/console-subpath.log
@@ -338,7 +338,7 @@ curl http://localhost:8000/v1/models                # 预期 qwen2.5-72b
 | `frpc.qwen.ini` | `[qwen-gw-20260610]` | `gateway.wudaima.com` | 8080 | ⚠ **8080 无监听，隧道空挂** |
 | `frpc.ini` | `[m3e]` | `m3e.embedding.wudaima.com` | 7590 | ✅ 嵌入服务 |
 | `sd.frpc.ini` | `[stable-diffusion-web]` | `stable-diffusion.wudaima.com` | 7860 | ✅ SD WebUI |
-| `comfyui.frpc.ini` | `[comfyui-web]` | `comfyui.wudaima.com` | 8188 | ⚠ **8188 无监听，隧道空挂** |
+| `comfyui.frpc.ini` | `[comfyui-web]` | `comfyui.wudaima.com` | 8188 | ✅ **2026-08-22 起 raylight 常驻监听 8188，隧道其实一直是活的**（旧结论"无监听隧道空挂"已过期）；**2026-08-29 补了 `http_user`/`http_pwd` 基本认证**（ini 里的原生字段，不用改 ComfyUI 代码），之前裸奔过一段时间见 `CHANGELOG.md` |
 | `ssh.frpc.ini` | `[ssh]` | — (tcp) | 22 → 公网 6000 | ⚠ **SSH 暴露公网** |
  
 ```bash
@@ -346,7 +346,7 @@ pm2 list                          # 需先 export PATH 或用绝对路径
 pm2 logs frpc-qwen-client --lines 50
 ```
  
-> ⚠ **安全**：`qwen.wudaima.com` 无任何鉴权，公网可直接调用本机 27B 推理。`gateway.wudaima.com → 8080` 那条隧道看名字本是做网关鉴权用的，但 8080 一直没有服务。SSH 映射到公网 6000 且允许密码登录、admin 在 sudo 组。
+> ⚠ **安全**：`qwen.wudaima.com` 无任何鉴权，公网可直接调用本机 27B 推理（llm38 目前已停，暂时不可利用）。`gateway.wudaima.com → 8080` 这条客户端隧道配置一直在、且 8080 现在确实有服务在监听（h3-console 局域网实例），但域名在 frp 服务端 `60.205.214.169` 没配对应 vhost，实测会打到一个无关的默认 nginx 页面，不是我们的服务——**这不是保证，只是目前观测到的状态，服务端配置随时可能被改，别把它当长期安全边界**。`qwen.wudaima.com/console`（h3-console 公网入口）**2026-08-29 起要求 `Authorization: Bearer <token>`**，token 见 `h3-console/README.md`。SSH 映射到公网 6000 且允许密码登录、admin 在 sudo 组。
  
 ### 8.2 Nginx