fix(channels): 修复 12 平台登录的系统性偏差（callback 闭环 + 动态模型 + Trae 设备身份）

用户报障：「除了 codebuddy，其他的登陆都不太正常，尤其是有道那个」。逐平台审计
参考实现（vendor/channel-pack/src）后发现根因不是 12 个独立 bug，而是几个系统性偏差。

## ① callback 流的回调是回环地址 → 必须走服务端浏览器（核心认识）
Trae/Gemini/有道 的 redirect_uri 都是回环地址（127.0.0.1 / localhost）。回环地址由
「打开授权页的那台机器」解析：远程用户在自己电脑上打开，重定向就落在**用户机器**上，
回调永远到不了网关。CodeBuddy 一直是好的，因为它走 state-poll，**根本不需要回调**。
→ 插件自起 loopback 接收器（Python，绑回环、双栈，路径按各平台注册值），
  由服务端浏览器（VNC）承载授权页，重定向落回本机。

## ② 三个平台的回调路径各是注册值（写错就是 redirect_uri_mismatch）
  有道 /auth/callback、Trae /authorize、Gemini /oauth-callback（参考 GEMINI_CALLBACK_PATH）
  且 Gemini 的 redirect_uri 主机是 **localhost** 而不是 127.0.0.1。
  另：Trae 的回调**不带 state**（token 直接放 query），其余平台必须带 → 校验规则按形态分。

## ③ 有道版本号不能写死
exchange/续期/签到的 version 是必填。实测 2026-10-13 上游已是 2026.9.23，而参考的兜底
常量还停在 2026.9.4。新增 lobsteraiClientVersion：远端为主（data.value.version，**非统一
信封**）+ 失败用兜底但**不缓存**（照参考 resolver）。失败时把上游 message 带出来
（实测形如 code=40102「无效或已过期的授权码」）。

## ④ Gemini token 交换缺 client_secret（症状正是「授权成功但账号不出现」）
参考注释点名：token 端点强制校验客户端身份，只发 client_id 会 invalid_request。
同时补 access_type=offline / prompt=consent（缺了拿不到 refresh_token），
并去掉误标的 pkce（上游 Cloud Code 用的是最朴素的 authorization_code + client_secret）。

## ⑤ Trae 授权 URL 少了 5 个必需参数
参考列为「一个都不能少」：login_trace_id（回调**反查 pending 的唯一凭据**）、
machine_id/device_id（hex32，每账号必须不同，否则被「该设备已签到」拦）、
x_device_id/x_machine_id。此前**完全没造**设备身份 → 登录页停在「授权中」。

## ⑥ Trae 签到头与设备身份
授权方案是 `Cloud-IDE-JWT`（不是 Bearer）；参考点明简化头**实测签到失败**，
需约 20 个客户端头，且 X-Device-Id 是**基于 user_id 确定性派生的 15 位数字**。
实现 seededStream（SHA256(utf8(salt:seed) ++ counterBE32) 串联）+ 三级派生，
并用参考实现（Node）生成期望值做**差分验证**逐字节对齐。
凭据改为 JSON 以保留 uid/device_id/machine_id（签到与轮换需要）。

## ⑦ 同段逻辑抽一个助手，防两条路漂移
lobsteraiExchange 被 oauth_callback 与 poll_login 两条路共用（原先各内联一份）。

## 判据（新增测试）
- TestLobsterLoopbackClosedLoop / TestLobsterExchangePreservesIdentity：loopback 闭环、
  state 不匹配 400、重放 409、凭据含 uuid/first_keyfrom
- TestCallbackPlatformsLoopback：三个平台的路径与 state 规则、Trae 无 state 也能接住
- TestAuthorizeURLsHaveNoUnfilledPlaceholders：授权 URL 不留 {占位符}
- TestTraeDeriveMatchesReference：与参考实现**逐字节**差分（tools/trae_derive_expected.mjs）
- TestTraeCheckinHeaders：Cloud-IDE-JWT + 派生设备身份 + 客户端头齐全
- TestRemoteModelCatalogMergesWithFallback：远端为主、兜底补位、失败不清缓存

## 顺带
- set_endpoints 补 callback / client_version 键（否则测试无法把端点指到假上游）
- 删掉 spawnBrowser 里会把 redirect_uri 一律改写为插件挂载点的死代码（对有道致害）
- session 过期与插件卸载时回收 loopback 接收器进程（防进程泄漏）
- e2e/channels_flows_e2e_test.go：qoder 已从 manual 改为 device-poll，断言同步更新

e2e/channels_flows_e2e_test.go

@@ -17,7 +17,7 @@ import (
 //
 //	Cline（WorkOS device-poll 两步：authenticate → register 换最终凭据）
 //	paste（opencode：直接 complete_login 贴 API key）
-//	manual（qoder：start_login 返回 manual_hint，再凭据完成）
+//	device-poll 授权页（qoder：本地造 PKCE，把手动授权页给用户，再凭据完成）
 //
 // 终局证据与 TestChannelsDevicePollE2E 同一标准：/v1/models 出现该平台模型。
 func TestChannelsFlowsE2E(t *testing.T) {
@@ -40,7 +40,7 @@ func TestChannelsFlowsE2E(t *testing.T) {
 			fmt.Fprint(w, `{"success":true,"data":{"accessToken":"CLINE-E2E-AT","refreshToken":"CLINE-E2E-RT","userInfo":{"email":"dev@example.com"}}}`)
 		// ---- 上游推理面（opencode/qoder/cline 的 base_url 都指到这里）----
 		case "/v1/models":
-			fmt.Fprint(w, `{"object":"list","data":[{"id":"big-pickle","object":"model"},{"id":"qoder-default","object":"model"},{"id":"stealth/space-bunny-alpha","object":"model"}]}`)
+			fmt.Fprint(w, `{"object":"list","data":[{"id":"big-pickle","object":"model"},{"id":"qmodel_38max","object":"model"},{"id":"stealth/space-bunny-alpha","object":"model"}]}`)
 		case "/v1/chat/completions":
 			fmt.Fprint(w, `{"choices":[{"message":{"content":"ok"},"finish_reason":"stop"}],"usage":{"prompt_tokens":1,"completion_tokens":1,"total_tokens":2}}`)
 		default:
@@ -166,7 +166,9 @@ func TestChannelsFlowsE2E(t *testing.T) {
 		t.Fatalf("opencode 接入后 /v1/models 未出现 big-pickle: %s", modelsBody)
 	}
 
-	// ---------- ③ manual（qoder）：hint 明确 + 凭据完成 ----------
+	// ---------- ③ device-poll（qoder）：给授权页 + 凭据完成 ----------
+	// qoder 曾走 manual（返回 manual_hint）；现已改为真实的 PKCE 授权页流程
+	// （本地造 challenge/verifier，服务端按 nonce 找回待授权会话）。
 	st, m = call("POST", "/api/plugins/channels/call/set_endpoints", fmt.Sprintf(
 		`{"platform":"qoder","base_url":%q}`, plat.URL))
 	if st != 200 {
@@ -176,9 +178,16 @@ func TestChannelsFlowsE2E(t *testing.T) {
 	if st != 200 {
 		t.Fatalf("qoder start_login status=%d", st)
 	}
-	hint, _ := m["manual_hint"].(string)
-	if !strings.Contains(hint, "WASM") {
-		t.Fatalf("qoder manual_hint 应说明 WASM 不可自动, 实得 %q", hint)
+	// 真流程必须给出授权页 URL（而不是「不支持自动登录」的 manual_hint），
+	// 且会话声明为 device-poll。
+	if hint, _ := m["manual_hint"].(string); hint != "" {
+		t.Fatalf("qoder 已不再走 manual，不应返回 manual_hint: %q", hint)
+	}
+	if sess, _ = m["session"].(map[string]interface{}); sess == nil || sess["flow"] != "device-poll" {
+		t.Fatalf("qoder 会话 flow 应 device-poll: %v", m)
+	}
+	if authURL, _ := m["url"].(string); !strings.Contains(authURL, "challenge=") {
+		t.Fatalf("qoder 授权页 URL 应带 PKCE challenge，实得 %q", authURL)
 	}
 	st, m = call("POST", "/api/plugins/http/channels/login/complete",
 		`{"platform":"qoder","credential":"QD-E2E-KEY"}`)
@@ -189,12 +198,12 @@ func TestChannelsFlowsE2E(t *testing.T) {
 	for time.Now().Before(deadline) {
 		resp, raw := g.do("GET", "/v1/models", "", true)
 		modelsBody = raw
-		if resp != nil && resp.StatusCode == 200 && strings.Contains(raw, "qoder-default") {
+		if resp != nil && resp.StatusCode == 200 && strings.Contains(raw, "qmodel_38max") {
 			break
 		}
 		time.Sleep(150 * time.Millisecond)
 	}
-	if !strings.Contains(modelsBody, "qoder-default") {
-		t.Fatalf("qoder 接入后 /v1/models 未出现 qoder-default: %s", modelsBody)
+	if !strings.Contains(modelsBody, "qmodel_38max") {
+		t.Fatalf("qoder 接入后 /v1/models 未出现 qmodel_38max: %s", modelsBody)
 	}
 }

internal/core/channels_authorize_test.go

@@ -0,0 +1,182 @@
+package core
+
+import (
+	"net/url"
+	"regexp"
+	"strings"
+	"testing"
+
+	"llmsproxy/internal/lua"
+)
+
+// callback 平台的授权 URL 是最容易"看起来对、实际不可用"的地方：URL 能拼出来、
+// 页面能打开，但参数名/编码/主机错一处，上游就拒绝授权。
+//
+// 判据照参考实现（trae-oauth.ts / gemini-oauth.ts / lobsterai-oauth.ts）逐条锁定：
+//   - Trae 参数名必须是 auth_callback_url（不是 redirect_uri）
+//   - Gemini redirect_uri 主机必须是 localhost（不是 127.0.0.1），token 交换要一致
+//   - LobsterAI 的 login 在 **hash 段**（/portal#/login），三个参数用 ? 起
+//   - redirect_uri 必须百分号编码（含 :// 与 :）
+func TestCallbackAuthorizeUrls(t *testing.T) {
+	c := kernelTestCore(t)
+	ps := c.Plugins()
+	src, err := readBundledChannels(t)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+
+	start := func(t *testing.T, plat string) (string, map[string]interface{}) {
+		t.Helper()
+		out, err := ps.InvokeHandler("channels", "start_login", &lua.HandlerRequest{
+			Method: "POST", Body: `{"platform":"` + plat + `"}`, Role: "admin",
+		})
+		if err != nil {
+			t.Fatalf("%s start_login: %v", plat, err)
+		}
+		j := out.JSON.(map[string]interface{})
+		u, _ := j["url"].(string)
+		return u, j
+	}
+
+	t.Run("行1 trae 用 auth_callback_url 而非 redirect_uri", func(t *testing.T) {
+		u, _ := start(t, "trae")
+		if u == "" {
+			t.Fatal("trae 未给出授权 URL")
+		}
+		if !strings.Contains(u, "auth_callback_url=") {
+			t.Fatalf("trae 必须用 auth_callback_url（参考注释点名：错名则登录必失败）: %s", u)
+		}
+		if strings.Contains(u, "redirect_uri=") {
+			t.Fatalf("trae 不该有 redirect_uri 参数: %s", u)
+		}
+		for _, want := range []string{"client_id=en1oxy7wnw8j9n", "auth_type=local", "login_channel=native_ide"} {
+			if !strings.Contains(u, want) {
+				t.Fatalf("trae 缺参数 %s: %s", want, u)
+			}
+		}
+		// 关键：不能再出现 "…/authorization&redirect_uri=" 这种坏的拼接
+		if strings.Contains(u, "authorization&") {
+			t.Fatalf("授权 URL 首参分隔符必须是 ? 而不是 &: %s", u)
+		}
+		// 参考 trae-oauth.ts 把参数集列为「一个都不能少」（早期只发 5 个参数，
+		// 登录页**永远停在授权中**，既不跳转也不回传）。逐条锁定：
+		// login_trace_id 是回调反查 pending 的唯一凭据；machine/device 身份除外
+		// 还可能被风控拦；x_* 是客户端形态伪装。
+		parsed, err := url.Parse(u)
+		if err != nil {
+			t.Fatalf("trae 授权 URL 无法解析: %v", err)
+		}
+		q := parsed.Query()
+		for _, k := range []string{
+			"login_version", "auth_from", "login_channel", "plugin_version",
+			"auth_type", "client_id", "redirect", "login_trace_id",
+			"auth_callback_url", "machine_id", "device_id",
+			"x_device_id", "x_machine_id", "x_device_brand", "x_device_type",
+			"x_os_version", "x_app_version", "x_app_type",
+		} {
+			if q.Get(k) == "" {
+				t.Fatalf("trae 缺参数 %s（参考列为必需）: %s", k, u)
+			}
+		}
+		// 设备身份是 hex32，trace_id 是它们拼接后的末 16 位
+		m, d := q.Get("machine_id"), q.Get("device_id")
+		if len(m) != 32 || !regexp.MustCompile(`^[0-9a-f]{32}$`).MatchString(m) {
+			t.Fatalf("machine_id 应为 hex32: %q", m)
+		}
+		if len(d) != 32 || !regexp.MustCompile(`^[0-9a-f]{32}$`).MatchString(d) {
+			t.Fatalf("device_id 应为 hex32: %q", d)
+		}
+		if m == d {
+			t.Fatalf("machine_id 与 device_id 不应相同（同源会削弱设备身份）")
+		}
+		joined := m + d
+		if got := q.Get("login_trace_id"); got != joined[len(joined)-16:] {
+			t.Fatalf("login_trace_id 应为 (machine_id+device_id) 末16位，实得 %q", got)
+		}
+		// 同一平台两次登录必须得到不同设备身份（否则多账号共用设备，
+		// 会被上游以「该设备已签到」拦截）
+		u2, _ := start(t, "trae")
+		q2, _ := url.Parse(u2)
+		if q2.Query().Get("device_id") == d {
+			t.Fatalf("两次登录的 device_id 应不同（每账号独立设备身份）")
+		}
+		// Trae 注册的回调路径是 /authorize（不是插件的 /api/plugins/http 挂载点）：
+		// 回环地址由「打开授权页的那台机器」解析，所以必须是本机 loopback 接收器。
+		if cb := q.Get("auth_callback_url"); cb != "" {
+			if !strings.HasSuffix(cb, "/authorize") {
+				t.Fatalf("trae auth_callback_url 必须以注册路径 /authorize 结尾，实得 %q", cb)
+			}
+			if !strings.HasPrefix(cb, "http://127.0.0.1:") {
+				t.Fatalf("trae auth_callback_url 应是 127.0.0.1 回环地址，实得 %q", cb)
+			}
+		}
+	})
+
+	t.Run("行2 gemini 主机是 localhost 且参数不重复", func(t *testing.T) {
+		u, _ := start(t, "gemini")
+		parsed, err := url.Parse(u)
+		if err != nil {
+			t.Fatalf("授权 URL 无法解析: %v", err)
+		}
+		ru := parsed.Query().Get("redirect_uri")
+		if !strings.HasPrefix(ru, "http://localhost:") {
+			t.Fatalf("gemini redirect_uri 主机必须是 localhost（参考注释明确）: %q", ru)
+		}
+		// 路径必须是注册值 /oauth-callback（参考 GEMINI_CALLBACK_PATH）——
+		// 换成别的路径就是 redirect_uri_mismatch。
+		if !strings.HasSuffix(ru, "/oauth-callback") {
+			t.Fatalf("gemini redirect_uri 路径必须是 /oauth-callback，实得 %q", ru)
+		}
+		for _, k := range []string{"client_id", "response_type", "scope", "state"} {
+			if parsed.Query().Get(k) == "" {
+				t.Fatalf("gemini 缺参数 %s: %s", k, u)
+			}
+		}
+		// 缺 access_type=offline 拿不到 refresh_token；prompt=consent 保证每次都发。
+		if got := parsed.Query().Get("access_type"); got != "offline" {
+			t.Fatalf("gemini access_type 应为 offline（否则无 refresh_token），实得 %q", got)
+		}
+		if got := parsed.Query().Get("prompt"); got != "consent" {
+			t.Fatalf("gemini prompt 应为 consent，实得 %q", got)
+		}
+		// 参数不得重复（通用分支曾再追加一次 redirect_uri）
+		if n := strings.Count(u, "redirect_uri="); n != 1 {
+			t.Fatalf("redirect_uri 出现 %d 次（应恰好 1 次）: %s", n, u)
+		}
+		if n := strings.Count(u, "client_id="); n != 1 {
+			t.Fatalf("client_id 出现 %d 次: %s", n, u)
+		}
+	})
+
+	t.Run("行3 lobsterai 的 login 在 hash 段且参数编码", func(t *testing.T) {
+		u, _ := start(t, "lobsterai")
+		if !strings.Contains(u, "/portal#/login?") {
+			t.Fatalf("lobsterai 授权页必须是 /portal#/login?…（login 在 hash 段）: %s", u)
+		}
+		if strings.Contains(u, "/login&") {
+			t.Fatalf("首参分隔符必须是 ? 而不是 &: %s", u)
+		}
+		if !strings.Contains(u, "source=electron") {
+			t.Fatalf("lobsterai 缺 source=electron: %s", u)
+		}
+		// redirect_uri 必须编码（含 :// 与 :），否则登录页校验失败
+		if !strings.Contains(u, "redirect_uri=http%3A%2F%2F") {
+			t.Fatalf("lobsterai redirect_uri 必须百分号编码: %s", u)
+		}
+	})
+
+	t.Run("行4 端口用本机监听值而非硬编码8081", func(t *testing.T) {
+		for _, plat := range []string{"trae", "gemini", "lobsterai"} {
+			u, _ := start(t, plat)
+			if strings.Contains(u, "127.0.0.1:8081") && plat != "trae" {
+				t.Fatalf("%s 不应硬编码 8081: %s", plat, u)
+			}
+			if strings.Contains(u, "{port}") {
+				t.Fatalf("%s 的 {port} 占位未被替换: %s", plat, u)
+			}
+		}
+	})
+}

internal/core/channels_callback_loopback_test.go

@@ -0,0 +1,220 @@
+package core
+
+import (
+	"encoding/json"
+	"net/http"
+	"net/http/httptest"
+	"net/url"
+	"strings"
+	"testing"
+	"time"
+
+	"llmsproxy/internal/lua"
+)
+
+// 三个 callback 平台的回调路径**各是注册值**，且校验规则不同：
+//
+//	Trae    /authorize      不带 state（token 直接放 query 里）
+//	有道    /auth/callback  必须带 state
+//	Gemini  /oauth-callback 必须带 state
+//
+// 路径写错 → 上游 redirect_uri_mismatch；校验写错 → 要么接不住回调、
+// 要么被伪造回调塞入凭据。本测试打真上游形态（本地 loopback 接收器）。
+func TestCallbackPlatformsLoopback(t *testing.T) {
+	c := kernelTestCore(t)
+	ps := c.Plugins()
+	src, err := readBundledChannels(t)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+
+	start := func(t *testing.T, plat string) (m map[string]interface{}, nonce, sid string) {
+		t.Helper()
+		out, err := ps.InvokeHandler("channels", "start_login", &lua.HandlerRequest{
+			Method: "POST", Body: `{"platform":"` + plat + `"}`, Role: "admin",
+		})
+		if err != nil {
+			t.Fatalf("%s start_login: %v", plat, err)
+		}
+		m = out.JSON.(map[string]interface{})
+		s := m["session"].(map[string]interface{})
+		return m, s["nonce"].(string), s["id"].(string)
+	}
+
+	poll := func(t *testing.T, sid string) map[string]interface{} {
+		t.Helper()
+		o, err := ps.InvokeHandler("channels", "poll_login", &lua.HandlerRequest{
+			Method: "GET", Query: map[string]string{"id": sid}, Role: "admin",
+		})
+		if err != nil {
+			t.Fatal(err)
+		}
+		return o.JSON.(map[string]interface{})
+	}
+
+	t.Run("行1 Trae 回调路径是 /authorize 且无 state 也能接住", func(t *testing.T) {
+		_, _, sid := start(t, "trae")
+		// 交换端点指到假上游
+		ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+			w.Header().Set("Content-Type", "application/json")
+			w.Write([]byte(`{"Token":"ACCESS-NEW"}`))
+		}))
+		defer ts.Close()
+		if _, err := ps.Call("channels", "set_endpoints", map[string]interface{}{
+			"platform": "trae", "callback": map[string]interface{}{"exchange_url": ts.URL},
+		}); err != nil {
+			t.Fatal(err)
+		}
+		// 重新起会话，拿到带 loopback 的 redirect_uri
+		m, nonce, sid := start(t, "trae")
+		ru, _ := m["redirect_uri"].(string)
+		if !strings.HasSuffix(ru, "/authorize") {
+			t.Fatalf("trae 回调路径必须是 /authorize，实得 %q", ru)
+		}
+		// Trae 的回调**不带 state**，而是把 token 放 query 里
+		q := url.Values{}
+		q.Set("refreshToken", "RT-1")
+		q.Set("userInfo", `{"UserID":"u1","ScreenName":"张三"}`)
+		resp, err := http.Get(ru + "?" + q.Encode())
+		if err != nil {
+			t.Fatalf("打 loopback 接收器失败: %v", err)
+		}
+		resp.Body.Close()
+		if resp.StatusCode != 200 {
+			t.Fatalf("Trae 回调（无 state）应被接住，实得 %d", resp.StatusCode)
+		}
+		st := waitState(t, poll, sid, "completed")
+		if st["state"] != "completed" {
+			t.Fatalf("应完成登录，实得 %v", st)
+		}
+		raw, ok, _ := ps.GetSecret("channels", "channels:trae")
+		if !ok {
+			t.Fatal("凭据未落库")
+		}
+		var cred map[string]interface{}
+		if err := json.Unmarshal([]byte(raw), &cred); err != nil {
+			t.Fatal(err)
+		}
+		if cred["access_token"] != "ACCESS-NEW" {
+			t.Fatalf("凭据应是交换后的新 access，实得 %v", cred["access_token"])
+		}
+		if cred["uid"] != "u1" {
+			t.Fatalf("uid 应从 userInfo.UserID 取出（签到设备身份的种子）, 实得 %v", cred["uid"])
+		}
+		_ = nonce
+	})
+
+	t.Run("行2 Gemini 路径是 /oauth-callback 且错 state 被拒", func(t *testing.T) {
+		m, nonce, sid := start(t, "gemini")
+		ru, _ := m["redirect_uri"].(string)
+		if !strings.HasSuffix(ru, "/oauth-callback") {
+			t.Fatalf("gemini 回调路径必须是 /oauth-callback（参考 GEMINI_CALLBACK_PATH），实得 %q", ru)
+		}
+		if !strings.HasPrefix(ru, "http://localhost:") {
+			t.Fatalf("gemini 回调主机必须是 localhost（参考注释明确），实得 %q", ru)
+		}
+		// 错 state 必须被接收器拒（400），且不推进会话
+		bad, err := http.Get(ru + "?code=C-1&state=WRONG")
+		if err != nil {
+			t.Fatal(err)
+		}
+		bad.Body.Close()
+		if bad.StatusCode != 400 {
+			t.Fatalf("state 不匹配应 400（防伪造回调），实得 %d", bad.StatusCode)
+		}
+		if st := poll(t, sid); st["state"] != "pending" {
+			t.Fatalf("错 state 不应推进会话，实得 %v", st)
+		}
+		// 正确 state → 完成（交换端点指到假上游）
+		ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+			_ = r.ParseForm()
+			// 必须带 client_secret：只发 client_id 会 invalid_request，
+			// 症状正是「浏览器显示授权成功但账号不出现」
+			if r.PostFormValue("client_secret") == "" {
+				t.Error("token 交换必须带 client_secret")
+			}
+			if r.PostFormValue("grant_type") != "authorization_code" {
+				t.Errorf("grant_type = %q", r.PostFormValue("grant_type"))
+			}
+			w.Header().Set("Content-Type", "application/json")
+			w.Write([]byte(`{"access_token":"GA-1","refresh_token":"GR-1","expires_in":3600}`))
+		}))
+		defer ts.Close()
+		if _, err := ps.Call("channels", "set_endpoints", map[string]interface{}{
+			"platform": "gemini",
+			"callback": map[string]interface{}{"token_url": ts.URL, "mode": "code"},
+		}); err != nil {
+			t.Fatal(err)
+		}
+		good, err := http.Get(ru + "?code=C-1&state=" + nonce)
+		if err != nil {
+			t.Fatal(err)
+		}
+		good.Body.Close()
+		st := waitState(t, poll, sid, "completed")
+		if st["state"] != "completed" {
+			t.Fatalf("应完成登录，实得 %v", st)
+		}
+		raw, ok, _ := ps.GetSecret("channels", "channels:gemini")
+		if !ok {
+			t.Fatal("凭据未落库")
+		}
+		var cred map[string]interface{}
+		if err := json.Unmarshal([]byte(raw), &cred); err != nil {
+			t.Fatal(err)
+		}
+		if cred["access_token"] != "GA-1" {
+			t.Fatalf("access_token = %v", cred["access_token"])
+		}
+	})
+}
+
+// waitState 轮询到目标状态或超时（loopback 写文件是异步的，需要一拍）。
+func waitState(t *testing.T, poll func(*testing.T, string) map[string]interface{},
+	sid, want string) map[string]interface{} {
+	t.Helper()
+	var st map[string]interface{}
+	for i := 0; i < 30; i++ {
+		st = poll(t, sid)
+		if st["state"] != "pending" {
+			return st
+		}
+		time.Sleep(100 * time.Millisecond)
+	}
+	return st
+}
+
+// 占位符未替换检查：授权 URL 里残留 {xxx} 会让上游收到字面量占位符
+// （而且往往不报错，只是行为诡异）。三个 callback 平台逐个验。
+func TestAuthorizeURLsHaveNoUnfilledPlaceholders(t *testing.T) {
+	c := kernelTestCore(t)
+	ps := c.Plugins()
+	src, err := readBundledChannels(t)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+	for _, plat := range []string{"trae", "gemini", "lobsterai"} {
+		out, err := ps.InvokeHandler("channels", "start_login", &lua.HandlerRequest{
+			Method: "POST", Body: `{"platform":"` + plat + `"}`, Role: "admin",
+		})
+		if err != nil {
+			t.Fatalf("%s: %v", plat, err)
+		}
+		m := out.JSON.(map[string]interface{})
+		for _, key := range []string{"url", "redirect_uri"} {
+			v, _ := m[key].(string)
+			if v == "" {
+				continue
+			}
+			if strings.Contains(v, "{") || strings.Contains(v, "nil") {
+				t.Errorf("%s 的 %s 仍有未替换占位符: %s", plat, key, v)
+			}
+		}
+	}
+}

internal/core/channels_lobster_exchange_test.go

@@ -0,0 +1,75 @@
+package core
+
+import (
+	"encoding/json"
+	"llmsproxy/internal/lua"
+	"net/http"
+	"net/http/httptest"
+	"testing"
+)
+
+func TestLobsterExchangePreservesIdentity(t *testing.T) {
+	var calls int
+	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		calls++
+		var b map[string]string
+		if err := json.NewDecoder(r.Body).Decode(&b); err != nil {
+			t.Error(err)
+		}
+		if b["authCode"] != "quote\"&code" || len(b["uuid"]) != 36 || b["firstKeyfrom"] == "" || b["firstKeyfrom"] == "cli" {
+			t.Errorf("invalid exchange fields: %#v", b)
+		}
+		if r.Header.Get("Content-Type") != "application/json" || r.Header.Get("User-Agent") != "LobsterAI/0.1.0" {
+			t.Error("wrong headers")
+		}
+		w.Header().Set("Content-Type", "application/json")
+		w.Write([]byte(`{"code":0,"data":{"accessToken":"at-test","refreshToken":"rt-test","expiresIn":3600,"user":{"id":"uid1","userId":"account1","nickname":"test"}}}`))
+	}))
+	defer ts.Close()
+	c := kernelTestCore(t)
+	ps := c.Plugins()
+	src, err := readBundledChannels(t)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err = ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+	// The fixture changes only the transport destination, not the upstream contract.
+	if _, err = ps.Call("channels", "set_endpoints", map[string]interface{}{"platform": "lobsterai", "callback": map[string]interface{}{"token_url": ts.URL}}); err != nil {
+		t.Fatal(err)
+	}
+	out, err := ps.InvokeHandler("channels", "start_login", &lua.HandlerRequest{Method: "POST", Body: `{"platform":"lobsterai"}`, Role: "admin"})
+	if err != nil {
+		t.Fatal(err)
+	}
+	nonce := out.JSON.(map[string]interface{})["session"].(map[string]interface{})["nonce"].(string)
+	req := &lua.HandlerRequest{Method: "GET", Query: map[string]string{"state": nonce, "authCode": "quote\"&code"}}
+	out, err = ps.InvokeHandler("channels", "oauth_callback", req)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if out.Status != 200 {
+		t.Fatalf("callback: %#v", out)
+	}
+	raw, ok, err := ps.GetSecret("channels", "channels:lobsterai")
+	if err != nil || !ok {
+		t.Fatal("missing credential", err)
+	}
+	var cred map[string]interface{}
+	if err = json.Unmarshal([]byte(raw), &cred); err != nil {
+		t.Fatal(err)
+	}
+	for _, k := range []string{"access_token", "refresh_token", "uuid", "first_keyfrom", "latest_keyfrom", "expires_at", "uid", "user_id"} {
+		if cred[k] == nil || cred[k] == "" {
+			t.Errorf("missing %s", k)
+		}
+	}
+	out, err = ps.InvokeHandler("channels", "oauth_callback", req)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if out.Status != 409 || calls != 1 {
+		t.Fatalf("replay accepted: status=%d calls=%d", out.Status, calls)
+	}
+}

internal/core/channels_lobster_loopback_test.go

@@ -0,0 +1,165 @@
+package core
+
+import (
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+	"net/http/httptest"
+	"strings"
+	"testing"
+	"time"
+
+	"llmsproxy/internal/lua"
+)
+
+// 有道登录闭环的判据：portal 会把授权重定向回 **本机 loopback 接收器**
+// （127.0.0.1:{port}/auth/callback 精确路径），而不是用户机器的 localhost、
+// 也不是本插件的 /api/plugins/http 挂载点。远程用户在服务端浏览器里完成后，
+// 重定向落本机端口，接收器写文件，poll_login 读它完成交换。
+//
+// 参考 lobsterai-oauth.ts 明确：redirect_uri 必须该形态（登录页会校验），
+// state 不匹配必须拒绝（400），交换体含 authCode/firstKeyfrom/latestKeyfrom/
+// uuid/version 五字段，凭据必须带 uuid+first_keyfrom（否则续期失败）。
+func TestLobsterLoopbackClosedLoop(t *testing.T) {
+	var exch int
+	var gotVersion string
+	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		exch++
+		var b map[string]string
+		_ = json.NewDecoder(r.Body).Decode(&b)
+		if b["authCode"] != "AC-1" {
+			t.Errorf("exchange authCode = %q", b["authCode"])
+		}
+		gotVersion = b["version"]
+		if b["firstKeyfrom"] == "" || b["uuid"] == "" {
+			t.Errorf("exchange 缺字段: %#v", b)
+		}
+		w.Header().Set("Content-Type", "application/json")
+		io.WriteString(w, `{"code":0,"data":{"accessToken":"AT-1","refreshToken":"RT-1","expiresIn":3600,"user":{"id":"UID1"}}}`)
+	}))
+	defer ts.Close()
+
+	// 版本号是 exchange 的必填字段，**不能写死**：2026-10-13 实测上游已是
+	// 2026.9.23，而参考的兜底常量还停在 2026.9.4。此处假上游返回真形态
+	// （非统一信封，值在 data.value.version）。
+	ver := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Content-Type", "application/json")
+		io.WriteString(w, `{"data":{"value":{"version":"2026.9.23","date":"2026-9-23"}}}`)
+	}))
+	defer ver.Close()
+
+	c := kernelTestCore(t)
+	ps := c.Plugins()
+	src, err := readBundledChannels(t)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+	_ = ps.SetPluginKernelPermission("channels", []string{"add_source", "remove_source", "status"}, false)
+	if _, err := ps.Call("channels", "set_endpoints", map[string]interface{}{
+		"platform":       "lobsterai",
+		"callback":       map[string]interface{}{"token_url": ts.URL},
+		"client_version": map[string]interface{}{"url": ver.URL},
+	}); err != nil {
+		t.Fatal(err)
+	}
+
+	out, err := ps.InvokeHandler("channels", "start_login", &lua.HandlerRequest{
+		Method: "POST", Body: `{"platform":"lobsterai"}`, Role: "admin",
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+	j := out.JSON.(map[string]interface{})
+	sess := j["session"].(map[string]interface{})
+	nonce := sess["nonce"].(string)
+	sid := sess["id"].(string)
+	redirectURI, _ := j["redirect_uri"].(string)
+	if !strings.HasPrefix(redirectURI, "http://127.0.0.1:") || !strings.HasSuffix(redirectURI, "/auth/callback") {
+		t.Fatalf("redirect_uri 必须是 127.0.0.1:{port}/auth/callback，实得 %q", redirectURI)
+	}
+	url, _ := j["url"].(string)
+	if !strings.Contains(url, "/portal#/login?") {
+		t.Fatalf("授权页应是 /portal#/login?…，实得 %q", url)
+	}
+	if !strings.Contains(url, "source=electron") {
+		t.Fatalf("授权页缺 source=electron: %q", url)
+	}
+
+	t.Run("行1 state 不匹配被拒", func(t *testing.T) {
+		resp, err := http.Get(redirectURI + "?code=AC-1&state=WRONG")
+		if err != nil {
+			t.Fatal(err)
+		}
+		defer resp.Body.Close()
+		if resp.StatusCode != 400 {
+			t.Fatalf("state 不匹配应 400，实得 %d", resp.StatusCode)
+		}
+		if exch != 0 {
+			t.Fatal("state 不匹配不应触发交换")
+		}
+	})
+
+	t.Run("行2 正确回调完成登录并落完整凭据", func(t *testing.T) {
+		resp, err := http.Get(redirectURI + "?code=AC-1&state=" + nonce)
+		if err != nil {
+			t.Fatal(err)
+		}
+		resp.Body.Close()
+		if resp.StatusCode != 200 {
+			t.Fatalf("合法回调应 200，实得 %d", resp.StatusCode)
+		}
+		// 接收器写文件后 poll_login 读它完成交换（可能需要一拍）
+		var st map[string]interface{}
+		for i := 0; i < 20; i++ {
+			o, err := ps.InvokeHandler("channels", "poll_login", &lua.HandlerRequest{
+				Method: "GET", Query: map[string]string{"id": sid}, Role: "admin",
+			})
+			if err != nil {
+				t.Fatal(err)
+			}
+			st = o.JSON.(map[string]interface{})
+			if st["state"] != "pending" {
+				break
+			}
+			time.Sleep(100 * time.Millisecond)
+		}
+		if st["state"] != "completed" {
+			t.Fatalf("应完成登录，实得 %v", st)
+		}
+		raw, ok, err := ps.GetSecret("channels", "channels:lobsterai")
+		if err != nil || !ok {
+			t.Fatalf("凭据未落库: %v", err)
+		}
+		var cred map[string]interface{}
+		if err := json.Unmarshal([]byte(raw), &cred); err != nil {
+			t.Fatal(err)
+		}
+		for _, k := range []string{"access_token", "refresh_token", "uuid", "first_keyfrom", "expires_at", "uid"} {
+			if cred[k] == nil || cred[k] == "" {
+				t.Errorf("凭据缺 %s（有道的 uuid/first_keyfrom 丢了就续期失败）: %s", k, raw)
+			}
+		}
+		if cred["access_token"] != "AT-1" {
+			t.Fatalf("access_token = %v", cred["access_token"])
+		}
+		// 版本号必须来自远端（2026.9.23），不能是写死的兜底 2026.9.4
+		if gotVersion != "2026.9.23" {
+			t.Fatalf("exchange version 应为远端 2026.9.23（写死 2026.9.4 是 bug），实得 %q", gotVersion)
+		}
+	})
+
+	t.Run("行3 接收器用完即收", func(t *testing.T) {
+		// 完成后监听应已关闭（连接被拒）
+		_, err := http.Get(redirectURI + "?code=AC-1&state=" + nonce)
+		if err == nil {
+			t.Fatal("接收器应在完成后关闭")
+		} else if !strings.Contains(err.Error(), "refused") && !strings.Contains(err.Error(), "connect") {
+			t.Logf("关闭判定: %v", err)
+		}
+	})
+	_ = fmt.Sprint
+}

internal/core/channels_models_remote_test.go

@@ -0,0 +1,201 @@
+package core
+
+import (
+	"fmt"
+	"net/http"
+	"net/http/httptest"
+	"strings"
+	"sync"
+	"testing"
+
+	"llmsproxy/internal/lua"
+)
+
+// 远端模型目录的判据：**远端为主 + 兜底补位**（照参考 reconcileWithFallback）。
+//
+// 参考明确："正确做法是**合并**，而不是「远端失败就用兜底」的简单回退"
+// （cline-models.ts）。故这里逐条锁定：
+//   - 远端有的以远端为准（顺序也照远端）
+//   - 远端没有的用兜底表补位
+//   - 拉取失败**不清空**既有缓存（宁可留旧目录也别让平台变空）
+//   - 平台声明的真实目录 key 必须在上游源里（占位名会让选模型调不通）
+type modelsHarness struct {
+	t    *testing.T
+	ps   *lua.Plugins
+	ts   *httptest.Server
+	mu   sync.Mutex
+	body string
+	code int
+	hits int
+}
+
+func newModelsHarness(t *testing.T, platform, body string) *modelsHarness {
+	t.Helper()
+	h := &modelsHarness{t: t, body: body, code: 200}
+	h.ts = httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		h.mu.Lock()
+		h.hits++
+		code, body := h.code, h.body
+		h.mu.Unlock()
+		w.Header().Set("Content-Type", "application/json")
+		w.WriteHeader(code)
+		fmt.Fprint(w, body)
+	}))
+	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", "remove_source", "list_sources", "status"}, false)
+	// 说明：测试上游是 127.0.0.1（loopback），出站白名单默认允许，
+	// 不需要额外授权 —— 也就不需要碰内核的授权 API。
+	// 把该平台的远端端点指到假上游
+	if _, err := h.ps.Call("channels", "set_endpoints", map[string]interface{}{
+		"platform": platform,
+		"models_remote": map[string]interface{}{
+			"endpoint0": h.ts.URL,
+		},
+	}); err != nil {
+		t.Logf("set_endpoints(models_remote) 未支持: %v", err)
+	}
+	return h
+}
+
+// modelIDs 从 model_list 的 Call 返回值（{json:{models:[...]}}）取 id 列表。
+func modelIDs(t *testing.T, got interface{}) []string {
+	t.Helper()
+	j := got.(map[string]interface{})["json"].(map[string]interface{})
+	ms, _ := j["models"].([]interface{})
+	ids := make([]string, 0, len(ms))
+	for _, e := range ms {
+		ids = append(ids, e.(map[string]interface{})["id"].(string))
+	}
+	return ids
+}
+
+func TestRemoteModelCatalogMergesWithFallback(t *testing.T) {
+	// zcode：远端 builtinModels 是**对象**（键为序号），且远端/兜底有重叠
+	body := `{"data":{"builtinModels":{"0":{"modelId":"GLM-5.3"},"1":{"modelId":"GLM-5.3-Flash"},"2":{"modelId":"NEW-MODEL-X"}}}}`
+	h := newModelsHarness(t, "zcode", body)
+
+	t.Run("行1 远端拉到就用远端并保留兜底独有的", func(t *testing.T) {
+		got, err := h.ps.Call("channels", "model_refresh", map[string]interface{}{"platform": "zcode"})
+		if err != nil {
+			t.Fatal(err)
+		}
+		m := got.(map[string]interface{})["json"].(map[string]interface{})
+		res := m["results"].([]interface{})[0].(map[string]interface{})
+		if res["ok"] != true {
+			t.Fatalf("刷新应成功, 实得 %v", res)
+		}
+		// NEW-MODEL-X 只由远端下发，必须出现（证明用的不是硬编码表）
+		ml, err := h.ps.Call("channels", "model_list", map[string]interface{}{"platform": "zcode"})
+		if err != nil {
+			t.Fatal(err)
+		}
+		ids := modelIDs(t, ml)
+		joined := strings.Join(ids, ",")
+		if !strings.Contains(joined, "NEW-MODEL-X") {
+			t.Fatalf("只由远端下发的模型必须出现（否则是硬编码表）: %v", ids)
+		}
+		if !strings.Contains(joined, "GLM-5.3") {
+			t.Fatalf("兜底/远端共有项应保留: %v", ids)
+		}
+		// 远端与兜底重叠项不得重复
+		seen := map[string]int{}
+		for _, id := range ids {
+			seen[id]++
+			if seen[id] > 1 {
+				t.Fatalf("模型 %s 重复出现（合并应去重）: %v", id, ids)
+			}
+		}
+	})
+
+	t.Run("行2 拉取失败不清空既有缓存", func(t *testing.T) {
+		// 先成功一次建立缓存
+		if _, err := h.ps.Call("channels", "model_refresh", map[string]interface{}{"platform": "zcode"}); err != nil {
+			t.Fatal(err)
+		}
+		// 再让上游 500
+		h.mu.Lock()
+		h.code = 500
+		h.body = `{}`
+		h.mu.Unlock()
+		got, err := h.ps.Call("channels", "model_refresh", map[string]interface{}{"platform": "zcode"})
+		if err != nil {
+			t.Fatal(err)
+		}
+		res := got.(map[string]interface{})["json"].(map[string]interface{})["results"].([]interface{})[0].(map[string]interface{})
+		if res["ok"] == true {
+			t.Fatalf("上游 500 时刷新应报失败, 实得 %v", res)
+		}
+		ml, _ := h.ps.Call("channels", "model_list", map[string]interface{}{"platform": "zcode"})
+		ids := modelIDs(t, ml)
+		if !strings.Contains(strings.Join(ids, ","), "NEW-MODEL-X") {
+			t.Fatalf("拉取失败必须保留既有目录（不能让平台变空）: %v", ids)
+		}
+	})
+}
+
+// TestPlatformModelsAreRealCatalogKeys 锁定 12 平台的模型名**不是编的占位名**。
+// 此前 qoder/zcode/loomy/raccoon 用的是 "*-default"（我编的），上游不认 ——
+// 后果是这些平台登录成功后选任何模型都调不通，而测试全绿（它测的就是我编的名字）。
+func TestPlatformModelsAreRealCatalogKeys(t *testing.T) {
+	c := kernelTestCore(t)
+	ps := c.Plugins()
+	src, err := readBundledChannels(t)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+	got, err := ps.Call("channels", "provider_status", map[string]interface{}{})
+	if err != nil {
+		t.Fatal(err)
+	}
+	plats := got.(map[string]interface{})["json"].(map[string]interface{})["statuses"].([]interface{})
+	if len(plats) != 12 {
+		t.Fatalf("应有 12 个真实平台, 实得 %d", len(plats))
+	}
+	realQoder := []string{"qfmodel", "qmodel_38max", "kmodel_latest", "dmodel"}
+	sawQoder := 0
+	for _, e := range plats {
+		p := e.(map[string]interface{})
+		id := p["id"].(string)
+		ml, err := ps.Call("channels", "model_list", map[string]interface{}{"platform": id})
+		if err != nil {
+			t.Fatalf("平台 %s model_list: %v", id, err)
+		}
+		ids := modelIDs(t, ml)
+		if len(ids) == 0 {
+			t.Fatalf("平台 %s 无模型", id)
+		}
+		for _, mid := range ids {
+			// 占位名特征：以 -default 结尾
+			if strings.HasSuffix(mid, "-default") {
+				t.Fatalf("平台 %s 的模型 %q 是编的占位名（上游不认，选了调不通）", id, mid)
+			}
+		}
+		if id == "qoder" {
+			j := map[string]bool{}
+			for _, mid := range ids {
+				j[mid] = true
+			}
+			for _, want := range realQoder {
+				if j[want] {
+					sawQoder++
+				}
+			}
+		}
+	}
+	if sawQoder == 0 {
+		t.Fatal("qoder 应含参考的真实目录 key（如 qfmodel），而非编造的占位名")
+	}
+}

internal/core/channels_trae_checkin_test.go

@@ -0,0 +1,111 @@
+package core
+
+import (
+	"encoding/json"
+	"net/http"
+	"net/http/httptest"
+	"testing"
+
+	"llmsproxy/internal/lua"
+)
+
+// Trae 签到是最容易被"看起来对"骗过的地方：请求能发出去、上游可能也返回 200，
+// 但头不对就只是一个失败/风控响应。参考实现明确记录：
+//
+//	① 授权方案是 Cloud-IDE-JWT，**不是** Bearer（用错前缀是 401 级失败）；
+//	② 简化头（只有 Authorization + 几个 Ug 头）**实测签到失败**，
+//	   真正成功的是约 20 个客户端头；
+//	③ X-Device-Id 不是凭据里的 hex32，而是**基于 user_id 确定性派生的 15 位数字**
+//	   （每账号天然不同设备，所以不再需要 9074 时换设备号重试）。
+//
+// 本测试按参考逐条锁定这些事实，并把派生的 device_id 钉死到与参考一致的值。
+func TestTraeCheckinHeaders(t *testing.T) {
+	var got map[string]string
+	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		got = map[string]string{}
+		for k := range r.Header {
+			got[k] = r.Header.Get(k)
+		}
+		w.Header().Set("Content-Type", "application/json")
+		w.Write([]byte(`{"code":0}`))
+	}))
+	defer ts.Close()
+
+	c := kernelTestCore(t)
+	ps := c.Plugins()
+	src, err := readBundledChannels(t)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+	// 把签到端点指到假上游（不覆盖 checkin.auth，验证声明真的在起作用）
+	if _, err := ps.Call("channels", "set_endpoints", map[string]interface{}{
+		"platform": "trae",
+		"checkin":  map[string]interface{}{"url": ts.URL},
+	}); err != nil {
+		t.Fatal(err)
+	}
+
+	// uid 必须是真值：设备身份由它派生。用参考实现算出的期望值（见 tools/trae_derive_expected.mjs）
+	const uid = "12345"
+	// credential 传**字符串**（凭据是一段 JSON 文本），不是对象 —— complete_login
+	// 会原样存进保险库，取用时 credentialOf 再解出 access_token。
+	cred, _ := json.Marshal(map[string]interface{}{
+		"access_token": "ACCESS-1", "uid": uid, "device_id": "deadbeef",
+	})
+	body, _ := json.Marshal(map[string]string{
+		"platform": "trae", "credential": string(cred), "account": "t",
+	})
+	if _, err := ps.InvokeHandler("channels", "complete_login", &lua.HandlerRequest{
+		Method: "POST", Role: "admin", Body: string(body),
+	}); err != nil {
+		t.Fatal(err)
+	}
+
+	out, err := ps.InvokeHandler("channels", "claim_daily", &lua.HandlerRequest{
+		Method: "POST", Role: "admin", Body: `{"platform":"trae"}`,
+	})
+	if err != nil {
+		t.Fatalf("claim_daily: %v", err)
+	}
+	if j, _ := out.JSON.(map[string]interface{}); j != nil && j["error"] != nil {
+		t.Fatalf("claim 失败: %v（完整响应 %v）", j["error"], j)
+	}
+
+	t.Run("行1 授权方案是 Cloud-IDE-JWT", func(t *testing.T) {
+		if v := got["Authorization"]; v != "Cloud-IDE-JWT ACCESS-1" {
+			t.Fatalf("Authorization 必须是 Cloud-IDE-JWT <token>（Bearer 会 401），实得 %q", v)
+		}
+	})
+	t.Run("行2 设备身份是按 user_id 派生的 15 位数字", func(t *testing.T) {
+		// 期望值来自参考实现（Node + node:crypto）的派生，不是本实现自己算的
+		if v := got["X-Device-Id"]; v != "707304999019651" {
+			t.Fatalf("X-Device-Id 应为按 uid 派生的 15 位数字 707304999019651，实得 %q", v)
+		}
+	})
+	t.Run("行3 客户端身份头齐全", func(t *testing.T) {
+		for k, want := range map[string]string{
+			"X-Market-Client-Id": "VSCode 1.107.1",
+			"X-User-Region":      "CN",
+			"Package-Type":       "stable_cn",
+			"X-Lgw-Req-Sdk-Type": "3",
+			"X-Lscbd-Platform":   "windows",
+			"App-Version":        "0.1.52",
+		} {
+			if v := got[k]; v != want {
+				t.Errorf("头 %s = %q，期望 %q", k, v, want)
+			}
+		}
+		if got["X-Market-User-Id"] == "" || len(got["X-Market-User-Id"]) != 36 {
+			t.Errorf("X-Market-User-Id 应是 UUID v4 形状，实得 %q", got["X-Market-User-Id"])
+		}
+		if len(got["Vscode-Sessionid"]) != 64 {
+			t.Errorf("Vscode-Sessionid 应是 64 位 hex，实得 %q", got["Vscode-Sessionid"])
+		}
+		if got["X-Tt-Trace-Id"] == "" || got["X-Request-Id"] == "" {
+			t.Error("每次请求都应有独立的 X-Tt-Trace-Id / X-Request-Id")
+		}
+	})
+}

internal/core/channels_trae_derive_test.go

@@ -0,0 +1,63 @@
+package core
+
+import (
+	"encoding/json"
+	"fmt"
+	"os"
+	"testing"
+
+	"llmsproxy/internal/lua"
+)
+
+// 手工移植的确定性派生必须与参考**逐字节一致**，否则签名的设备身份是错的
+// 且不会报错（上游只会返回风控/失败）。所以拿参考实现（Node + node:crypto）
+// 生成期望值，再让插件的 Lua 实现算同一组输入做差分。
+//
+// 期望值由 tools/trae_derive_expected.json 提供（用参考 seededStream 生成）。
+func TestTraeDeriveMatchesReference(t *testing.T) {
+	raw, err := os.ReadFile("trae_derive_expected.json")
+	if err != nil {
+		t.Skipf("缺差分数据（跳过）: %v", err)
+	}
+	var cases []struct {
+		U      string `json:"u"`
+		Devid  string `json:"devid"`
+		Market string `json:"market"`
+		Sess   string `json:"sess"`
+	}
+	if err := json.Unmarshal(raw, &cases); err != nil {
+		t.Fatal(err)
+	}
+
+	c := kernelTestCore(t)
+	ps := c.Plugins()
+	src, err := readBundledChannels(t)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if err := ps.LoadSource("channels", src); err != nil {
+		t.Fatal(err)
+	}
+
+	for _, tc := range cases {
+		got, err := ps.Call("channels", "__trae_derive_probe", map[string]interface{}{"uid": tc.U})
+		if err != nil {
+			t.Fatalf("probe %q: %v", tc.U, err)
+		}
+		wrapped, _ := got.(map[string]interface{})
+		m, _ := wrapped["json"].(map[string]interface{})
+		if m == nil {
+			t.Fatalf("probe %q 无 json: %#v", tc.U, got)
+		}
+		if fmt.Sprint(m["devid"]) != tc.Devid {
+			t.Errorf("devid(%q) = %v，参考 %s", tc.U, m["devid"], tc.Devid)
+		}
+		if fmt.Sprint(m["market"]) != tc.Market {
+			t.Errorf("market(%q) = %v，参考 %s", tc.U, m["market"], tc.Market)
+		}
+		if fmt.Sprint(m["sess"]) != tc.Sess {
+			t.Errorf("sess(%q) = %v，参考 %s", tc.U, m["sess"], tc.Sess)
+		}
+	}
+	_ = lua.HandlerRequest{}
+}

internal/core/channels_trae_test.go

@@ -1,6 +1,7 @@
 package core
 
 import (
+	"encoding/json"
 	"fmt"
 	"io"
 	"net/http"
@@ -115,10 +116,26 @@ func TestTraeCallbackBehavior(t *testing.T) {
 		if st != 200 {
 			t.Fatalf("应 200: %d %s", st, body)
 		}
-		// 凭据必须是 ExchangeToken 的新 Token，不是回调原值
+		// 凭据必须是 ExchangeToken 的新 Token，不是回调原值。
+		// 凭据是 JSON（Trae 需 device_id/uid 供签到派生设备身份），故解出 access_token。
 		v, _, _ := h.ps.GetSecret("channels", "channels:trae")
-		if !strings.HasPrefix(v, "ACCESS-") {
-			t.Fatalf("凭据应是 ExchangeToken 的新 access, 实得 %q", v)
+		var cred map[string]interface{}
+		if err := json.Unmarshal([]byte(v), &cred); err != nil {
+			t.Fatalf("凭据应为 JSON（含 device_id/uid）: %v (%q)", err, v)
+		}
+		if at, _ := cred["access_token"].(string); !strings.HasPrefix(at, "ACCESS-") {
+			t.Fatalf("凭据应是 ExchangeToken 的新 access, 实得 %q", at)
+		}
+		// uid 来自 userInfo.UserID —— 签到设备身份的派生种子，丢了就无法签到
+		if cred["uid"] != "u1" {
+			t.Fatalf("凭据应保留 uid=u1（签到设备身份的种子）, 实得 %v", cred["uid"])
+		}
+		if cred["enterprise_id"] != "t1" {
+			t.Fatalf("凭据应保留 TenantID, 实得 %v", cred["enterprise_id"])
+		}
+		// 设备身份来自登录会话（授权 URL 里下发的那对 hex32）
+		if d, _ := cred["device_id"].(string); len(d) != 32 {
+			t.Fatalf("凭据应带 32 位 device_id（签到轮换用）, 实得 %q", d)
 		}
 	})
 
@@ -131,8 +148,12 @@ func TestTraeCallbackBehavior(t *testing.T) {
 			t.Fatalf("应 200: %d %s", st, body)
 		}
 		v, _, _ := h.ps.GetSecret("channels", "channels:trae")
-		if v != "JWT-TOKEN-1" {
-			t.Fatalf("兜底凭据应是 userJwt.Token, 实得 %q", v)
+		var cred2 map[string]interface{}
+		if err := json.Unmarshal([]byte(v), &cred2); err != nil {
+			t.Fatalf("凭据应为 JSON: %v (%q)", err, v)
+		}
+		if cred2["access_token"] != "JWT-TOKEN-1" {
+			t.Fatalf("兜底凭据应是 userJwt.Token, 实得 %v", cred2["access_token"])
 		}
 		if atomic.LoadInt32(&h.exchHit) != before {
 			t.Fatal("无 refreshToken 不应调 ExchangeToken（参考实现分支2）")
@@ -208,7 +229,7 @@ func TestTraeCallbackPoolPath(t *testing.T) {
 	// ① 凭据必须落在池账号的 ref
 	v, ok, _ := h.ps.GetSecret("channels", "channels:trae:"+aid)
 	if !ok || v == "" {
-		t.Fatalf("★ callback 池路径凭据未落到 channels:trae:%s（用户报障的同一缺陷）", aid)
+		t.Fatalf("callback 池路径凭据未落到 channels:trae:%s（用户报障的同一缺陷）", aid)
 	}
 	// ② account_list 必须报 has_credential=true
 	lst, err := h.ps.InvokeHandler("channels", "account_list", &lua.HandlerRequest{

internal/core/trae_derive_expected.json

@@ -0,0 +1,44 @@
+[
+ {
+  "u": "12345",
+  "devid": "707304999019651",
+  "market": "5daa819c-8425-4bae-88b7-2bbfec3c25ba",
+  "sess": "e5b8dfc5830ce0bdb141f7177effb90a7cf8227bb23b930a427a8550bf7357df"
+ },
+ {
+  "u": "UID-abc",
+  "devid": "579362202930608",
+  "market": "a5388fc1-5969-4666-bc74-be9a11f69567",
+  "sess": "a47da2e13fe16d49dc859fbed58d1d99e0faef5d116acafc64a2d26013d17a1f"
+ },
+ {
+  "u": "900000001",
+  "devid": "764948639142479",
+  "market": "e449daa5-b0c0-4f35-918e-8bb01b33f179",
+  "sess": "fdd37c37d1cc950439c25467e6dca75fcc84a2b0d294aa910387a9a965645650"
+ },
+ {
+  "u": "x",
+  "devid": "268405722745284",
+  "market": "4f2427c5-0583-4f82-8e18-4e38566dd857",
+  "sess": "79be40fff0fbaee572d1ba3ab13a47af9d2f4d943115ef512c56e42132e23a66"
+ },
+ {
+  "u": "",
+  "devid": "170789623621479",
+  "market": "b32897c1-f9c0-4ad2-b2b4-725455fffb6b",
+  "sess": "4a61a6b4c4bcbf1040bf0edf3df2b3e7d76a956f3ef81ef8f148eadcc03d25cc"
+ },
+ {
+  "u": "用户1",
+  "devid": "263026789643405",
+  "market": "1c1b4e1f-9d7a-4698-9f34-b057d9a74b0b",
+  "sess": "a13dbde68977eee49818e2e2fb7d3bbb1ffb4c807a6e6f1831168a84adea0dfe"
+ },
+ {
+  "u": "1234567890123456789012345",
+  "devid": "358669731114854",
+  "market": "449882ec-9a69-4a7a-b9ab-25aa59b28c50",
+  "sess": "305eb96fe14a194386c0fd4148d4919870ed803b69cf75296b53ea1f41e4c574"
+ }
+]

tools/trae_derive_expected.mjs

@@ -0,0 +1,74 @@
+// 生成 Trae 设备身份派生的差分期望值（供 internal/core/channels_trae_derive_test.go 比对）。
+//
+// 为什么要有这个文件：channels.lua 里的 traeDeriveStream 是**手工移植**的
+// SHA-256 确定性伪随机流（Lua 5.1 没有 node:crypto）。移植错了不会报错 ——
+// 上游只会返回风控/失败，看起来像"运气不好"。所以拿参考实现（参考仓库
+// vendor/channel-pack/src/trae.ts 的 seededStream/seededDigits）生成期望值，
+// 再让 Lua 侧算同一组输入做差分。
+//
+// 用法（改了参考或改了移植后都要重跑）：
+//   node tools/trae_derive_expected.mjs > internal/core/trae_derive_expected.json
+//
+// 注意：这里刻意**逐行照抄**参考的 seededStream，而不是从参考仓库 import ——
+// 参考是 TS/ESM 且依赖其构建链，直接抄这 20 行更能保证"同一算法"。
+
+import { createHash } from 'node:crypto'
+
+/** 照抄 trae.ts:seededStream —— SHA256(utf8(salt:seed) ++ counterBE32) 串联。 */
+function seededStream(seed, salt, nbytes) {
+  const prefix = `${salt}:${seed}`
+  const result = []
+  let counter = 0
+  while (result.length < nbytes) {
+    const counterBuf = new Uint8Array(4)
+    counterBuf[0] = (counter >> 24) & 0xff
+    counterBuf[1] = (counter >> 16) & 0xff
+    counterBuf[2] = (counter >> 8) & 0xff
+    counterBuf[3] = counter & 0xff
+    const h = createHash('sha256')
+    h.update(prefix, 'utf8')
+    h.update(counterBuf)
+    for (const b of h.digest()) {
+      result.push(b)
+      if (result.length >= nbytes) break
+    }
+    counter++
+  }
+  return result.slice(0, nbytes)
+}
+
+/** 照抄 trae.ts:seededDigits —— 每字节 % 10，拼成 n 位数字串。 */
+function seededDigits(n, seed, salt) {
+  return seededStream(seed, salt, n).map((b) => b % 10).join('')
+}
+
+/** 照抄 trae.ts:deriveDeviceId15。 */
+function deriveDeviceId15(userId) {
+  return seededDigits(15, userId, 'devid')
+}
+
+/** 照抄 trae.ts:deriveMarketUserId —— UUID v4 形状。 */
+function deriveMarketUserId(userId) {
+  const bs = seededStream(userId, 'market', 16)
+  bs[6] = (bs[6] & 0x0f) | 0x40
+  bs[8] = (bs[8] & 0x3f) | 0x80
+  const hex = bs.map((b) => b.toString(16).padStart(2, '0')).join('')
+  return `${hex.slice(0, 8)}-${hex.slice(8, 12)}-${hex.slice(12, 16)}-${hex.slice(16, 20)}-${hex.slice(20, 32)}`
+}
+
+/** 照抄 trae.ts:deriveSessionId —— 64 位 hex。 */
+function deriveSessionId(userId) {
+  return seededStream(userId, 'sess', 32).map((b) => b.toString(16).padStart(2, '0')).join('')
+}
+
+// 覆盖边界：纯数字 / 带连字符 / 空串（空串也要能算，不能崩）/ 多字节 UTF-8 /
+// 超长（超过一个 SHA-256 块，逼出 counter 递增分支 —— 移植时最易错的地方）。
+const ids = ['12345', 'UID-abc', '900000001', 'x', '', '用户1', '1234567890123456789012345']
+
+const out = ids.map((u) => ({
+  u,
+  devid: deriveDeviceId15(u),
+  market: deriveMarketUserId(u),
+  sess: deriveSessionId(u),
+}))
+process.stdout.write(`${JSON.stringify(out, null, 1)}\n`)