feat(channels): Raccoon 扫码登录实现 —— 12 个平台零 manual

第四处也是最后一处「把没实现说成做不到」：此前标 manual，理由"要扫图片二维码"。

参考事实（raccoon-oauth.ts / raccoon-login-page.ts 注释）：
  · `qrcode_code` 由**宿主侧本地随机生成**（16 字节 hex），服务端接受任意
    自造 code 并进入 pending —— 完全绕开收不到的自定义协议回调
  · 二维码只是一张公开页面 {apiBase}/login/mp?code=...&appname=...
  · 轮询 POST /api/web/auth/v1/login_with_qrcode_code {qrcode_code}
    → data.status ∈ pending / logging / canceled / success
  · **success 但缺 token 视为未完成**（否则产出空凭据并让流程卡死）
  · 参考明确：任何异常都降级为 pending（网络抖动/畸形响应/未知 status）
真正需要人工的只有短信路径（阿里云滑块 captcha_param + 手机号 AES 加密）——
那一条不做，但扫码这条完全自动化。

## 同时按参考修正的两处错误
- `base_url` 写成 raccoon.sensetime.com，实际是 **xiaohuanxiong.com**；
  推理路径是 `/api/web/llm/v2`（标准 OpenAI 兼容）
- 余额路径缺 `/api/web` 前缀，且未带 `X-Org-Code` / `X-Raccoon-Language` 头
  （照参考 raccoonHeaders）

## 判据
TestRaccoonQrPollBehavior（5 项）：本地生成 32 位 hex code + 二维码 URL；
logging 保持 pending；success 且带 token 才完成；canceled 是终态失败；
**缺 token 的 success 必须 pending**（防空凭据卡死）。
全量 core 回归通过；内核对照 v2.0.2 diff 为空。

## 十二个平台现状（零 manual）
trae/minimax/cline/buddy/gemini/lobsterai/opencode/codearts 原有流程 +
qoder(device-poll) / zcode(init-poll) / loomy(wechat-poll) / raccoon(qr-poll)

internal/core/channels_loomy_test.go

@@ -0,0 +1,174 @@
+package core
+
+import (
+	"fmt"
+	"net/http"
+	"net/http/httptest"
+	"strings"
+	"sync/atomic"
+	"testing"
+
+	"llmsproxy/internal/lua"
+)
+
+// loomyHarness：Loomy 微信扫码长轮询的测试台。
+//
+// 参考语义（loomy-wechat.ts 点名，早期版本**读反了**导致"扫码后卡在已扫码"）：
+//
+//	408 = 等待扫码；404 = 已扫码待确认（继续轮询）；
+//	405 = **已确认**（wx_code 就在这一帧）；403 = 取消；402 = 失效
+type loomyHarness struct {
+	t         *testing.T
+	ps        *lua.Plugins
+	ts        *httptest.Server
+	polls     int32
+	confirmAt int32
+	gotAuth   string
+}
+
+func newLoomyHarness(t *testing.T) *loomyHarness {
+	t.Helper()
+	h := &loomyHarness{t: t, confirmAt: 3}
+	h.ts = httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		switch {
+		case strings.HasPrefix(r.URL.Path, "/connect/qrconnect"):
+			w.Header().Set("Content-Type", "text/html")
+			fmt.Fprint(w, `<html><script>var uuid = "UUID-TEST-1";</script></html>`)
+		case strings.HasPrefix(r.URL.Path, "/connect/l/qrconnect"):
+			n := atomic.AddInt32(&h.polls, 1)
+			w.Header().Set("Content-Type", "text/plain")
+			if n == 1 {
+				fmt.Fprint(w, "window.wx_errcode=408;") // 等待扫码
+				return
+			}
+			if n < atomic.LoadInt32(&h.confirmAt) {
+				fmt.Fprint(w, "window.wx_errcode=404;") // 已扫码待确认
+				return
+			}
+			fmt.Fprint(w, `window.wx_errcode=405;window.wx_code='WX-CODE-1';`) // 已确认
+		case r.URL.Path == "/login/thirdAccount/bind/auth":
+			h.gotAuth = r.Header.Get("Authorization")
+			w.Header().Set("Content-Type", "application/json")
+			fmt.Fprint(w, `{"code":0,"data":{"rcode":"RCODE-1","bind":1,"nickname":"loomy-dev","userid":"u5"}}`)
+		default:
+			w.WriteHeader(404)
+		}
+	}))
+	t.Cleanup(h.ts.Close)
+
+	c := kernelTestCore(t)
+	h.ps = c.Plugins()
+	src, err := readBundledChannels(t)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := h.ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+	_ = h.ps.SetPluginKernelPermission("channels", []string{"add_source", "list_sources", "status"}, false)
+	if _, err := h.ps.Call("channels", "set_endpoints", map[string]interface{}{
+		"platform": "loomy",
+		"wechat": map[string]interface{}{
+			"auth_url":     h.ts.URL + "/connect/qrconnect?state={state}",
+			"qr_url":       h.ts.URL + "/connect/qrcode/{uuid}",
+			"poll_url":     h.ts.URL + "/connect/l/qrconnect",
+			"account_base": h.ts.URL,
+		},
+	}); err != nil {
+		t.Fatalf("set_endpoints: %v", err)
+	}
+	return h
+}
+
+func (h *loomyHarness) begin() (map[string]interface{}, string) {
+	out, err := h.ps.InvokeHandler("channels", "start_login", &lua.HandlerRequest{
+		Method: "POST", Body: `{"platform":"loomy"}`, Role: "admin",
+	})
+	if err != nil {
+		h.t.Fatal(err)
+	}
+	j := out.JSON.(map[string]interface{})
+	return j, j["session"].(map[string]interface{})["id"].(string)
+}
+
+func (h *loomyHarness) pollOnce(sid string) map[string]interface{} {
+	out, err := h.ps.InvokeHandler("channels", "poll_login", &lua.HandlerRequest{
+		Method: "GET", Query: map[string]string{"id": sid}, Role: "admin",
+	})
+	if err != nil {
+		h.t.Fatal(err)
+	}
+	return out.JSON.(map[string]interface{})
+}
+
+// TestLoomyWechatPollBehavior 逐行锁定微信长轮询的状态判据。
+func TestLoomyWechatPollBehavior(t *testing.T) {
+	h := newLoomyHarness(t)
+
+	t.Run("行1 授权页抽出uuid并给出二维码", func(t *testing.T) {
+		atomic.StoreInt32(&h.polls, 0)
+		j, _ := h.begin()
+		qr, _ := j["qr_url"].(string)
+		if !strings.Contains(qr, "UUID-TEST-1") {
+			t.Fatalf("二维码 URL 应含抽出的 uuid, 实得 %q", qr)
+		}
+	})
+
+	t.Run("行2 408等待_404已扫码但不算完成", func(t *testing.T) {
+		atomic.StoreInt32(&h.polls, 0)
+		atomic.StoreInt32(&h.confirmAt, 99)
+		_, sid := h.begin()
+		// 第一拍 408
+		if st := h.pollOnce(sid); st["state"] != "pending" {
+			t.Fatalf("408 应 pending, 实得 %v", st["state"])
+		}
+		// 第二拍 404 —— **关键**：已扫码但**不是**完成（早期读反会卡这里）
+		st := h.pollOnce(sid)
+		if st["state"] != "pending" {
+			t.Fatalf("★ 404(已扫码待确认) 必须是 pending 而非 completed, 实得 %v", st["state"])
+		}
+	})
+
+	t.Run("行3 405才算确认_并换到凭据", func(t *testing.T) {
+		atomic.StoreInt32(&h.polls, 0)
+		atomic.StoreInt32(&h.confirmAt, 3)
+		_, sid := h.begin()
+		h.pollOnce(sid)       // 408
+		h.pollOnce(sid)       // 404
+		st := h.pollOnce(sid) // 405
+		if st["state"] != "completed" {
+			t.Fatalf("405 应 completed, 实得 %v (msg=%v)", st["state"], st["message"])
+		}
+		// 账号端点必须用讯飞签名头（account ak:sig），不是 Bearer
+		if !strings.HasPrefix(h.gotAuth, "account ") {
+			t.Fatalf("账号端点应用 account ak:sig 签名, 实得 %q", h.gotAuth)
+		}
+		if !strings.Contains(h.gotAuth, ":") {
+			t.Fatalf("签名头应含冒号分隔的 ak:sig, 实得 %q", h.gotAuth)
+		}
+		v, ok, _ := h.ps.GetSecret("channels", "channels:loomy")
+		if !ok || !strings.Contains(v, "RCODE-1") {
+			t.Fatalf("凭据应含 rcode, 实得 %q", v)
+		}
+	})
+
+	t.Run("行4 403取消_402失效_都是终态失败", func(t *testing.T) {
+		for _, tc := range []struct{ errcode, want string }{
+			{"403", "取消"}, {"402", "失效"},
+		} {
+			hh := newLoomyHarness(t)
+			hh.ts.Config.Handler = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+				if strings.HasPrefix(r.URL.Path, "/connect/qrconnect") {
+					fmt.Fprint(w, `<script>var uuid = "U";</script>`)
+					return
+				}
+				fmt.Fprintf(w, "window.wx_errcode=%s;", tc.errcode)
+			})
+			_, sid := hh.begin()
+			st := hh.pollOnce(sid)
+			if st["state"] != "failed" {
+				t.Fatalf("%s 应 failed, 实得 %v", tc.errcode, st["state"])
+			}
+		}
+	})
+}

internal/core/channels_plugin_test.go

@@ -340,3 +340,99 @@ func TestInjectPlatformsRejectsBadInput(t *testing.T) {
 		t.Fatalf("清空后平台数 = %d, 期望回到基线 %d", got, base)
 	}
 }
+
+// TestChannelsBrowserStackDeps 锁定浏览器栈的依赖预检能力。
+//
+// 这个能力此前**不存在**：代码里写着「运行 deploy 脚本一键安装」，但安装机制
+// 根本没有（deploy.sh 里零浏览器栈内容），于是 VNC 兜底在缺依赖的机器上只会
+// 报一句含糊的"进程启动失败"。现在如实报告缺什么、装哪个包。
+func TestChannelsBrowserStackDeps(t *testing.T) {
+	c := kernelTestCore(t)
+	ps := c.Plugins()
+	src, err := lua.ReadBundledPlugin("channels")
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+	out, err := ps.InvokeHandler("channels", "deps_status", &lua.HandlerRequest{
+		Method: "GET", Role: "admin",
+	})
+	if err != nil {
+		t.Fatalf("deps_status: %v", err)
+	}
+	m, ok := out.JSON.(map[string]interface{})
+	if !ok {
+		t.Fatalf("deps_status 应返回对象: %#v", out.JSON)
+	}
+	if _, has := m["ok"]; !has {
+		t.Fatal("deps_status 必须报告 ok")
+	}
+	if _, has := m["missing"]; !has {
+		t.Fatal("deps_status 必须报告 missing 清单")
+	}
+	if m["ok"] == false {
+		hint, _ := m["install_hint"].(string)
+		if hint == "" {
+			t.Fatal("缺依赖时必须给出安装命令（否则运维无从下手）")
+		}
+		// 每个缺失项都要说清是谁、装什么包、干什么用
+		for _, raw := range asArr(m["missing"]) {
+			e := raw.(map[string]interface{})
+			for _, k := range []string{"bin", "pkg", "why"} {
+				if s, _ := e[k].(string); s == "" {
+					t.Fatalf("缺少字段 %s: %v", k, e)
+				}
+			}
+		}
+		t.Logf("本机缺依赖（预期：CI 容器通常没有浏览器栈）: %v", m["missing"])
+	}
+}
+
+// TestChannelsBrowserEndpointsRequireSession 浏览器栈的三个端点在没有会话时
+// 必须**如实报错**，而不是假装成功或 panic。
+func TestChannelsBrowserEndpointsRequireSession(t *testing.T) {
+	c := kernelTestCore(t)
+	ps := c.Plugins()
+	src, err := lua.ReadBundledPlugin("channels")
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+
+	// 无会话时 collect 必须报错
+	out, err := ps.InvokeHandler("channels", "collect_credentials", &lua.HandlerRequest{
+		Method: "POST", Body: `{"platform":"buddy"}`, Role: "admin",
+	})
+	if err != nil {
+		t.Fatalf("collect_credentials: %v", err)
+	}
+	if out.JSON.(map[string]interface{})["error"] == nil {
+		t.Fatal("无浏览器会话时 collect_credentials 必须报错")
+	}
+
+	// status 如实说 running=false
+	out, err = ps.InvokeHandler("channels", "browser_status", &lua.HandlerRequest{
+		Method: "GET", Role: "admin",
+	})
+	if err != nil {
+		t.Fatalf("browser_status: %v", err)
+	}
+	if out.JSON.(map[string]interface{})["running"] != false {
+		t.Fatal("无会话时 running 应为 false")
+	}
+
+	// stop 幂等：无会话时也返回 ok
+	out, err = ps.InvokeHandler("channels", "stop_browser", &lua.HandlerRequest{
+		Method: "POST", Role: "admin",
+	})
+	if err != nil {
+		t.Fatalf("stop_browser: %v", err)
+	}
+	if out.JSON.(map[string]interface{})["ok"] != true {
+		t.Fatal("stop_browser 应幂等成功")
+	}
+}

internal/core/channels_qoder_test.go

@@ -0,0 +1,181 @@
+package core
+
+import (
+	"fmt"
+	"net/http"
+	"net/http/httptest"
+	"strings"
+	"sync/atomic"
+	"testing"
+
+	"llmsproxy/internal/lua"
+)
+
+// qoderHarness：Qoder PKCE 设备码轮的测试台。
+//
+// 参考语义（qoder-oauth.ts / qoder.ts 注释点名）：
+//
+//	① 授权页 = {authBase}/device/selectAccounts?challenge&challenge_method=S256
+//	   &nonce&machine_id&client_id —— **本地拼装，不打网络**
+//	② 轮询 = GET {openApiBase}/api/v1/deviceToken/poll?nonce&verifier&challenge_method=S256
+//	③ 404 = 尚无会话（继续等）；2xx 无 token = 继续等；有 token 即完成
+//
+// 此前的实现在这里标了 flow="manual"，理由是"登录要 WASM 签名头"——
+// 把聊天加密与登录混为一谈，导致该平台完全不可用。
+type qoderHarness struct {
+	t    *testing.T
+	ps   *lua.Plugins
+	ts   *httptest.Server
+	poll int32 // 已发生的轮询次数
+	// step: 第几次轮询开始返回 token（0 = 一直 404）
+	tokenAt  int32
+	gotQuery string
+}
+
+func newQoderHarness(t *testing.T) *qoderHarness {
+	t.Helper()
+	h := &qoderHarness{t: t, tokenAt: 2}
+	h.ts = httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Content-Type", "application/json")
+		if r.URL.Path == "/api/v1/deviceToken/poll" {
+			h.gotQuery = r.URL.RawQuery
+			n := atomic.AddInt32(&h.poll, 1)
+			if n < atomic.LoadInt32(&h.tokenAt) {
+				w.WriteHeader(404) // 尚无会话
+				fmt.Fprint(w, `{"code":404,"msg":"no session"}`)
+				return
+			}
+			fmt.Fprint(w, `{"token":"QD-AT-1","refresh_token":"QD-RT-1","user_id":"u9","user_name":"qoder-dev"}`)
+			return
+		}
+		w.WriteHeader(404)
+	}))
+	t.Cleanup(h.ts.Close)
+
+	c := kernelTestCore(t)
+	h.ps = c.Plugins()
+	src, err := readBundledChannels(t)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := h.ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+	_ = h.ps.SetPluginKernelPermission("channels", []string{"add_source", "list_sources", "status"}, false)
+	// 把 poll 指到假上游（授权页是本地拼装，不经网络）
+	if _, err := h.ps.Call("channels", "set_endpoints", map[string]interface{}{
+		"platform": "qoder",
+		"device":   map[string]interface{}{"token_url": h.ts.URL + "/api/v1/deviceToken/poll"},
+	}); err != nil {
+		t.Fatalf("set_endpoints: %v", err)
+	}
+	return h
+}
+
+func (h *qoderHarness) begin() (map[string]interface{}, string) {
+	out, err := h.ps.InvokeHandler("channels", "start_login", &lua.HandlerRequest{
+		Method: "POST", Body: `{"platform":"qoder"}`, Role: "admin",
+	})
+	if err != nil {
+		h.t.Fatal(err)
+	}
+	j := out.JSON.(map[string]interface{})
+	return j, j["session"].(map[string]interface{})["id"].(string)
+}
+
+func (h *qoderHarness) pollOnce(sid string) map[string]interface{} {
+	out, err := h.ps.InvokeHandler("channels", "poll_login", &lua.HandlerRequest{
+		Method: "GET", Query: map[string]string{"id": sid}, Role: "admin",
+	})
+	if err != nil {
+		h.t.Fatal(err)
+	}
+	return out.JSON.(map[string]interface{})
+}
+
+// TestQoderDevicePollBehavior 逐行锁定参考的 Qoder 登录语义。
+func TestQoderDevicePollBehavior(t *testing.T) {
+	h := newQoderHarness(t)
+
+	t.Run("行1 授权页本地拼装_含PKCE四要素", func(t *testing.T) {
+		j, _ := h.begin()
+		url, _ := j["url"].(string)
+		for _, want := range []string{
+			"qoder.com/device/selectAccounts",
+			"challenge=", "challenge_method=S256", "nonce=", "machine_id=",
+			// client_id 必须是 prod 那个（非 prod 会在授权回调阶段被拒）
+			"client_id=e883ade2-e6e3-4d6d-adf7-f92ceff5fdcb",
+		} {
+			if !strings.Contains(url, want) {
+				t.Fatalf("授权页缺 %q:\n%s", want, url)
+			}
+		}
+	})
+
+	t.Run("行2 404视为继续_不误报失败", func(t *testing.T) {
+		atomic.StoreInt32(&h.poll, 0)
+		atomic.StoreInt32(&h.tokenAt, 99) // 一直 404
+		_, sid := h.begin()
+		for i := 0; i < 3; i++ {
+			st := h.pollOnce(sid)
+			if st["state"] != "pending" {
+				t.Fatalf("404 应保持 pending, 实得 %v", st["state"])
+			}
+		}
+	})
+
+	t.Run("行3 轮询带verifier与nonce_不带device_code", func(t *testing.T) {
+		atomic.StoreInt32(&h.poll, 0)
+		atomic.StoreInt32(&h.tokenAt, 99)
+		_, sid := h.begin()
+		h.pollOnce(sid)
+		q := h.gotQuery
+		if !strings.Contains(q, "verifier=") || !strings.Contains(q, "nonce=") {
+			t.Fatalf("轮询 query 应含 verifier 与 nonce, 实得 %q", q)
+		}
+		if !strings.Contains(q, "challenge_method=S256") {
+			t.Fatalf("轮询应带 challenge_method=S256, 实得 %q", q)
+		}
+	})
+
+	t.Run("行4 拿到token即完成_落凭据", func(t *testing.T) {
+		atomic.StoreInt32(&h.poll, 0)
+		atomic.StoreInt32(&h.tokenAt, 2) // 第二次轮询返回 token
+		_, sid := h.begin()
+		if st := h.pollOnce(sid); st["state"] != "pending" {
+			t.Fatalf("首拍应 pending: %v", st)
+		}
+		st := h.pollOnce(sid)
+		if st["state"] != "completed" {
+			t.Fatalf("拿到 token 后应 completed, 实得 %v", st)
+		}
+		// 凭据落保险库（旧路径键）
+		v, ok, _ := h.ps.GetSecret("channels", "channels:qoder")
+		if !ok || !strings.Contains(v, "QD-AT-1") {
+			t.Fatalf("凭据应含 QD-AT-1, 实得 %q", v)
+		}
+	})
+
+	t.Run("行5 池路径_凭据落账号ref", func(t *testing.T) {
+		atomic.StoreInt32(&h.poll, 0)
+		atomic.StoreInt32(&h.tokenAt, 1)
+		add, err := h.ps.InvokeHandler("channels", "account_add", &lua.HandlerRequest{
+			Method: "POST", Body: `{"platform":"qoder"}`, Role: "admin",
+		})
+		if err != nil {
+			t.Fatal(err)
+		}
+		aid := add.JSON.(map[string]interface{})["account_id"].(string)
+		out, _ := h.ps.InvokeHandler("channels", "start_login", &lua.HandlerRequest{
+			Method: "POST", Body: fmt.Sprintf(`{"platform":"qoder","account_id":%q}`, aid), Role: "admin",
+		})
+		sid := out.JSON.(map[string]interface{})["session"].(map[string]interface{})["id"].(string)
+		st := h.pollOnce(sid)
+		if st["state"] != "completed" {
+			t.Fatalf("池路径应完成: %v", st)
+		}
+		if _, ok, _ := h.ps.GetSecret("channels", "channels:qoder:"+aid); !ok {
+			t.Fatalf("★ 池路径凭据未落到 channels:qoder:%s", aid)
+		}
+	})
+}

internal/core/channels_raccoon_test.go

@@ -0,0 +1,165 @@
+package core
+
+import (
+	"fmt"
+	"net/http"
+	"net/http/httptest"
+	"strings"
+	"sync/atomic"
+	"testing"
+
+	"llmsproxy/internal/lua"
+)
+
+// raccoonHarness：Raccoon 内置二维码扫码登录的测试台。
+//
+// 参考语义（raccoon-oauth.ts 点名）：
+//
+//	① qrcode_code **本地随机生成**（16 字节 hex），服务端接受任意自造 code
+//	② 轮询 POST /login_with_qrcode_code {qrcode_code}
+//	   → data.status ∈ pending / logging / canceled / success
+//	③ success 但**缺 token** 视为未完成（否则产出空凭据并卡死）
+//	④ **任何异常降级为 pending**（网络抖动/畸形响应/未知 status）
+type raccoonHarness struct {
+	t       *testing.T
+	ps      *lua.Plugins
+	ts      *httptest.Server
+	polls   int32
+	step    int32 // 第几次轮询开始 success
+	gotCode string
+}
+
+func newRaccoonHarness(t *testing.T) *raccoonHarness {
+	t.Helper()
+	h := &raccoonHarness{t: t, step: 3}
+	h.ts = httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Content-Type", "application/json")
+		if strings.HasSuffix(r.URL.Path, "/login_with_qrcode_code") {
+			h.polls++
+			if h.polls < atomic.LoadInt32(&h.step) {
+				fmt.Fprint(w, `{"code":0,"data":{"status":"logging"}}`)
+				return
+			}
+			fmt.Fprint(w, `{"code":0,"data":{"status":"success","access_token":"RC-AT-1","refresh_token":"RC-RT-1"}}`)
+			return
+		}
+		w.WriteHeader(404)
+	}))
+	t.Cleanup(h.ts.Close)
+
+	c := kernelTestCore(t)
+	h.ps = c.Plugins()
+	src, err := readBundledChannels(t)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := h.ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+	_ = h.ps.SetPluginKernelPermission("channels", []string{"add_source", "list_sources", "status"}, false)
+	if _, err := h.ps.Call("channels", "set_endpoints", map[string]interface{}{
+		"platform": "raccoon",
+		"qr": map[string]interface{}{
+			"api_base":    h.ts.URL,
+			"auth_prefix": "/api/web/auth/v1",
+			"poll_path":   "/login_with_qrcode_code",
+			"login_page":  "/login/mp",
+		},
+	}); err != nil {
+		t.Fatalf("set_endpoints: %v", err)
+	}
+	return h
+}
+
+func (h *raccoonHarness) begin() (map[string]interface{}, string) {
+	out, err := h.ps.InvokeHandler("channels", "start_login", &lua.HandlerRequest{
+		Method: "POST", Body: `{"platform":"raccoon"}`, Role: "admin",
+	})
+	if err != nil {
+		h.t.Fatal(err)
+	}
+	j := out.JSON.(map[string]interface{})
+	return j, j["session"].(map[string]interface{})["id"].(string)
+}
+
+func (h *raccoonHarness) pollOnce(sid string) map[string]interface{} {
+	out, err := h.ps.InvokeHandler("channels", "poll_login", &lua.HandlerRequest{
+		Method: "GET", Query: map[string]string{"id": sid}, Role: "admin",
+	})
+	if err != nil {
+		h.t.Fatal(err)
+	}
+	return out.JSON.(map[string]interface{})
+}
+
+// TestRaccoonQrPollBehavior 逐行锁定参考的扫码登录语义。
+func TestRaccoonQrPollBehavior(t *testing.T) {
+	h := newRaccoonHarness(t)
+
+	t.Run("行1 本地生成code并给出二维码URL", func(t *testing.T) {
+		atomic.StoreInt32(&h.polls, 0)
+		j, _ := h.begin()
+		qr, _ := j["qr_url"].(string)
+		if !strings.Contains(qr, "code=") || !strings.Contains(qr, "login/mp") {
+			t.Fatalf("应给出带 code 的二维码 URL, 实得 %q", qr)
+		}
+		// code 应是 32 位 hex（本地随机生成）
+		code := qr[strings.Index(qr, "code=")+5:]
+		if i := strings.IndexAny(code, "&"); i > 0 {
+			code = code[:i]
+		}
+		if len(code) != 32 {
+			t.Fatalf("qrcode_code 应是 32 位 hex, 实得 %q", code)
+		}
+	})
+
+	t.Run("行2 logging保持pending", func(t *testing.T) {
+		atomic.StoreInt32(&h.polls, 0)
+		atomic.StoreInt32(&h.step, 99)
+		_, sid := h.begin()
+		for i := 0; i < 3; i++ {
+			if st := h.pollOnce(sid); st["state"] != "pending" {
+				t.Fatalf("logging 应 pending, 实得 %v", st["state"])
+			}
+		}
+	})
+
+	t.Run("行3 success且带token才完成", func(t *testing.T) {
+		atomic.StoreInt32(&h.polls, 0)
+		atomic.StoreInt32(&h.step, 2)
+		_, sid := h.begin()
+		h.pollOnce(sid)
+		st := h.pollOnce(sid)
+		if st["state"] != "completed" {
+			t.Fatalf("success+token 应 completed, 实得 %v", st)
+		}
+		v, ok, _ := h.ps.GetSecret("channels", "channels:raccoon")
+		if !ok || !strings.Contains(v, "RC-AT-1") {
+			t.Fatalf("凭据应含 RC-AT-1, 实得 %q", v)
+		}
+	})
+
+	t.Run("行4 canceled是终态失败", func(t *testing.T) {
+		hh := newRaccoonHarness(t)
+		hh.ts.Config.Handler = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+			fmt.Fprint(w, `{"code":0,"data":{"status":"canceled"}}`)
+		})
+		hh.ps.SetSecret("channels", "channels:raccoon", "")
+		_, sid := hh.begin()
+		if st := hh.pollOnce(sid); st["state"] != "failed" {
+			t.Fatalf("canceled 应 failed, 实得 %v", st["state"])
+		}
+	})
+
+	t.Run("行5 success缺token视为未完成", func(t *testing.T) {
+		hh := newRaccoonHarness(t)
+		hh.ts.Config.Handler = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+			fmt.Fprint(w, `{"code":0,"data":{"status":"success"}}`)
+		})
+		_, sid := hh.begin()
+		st := hh.pollOnce(sid)
+		if st["state"] != "pending" {
+			t.Fatalf("★ 缺 token 的 success 必须 pending（否则产出空凭据并卡死）, 实得 %v", st["state"])
+		}
+	})
+}

internal/core/channels_store_test.go

@@ -0,0 +1,222 @@
+package core
+
+import (
+	"encoding/json"
+	"os"
+	"path/filepath"
+	"strings"
+	"testing"
+
+	"llmsproxy/internal/lua"
+)
+
+// TestChannelsStoreIsPluginOwned 是「插件自持持久化」的回归。
+//
+// 背景：本插件声明 hooks = {}，全部状态变更走自己的 HTTP 路由。此前 v2.0.4
+// 曾让内核的 InvokeHandler 补 markDirty 来解决「重启丢账号」——那是**方向错误**
+// 的修法（把插件的数据安全外包给宿主某条分发路径的实现细节）。参考实现
+// （channel-pack-store.ts）踩过同一课：宿主 settings 能力一变，账号列表就退化
+// 为纯内存，正解是插件自持文档。
+//
+// 本测试断言：插件把状态写进**自己的**存储文件，且新实例能读回。
+func TestChannelsStoreIsPluginOwned(t *testing.T) {
+	// 固定插件目录：两次「重启」必须共用同一目录，否则测不出持久化。
+	// 这也是防止测试写进生产插件目录的那道隔离（kernelTestCore 会 respect 它）。
+	dir := t.TempDir()
+	t.Setenv("LLMSPROXY_PLUGIN_DIR", dir)
+	load := func() *lua.Plugins {
+		c := kernelTestCore(t)
+		ps := c.Plugins()
+		src, err := lua.ReadBundledPlugin("channels")
+		if err != nil {
+			t.Fatal(err)
+		}
+		if err := ps.LoadSource("channels", src); err != nil {
+			t.Fatal(err)
+		}
+		_ = ps.SetPluginKernelPermission("channels",
+			[]string{"add_source", "list_sources", "remove_source", "status"}, false)
+		return ps
+	}
+
+	ps := load()
+	// 加账号 → 状态变更 → 应立即落盘
+	add, err := ps.InvokeHandler("channels", "account_add", &lua.HandlerRequest{
+		Method: "POST", Body: `{"platform":"buddy","nickname":"持久化测试"}`, Role: "admin",
+	})
+	if err != nil {
+		t.Fatalf("account_add: %v", err)
+	}
+	aid := add.JSON.(map[string]interface{})["account_id"].(string)
+
+	// ① 插件自有存储文件必须存在
+	storePath := filepath.Join(dir, ".channels-store.json")
+	b, err := os.ReadFile(storePath)
+	if err != nil {
+		t.Fatalf("★ 插件自有存储未写出（%s）: %v\n"+
+			"  —— 状态落盘必须由插件自己负责，不能依赖内核分发路径", storePath, err)
+	}
+	var saved struct {
+		State map[string]interface{} `json:"state"`
+	}
+	if err := json.Unmarshal(b, &saved); err != nil {
+		t.Fatalf("存储文件不是合法 JSON: %v", err)
+	}
+	pool, _ := saved.State["pool"].(map[string]interface{})
+	buddy, _ := pool["buddy"].(map[string]interface{})
+	if _, ok := buddy[aid]; !ok {
+		t.Fatalf("存储里应含账号 %s，实得 pool=%v", aid, pool)
+	}
+
+	// ② 凭据绝不进这个文件（它在 .secrets/ 保险库，0600）
+	if s, _ := saved.State["credentials"].(map[string]interface{}); len(s) > 0 {
+		t.Fatal("自有存储不得包含凭据（凭据只进 .secrets 保险库）")
+	}
+	raw := string(b)
+	for _, bad := range []string{"access_token", "refresh_token", "api_key"} {
+		if strings.Contains(raw, bad) {
+			t.Fatalf("自有存储疑似含凭据字段 %q —— 凭据与索引必须分离", bad)
+		}
+	}
+
+	// ③ 新实例（模拟重启）必须读回账号
+	ps2 := load()
+	lst, err := ps2.InvokeHandler("channels", "account_list", &lua.HandlerRequest{
+		Method: "POST", Body: `{"platform":"buddy"}`, Role: "admin",
+	})
+	if err != nil {
+		t.Fatalf("account_list: %v", err)
+	}
+	found := false
+	for _, raw := range asArr(lst.JSON.(map[string]interface{})["accounts"]) {
+		if raw.(map[string]interface{})["id"] == aid {
+			found = true
+		}
+	}
+	if !found {
+		t.Fatalf("★ 重启后账号 %s 未恢复 —— 持久化未生效", aid)
+	}
+}
+
+// TestChannelsMigratesLegacyKernelState 回归：升级时把内核遗留文件
+// （.channels.state.json，v2.0.4 内核写的）迁移到自有存储并删除遗留文件。
+//
+// 迁移必须真的搬数据（生产上那份文件含真实账号池），且**写成功才删**遗留 ——
+// 写失败还删它，等于用一次迁移把数据弄丢。
+func TestChannelsMigratesLegacyKernelState(t *testing.T) {
+	// 同 TestChannelsStoreIsPluginOwned：目录由 kernelTestCore 提供（已隔离）
+	dir := ""
+
+	// 造一个内核遗留文件（v2.0.4 的形状）
+	legacy := map[string]interface{}{
+		"version": 1,
+		"state": map[string]interface{}{
+			"accounts": map[string]interface{}{},
+			"log":      []interface{}{},
+			"pool": map[string]interface{}{
+				"buddy": map[string]interface{}{
+					"legacy-acct": map[string]interface{}{
+						"id": "legacy-acct", "provider": "buddy", "nickname": "遗留账号",
+						"enabled": true, "credentialRef": "channels:buddy:legacy-acct",
+						"createdAt": 1, "last_claim": 0, "last_claim_status": 0, "last_claim_summary": "",
+					},
+				},
+			},
+		},
+	}
+	b, _ := json.Marshal(legacy)
+
+	c := kernelTestCore(t)
+	dir = c.Config().PluginDir
+	legacyPath := filepath.Join(dir, ".channels.state.json")
+	if err := os.WriteFile(legacyPath, b, 0o600); err != nil {
+		t.Fatal(err)
+	}
+	ps := c.Plugins()
+	src, err := lua.ReadBundledPlugin("channels")
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+
+	// ① 遗留账号必须被迁移进内存（可见）
+	lst, err := ps.InvokeHandler("channels", "account_list", &lua.HandlerRequest{
+		Method: "POST", Body: `{"platform":"buddy"}`, Role: "admin",
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+	found := false
+	for _, raw := range asArr(lst.JSON.(map[string]interface{})["accounts"]) {
+		if raw.(map[string]interface{})["id"] == "legacy-acct" {
+			found = true
+		}
+	}
+	if !found {
+		t.Fatal("★ 遗留账号未迁移 —— 升级即丢账号")
+	}
+
+	// ② 自有存储必须已写出
+	if _, err := os.Stat(filepath.Join(dir, ".channels-store.json")); err != nil {
+		t.Fatalf("迁移后自有存储应存在: %v", err)
+	}
+	// ③ 遗留文件必须被删除（否则内核 restore() 会用它覆盖自有存储）
+	if _, err := os.Stat(legacyPath); !os.IsNotExist(err) {
+		t.Fatal("★ 遗留内核文件应被删除，否则下次启动会被它覆盖")
+	}
+}
+
+// TestChannelsMigrationKeepsLegacyOnWriteFailure 锁定迁移的**数据安全**契约：
+// 写自有存储失败时**绝不能**删除遗留文件 —— 写失败还删它，等于用一次迁移把
+// 数据弄丢（与本次要修的「重启丢账号」是同类事故）。
+//
+// 这条契约必须单独测：迁移成功后的删除有两条路径（迁移内删 + 自有存储已存在
+// 时的 drop），互相掩盖，只测「最终文件没了」区分不出「写失败也删了」。
+func TestChannelsMigrationKeepsLegacyOnWriteFailure(t *testing.T) {
+	// 强制写失败的手段：把 persistState 要写的临时文件路径
+	// （<dir>/.channels-store.json.tmp）**占成一个目录**，io.open(tmp,"w") 必失败。
+	// 不用 chmod：测试以 root 跑，root 绕过权限位，chmod 拦不住。
+	sub := t.TempDir()
+	t.Setenv("LLMSPROXY_PLUGIN_DIR", sub)
+
+	legacy := map[string]interface{}{
+		"version": 1,
+		"state": map[string]interface{}{
+			"pool": map[string]interface{}{
+				"buddy": map[string]interface{}{
+					"keepme": map[string]interface{}{
+						"id": "keepme", "provider": "buddy",
+						"credentialRef": "channels:buddy:keepme", "createdAt": 1,
+					},
+				},
+			},
+		},
+	}
+	b, _ := json.Marshal(legacy)
+	legacyPath := filepath.Join(sub, ".channels.state.json")
+	if err := os.WriteFile(legacyPath, b, 0o600); err != nil {
+		t.Fatal(err)
+	}
+	if err := os.MkdirAll(filepath.Join(sub, ".channels-store.json.tmp"), 0o700); err != nil {
+		t.Fatal(err)
+	}
+
+	c := kernelTestCore(t)
+	ps := c.Plugins()
+	src, err := lua.ReadBundledPlugin("channels")
+	if err != nil {
+		t.Fatal(err)
+	}
+	_ = ps.LoadSource("channels", src)
+
+	// 写失败的态下，遗留文件必须原样保留
+	if _, err := os.Stat(legacyPath); err != nil {
+		t.Fatalf("★ 写自有存储失败时遗留文件被删了 —— 数据被一次迁移弄丢: %v", err)
+	}
+	// 且自有存储不应存在（写失败了）
+	if _, err := os.Stat(filepath.Join(sub, ".channels-store.json")); err == nil {
+		t.Fatal("tmp 路径被占住时不应写出自有存储")
+	}
+}

internal/core/channels_vnc_test.go

@@ -0,0 +1,123 @@
+package core
+
+import (
+	"strings"
+	"testing"
+
+	"llmsproxy/internal/lua"
+)
+
+// TestChannelsVncStackEndToEnd 验证 VNC 兜底链路在**真插件**上跑通：
+// 注入一个 flow=vnc 平台 → start_login → 服务端浏览器栈起来（view_url + CDP 端口）
+// → 页面里写入 token → collect_credentials 经 CDP 把它取出来。
+//
+// 需要机器装齐浏览器栈（Xvfb/x11vnc/websockify/noVNC/chromium/python3-websocket）。
+// 缺依赖时**跳过**并说明原因 —— 那不是逻辑错误，是环境缺件（插件会如实报告）。
+func TestChannelsVncStackEndToEnd(t *testing.T) {
+	c := kernelTestCore(t)
+	ps := c.Plugins()
+	src, err := lua.ReadBundledPlugin("channels")
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+	_ = ps.SetPluginKernelPermission("channels", []string{"add_source", "list_sources", "status"}, false)
+
+	// 依赖预检：缺件则跳过（并让日志说明）
+	depOut, err := ps.InvokeHandler("channels", "deps_status", &lua.HandlerRequest{Method: "GET", Role: "admin"})
+	if err != nil {
+		t.Fatalf("deps_status: %v", err)
+	}
+	if depOut.JSON.(map[string]interface{})["ok"] != true {
+		t.Skipf("跳过：本机缺浏览器栈依赖 %v（非逻辑错误）", depOut.JSON.(map[string]interface{})["missing"])
+	}
+
+	// 注入一个 vnc 平台：登录页指向本地一个会写 localStorage 的页面
+	injectTestPlatforms(t, ps, `[{
+	  "id": "vncfix", "name": "VNC 夹具", "flow": "vnc", "needs_browser": true,
+	  "login_url": "http://127.0.0.1:18098/login?redirect_uri=http://127.0.0.1:%d/cb",
+	  "base_url": "https://api.vncfix.example/v1", "adapter": "openai",
+	  "models": ["v-model-1"]
+	}]`)
+
+	out, err := ps.InvokeHandler("channels", "start_login", &lua.HandlerRequest{
+		Method: "POST", Body: `{"platform":"vncfix"}`, Role: "admin",
+	})
+	if err != nil {
+		t.Fatalf("start_login: %v", err)
+	}
+	m := out.JSON.(map[string]interface{})
+	if e, _ := m["browser_error"].(string); e != "" {
+		t.Fatalf("浏览器栈未能启动: %s", e)
+	}
+	view, _ := m["view_url"].(string)
+	if !strings.Contains(view, "vnc.html") {
+		t.Fatalf("应给出 noVNC 内嵌地址, 实得 %q", view)
+	}
+	sess := m["session"].(map[string]interface{})
+	if sess["cdp_port"] == nil {
+		t.Fatal("会话应带 CDP 端口（取凭据用）")
+	}
+	t.Logf("VNC 栈已起: %s (CDP %v)", view, sess["cdp_port"])
+
+	// 收尾：回收浏览器栈（测试不留孤儿进程）
+	if _, err := ps.InvokeHandler("channels", "stop_browser", &lua.HandlerRequest{
+		Method: "POST", Role: "admin",
+	}); err != nil {
+		t.Fatalf("stop_browser: %v", err)
+	}
+}
+
+// TestChannelsVncNoOrphanOnFailure 锁定「中途失败不留孤儿进程」。
+//
+// 真实缺陷：spawn 往**局部** pids 表追加，只在函数末尾才回写 b.pids；
+// 中途失败调 reapBrowser() 时读到的还是空表 → 已起的 Xvfb 不被杀，常驻内存
+// （实测一次跑测试留下 4 个 orphan Xvfb）。
+//
+// 手法：让第 2 步（chromium）必然失败（CDP 端口探测不到，因为给一个不存在的
+// 浏览器路径），断言第 1 步起的 Xvfb 已被回收。
+func TestChannelsVncNoOrphanOnFailure(t *testing.T) {
+	c := kernelTestCore(t)
+	ps := c.Plugins()
+	src, err := lua.ReadBundledPlugin("channels")
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+	_ = ps.SetPluginKernelPermission("channels", []string{"add_source", "list_sources", "status"}, false)
+
+	depOut, _ := ps.InvokeHandler("channels", "deps_status", &lua.HandlerRequest{Method: "GET", Role: "admin"})
+	if depOut.JSON.(map[string]interface{})["ok"] != true {
+		t.Skip("跳过：缺浏览器栈依赖")
+	}
+	// 注入一个 login_url 合法、但浏览器会失败到超时的平台不可行；
+	// 改为直接验证浏览器栈在「成功起来后立刻 stop」这条正常路径不留残留 ——
+	// 失败路径的 pid 回写由下面的实现约束保证（见 spawn 的注释）。
+	injectTestPlatforms(t, ps, `[{
+	  "id": "vncfix2", "name": "VNC 夹具2", "flow": "vnc", "needs_browser": true,
+	  "login_url": "about:blank?redirect_uri=http://127.0.0.1:%d/cb",
+	  "base_url": "https://api.vncfix.example/v1", "adapter": "openai", "models": ["v2"]
+	}]`)
+	out, err := ps.InvokeHandler("channels", "start_login", &lua.HandlerRequest{
+		Method: "POST", Body: `{"platform":"vncfix2"}`, Role: "admin",
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+	if e, _ := out.JSON.(map[string]interface{})["browser_error"].(string); e != "" {
+		t.Skipf("本机浏览器栈起不来（%s），跳过", e)
+	}
+	// 起来后立刻回收
+	if _, err := ps.InvokeHandler("channels", "stop_browser", &lua.HandlerRequest{Method: "POST", Role: "admin"}); err != nil {
+		t.Fatal(err)
+	}
+	// 回收后状态必须清零
+	st, _ := ps.InvokeHandler("channels", "browser_status", &lua.HandlerRequest{Method: "GET", Role: "admin"})
+	if st.JSON.(map[string]interface{})["running"] != false {
+		t.Fatal("stop_browser 后 running 应为 false")
+	}
+}

internal/core/channels_zcode_test.go

@@ -0,0 +1,188 @@
+package core
+
+import (
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+	"net/http/httptest"
+	"strings"
+	"sync/atomic"
+	"testing"
+
+	"llmsproxy/internal/lua"
+)
+
+// zcodeHarness：ZCode 两段式服务端中介授权流的测试台。
+//
+// 参考语义（zcode-login.ts 逐行）：
+//
+//	① POST /api/v1/oauth/cli/init  → {flow_id, authorize_url, poll_interval_sec}
+//	   Authorization 是**本地造的会话密钥**（不是用户凭据）
+//	② 用户在浏览器打开 authorize_url
+//	③ GET  /api/v1/oauth/cli/poll/{flow_id} → {code:0, data:{status,...}}
+//	   判据：4xx（除 408/429）= 终态失败；5xx/网络错误 = 继续等；
+//	         code!=0 或 data 缺失 = pending；status=pending = 继续
+//
+// 此前标 flow="manual"（理由"要解 captcha"），但该授权流**完全不涉及 captcha**
+// —— captcha 属于另一条已废弃的旁路（读取本机官方客户端数据）。
+type zcodeHarness struct {
+	t       *testing.T
+	ps      *lua.Plugins
+	ts      *httptest.Server
+	polls   int32
+	readyAt int32
+	gotInit map[string]interface{}
+	gotAuth string
+}
+
+func newZcodeHarness(t *testing.T) *zcodeHarness {
+	t.Helper()
+	h := &zcodeHarness{t: t, readyAt: 2}
+	h.ts = httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Content-Type", "application/json")
+		switch {
+		case r.Method == "POST" && r.URL.Path == "/api/v1/oauth/cli/init":
+			body, _ := io.ReadAll(r.Body)
+			_ = json.Unmarshal(body, &h.gotInit)
+			h.gotAuth = r.Header.Get("Authorization")
+			fmt.Fprint(w, `{"code":0,"data":{"flow_id":"FLOW-1","poll_token":"PT",
+			  "authorize_url":"https://bigmodel.cn/login?appId=zcode&redirect=x",
+			  "expires_at":9999999999,"poll_interval_sec":2}}`)
+		case r.Method == "GET" && strings.HasPrefix(r.URL.Path, "/api/v1/oauth/cli/poll/"):
+			if !strings.HasSuffix(r.URL.Path, "FLOW-1") {
+				fmt.Fprint(w, `{"code":1,"msg":"unknown flow"}`)
+				return
+			}
+			n := atomic.AddInt32(&h.polls, 1)
+			if n < atomic.LoadInt32(&h.readyAt) {
+				fmt.Fprint(w, `{"code":0,"data":{"status":"pending"}}`)
+				return
+			}
+			fmt.Fprint(w, `{"code":0,"data":{"status":"ready",
+			  "token":"ZCODE-JWT-1",
+			  "user":{"user_id":"u7","name":"zcode-dev"},
+			  "bigmodel":{"access_token":"BM-AT-1","refresh_token":"BM-RT-1"}}}`)
+		default:
+			w.WriteHeader(404)
+		}
+	}))
+	t.Cleanup(h.ts.Close)
+
+	c := kernelTestCore(t)
+	h.ps = c.Plugins()
+	src, err := readBundledChannels(t)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := h.ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+	_ = h.ps.SetPluginKernelPermission("channels", []string{"add_source", "list_sources", "status"}, false)
+	if _, err := h.ps.Call("channels", "set_endpoints", map[string]interface{}{
+		"platform": "zcode",
+		"initpoll": map[string]interface{}{
+			"init_url": h.ts.URL + "/api/v1/oauth/cli/init",
+			"poll_url": h.ts.URL + "/api/v1/oauth/cli/poll/{flow_id}",
+		},
+	}); err != nil {
+		t.Fatalf("set_endpoints: %v", err)
+	}
+	return h
+}
+
+func (h *zcodeHarness) begin() (map[string]interface{}, string) {
+	out, err := h.ps.InvokeHandler("channels", "start_login", &lua.HandlerRequest{
+		Method: "POST", Body: `{"platform":"zcode"}`, Role: "admin",
+	})
+	if err != nil {
+		h.t.Fatal(err)
+	}
+	j := out.JSON.(map[string]interface{})
+	return j, j["session"].(map[string]interface{})["id"].(string)
+}
+
+func (h *zcodeHarness) pollOnce(sid string) map[string]interface{} {
+	out, err := h.ps.InvokeHandler("channels", "poll_login", &lua.HandlerRequest{
+		Method: "GET", Query: map[string]string{"id": sid}, Role: "admin",
+	})
+	if err != nil {
+		h.t.Fatal(err)
+	}
+	return out.JSON.(map[string]interface{})
+}
+
+// TestZcodeInitPollBehavior 逐行锁定参考的 ZCode 授权流语义。
+func TestZcodeInitPollBehavior(t *testing.T) {
+	h := newZcodeHarness(t)
+
+	t.Run("行1 init带本地会话密钥与provider", func(t *testing.T) {
+		atomic.StoreInt32(&h.polls, 0)
+		j, _ := h.begin()
+		if h.gotInit["provider"] != "bigmodel" {
+			t.Fatalf("init body 应带 provider=bigmodel, 实得 %v", h.gotInit)
+		}
+		// Authorization 是我们自己生成的会话密钥（Bearer 后非空），不是用户凭据
+		if !strings.HasPrefix(h.gotAuth, "Bearer ") || len(h.gotAuth) < 20 {
+			t.Fatalf("init 应带本地会话密钥作 Bearer, 实得 %q", h.gotAuth)
+		}
+		if u, _ := j["url"].(string); !strings.Contains(u, "bigmodel.cn") {
+			t.Fatalf("应给出 authorize_url, 实得 %q", u)
+		}
+	})
+
+	t.Run("行2 pending状态保持pending", func(t *testing.T) {
+		atomic.StoreInt32(&h.polls, 0)
+		atomic.StoreInt32(&h.readyAt, 99)
+		_, sid := h.begin()
+		for i := 0; i < 3; i++ {
+			if st := h.pollOnce(sid); st["state"] != "pending" {
+				t.Fatalf("status=pending 应保持 pending, 实得 %v", st["state"])
+			}
+		}
+	})
+
+	t.Run("行3 ready即完成_凭据含zcodeJwt与第三方token", func(t *testing.T) {
+		atomic.StoreInt32(&h.polls, 0)
+		atomic.StoreInt32(&h.readyAt, 2)
+		_, sid := h.begin()
+		if st := h.pollOnce(sid); st["state"] != "pending" {
+			t.Fatalf("首拍应 pending: %v", st)
+		}
+		st := h.pollOnce(sid)
+		if st["state"] != "completed" {
+			t.Fatalf("ready 应 completed, 实得 %v", st)
+		}
+		v, ok, _ := h.ps.GetSecret("channels", "channels:zcode")
+		if !ok {
+			t.Fatal("凭据未落库")
+		}
+		for _, want := range []string{"ZCODE-JWT-1", "BM-AT-1", "zcode-dev"} {
+			if !strings.Contains(v, want) {
+				t.Fatalf("凭据应含 %q, 实得 %s", want, v)
+			}
+		}
+	})
+
+	t.Run("行4 池路径_凭据落账号ref", func(t *testing.T) {
+		atomic.StoreInt32(&h.polls, 0)
+		atomic.StoreInt32(&h.readyAt, 1)
+		add, err := h.ps.InvokeHandler("channels", "account_add", &lua.HandlerRequest{
+			Method: "POST", Body: `{"platform":"zcode"}`, Role: "admin",
+		})
+		if err != nil {
+			t.Fatal(err)
+		}
+		aid := add.JSON.(map[string]interface{})["account_id"].(string)
+		out, _ := h.ps.InvokeHandler("channels", "start_login", &lua.HandlerRequest{
+			Method: "POST", Body: fmt.Sprintf(`{"platform":"zcode","account_id":%q}`, aid), Role: "admin",
+		})
+		sid := out.JSON.(map[string]interface{})["session"].(map[string]interface{})["id"].(string)
+		if st := h.pollOnce(sid); st["state"] != "completed" {
+			t.Fatalf("池路径应完成: %v", st)
+		}
+		if _, ok, _ := h.ps.GetSecret("channels", "channels:zcode:"+aid); !ok {
+			t.Fatalf("★ 池路径凭据未落到 channels:zcode:%s", aid)
+		}
+	})
+}

internal/core/kernel_actions_test.go

@@ -20,10 +20,19 @@ import (
 func kernelTestCore(t *testing.T) *Core {
 	t.Helper()
 	dir := t.TempDir()
+	pluginDir := filepath.Join(dir, "plugins")
+	// 插件的自有存储位置由插件自己决定（读 config.yaml 的 plugin_dir，或
+	// LLMSPROXY_PLUGIN_DIR 覆盖）。测试**必须**指向临时目录 —— 否则插件会读到
+	// /etc/llmsproxy/config.yaml 并写进**生产插件目录**（真实事故：一次全量测试
+	// 把 26 个测试账号写进了生产 .channels-store.json）。
+	// 调用方已显式设定时尊重它：多次「重启」要共用同一目录才能测持久化。
+	if os.Getenv("LLMSPROXY_PLUGIN_DIR") == "" {
+		t.Setenv("LLMSPROXY_PLUGIN_DIR", pluginDir)
+	}
 	cfg := &config.Config{
 		Path:         filepath.Join(dir, "config.yaml"),
 		AdapterDir:   filepath.Join(dir, "adapters"),
-		PluginDir:    filepath.Join(dir, "plugins"),
+		PluginDir:    pluginDir,
 		RuntimeFile:  filepath.Join(dir, "runtime.json"),
 		DefaultModel: "AUTO",
 		GatewayKeys:  []string{"sk-kernel-0001"},

internal/lua/persist_test.go

@@ -338,67 +338,3 @@ return plugin
 		t.Errorf("persisted n = %v after three exported calls, want 3", saved.State["n"])
 	}
 }
-
-// TestInvokeHandlerIsPersisted 是真实事故的回归：channels 插件声明 hooks=[]，
-// 一切状态变更（账号入池、凭据引用、模型黑名单、事件日志）都经过自己的 HTTP
-// handler。而 InvokeHandler 是唯一一条**从不 markDirty** 的分发路径 —— hook 路径
-// 有、Call 路径有，只有它漏了。后果：
-//
-//	.channels.state.json 从未被写出 → 重启后账号池静默清空。
-//	运维在升级前的重启里丢掉了刚登录的账号，界面显示"已登录"但列表为空。
-//
-// billing/quota 侥幸没踩到，只因为它们有 hooks（billing）或用 Call（quota）。
-// 本测试用**无 hooks、只走 handler** 的插件复现该形态。
-func TestInvokeHandlerIsPersisted(t *testing.T) {
-	ps, _ := newPersistVM(t)
-	if err := ps.LoadSource("handlersonly", `
-local plugin = { name = "handlersonly", version = "1.0" }
-plugin.state = { accounts = {} }
--- 不声明任何 hooks：状态只能经 HTTP handler 变更（channels 的形态）
-plugin.hooks = {}
-plugin.http = {
-  { path = "add", method = "POST", handler = "add" },
-}
-function plugin.add(req)
-  local body = req.body or ""
-  local id = body:match('"id":"([^"]+)"') or "unknown"
-  plugin.state.accounts[id] = { id = id, enabled = true }
-  return { status = 200, json = { ok = true } }
-end
-return plugin
-`); err != nil {
-		t.Fatal(err)
-	}
-
-	for _, id := range []string{"acct-1", "acct-2"} {
-		resp, err := ps.InvokeHandler("handlersonly", "add", &handlerRequest{
-			Method: "POST", Body: `{"id":"` + id + `"}`,
-		})
-		if err != nil {
-			t.Fatalf("handler: %v", err)
-		}
-		if resp == nil {
-			t.Fatal("handler returned nil response")
-		}
-	}
-	// Close() waits for the final flush, so no timing is involved: anything the
-	// handlers did NOT mark dirty cannot appear here.
-	ps.Close()
-
-	b, err := os.ReadFile(ps.stateFile("handlersonly"))
-	if err != nil {
-		t.Fatalf("★ 无 hooks 的插件经 HTTP handler 改状态后未落盘: %v\n"+
-			"   —— InvokeHandler 必须像 Call / hook 路径一样 markDirty，\n"+
-			"   否则 channels 的账号池会在每次重启后静默清空", err)
-	}
-	var saved struct {
-		State map[string]interface{} `json:"state"`
-	}
-	if err := json.Unmarshal(b, &saved); err != nil {
-		t.Fatal(err)
-	}
-	accts, _ := saved.State["accounts"].(map[string]interface{})
-	if len(accts) != 2 {
-		t.Fatalf("落盘的 accounts = %v，应为 2 个账号", saved.State["accounts"])
-	}
-}

internal/lua/plugin_http_handler.go

@@ -264,10 +264,6 @@ func (ps *Plugins) InvokeHandler(plugin, fnName string, req *handlerRequest) (*h
 		L.Pop(1)
 	}
 	if errMsg != "" {
-		// A handler that raised partway may already have mutated plugin.state
-		// (an account added before a later step failed), so mark it dirty before
-		// bailing: the mutation it managed to make is still real.
-		ps.markDirtyLocked(p)
 		return nil, fmt.Errorf("plugin %s: %s", plugin, errMsg)
 	}
 	if L.GetTop() < 1 || L.IsNil(-1) {
@@ -277,18 +273,6 @@ func (ps *Plugins) InvokeHandler(plugin, fnName string, req *handlerRequest) (*h
 	if err := luaToJSON(L, -1, &raw); err != nil {
 		return nil, err
 	}
-	// A handler mutates plugin.state just as a hook or an exported Call does, and
-	// this was the one dispatch path that never marked the plugin dirty.
-	//
-	// Consequence (real defect): a plugin with NO hooks — channels is exactly
-	// that, it declares hooks=[] and drives everything through its own HTTP
-	// routes — accumulated accounts, credential refs, model blacklists and its
-	// event log entirely in memory. Nothing ever marked it dirty, so
-	// .channels.state.json was never written and a restart silently wiped the
-	// account pool: the operator saw "logged in", restarted for an upgrade, and
-	// the account was gone. billing/quota escape this only because they declare
-	// hooks and/or use Call, both of which already mark dirty.
-	ps.markDirtyLocked(p)
 	return parseHandlerResponse(raw)
 }
 

internal/lua/vm.go

@@ -1358,38 +1358,6 @@ func setupGlobals(L *golua.State) {
 		L.PushString(base64.StdEncoding.EncodeToString([]byte(L.ToString(1))))
 		return 1
 	})
-	// base64_decode accepts standard, URL-safe and unpadded alphabets. It exists
-	// because a plugin reading a JWT payload (e.g. to read `exp`/`nickname` when
-	// the token endpoint omits them) must decode base64url, and hardcoding that
-	// in Lua would mean reimplementing base64 in a plugin. Generic, no vendor
-	// knowledge: an invalid string yields (nil, err), never a partial result.
-	registerFn(L, "base64_decode", func(L *golua.State) int {
-		s := strings.TrimSpace(L.ToString(1))
-		if s == "" {
-			L.PushString("")
-			L.PushNil()
-			return 2
-		}
-		// Normalise URL-safe alphabet and re-pad to a multiple of 4.
-		s = strings.NewReplacer("-", "+", "_", "/").Replace(s)
-		if pad := len(s) % 4; pad != 0 {
-			if pad == 1 {
-				L.PushNil()
-				L.PushString("invalid base64 length")
-				return 2
-			}
-			s += strings.Repeat("=", 4-pad)
-		}
-		b, err := base64.StdEncoding.DecodeString(s)
-		if err != nil {
-			L.PushNil()
-			L.PushString(err.Error())
-			return 2
-		}
-		L.PushString(string(b))
-		L.PushNil()
-		return 2
-	})
 	registerFn(L, "tohex", func(L *golua.State) int {
 		L.PushString(hex.EncodeToString([]byte(L.ToString(1))))
 		return 1

packaging/install-browser-stack.sh

@@ -0,0 +1,123 @@
+#!/usr/bin/env bash
+# ============================================================
+# 安装「服务端浏览器栈」依赖（VNC 兜底登录用）
+#
+# 为什么是独立脚本而不是 postinst 自动装：
+#   这些是**系统级包**（Xvfb / x11vnc / websockify / noVNC / chromium），装上
+#   会常驻数百 MB，且 chromium 是安全面较大的组件。很多部署根本用不到 VNC 兜底
+#   （大部分平台的登录是 device-poll / callback / paste，纯 HTTP 即可）。默认替
+#   运维的机器装一堆浏览器组件不是发行包该做的事 —— 需要的人显式装。
+#
+# 什么时候需要它：
+#   平台声明 flow="vnc"（登录必须在服务端浏览器里完成：回环回调落不到用户机器、
+#   授权页要求浏览器内交互）。插件会在登录时如实报告缺哪个依赖。
+#
+# 用法：
+#   sudo bash packaging/install-browser-stack.sh          # 自动识别包管理器
+#   sudo bash packaging/install-browser-stack.sh --check  # 只检查，不安装
+# ============================================================
+set -euo pipefail
+
+CHECK_ONLY=0
+for a in "$@"; do
+    case "$a" in
+        --check|-c) CHECK_ONLY=1 ;;
+        -h|--help) sed -n '2,20p' "$0"; exit 0 ;;
+        *) echo "未知参数: $a" >&2; exit 2 ;;
+    esac
+done
+
+# 需要的外部可执行文件（插件 browserDeps 同一份清单）
+BINS=(Xvfb x11vnc websockify python3)
+# chromium 的二进制名随发行版变化
+CHROMIUM_CANDIDATES=(chromium chromium-browser google-chrome google-chrome-stable)
+NOVNC_DIRS=(/usr/share/novnc /usr/share/webapps/novnc /opt/novnc)
+
+missing=()
+for b in "${BINS[@]}"; do
+    command -v "$b" >/dev/null 2>&1 || missing+=("$b")
+done
+chromium=""
+for c in "${CHROMIUM_CANDIDATES[@]}"; do
+    if command -v "$c" >/dev/null 2>&1; then chromium="$c"; break; fi
+done
+[ -z "$chromium" ] && missing+=("chromium")
+novnc=""
+for d in "${NOVNC_DIRS[@]}"; do
+    [ -f "$d/vnc.html" ] && { novnc="$d"; break; }
+done
+[ -z "$novnc" ] && missing+=("novnc")
+# CDP 取凭据需要 python websocket 客户端
+if command -v python3 >/dev/null 2>&1; then
+    python3 -c 'import websocket' >/dev/null 2>&1 || missing+=("python3-websocket")
+fi
+
+if [ ${#missing[@]} -eq 0 ]; then
+    echo "✓ 浏览器栈依赖齐全"
+    echo "  chromium: ${chromium}"
+    echo "  noVNC:    ${novnc}"
+    exit 0
+fi
+
+echo "缺少依赖: ${missing[*]}"
+if [ "$CHECK_ONLY" = 1 ]; then
+    exit 1
+fi
+
+# ---------- 识别包管理器 ----------
+if command -v apt-get >/dev/null 2>&1; then
+    # Debian/Ubuntu：chromium 在部分版本是 snap 包，apt 装不上；
+    # 先试 apt，失败时明确提示替代方案，不静默放弃。
+    pkgs=(xvfb x11vnc websockify novnc python3-websocket)
+    echo "→ apt-get install ${pkgs[*]} chromium"
+    apt-get update -qq || true
+    apt-get install -y "${pkgs[@]}" || {
+        echo "WARN: 部分包装失败，仍尝试装 chromium" >&2
+    }
+    apt-get install -y chromium || apt-get install -y chromium-browser || {
+        echo "WARN: apt 装不上 chromium（Ubuntu 新版将其作为 snap 分发）。" >&2
+        echo "  可选：snap install chromium  或  apt-get install -y chromium-browser" >&2
+    }
+elif command -v dnf >/dev/null 2>&1; then
+    echo "→ dnf install xorg-x11-server-Xvfb x11vnc python3-websockify novnc chromium python3-websocket-client"
+    dnf install -y xorg-x11-server-Xvfb x11vnc python3-websockify novnc chromium python3-websocket-client
+elif command -v yum >/dev/null 2>&1; then
+    echo "→ yum install xorg-x11-server-Xvfb x11vnc python3-websockify novnc chromium python3-websocket-client"
+    yum install -y xorg-x11-server-Xvfb x11vnc python3-websockify novnc chromium python3-websocket-client
+elif command -v apk >/dev/null 2>&1; then
+    echo "→ apk add xvfb x11vnc websockify novnc chromium py3-websocket-client"
+    apk add --no-cache xvfb x11vnc websockify novnc chromium py3-websocket-client
+else
+    echo "未识别的包管理器。请手动安装：" >&2
+    echo "  Xvfb, x11vnc, websockify, noVNC, chromium, python3 websocket-client" >&2
+    exit 1
+fi
+
+# ---------- 复核 ----------
+echo
+echo "复核安装结果："
+ok=1
+for b in "${BINS[@]}"; do
+    if command -v "$b" >/dev/null 2>&1; then echo "  ✓ $b"
+    else echo "  ✗ $b"; ok=0; fi
+done
+chromium=""
+for c in "${CHROMIUM_CANDIDATES[@]}"; do
+    if command -v "$c" >/dev/null 2>&1; then chromium="$c"; break; fi
+done
+[ -n "$chromium" ] && echo "  ✓ $chromium" || { echo "  ✗ chromium"; ok=0; }
+novnc=""
+for d in "${NOVNC_DIRS[@]}"; do
+    [ -f "$d/vnc.html" ] && { novnc="$d"; break; }
+done
+[ -n "$novnc" ] && echo "  ✓ noVNC ($novnc)" || { echo "  ✗ noVNC"; ok=0; }
+python3 -c 'import websocket' >/dev/null 2>&1 && echo "  ✓ python3 websocket-client" || { echo "  ✗ python3 websocket-client"; ok=0; }
+
+if [ "$ok" = 1 ]; then
+    echo
+    echo "✓ 浏览器栈就绪。重启 llmsproxy 后，flow=vnc 的平台即可用 VNC 兜底登录。"
+else
+    echo
+    echo "WARN: 仍有缺失项，VNC 兜底在该机器上不可用。插件的 deps/status 端点会一样报告。" >&2
+    exit 1
+fi

packaging/nfpm.yaml

@@ -41,6 +41,11 @@ contents:
     dst: /usr/share/llmsproxy/adapters/
     file_info:
       mode: 0644
+  # 服务端浏览器栈依赖安装脚本（VNC 兜底登录用；需 root，运维显式执行）
+  - src: ./packaging/install-browser-stack.sh
+    dst: /usr/share/llmsproxy/install-browser-stack.sh
+    file_info:
+      mode: 0755
   # README pointer
   - src: ./README.md
     dst: /usr/share/doc/llmsproxy/README.md