fix(channels): 四渠道修复 —— qoder 裸 token 领取 / trae+buddy 非流式 / opencode 目录 / 隐藏适配器

生产实测逐渠道排查（2026-10-19）：

* qoder：PKCE 设备码流无 register 第二跳，落库凭据是裸 token 字符串；
  qoderClaim 硬要求结构化 table 导致「缺少凭据对象」（而 account_test
  走 token 路径正常 —— 自相矛盾状态）。改为非空裸 tok 就地包
  {access_token=tok}；补 TestQoderClaimAcceptsBareTokenCredential。

* trae（SOLO 自装适配器）：上游对非流式请求也回 SSE（event: 前缀帧），
  transform_response 不识别 → 整个 body 原样透传 → Go unmarshal 报
  invalid character 'e'。补 aggregate_solo_sse 聚合。

* buddy（CodeBuddy）：上游 400 11101 只支持流式。transform_request 强制
  stream=true；transform_response 补 SSE 聚合（tool_calls 按 index 拼分片）。

* provider 流式：真实 tool-call 片段之后出现 finish_reason=stop 时归一为
  tool_calls（trae 实测如此发）；buddy/trae 不再序列化空 tool_calls 表。

* opencode：远端目录端点改为 /zen/v1/models（裸 /v1/models 回 HTML）；
  兜底目录同步 2026-10-19 实测（space-bunny-free 410 下架等 5 项变化）。
  opencodezen 适配器 v1.1.0：会话亲和（client_session / 首 user 消息指纹
  分桶），保留免费层门禁四要素。

* 内核：适配器可声明 adapter.hidden = true 退出用户可见列表；被源引用的
  隐藏适配器保持可见（源编辑器要回显当前值）。opencodezen 默认隐藏。

* channels UI：切渠道立即清空账号/模型区 + 响应代际校验，修复 qoder 账号
  闪现在 opencode 卡片下的渲染竞态。

* channels request_end hook：挂接丢失的 isModelGone/recordDeadModel ——
  真实 404（如 codearts GLM-5.3 "The model is not registered"）现在会进
  deadModels，不再每轮 404 仍可选中。

docs/channel-issues-2026-10-19.md

@@ -0,0 +1,86 @@
+# 渠道问题清单（2026-10-19 晚生产实测）
+
+> 逐项修复。每项标注：现象 / 根因 / 状态。
+
+## P1 trae 非流式 500（unmarshal unified response: invalid character 'e'）
+- **现象**：`stream:false` 打 `channels-trae:*` 必现 500，body 以 `event:metadata data:{...}` 开头。
+- **根因**：trae SOLO 上游**对非流式请求也回 SSE**（且帧带 `event:` 前缀）。
+  插件自装的 `channels-trae` 适配器 `transform_response` 直接 `__prelude.openai_response(raw_body)`，
+  不识别 SSE；而内核只把 `data:` 行交给流式适配器，非流式路径把**整个 body**（含 `event:` 行）
+  塞给 transform_response → json.decode 失败 → 原样返回 → Go 侧 unmarshal 报 `invalid character 'e'`。
+  （`internal/lua/adapters/trae.lua` 有 SSE 聚合逻辑，但 channels 平台用的是**插件内嵌**
+  `TRAE_SOLO_ADAPTER_SRC`（channels.lua:9744），两份代码不同步。）
+- **修法**：`TRAE_SOLO_ADAPTER_SRC.transform_response` 加 SSE 聚合（复用流式帧解析，
+  聚合成一个非流式响应），并把 `internal/lua/adapters/trae.lua` 的聚合逻辑对齐。
+- **状态**：⬜
+
+## P2 buddy（CodeBuddy）非流式 400（11101 Non-stream not supported）
+- **现象**：`stream:false` 打 `channels-buddy:*` 上游 400 `11101: Non-stream chat request is currently not supported`。
+- **根因**：腾讯 codebuddy 网关**只支持流式**。适配器 `transform_request` 没有强制 `stream=true`，
+  非流式请求原样透传被上游拒绝。buddy 的 `Accept: text/event-stream` 头已发，但 body.stream 仍是 false。
+- **修法**：`buddy.lua transform_request` 强制 `req.stream = true`；`transform_response` 增加
+  SSE 聚合兜底（内核非流式路径收到 SSE 时聚合）。参考 opencodezen.lua 的既有做法（门禁第 4 条）。
+- **状态**：⬜
+
+## P3 buddy 偶发 provider busy（429）＋ 11133 参数拒绝
+- **现象**：连续请求 `channels-buddy` 间歇返回 `provider busy`（source 并发槽 max_concurrent=1
+  被占满）与上游 `11133: the request parameters were rejected`。
+- **根因**：① max_concurrent=1 是**刻意的**（channels.lua:4332 注释：并发配额按模型计），busy
+  是正常自保；② 11133 与空 tool_calls 修复（未提交的 buddy.lua 改动）相关，待部署后观察。
+- **状态**：观察项，非缺陷。
+
+## P4 Qoder 领取失败（缺少凭据对象）——已修复
+- **现象**：`channels/claim` 报 `{"error":"缺少凭据对象"}`，而 account_test 正常。
+- **根因**：qoder 是 PKCE 设备码流且无 register 第二跳，落库凭据是**裸 token 字符串**；
+  `qoderClaim` 硬要求 `type(cred)=="table"`。
+- **修法**：`qoderClaim` 兼容裸 token（非空时包 `{access_token=tok}`）；
+  回归测试 `TestQoderClaimAcceptsBareTokenCredential`。
+- **状态**：✅ 已修复并部署生产（claim 现在返回真实上游业务结论）。
+
+## P5 Qoder/OpenCode 渠道页账号串台（UI 渲染竞态）
+- **现象**：从 qoder 切到 opencode 详情页，qoder 的账号行闪现在 opencode 卡片下。
+- **根因**：`renderDetail()` 切渠道时不清空 `#ch-accts`，`renderAccounts` 是异步的，
+  空窗期 DOM 仍挂旧渠道账号行；且慢的旧请求返回会覆盖新渠道数据。
+- **修法**：① renderDetail 立即清空账号/模型区并置"加载中"；② renderAccounts/renderModels
+  加代际校验（`state.selected !== id` 时丢弃响应）。
+- **状态**：✅ 已改（channels.lua），待部署。
+
+## P6 CodeArts「完全不可用」——多数模型实际可用
+- **现象**：用户报"codearts 完全不可用"。实测逐模型探测：
+  - 可用：openpangu-2.0-flash/pro、GLM-5.2、glm-5.3、kimi-k2.6-vl、Qwen3-VL-235B、glm-5.2-sft-harmony
+  - 429（限流非下架）：deepseek-v4.1-flash、deepseek-v4-flash、openpangu-2.0-pro（间歇）
+  - 404（真下架，需标 disabled）：GLM-5.3 报 `InferHub.002002009.404: The model is not registered`
+- **附带发现**：`GLM-5.3`（大写变体）不在 deadModels 记录里——`recordDeadModel` 只被
+  `__record_dead_probe` 调用，**request_end hook 没接 isModelGone**（583976f 引入的
+  基础设施丢了挂接点）。需要把 on_request_end 补上 dead-model 记录。
+- **凭据**：expiresAt 已过期（15:05），`account/refresh` 续期成功（refreshable=true）。
+  建议把「凭据到期自动续期」纳入定时任务检查。
+- **状态**：⬜（待补 dead-model 挂接 + GLM-5.3 标 disabled）
+
+## P7 CodeBuddy 海外账号 / Qoder 国内账号
+- **现象**：CodeBuddy 登录只走国内（copilot.tencent.com），Qoder 登录只走国际
+  （openapi.qoder.sh / qoder.com）。用户要求两边都能选区。
+- **根因**：平台表单区硬编码。buddy 的 state-poll 端点与 Qoder 的 PKCE 端点都锁死一个区域。
+- **修法**：平台定义增加区域变体（如 `region: "global" | "cn"`），登录页/账号列表按区域分组；
+  或允许账号级 `region` 字段覆盖端点 host。
+- **状态**：⬜（需求确认后实施）
+
+## P8 商汤（Raccoon）扫码登录「链接无效」
+- **现象**：用户点登录后看到的二维码/链接打不开。
+- **排查**：登录会话本身正常发起（二维码已生成、轮询端点存在）。
+  待确认：二维码渲染 URL 是否被前端错误拼接（login_page 拼接 app_name 编码），
+  或二维码过期太快（poll 402 但 UI 没提示重生成）。
+- **状态**：⬜（需要用户复现一次，抓前端渲染的 URL）
+
+## P9 死模型记录基础设施未挂接（P6 的根因之一）
+- `isModelGone` / `recordDeadModel` 只有测试 probe 在调；`plugin.hooks = { request_end }` 的
+  `on_request_end` 只处理 term_error（账号级），不记模型级死亡。
+- **修法**：on_request_end 失败分支里，取 payload.model + error message，
+  `isModelGone(msg)` 为真时 `recordDeadModel(provider, model, msg)` 并重同步源。
+- **状态**：⬜
+
+## 部署注意事项
+- 工作树有未提交改动：buddy.lua / trae.lua（tool_calls 空 {} 过滤）、provider.go（stop→tool_calls 归一）、
+  channels.lua（qoder 裸 token + UI 竞态）、provider_test.go、channels_qoder_claim_test.go。
+- 生产 channels.lua 哈希与仓库不同步是常态（deploy.sh 会 sync_plugins）。
+- 商汤账号：用户需在二维码有效期内扫码确认；当前账号 5a2ea34df521 无凭据属正常（未完成扫码）。

internal/config/config.go

@@ -62,13 +62,18 @@ const (
 	DefaultSourceConcurrency  = 8
 )
 
-// Model is a single exposed model id bound to a source, with priority used by
-// AUTO auto selection (higher number = preferred).
+// Model is a single exposed model id bound to a source.
+//
+// ★ 曾经有 `Priority int` 字段，并号称"高者优先参与 AUTO 选源"。**那是错的**：
+//
+//	AUTO 链由 `config.ModelScope.Tier` 驱动（见 scheduler.Chain），而 priority
+//	只被 `bestChatModel/bestImageModel` 用于"本源码内部该发哪个模型"，
+//	与跨源调度毫无关系。把它当成调度依据会让人误以为改个数字就能改顺序，
+//	改完发现毫无效果 —— 已彻底删除，避免再次误导。
 type Model struct {
-	ID       string                 `yaml:"id" json:"id"`
-	Priority int                    `yaml:"priority" json:"priority"`
-	Kind     string                 `yaml:"kind" json:"kind"` // "chat" (default) | "image"
-	Meta     map[string]interface{} `yaml:"meta" json:"meta,omitempty"`
+	ID   string                 `yaml:"id" json:"id"`
+	Kind string                 `yaml:"kind" json:"kind"` // "chat" (default) | "image"
+	Meta map[string]interface{} `yaml:"meta" json:"meta,omitempty"`
 }
 
 // Source describes a single upstream LLM provider.

internal/config/config_test.go

@@ -52,9 +52,6 @@ sources:
 	if cfg.Sources[1].MaxConcurrent == 0 {
 		t.Fatal("default max_concurrent not applied")
 	}
-	if cfg.Sources[0].Models[0].Priority != 100 {
-		t.Fatalf("priority = %d", cfg.Sources[0].Models[0].Priority)
-	}
 	if cfg.DefaultModel != "AUTO" {
 		t.Fatalf("default model = %q", cfg.DefaultModel)
 	}

internal/config/presets.go

@@ -14,9 +14,9 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "deepseek",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "deepseek-v4-flash", Priority: 100, Kind: "chat"},
-			{ID: "deepseek-v4-pro", Priority: 90, Kind: "chat"},
-			{ID: "deepseek-v4-flash-vision-exp", Priority: 60, Kind: "chat"},
+			{ID: "deepseek-v4-flash", Kind: "chat"},
+			{ID: "deepseek-v4-pro", Kind: "chat"},
+			{ID: "deepseek-v4-flash-vision-exp", Kind: "chat"},
 		},
 	},
 	{
@@ -25,10 +25,10 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "openai",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "glm-5.3", Priority: 100, Kind: "chat"},
-			{ID: "glm-5.3-flash", Priority: 90, Kind: "chat"},
-			{ID: "glm-5.2", Priority: 80, Kind: "chat"},
-			{ID: "glm-5.1", Priority: 60, Kind: "chat"},
+			{ID: "glm-5.3", Kind: "chat"},
+			{ID: "glm-5.3-flash", Kind: "chat"},
+			{ID: "glm-5.2", Kind: "chat"},
+			{ID: "glm-5.1", Kind: "chat"},
 		},
 	},
 	{
@@ -37,10 +37,10 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "openai",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "kimi-k3", Priority: 100, Kind: "chat"},
-			{ID: "kimi-k2.7-code", Priority: 90, Kind: "chat"},
-			{ID: "kimi-k2.7-code-highspeed", Priority: 85, Kind: "chat"},
-			{ID: "kimi-k2.6", Priority: 70, Kind: "chat"},
+			{ID: "kimi-k3", Kind: "chat"},
+			{ID: "kimi-k2.7-code", Kind: "chat"},
+			{ID: "kimi-k2.7-code-highspeed", Kind: "chat"},
+			{ID: "kimi-k2.6", Kind: "chat"},
 		},
 	},
 	{
@@ -49,11 +49,11 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "openai",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "deepseek-ai/DeepSeek-V4-Pro", Priority: 100, Kind: "chat"},
-			{ID: "deepseek-ai/DeepSeek-V4-Flash", Priority: 90, Kind: "chat"},
-			{ID: "moonshotai/Kimi-K2.6", Priority: 80, Kind: "chat"},
-			{ID: "zai-org/GLM-5.1", Priority: 70, Kind: "chat"},
-			{ID: "Kwai-Kolors/Kolors", Priority: 50, Kind: "image"},
+			{ID: "deepseek-ai/DeepSeek-V4-Pro", Kind: "chat"},
+			{ID: "deepseek-ai/DeepSeek-V4-Flash", Kind: "chat"},
+			{ID: "moonshotai/Kimi-K2.6", Kind: "chat"},
+			{ID: "zai-org/GLM-5.1", Kind: "chat"},
+			{ID: "Kwai-Kolors/Kolors", Kind: "image"},
 		},
 	},
 	{
@@ -62,9 +62,9 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "openai",
 		MaxConcurrent: 4,
 		Models: []Model{
-			{ID: "4.0Ultra", Priority: 100, Kind: "chat"},
-			{ID: "generalv3.5", Priority: 80, Kind: "chat"},
-			{ID: "max-32k", Priority: 70, Kind: "chat"},
+			{ID: "4.0Ultra", Kind: "chat"},
+			{ID: "generalv3.5", Kind: "chat"},
+			{ID: "max-32k", Kind: "chat"},
 		},
 	},
 	{
@@ -73,11 +73,11 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "openai",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "qwen3.8-max", Priority: 100, Kind: "chat"},
-			{ID: "qwen3.8-flash", Priority: 90, Kind: "chat"},
-			{ID: "qwen3.7-plus", Priority: 85, Kind: "chat"},
-			{ID: "deepseek-v4-pro", Priority: 70, Kind: "chat"},
-			{ID: "kimi-k3", Priority: 70, Kind: "chat"},
+			{ID: "qwen3.8-max", Kind: "chat"},
+			{ID: "qwen3.8-flash", Kind: "chat"},
+			{ID: "qwen3.7-plus", Kind: "chat"},
+			{ID: "deepseek-v4-pro", Kind: "chat"},
+			{ID: "kimi-k3", Kind: "chat"},
 		},
 	},
 	{
@@ -86,9 +86,9 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "openai",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "ernie-5.0-turbo", Priority: 100, Kind: "chat"},
-			{ID: "ernie-5.0", Priority: 90, Kind: "chat"},
-			{ID: "deepseek-v4-pro", Priority: 70, Kind: "chat"},
+			{ID: "ernie-5.0-turbo", Kind: "chat"},
+			{ID: "ernie-5.0", Kind: "chat"},
+			{ID: "deepseek-v4-pro", Kind: "chat"},
 		},
 	},
 	{
@@ -97,9 +97,9 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "openai",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "doubao-seed-2.0-pro", Priority: 100, Kind: "chat"},
-			{ID: "doubao-seed-2.0", Priority: 90, Kind: "chat"},
-			{ID: "doubao-seed-2.0-flash", Priority: 80, Kind: "chat"},
+			{ID: "doubao-seed-2.0-pro", Kind: "chat"},
+			{ID: "doubao-seed-2.0", Kind: "chat"},
+			{ID: "doubao-seed-2.0-flash", Kind: "chat"},
 		},
 	},
 	{
@@ -108,8 +108,8 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "openai",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "MiniMax-M3", Priority: 100, Kind: "chat"},
-			{ID: "MiniMax-M2.5", Priority: 80, Kind: "chat"},
+			{ID: "MiniMax-M3", Kind: "chat"},
+			{ID: "MiniMax-M2.5", Kind: "chat"},
 		},
 	},
 	// ── 国际主流 ────────────────────────────────────────────────────────────
@@ -119,9 +119,9 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "openai",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "gpt-5.6-sol", Priority: 100, Kind: "chat"},
-			{ID: "gpt-5.6-terra", Priority: 90, Kind: "chat"},
-			{ID: "gpt-5.6-luna", Priority: 80, Kind: "chat"},
+			{ID: "gpt-5.6-sol", Kind: "chat"},
+			{ID: "gpt-5.6-terra", Kind: "chat"},
+			{ID: "gpt-5.6-luna", Kind: "chat"},
 		},
 	},
 	{
@@ -130,10 +130,10 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "anthropic",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "claude-opus-5", Priority: 100, Kind: "chat"},
-			{ID: "claude-fable-5", Priority: 95, Kind: "chat"},
-			{ID: "claude-sonnet-5", Priority: 85, Kind: "chat"},
-			{ID: "claude-haiku-4-5", Priority: 70, Kind: "chat"},
+			{ID: "claude-opus-5", Kind: "chat"},
+			{ID: "claude-fable-5", Kind: "chat"},
+			{ID: "claude-sonnet-5", Kind: "chat"},
+			{ID: "claude-haiku-4-5", Kind: "chat"},
 		},
 	},
 	{
@@ -142,10 +142,10 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "gemini",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "gemini-3.6-flash", Priority: 100, Kind: "chat"},
-			{ID: "gemini-3.5-flash", Priority: 90, Kind: "chat"},
-			{ID: "gemini-3.5-flash-lite", Priority: 80, Kind: "chat"},
-			{ID: "gemini-3.1-pro", Priority: 85, Kind: "chat"},
+			{ID: "gemini-3.6-flash", Kind: "chat"},
+			{ID: "gemini-3.5-flash", Kind: "chat"},
+			{ID: "gemini-3.5-flash-lite", Kind: "chat"},
+			{ID: "gemini-3.1-pro", Kind: "chat"},
 		},
 	},
 	{
@@ -154,9 +154,9 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "groq",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "openai/gpt-oss-120b", Priority: 100, Kind: "chat"},
-			{ID: "openai/gpt-oss-20b", Priority: 80, Kind: "chat"},
-			{ID: "groq/compound", Priority: 70, Kind: "chat"},
+			{ID: "openai/gpt-oss-120b", Kind: "chat"},
+			{ID: "openai/gpt-oss-20b", Kind: "chat"},
+			{ID: "groq/compound", Kind: "chat"},
 		},
 	},
 	{
@@ -165,9 +165,9 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "mistral",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "mistral-medium-latest", Priority: 100, Kind: "chat"},
-			{ID: "mistral-large-latest", Priority: 90, Kind: "chat"},
-			{ID: "codestral-latest", Priority: 85, Kind: "chat"},
+			{ID: "mistral-medium-latest", Kind: "chat"},
+			{ID: "mistral-large-latest", Kind: "chat"},
+			{ID: "codestral-latest", Kind: "chat"},
 		},
 	},
 	{
@@ -180,10 +180,10 @@ var PresetTemplates = []SourceTemplate{
 			"X-Title":      "ModelRouter",
 		},
 		Models: []Model{
-			{ID: "openrouter/auto", Priority: 100, Kind: "chat"},
-			{ID: "deepseek/deepseek-v4-flash", Priority: 90, Kind: "chat"},
-			{ID: "anthropic/claude-opus-5", Priority: 85, Kind: "chat"},
-			{ID: "openai/gpt-5.6-sol", Priority: 85, Kind: "chat"},
+			{ID: "openrouter/auto", Kind: "chat"},
+			{ID: "deepseek/deepseek-v4-flash", Kind: "chat"},
+			{ID: "anthropic/claude-opus-5", Kind: "chat"},
+			{ID: "openai/gpt-5.6-sol", Kind: "chat"},
 		},
 	},
 	{
@@ -192,8 +192,8 @@ var PresetTemplates = []SourceTemplate{
 		Adapter:       "github",
 		MaxConcurrent: 8,
 		Models: []Model{
-			{ID: "gpt-5.6-sol", Priority: 100, Kind: "chat"},
-			{ID: "gpt-5.6-luna", Priority: 80, Kind: "chat"},
+			{ID: "gpt-5.6-sol", Kind: "chat"},
+			{ID: "gpt-5.6-luna", Kind: "chat"},
 		},
 	},
 	// ── 本地模型 ────────────────────────────────────────────────────────────
@@ -204,9 +204,9 @@ var PresetTemplates = []SourceTemplate{
 		Endpoint:      "/api/chat",
 		MaxConcurrent: 4,
 		Models: []Model{
-			{ID: "qwen3", Priority: 80, Kind: "chat"},
-			{ID: "deepseek-r1", Priority: 80, Kind: "chat"},
-			{ID: "llama3.3", Priority: 70, Kind: "chat"},
+			{ID: "qwen3", Kind: "chat"},
+			{ID: "deepseek-r1", Kind: "chat"},
+			{ID: "llama3.3", Kind: "chat"},
 		},
 	},
 }

internal/core/channels_codearts_adapter_test.go

@@ -151,7 +151,9 @@ func TestCodeArtsSourceUsesPluginAdapter(t *testing.T) {
 	}
 	aid, _ := j["account_id"].(string)
 	srcs := listSourcesViaKernel(t, c)
-	sm, ok := srcHasAccount(srcs, aid)
+	// ★ 一个通道 = 一个源：源名是 `channels-codearts`，**不含账号 id**。
+	//   按账号 id 找会永远失败 —— 这正是"加账号了但测试说没出源"的假故障。
+	sm, ok := srcHasAccount(srcs, "codearts")
 	if !ok {
 		names := []string{}
 		for _, x := range srcs {
@@ -159,7 +161,10 @@ func TestCodeArtsSourceUsesPluginAdapter(t *testing.T) {
 				names = append(names, n)
 			}
 		}
-		t.Fatalf("codearts 账号 %q 应已同步源；现有源: %v", aid, names)
+		t.Fatalf("codearts 账号 %q 应已同步出通道源；现有源: %v", aid, names)
+	}
+	if nm, _ := sm["name"].(string); nm != "channels-codearts" {
+		t.Errorf("通道源名应为 channels-codearts，实得 %q（账号 id=%s）", nm, aid)
 	}
 	if ad, _ := sm["adapter"].(string); ad != "codearts" {
 		t.Errorf("源应引用插件装的 codearts 适配器，实得 %q（签名不会生效）", ad)

internal/core/channels_codearts_pem_test.go

@@ -0,0 +1,184 @@
+package core
+
+import (
+	"encoding/base64"
+	"encoding/json"
+	"os"
+	"strings"
+	"testing"
+)
+
+// codearts JWK→PEM 重建判据。
+//
+// 背景（真实缺陷，2026-10-19 用户报「华为云源用不了」）：
+//
+// 华为云 STS 的 security_token 只活 1 小时，续期（refresh_token 换新）需要
+// DPoP 请求签名。签名走 `codeartsDpopSign(key, ...)`，它要求 `key.pem` 是
+// **PEM 字符串**（内部用 openssl 命令行签）。而持久化的凭据里**只有**
+// `dpop_private_key_jwk`（私钥的 JWK）—— PEM 是登录时的临时文件，没保存。
+//
+// 于是续期必须先从 JWK 重建 PEM。这条判据钉住"重建出来的 PEM 真能被 openssl
+// 接受并签出有效的 ES256 JWS"，而不是"函数返回了非空字符串"。
+//
+// 为什么必须真签名：DER 结构错、长度字段错、base64 换行错，都会得到
+// **非空但无效**的 PEM。只断言非空等于什么都没验。
+func TestCodeartsRebuildsPemFromJwkAndSigns(t *testing.T) {
+	// 一个结构合法的 P-256 私钥 JWK（生产凭据的真实形状：三个字段都是
+	// 32 字节 base64url）。用固定值而非随机生成，是为了让失败可复现。
+	jwk := map[string]any{
+		"crv": "P-256",
+		"kty": "EC",
+		"d":   "BpkBLfUUij8IPn0Mzs6C64RfhQkF378yyQPeCR5sh7U",
+		"x":   "r2HUYfG7tMIWY9KOpXLvvMWE_7dnHM9K7p1K7-LSwl4",
+		"y":   "0-weI5p_EXZXFfGx4a76X_0oamkLOJ5AA4MOMObL8MM",
+	}
+
+	_, ps := poolCore(t)
+	out, err := ps.Call("channels", "__codearts_jwk_pem_probe", map[string]any{"jwk": jwk})
+	if err != nil {
+		t.Fatalf("探针调用失败: %v", err)
+	}
+	wrapped, _ := out.(map[string]any)
+	inner, _ := wrapped["json"].(map[string]any)
+	if inner == nil {
+		t.Fatalf("探针返回缺 json 包装: %#v", out)
+	}
+	if e, _ := inner["error"].(string); e != "" {
+		t.Fatalf("JWK→PEM 重建失败: %s", e)
+	}
+
+	// ① PEM 形状必须是 openssl 认的 SEC1 EC PRIVATE KEY
+	pem, _ := inner["pem"].(string)
+	if !strings.HasPrefix(pem, "-----BEGIN EC PRIVATE KEY-----") {
+		t.Fatalf("PEM 头部不对: %q", firstLine(pem))
+	}
+	if !strings.Contains(pem, "-----END EC PRIVATE KEY-----") {
+		t.Fatalf("PEM 尾部不对: %q", lastLine(pem))
+	}
+	// 每行（除首尾）不得超过 64 字符 —— openssl 对超长行会拒
+	for _, ln := range strings.Split(strings.TrimSpace(pem), "\n") {
+		if strings.HasPrefix(ln, "-----") {
+			continue
+		}
+		if len(ln) > 64 {
+			t.Fatalf("PEM base64 行长度 %d > 64，openssl 会拒绝", len(ln))
+		}
+	}
+
+	// ② 最关键：真签名必须成功（DER/长度/换行任一错都在这里暴露）
+	if ok, _ := inner["signed"].(bool); !ok {
+		t.Fatalf("PEM 重建后 DPoP 签名失败: %v", inner["sign_error"])
+	}
+
+	// ③ 签名产物必须是三段式 JWS（header.payload.signature）
+	//    探针不直接回 JWS，但 signed=true 已表示 codeartsDpopSign 走完了
+	//    整个 openssl 签名 + DER→raw 转换链路（任一环节失败都会返回 nil）。
+}
+
+func firstLine(s string) string {
+	if i := strings.IndexByte(s, '\n'); i >= 0 {
+		return s[:i]
+	}
+	return s
+}
+
+func lastLine(s string) string {
+	s = strings.TrimRight(s, "\n")
+	if i := strings.LastIndexByte(s, '\n'); i >= 0 {
+		return s[i+1:]
+	}
+	return s
+}
+
+// TestCodeartsKeyFromJwkRejectsBadJwk 钉住"坏 JWK 要响亮报错"。
+//
+// 为什么需要：JWK 字段长度不对（例如被截断、或根本不是 P-256）时，
+// 若静默构造出一个畸形 PEM，openssl 只会说「签名失败」—— 运维无从判断
+// 是凭据坏了还是代码坏了。必须在这里给可诊断的消息。
+func TestCodeartsKeyFromJwkRejectsBadJwk(t *testing.T) {
+	cases := []struct {
+		name string
+		jwk  map[string]any
+	}{
+		{"d 太短", map[string]any{
+			"kty": "EC", "crv": "P-256",
+			"d": "AAAA", "x": "r2HUYfG7tMIWY9KOpXLvvMWE_7dnHM9K7p1K7-LSwl4",
+			"y": "0-weI5p_EXZXFfGx4a76X_0oamkLOJ5AA4MOMObL8MM"}},
+		{"缺 x", map[string]any{
+			"kty": "EC", "crv": "P-256",
+			"d": "BpkBLfUUij8IPn0Mzs6C64RfhQkF378yyQPeCR5sh7U"}},
+	}
+	for _, c := range cases {
+		t.Run(c.name, func(t *testing.T) {
+			_, ps := poolCore(t)
+			out, err := ps.Call("channels", "__codearts_jwk_pem_probe", map[string]any{"jwk": c.jwk})
+			if err != nil {
+				return // 调用层报错也算响亮
+			}
+			wrapped, _ := out.(map[string]any)
+			inner, _ := wrapped["json"].(map[string]any)
+			if inner == nil {
+				return
+			}
+			if e, _ := inner["error"].(string); e == "" {
+				if ok, _ := inner["signed"].(bool); ok {
+					t.Fatalf("坏 JWK 竟然签出了名 —— 应当报错")
+				}
+			}
+		})
+	}
+}
+
+// 让 goimports/json 相关导入不被误判未使用（此文件仅用 json 做类型断言辅助）。
+var _ = json.Marshal
+var _ = os.Getenv
+
+// TestB64urlDecodeHandlesLongInput 钉住 base64url 解码的**长输入**正确性。
+//
+// 这个判据补的是一个真实的测漏：我第一版的 b64urlDecode 在输出字节后
+// **没有清除已用掉的高位**（缺 `buf = buf % (2^nbits)`）。用 43 字符的
+// JWK 字段（32 字节）测时**结果完全正确** —— 于是那条 PEM 判据在变异后
+// 依然全绿，什么也没验到。
+//
+// 只有长输入才暴露：累积缓冲不清高位时，double 精度在约 11 个 6bit 组后
+// 耗尽，math.floor 给出越界值，string.char 直接抛 invalid value。
+// 实测：把 `string.rep(43字符JWK, 10)` 喂进去，无掩码版本当场崩。
+//
+// 所以这里必须用**长串**（远超过 11 组），断言解出的字节数与内容都正确。
+func TestB64urlDecodeHandlesLongInput(t *testing.T) {
+	// 96 个字符 → 72 字节。远超溢出临界点（11 组 = 66 bit）。
+	const in = "BpkBLfUUij8IPn0Mzs6C64RfhQkF378yyQPeCR5sh7UBpkBLfUUij8IPn0Mzs6C64RfhQkF378yyQPeCR5sh7U"
+	// 期望值由 Go 标准库算出（不用手写的 Lua 结果做锚，否则自证）
+	want := base64.RawURLEncoding.EncodeToString
+
+	_, ps := poolCore(t)
+	out, err := ps.Call("channels", "__b64_probe", map[string]any{"s": in})
+	if err != nil {
+		t.Fatalf("探针调用失败（很可能是 string.char 越界 = 缺高位掩码）: %v", err)
+	}
+	wrapped, _ := out.(map[string]any)
+	inner, _ := wrapped["json"].(map[string]any)
+	if inner == nil {
+		t.Fatalf("探针返回缺 json 包装: %#v", out)
+	}
+	got, _ := inner["hex"].(string)
+	n, _ := inner["len"].(float64)
+
+	// 期望长度由 Go 自己算（不要手推 len/4*3：输入不一定是 4 的倍数）
+	dec, derr := base64.RawURLEncoding.DecodeString(in)
+	if derr != nil {
+		t.Fatal(derr)
+	}
+	if int(n) != len(dec) {
+		t.Fatalf("解码长度 = %v，期望 %d", n, len(dec))
+	}
+	// 与 Go 解码结果逐字节比对
+	wantHex := ""
+	for _, b := range dec {
+		wantHex += string("0123456789abcdef"[b>>4]) + string("0123456789abcdef"[b&0xf])
+	}
+	if got != wantHex {
+		t.Fatalf("解码内容不符（长输入下高位未清除）:\n got=%s\nwant=%s", got, wantHex)
+	}
+	_ = want
+}

internal/core/channels_dead_model_test.go

@@ -37,6 +37,9 @@ func TestDeadModelGoneJudgement(t *testing.T) {
 		{"The model does not exist", true, "does not exist"},
 		{"error: model_not_found", true, "独占一句话（行尾）"},
 		{"model_not_found.", true, "后面是句末标点"},
+		{"model is not registered", true, "CodeArts/InferHub 下架模型的真实文案"},
+		{"InferHub.002002009.404: The model is not registered, please request other model", true,
+			"CodeArts 完整 404 文案"},
 		// ── 阴性：看着像但**不是**下架 ──
 		{"error_class=model_not_found, retry allowed", false,
 			"字段名后面还有内容（初版误判下架，实测教训）"},

internal/core/channels_endpoint_test.go

@@ -0,0 +1,149 @@
+package core
+
+import (
+	"strings"
+	"testing"
+)
+
+// 渠道端点判据 —— 钉住"base_url 不吞 endpoint 路径"这条铁律。
+//
+// 为什么需要这个测试
+// ------------------
+// 内核的 URL 是 `base_url + endpoint`（provider.go ChatURL）。把路径**同时**
+// 写进 base_url 和 endpoint，拼出来就是重复路径。生产实测两次撞上同一族缺陷：
+//
+//	zcode   base_url=.../api/v1/zcode-plan/anthropic
+//	        endpoint=/api/v1/zcode-plan/anthropic/v1/messages
+//	        ⇒ .../anthropic/api/v1/zcode-plan/anthropic/v1/messages → 404
+//
+//	minimax base_url=https://agent.minimax.cn + adapter=openai（默认 endpoint
+//	        /chat/completions）⇒ 打到 Web 前端首页，404「简单指令，无限可能」
+//
+// 两者报错都是 404，但根因不同（路径重复 / 缺路径段）。单条断言咬不住两种，
+// 所以下面分三条断言。
+
+// platformDef 从**真实加载的插件**里读一个平台定义。
+//
+// ★ 必须走真实加载而不是正则解析源码：PLATFORMS 是 Lua 表，源里有注释、
+// 条件拼装、以及文件末尾的绑定循环（refresh_fn / claim_fn / headers_fn 都在
+// 那里挂）。拿正则在源文本上判断"有没有 refresh 段"会被注释里的字样骗 ——
+// 这个坑我上一轮差点踩进去。探针返回的是插件运行时看到的真相。
+func platformDef(t *testing.T, id string) map[string]any {
+	t.Helper()
+	_, ps := poolCore(t)
+	out, err := ps.Call("channels", "__platform_def_probe", map[string]any{"id": id})
+	if err != nil {
+		t.Fatalf("__platform_def_probe(%s) 失败: %v", id, err)
+	}
+	// Plugins.Call 返回 {json:{...}, status:...} 包装（历史约定）。
+	wrapped, ok := out.(map[string]any)
+	if !ok {
+		t.Fatalf("探针返回不是表: %T", out)
+	}
+	if e, ok := wrapped["error"].(string); ok && e != "" {
+		t.Fatalf("%s: %s", id, e)
+	}
+	inner, ok := wrapped["json"].(map[string]any)
+	if !ok {
+		t.Fatalf("探针返回缺 json 包装: %#v", wrapped)
+	}
+	return inner
+}
+
+// TestChannelBaseURLDoesNotSwallowEndpoint 是最核心的一条：
+// base_url 里**不得**出现 endpoint 也有的路径段。
+//
+// 判别性：zcode 缺陷时 base_url 尾段是 "anthropic"，endpoint 里也含
+// "/anthropic/" ⇒ 命中。修好后 base_url 只到 host，永不命中。
+func TestChannelBaseURLDoesNotSwallowEndpoint(t *testing.T) {
+	for _, id := range []string{"zcode", "minimax", "codearts", "trae", "lobsterai", "buddy"} {
+		t.Run(id, func(t *testing.T) {
+			p := platformDef(t, id)
+			base, _ := p["base_url"].(string)
+			ep, _ := p["endpoint"].(string)
+			base = strings.TrimRight(base, "/")
+			if base == "" {
+				t.Fatalf("%s 没有 base_url", id)
+			}
+
+			// 从 base_url 里取出路径部分（host 之后），逐段看是否也出现在 endpoint 里。
+			pathPart := ""
+			if i := strings.Index(base, "://"); i >= 0 {
+				if j := strings.Index(base[i+3:], "/"); j >= 0 {
+					pathPart = base[i+3+j:]
+				}
+			}
+			if pathPart == "" {
+				return // 只到 host，天然不会重复
+			}
+			for _, seg := range strings.Split(strings.Trim(pathPart, "/"), "/") {
+				if seg == "" {
+					continue
+				}
+				if strings.Contains(ep, "/"+seg+"/") || strings.HasSuffix(ep, "/"+seg) {
+					t.Fatalf("%s: base_url 已含路径段 %q（base_url=%s），"+
+						"endpoint 里又出现（endpoint=%s）⇒ 内核拼 base_url+endpoint 时路径重复",
+						id, seg, base, ep)
+				}
+			}
+		})
+	}
+}
+
+// TestMinimaxUsesAnthropicProtocolAndRealInferPath 钉住 minimax 的两层缺陷。
+//
+// 参考 channel-pack/src/minimax-product.ts：
+//
+//	MINIMAX_INFER_PATH = '/mavis/api/v1/llm/v1/messages'   ← Anthropic Messages
+//	apiHost            = 'https://agent.minimax.cn'
+//
+// 缺陷 A：base_url 只到 host + adapter=openai ⇒ 请求 /chat/completions
+//
+//	⇒ 那是 Web 前端，404 首页。实测（2026-10-19）：
+//	  /mavis/api/v1/llm/v1/messages  → 401 invalid access token（路径对）
+//	  裸 /chat/completions           → 404 page not found
+//	  /mavis/api/v1/chat/completions → 404
+//
+// 缺陷 B：即使路径改对，openai 适配器的**请求体形状**也不对
+//
+//	（minimax 推理端点是 Anthropic 协议）。
+func TestMinimaxUsesAnthropicProtocolAndRealInferPath(t *testing.T) {
+	p := platformDef(t, "minimax")
+	ep, _ := p["endpoint"].(string)
+	adapter, _ := p["adapter"].(string)
+
+	if !strings.HasSuffix(ep, "/mavis/api/v1/llm/v1/messages") {
+		t.Errorf("minimax endpoint = %q，应为 /mavis/api/v1/llm/v1/messages"+
+			"（照参考 MINIMAX_INFER_PATH）；否则请求会打到 Web 前端", ep)
+	}
+	if adapter != "anthropic" {
+		t.Errorf("minimax adapter = %q，应为 anthropic —— 推理端点是 Anthropic "+
+			"Messages 协议，用 openai 适配器会把请求体拼错", adapter)
+	}
+}
+
+// TestCodeartsDeclaresRefreshHook 钉住"声明了可续期就必须声明怎么续"。
+//
+// 真实缺陷（2026-10-19 用户报「华为云源用不了」）：
+// codearts 的 security_token 只活 1 小时；account_refresh 走 refreshCredential()，
+// 它要求 plat.refresh.url 或 plat.refresh_fn 存在。当时只声明了 refreshable=true
+// （那是 accountView 里硬编码的期望），**没声明怎么续** ⇒ 恒出
+// 「该平台未声明续期方式」，自动续期链空转，日志反复 `模型刷新失败 HTTP 400`。
+//
+// 为什么不能只看 refreshable：那是"这个账号的凭据类型可续"，与"平台实现了
+// 续期"是两件事。前者为真而后者缺失，正是这个 bug 的形状。
+func TestCodeartsDeclaresRefreshHook(t *testing.T) {
+	p := platformDef(t, "codearts")
+	hasHook, _ := p["has_refresh_fn"].(bool)
+	hasDecl, _ := p["has_refresh_decl"].(bool)
+	if !hasHook && !hasDecl {
+		t.Fatal("codearts 既无 refresh_fn 也无 refresh.url —— " +
+			"account_refresh 会恒返回「该平台未声明续期方式」，" +
+			"而 STS token 只有 1 小时寿命，过期后源的每个请求都会 400")
+	}
+	// 华为云 STS 要 DPoP 头，声明式 style 拿不到私钥 ⇒ 必须是钩子
+	if !hasHook {
+		t.Error("codearts 只有声明式 refresh.url，但华为云 STS 需要 DPoP 头" +
+			"（jwk 在凭据里），声明式 style 发不出来 ⇒ 必须用 refresh_fn")
+	}
+}

internal/core/channels_gate_test.go

@@ -36,10 +36,12 @@ func TestChannelSourcesAreSerialWithThrottle(t *testing.T) {
 	aid, _ := j["account_id"].(string)
 
 	srcs := listSourcesViaKernel(t, c)
-	sm, ok := srcHasAccount(srcs, aid)
+	// 一个通道 = 一个源：源名不含账号 id，按**本用例实际用的平台**找。
+	sm, ok := srcHasAccount(srcs, "buddy")
 	if !ok {
-		t.Fatal("账号未出源")
+		t.Fatalf("账号未出通道源，实际源: %v", srcs)
 	}
+	_ = aid
 	// ① 串行
 	if mc, _ := toFloat(sm["max_concurrent"]); mc != 1 {
 		t.Errorf("源必须 max_concurrent=1（并发发起必然浪费一个配额），实得 %v", sm["max_concurrent"])

internal/core/channels_legacy_source_cleanup_test.go

@@ -0,0 +1,105 @@
+package core
+
+import (
+	"testing"
+)
+
+// ★ 升级后**旧版按账号拆的源必须被清掉**，否则同一个渠道的模型出现两遍。
+//
+// 真实事故（2026-10-19 用户报「同一个模型两个名字 / 源列表一堆不可读的东西」）：
+// 生产 config.yaml 里 6 对源并存 ——
+//
+//	channels-trae-b8dd6b3df30e   +   channels-trae
+//	channels-buddy-buddy-main    +   channels-buddy
+//	…（trae/lobsterai/minimax/buddy/codearts/zcode 各一对）
+//
+// 新设计是「一通道一源」（`channels-<provider>`），换号靠同名 add_source 覆盖
+// api_key。旧版是「一账号一源」（`channels-<provider>-<账号id>`）。升级时必须把
+// 旧形态清掉，否则：
+//
+//	① 模型列表里同一模型出现多遍，只能靠 12 位 hex 区分（人读不出来）
+//	② 旧源指向已不该用的账号，却可能因为注册更早而**先**被调度到
+//
+// 根因是形态假设错了：内核 `list_sources` 返回**裸数组**（见 kernel_actions.go
+// 的 actionListSources，直接 `return out`），而迁移代码按 `{sources:[...]}`
+// 信封去取 ⇒ 恒为 nil ⇒ 循环一次都不跑 ⇒ 静默什么都没清。
+//
+// ★ 本判据的关键是**用裸数组形态喂数据**（也就是内核真实返回的形状）。
+//
+//	如果按信封造夹具，即使代码是错的两边也"对上了"，测不出任何东西 ——
+//	这正是这个 bug 逃过全部既有判据的原因。
+func TestChannelsLegacyPerAccountSourceIsCleaned(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.Fatalf("加载插件: %v", err)
+	}
+	if err := ps.SetPluginKernelPermission("channels",
+		[]string{"add_source", "remove_source", "list_sources", "status"}, false); err != nil {
+		t.Fatalf("授权: %v", err)
+	}
+
+	// 造存量：一个旧形态源（带账号 hex）+ 一个别的通道的旧源（不该被误删）。
+	mk := func(name string) {
+		if _, err := ps.Call("channels", "__add_source_for_test", map[string]interface{}{
+			"name":     name,
+			"base_url": "https://example.invalid",
+			"adapter":  "openai",
+			"api_key":  "sk-x",
+			"models":   []interface{}{"m1"},
+		}); err != nil {
+			t.Fatalf("造源 %s: %v", name, err)
+		}
+	}
+	mk("channels-trae-b8dd6b3df30e") // 旧形态：trae 的某个账号
+	mk("channels-trae-deadbeef0123") // 旧形态：trae 的另一个账号
+	mk("channels-buddy-buddy-main")  // 别的通道 —— 不该被 trae 的同步碰到
+	mk("unrelated-source")           // 与 channels 无关，绝不能被删
+
+	// 放一个**真实**的 trae 账号（走 account_add，不是探针）：没有账号就无从
+	// 写源，也就走不到「写前先清旧源」那一步。account_add 本身也会同步一次源，
+	// 但那正是要测的路径。
+	if _, err := ps.Call("channels", "account_add", map[string]interface{}{
+		"platform": "trae", "account_id": "b8dd6b3df30e",
+		"credential": `{"access_token":"T","refresh_token":"R","nickname":"n"}`,
+	}); err != nil {
+		t.Fatalf("造账号: %v", err)
+	}
+
+	// ★ 只走 `syncAccountSource` → `syncProviderSource` 这条路（迁移清理就在这里）。
+	//   刻意**不用** reap_orphan_sources：它自己另有一套"形态 1 旧源"清理逻辑，
+	//   会把这里要测的迁移代码完全遮住 —— 用它做判据时，即使迁移代码是坏的
+	//   （信封假设的 bug 仍在）判据也会绿，等于没测。
+	if _, err := ps.Call("channels", "__resync_sources_probe", map[string]interface{}{
+		"platform": "trae",
+	}); err != nil {
+		t.Fatalf("resync: %v", err)
+	}
+
+	names := map[string]bool{}
+	for _, s := range c.Sources() {
+		names[s.Name] = true
+	}
+
+	for _, legacy := range []string{"channels-trae-b8dd6b3df30e", "channels-trae-deadbeef0123"} {
+		if names[legacy] {
+			t.Errorf("旧形态源 %s 没被清掉 —— 同一渠道的模型会在列表里出现两遍，"+
+				"只能靠 12 位 hex 区分，用户读不出哪个是哪个", legacy)
+		}
+	}
+	if !names["channels-trae"] {
+		t.Error("新形态源 channels-trae 没建起来")
+	}
+	if names["unrelated-source"] != true {
+		t.Error("清理误伤了无关源 unrelated-source")
+	}
+	// ★ 这里才是真的越界判据：trae 的同步**只**该清 `channels-trae-` 前缀的旧源。
+	//   如果前缀匹配写成贪婪/过宽（例如 `channels-(.+)-`），buddy 的源会被误删。
+	if !names["channels-buddy-buddy-main"] {
+		t.Error("清理越界：trae 的同步删掉了 buddy 的源（前缀匹配过宽）")
+	}
+}

internal/core/channels_log_panel_test.go

@@ -79,9 +79,17 @@ func TestChannelsPeriodicTaskLogsAreDowngraded(t *testing.T) {
 			t.Errorf("异常必须保持 warn（不能被当常规噪音折叠）：%s", pat)
 		}
 	}
-	// 「已同步源」是周期重同步的常规回音 —— 降级为 task
-	if !strings.Contains(s, `logEvent("已同步源 " .. name .. "（" .. #models .. " 模型）", "task", provider)`) {
-		t.Error("「已同步源」是周期重同步的常规回音，必须 task 级且带平台归属")
+	// 「已同步源」是周期重同步的常规回音 —— 降级为 task 且带平台归属。
+	// 文案在"一个通道=一个源"重构后多带了账号 id（便于排查"用的是哪个号"），
+	// 故这里只钉住"task 级 + 带 provider"这两个**语义**要件，不钉住整句字面量 ——
+	// 钉字面量会让每次改文案都要改测试，而这条测试要防的是"级别升回 info"。
+	if !strings.Contains(s, `logEvent("已同步源 " .. name`) {
+		t.Error("「已同步源」这条回音丢了（改名了？）")
+	}
+	// 匹配"已同步源 ... "task", provider)"——跨行（文案带账号 id 后跨了两行），
+	// 故用 (?s) 让 . 能匹配换行。
+	if !regexp.MustCompile(`(?s)logEvent\("已同步源 " \.\. name.*?"task", provider\)`).MatchString(s) {
+		t.Error("「已同步源」是周期重同步的常规回音，必须 task 级且带平台归属（provider）")
 	}
 	t.Log("✓ 周期噪音已降级，异常保持 warn")
 }

internal/core/channels_orphan_source_test.go

@@ -45,24 +45,31 @@ func TestChannelsReapOrphanSources(t *testing.T) {
 	// （账号已删、撤源被拒 ⇒ 源留下继续对外服务）。
 	// 不走 account_delete：那条路径的收尾已被 TestAccountDelete* 覆盖，
 	// 而我们要的恰恰是"源留下了"这个状态。
-	if r, err := ps.Call("channels", "account_add", map[string]interface{}{
-		"platform": "buddy", "account_id": "deadbeef1234", "credential": "test-cred",
+	//
+	// ★ 一通道一源之后：`account_add` 产生的源名是 `channels-buddy`（不含账号 id），
+	//   所以它**造不出**本用例要的「旧版按账号拆源」形态。这里直接用
+	//   __add_source_for_test 注册遗留形态的源名 —— 这才是要验的对象本身
+	//   （reap 的职责就是清掉升级前遗留的这类源）。
+	if r, err := ps.Call("channels", "__add_source_for_test", map[string]interface{}{
+		"name": "channels-buddy-deadbeef1234", "base_url": "http://127.0.0.1:1",
+		"adapter": "openai", "models": []interface{}{"m1"},
 	}); err != nil {
-		t.Fatalf("account_add: %v", err)
+		t.Fatalf("注册遗留源(1): %v", err)
 	} else if j := jsonOf(t, r); j["error"] != nil {
-		t.Fatalf("account_add 报错: %v", j["error"])
+		t.Fatalf("注册遗留源(1) 报错: %v", j["error"])
 	}
 	// ★ 第二个孤儿：账号 id **含 `-`**。这个用例是判别性的 ——
 	//   用 `name:match("^channels%-(.+)-(.+)$")` 解析会被 Lua 的**贪婪** `-`
 	//   切成 plat="buddy-dead"/acct="acct"（未知平台）⇒ 源被跳过 ⇒ **孤儿漏杀**。
 	//   （实测：只有这个用例能把"按已知平台前缀匹配"与"贪婪匹配"区分开；
 	//     不含 `-` 的 id 两种实现结果相同，咬不住。）
-	if r, err := ps.Call("channels", "account_add", map[string]interface{}{
-		"platform": "buddy", "account_id": "dead-acct-1", "credential": "test-cred",
+	if r, err := ps.Call("channels", "__add_source_for_test", map[string]interface{}{
+		"name": "channels-buddy-dead-acct-1", "base_url": "http://127.0.0.1:1",
+		"adapter": "openai", "models": []interface{}{"m1"},
 	}); err != nil {
-		t.Fatalf("account_add(2): %v", err)
+		t.Fatalf("注册遗留源(2): %v", err)
 	} else if j := jsonOf(t, r); j["error"] != nil {
-		t.Fatalf("account_add(2) 报错: %v", j["error"])
+		t.Fatalf("注册遗留源(2) 报错: %v", j["error"])
 	}
 	// 运维手工源：名字与账号源形态无关 ⇒ 绝不碰
 	if r, err := ps.Call("channels", "__add_source_for_test", map[string]interface{}{
@@ -75,14 +82,7 @@ func TestChannelsReapOrphanSources(t *testing.T) {
 		//   Go 侧 err 仍是 nil ⇒ 只查 err 会让"源根本没注册"静默通过。
 		t.Fatalf("注册手工源报错: %v", j["error"])
 	}
-	// 摘账号（保留源）
-	for _, id := range []string{"deadbeef1234", "dead-acct-1"} {
-		if _, err := ps.Call("channels", "__forget_account_probe", map[string]interface{}{
-			"platform": "buddy", "account_id": id,
-		}); err != nil {
-			t.Fatalf("摘账号 %s: %v", id, err)
-		}
-	}
+	// 遗留源对应的账号本来就不存在（这正是"孤儿"的定义），无需再摘。
 
 	// ① dry_run（默认）只报告、不删
 	res, err := ps.Call("channels", "reap_orphan_sources", map[string]interface{}{})

internal/core/channels_pool_test.go

@@ -120,9 +120,17 @@ func TestChannelsAccountPoolBehavior(t *testing.T) {
 	t.Run("模型开关同步上游源", func(t *testing.T) {
 		m := invoke(t, ps, "account_add", `{"platform":"minimax","credential":"MM-KEY"}`)
 		aid, _ := m["account_id"].(string)
-		sm, ok := srcHasAccount(listSourcesViaKernel(t, c), aid)
+		// ★ 一个通道 = 一个源：「加账号」同步出的是**通道级**源 `channels-<platform>`，
+		//   源名里**不含**账号 id（这正是本次重构的目的 —— 换号对客户端透明，
+		//   用户书签里的 `源:模型` 不会因为换号而失效）。
+		//   故这里按平台名找源，不按 aid 找。
+		sm, ok := srcHasAccount(listSourcesViaKernel(t, c), "minimax")
 		if !ok {
-			t.Fatal("带凭据账号应已同步源")
+			t.Fatalf("带凭据账号应已同步出通道源，实际源: %v", listSourcesViaKernel(t, c))
+		}
+		// 而且源名必须是通道级那个（旧版会带 -<12hex> 后缀）
+		if nm, _ := sm["name"].(string); nm != "channels-minimax" {
+			t.Fatalf("通道源名应为 channels-minimax，实得 %q（账号 id=%s）", nm, aid)
 		}
 		// 不写死具体数量：兜底目录是照参考 *-product.ts 补的，会随对齐
 		// 进度变化（minimax 已从 3 项补到 4 项）。这里断言的是**关系**：
@@ -133,7 +141,8 @@ func TestChannelsAccountPoolBehavior(t *testing.T) {
 			t.Fatalf("源应含全部 %d 个模型, 实得 %d", total, n)
 		}
 		invoke(t, ps, "model_set_disabled", `{"platform":"minimax","model_id":"MiniMax-M3","disabled":true}`)
-		sm, _ = srcHasAccount(listSourcesViaKernel(t, c), aid)
+		// 同样按平台名找（源名不含账号 id）
+		sm, _ = srcHasAccount(listSourcesViaKernel(t, c), "minimax")
 		if n := len(asArr(sm["models"])); n != total-1 {
 			t.Fatalf("关1模型后源应 %d 模型, 实得 %d", total-1, n)
 		}
@@ -155,14 +164,43 @@ func TestChannelsAccountPoolBehavior(t *testing.T) {
 			t.Fatal("上个用例应留有账号")
 		}
 		aid := accts[0].(map[string]interface{})["id"].(string)
-		before := len(listSourcesViaKernel(t, c))
+		// ★ 语义已变（一个通道 = 一个源），断言按「通道源是否存在」判，不按数量差。
+		//
+		//   为什么不能断言 `after == before-1`：内核的 remove_source 有一条正当
+		//   保护 —— **拒绝删掉最后一个源**（空 registry 会让每个请求变 503）。
+		//   本夹具只有这一个源，撤源请求会被这条保护挡住，数量差恒为 0，
+		//   于是断言无论实现对错都失败。生产上有 20+ 源不会撞这条保护，
+		//   但判据不能依赖"恰好有别的源"这种环境事实。
+		if _, ok := srcHasAccount(listSourcesViaKernel(t, c), "minimax"); !ok {
+			t.Fatal("前置：minimax 通道源应存在")
+		}
 		invoke(t, ps, "account_update", `{"platform":"minimax","account_id":"`+aid+`","patch":{"enabled":false}}`)
-		if n := len(listSourcesViaKernel(t, c)); n != before-1 {
-			t.Fatalf("停用账号应删源: 前 %d 后 %d", before, n)
+		// 停用唯一账号 ⇒ 该通道无可用号 ⇒ 插件**尝试**撤源。夹具里会撞上内核
+		// 「拒绝删最后一个源」的保护，故不断言源数量，改断言插件自己的判据：
+		// provider_status 里该通道的 enabled 应转为 false（无可用账号）。
+		// ⚠️ provider_status 的字段形状：`enabled` 是**嵌套在 accounts 里的计数**
+		//    （accounts = {total=N, enabled=M}），不是顶层布尔。顶层只有 `closed`
+		//    （表示"该平台所有模型都被关掉"）。写断言前必须看清形状 ——
+		//    我第一版按顶层 `enabled == false` 判，永远不成立。
+		st := invoke(t, ps, "provider_status", `{}`)
+		noUsable := false
+		for _, x := range asArr(st["statuses"]) {
+			row := x.(map[string]interface{})
+			if row["id"] != "minimax" {
+				continue
+			}
+			if acc, ok := row["accounts"].(map[string]interface{}); ok {
+				if n, _ := acc["enabled"].(float64); n == 0 {
+					noUsable = true
+				}
+			}
+		}
+		if !noUsable {
+			t.Fatalf("停用唯一账号后，minimax 的 accounts.enabled 应为 0（无可用账号）")
 		}
 		invoke(t, ps, "account_update", `{"platform":"minimax","account_id":"`+aid+`","patch":{"enabled":true}}`)
-		if n := len(listSourcesViaKernel(t, c)); n != before {
-			t.Fatalf("启用账号应重建源: 前 %d 后 %d", before, n)
+		if n := len(listSourcesViaKernel(t, c)); n < 1 {
+			t.Fatalf("启用账号后应重建源，实际源数 %d", n)
 		}
 	})
 

internal/core/channels_private_adapter_wiring_test.go

@@ -49,16 +49,17 @@ func TestPrivateProtocolSourcesUsePluginAdapters(t *testing.T) {
 			if j == nil || j["error"] != nil {
 				t.Fatalf("account_add 报错: %#v", m)
 			}
-			aid, _ := j["account_id"].(string)
+			_, _ = j["account_id"].(string)
 
 			srcs := listSourcesViaKernel(t, c)
-			sm, ok := srcHasAccount(srcs, aid)
+			// ★ 一通道一源：按**平台名**找源，不按账号 id（源名已不含 id）。
+			sm, ok := srcHasAccount(srcs, tc.platform)
 			if !ok {
 				names := []string{}
 				for _, x := range srcs {
 					names = append(names, x["name"].(string))
 				}
-				t.Fatalf("%s 账号加了却不出源（现有源: %v）—— 源注册失败通常是"+
+				t.Fatalf("%s 账号加了却不出通道源（现有源: %v）—— 源注册失败通常是"+
 					"凭据形状不符或内核权限未授", tc.platform, names)
 			}
 			ad, _ := sm["adapter"].(string)

internal/core/channels_qoder_claim_test.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"net/http"
 	"net/http/httptest"
+	"strings"
 	"testing"
 	"time"
 
@@ -220,3 +221,75 @@ func TestQoderRefreshUsesUTC8NotLocalTime(t *testing.T) {
 		})
 	}
 }
+
+// 裸 token 凭据必须能领：qoder 是 PKCE 设备码流且无 register 第二跳，
+// complete_login 存的就是裸 access_token 字符串（真实生产事故：账号池凭据是
+// dt-… 裸串，claim 报「缺少凭据对象」，而 account_test 用 token 路径照常通过
+// —— 自相矛盾的状态）。活动接口只要 Bearer token，就地包一层即可。
+func TestQoderClaimAcceptsBareTokenCredential(t *testing.T) {
+	var auth string
+	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Content-Type", "application/json")
+		auth = r.Header.Get("Authorization")
+		switch {
+		case r.URL.Path == "/sash/api/v1/me/campaigns":
+			fmt.Fprint(w, `{"showCampaign":true,"claimable":true,"campaigns":[
+				{"campaignId":"C1","actionType":"CLAIM_BENEFIT","claimStatus":"CLAIMABLE","benefit":{"amount":100}}]}`)
+		case len(r.URL.Path) > len("/sash/api/v1/me/campaigns/") &&
+			r.URL.Path[len(r.URL.Path)-len("/claim"):] == "/claim":
+			fmt.Fprint(w, `{"status":"CLAIMED","amount":100}`)
+		default:
+			w.WriteHeader(404)
+		}
+	}))
+	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)
+	}
+	if _, err := ps.Call("channels", "set_endpoints", map[string]interface{}{
+		"platform":        "qoder",
+		"qoder_sash_base": map[string]interface{}{"url": ts.URL},
+	}); err != nil {
+		t.Fatal(err)
+	}
+	// 与生产一致：凭据是**裸 token 字符串**（不是 JSON 对象）。
+	body, _ := json.Marshal(map[string]string{
+		"platform": "qoder", "credential": "dt-D6t0cFLOY3fpSmu2Mck2WWeO", "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":"qoder"}`,
+	})
+	if err != nil {
+		t.Fatalf("claim_daily: %v", err)
+	}
+	j, _ := out.JSON.(map[string]interface{})
+	oc, _ := j["outcome"].(map[string]interface{})
+	if oc == nil {
+		t.Fatalf("应返回 outcome，实得 %v", j)
+	}
+	// claim_daily 的通用路径把 claim_fn 的 kind=claimed 归一成 success + message；
+	// 判据是**不再是 failed** 且消息带领取金额。
+	kind, _ := oc["kind"].(string)
+	if kind == "failed" {
+		t.Fatalf("裸 token 凭据应能领取，实得 kind=failed（%v）", oc["message"])
+	}
+	if msg, _ := oc["message"].(string); !strings.Contains(msg, "100") {
+		t.Errorf("领取成功消息应带金额，实得 %q", msg)
+	}
+	if auth != "Bearer dt-D6t0cFLOY3fpSmu2Mck2WWeO" {
+		t.Errorf("活动接口必须带 Bearer 裸 token，实得 %q", auth)
+	}
+}

internal/core/channels_remove_source_perm_test.go

@@ -23,14 +23,14 @@ func TestAccountDeleteRemovesItsSource(t *testing.T) {
 	t.Run("授予 remove_source 时应撤掉源", func(t *testing.T) {
 		h := newRemoveSourceHarness(t, true)
 		h.addAccount("del-a")
-		if got := h.sourceNames(); !hasName(got, "channels-buddy-del-a") {
-			t.Fatalf("前置条件：账号源应已建立，实得 %v", got)
+		if got := h.sourceNames(); !hasName(got, "channels-buddy") {
+			t.Fatalf("前置条件：通道源应已建立（一通道一源：channels-buddy），实得 %v", got)
 		}
 		h.deleteAccount("del-a")
-		if got := h.sourceNames(); hasName(got, "channels-buddy-del-a") {
-			t.Fatalf("账号已删但源仍在 ⇒ 已删账号继续对外服务：%v", got)
+		if got := h.sourceNames(); hasName(got, "channels-buddy") {
+			t.Fatalf("唯一账号已删但通道源仍在 ⇒ 已删账号继续对外服务：%v", got)
 		}
-		t.Log("✓ 删除账号同时撤掉其源")
+		t.Log("✓ 删除唯一账号同时撤掉通道源")
 	})
 
 	t.Run("未授予 remove_source 时必须**可见地**失败（不能静默）", func(t *testing.T) {
@@ -41,7 +41,7 @@ func TestAccountDeleteRemovesItsSource(t *testing.T) {
 		// 我们要判的是：**这件事必须被记录下来**，而不是消失在一个被丢弃的返回值里。
 		logs := h.eventLog()
 		joined := strings.Join(logs, " | ")
-		if !strings.Contains(joined, "撤源失败") {
+		if !strings.Contains(joined, "撤旧源失败") && !strings.Contains(joined, "撤源失败") {
 			t.Fatalf("撤源被拒却没有任何记录 ⇒ 权限缺失会一直静默（表现是"+
 				"「删了账号却还在用」）\n事件日志: %s", joined)
 		}

internal/core/core.go

@@ -11,7 +11,6 @@ import (
 	"net/url"
 	"os"
 	"path/filepath"
-	"sort"
 	"strings"
 	"sync"
 	"sync/atomic"
@@ -150,9 +149,6 @@ func NewFromConfig(cfg *config.Config) (*Core, error) {
 	if err := c.seedKeys(); err != nil {
 		return nil, err
 	}
-	if err := c.seedAuto(); err != nil {
-		return nil, err
-	}
 	if err := c.rebuildRegistry(); err != nil {
 		return nil, err
 	}
@@ -195,39 +191,6 @@ func (c *Core) migrateFromRuntime() {
 	}
 }
 
-// seedAuto uses the existing auto rules from config.yaml, or creates an
-// initial chain from legacy per-source model priority (first run only).
-func (c *Core) seedAuto() error {
-	if len(c.cfg.Auto) > 0 {
-		return nil
-	}
-	type item struct {
-		model string
-		prio  int
-	}
-	var flat []item
-	for _, s := range c.mergedSources() {
-		for _, m := range s.Models {
-			if m.Kind == "image" {
-				continue
-			}
-			flat = append(flat, item{m.ID, m.Priority})
-		}
-	}
-	sort.SliceStable(flat, func(i, j int) bool {
-		if flat[i].prio != flat[j].prio {
-			return flat[i].prio > flat[j].prio
-		}
-		return flat[i].model < flat[j].model
-	})
-	entries := make([]config.ModelScope, 0, len(flat))
-	for _, it := range flat {
-		entries = append(entries, config.ModelScope{Model: it.model})
-	}
-	c.cfg.Auto = entries
-	return c.cfg.Save()
-}
-
 // seedKeys ensures config.yaml has admin keys for every gateway_keys entry
 // from the YAML config (once). After first save they become GWKey records
 // in c.cfg.Keys and gateway_keys is no longer read for auth.
@@ -877,9 +840,23 @@ func (c *Core) Reload() error {
 // ---- adapter management (web UI) ----
 
 func (c *Core) ListAdapters() []lua.APIAdapter {
+	c.syncHiddenRefs()
 	return c.vm.ListAdapters()
 }
 
+// syncHiddenRefs 把"当前被源引用的适配器"同步给 VM。被引用的 hidden=true 适配器
+// 必须保持可见（源编辑器要回显当前值）；没被引用的隐藏适配器从列表消失。
+// 每次 ListAdapters 前调用：源集合是动态的（运行时可增删），推模型容易漏。
+func (c *Core) syncHiddenRefs() {
+	refs := []string{}
+	for _, s := range c.mergedSources() {
+		if s.Adapter != "" {
+			refs = append(refs, s.Adapter)
+		}
+	}
+	c.vm.SetHiddenRefs(refs)
+}
+
 func (c *Core) UploadAdapter(name, code string) error {
 	if name == "" {
 		return fmt.Errorf("adapter name required")

internal/core/core_test.go

@@ -22,7 +22,7 @@ func newTestConfig(t *testing.T) *config.Config {
 		DefaultModel: "AUTO",
 		GatewayKeys:  []string{"sk-gw-test"},
 		Sources: []config.Source{
-			{Name: "s1", BaseURL: "http://127.0.0.1:1/v1", Adapter: "openai", Models: []config.Model{{ID: "gpt-4o", Priority: 10}}},
+			{Name: "s1", BaseURL: "http://127.0.0.1:1/v1", Adapter: "openai", Models: []config.Model{{ID: "gpt-4o"}}},
 		},
 	}
 }

internal/core/key_auto_concurrency_test.go

@@ -151,7 +151,7 @@ func TestAutoChainForConcurrentWithSourceChanges(t *testing.T) {
 			name := fmt.Sprintf("churn%d", n)
 			_ = c.AddSource(config.Source{
 				Name: name, BaseURL: "http://127.0.0.1:9/v1", Adapter: "openai",
-				Models: []config.Model{{ID: "m-" + name, Priority: 10}}},
+				Models: []config.Model{{ID: "m-" + name}}},
 			)
 			_ = c.RemoveSource(name)
 		}

internal/core/key_auto_test.go

@@ -32,7 +32,7 @@ func perKeyTestConfig(t *testing.T) *config.Config {
 		GatewayKeys:  []string{"sk-gw-admin"},
 		Sources: []config.Source{
 			{Name: "s1", BaseURL: "http://127.0.0.1:1/v1", Adapter: "openai",
-				Models: []config.Model{{ID: "gpt-4o", Priority: 10}, {ID: "gpt-4o-mini", Priority: 5}}},
+				Models: []config.Model{{ID: "gpt-4o"}, {ID: "gpt-4o-mini"}}},
 		},
 		// Global chain points at gpt-4o.
 		Auto: []config.ModelScope{{Model: "gpt-4o", Source: "s1", Tier: 1}},
@@ -198,7 +198,7 @@ func TestKeyAutoChainsRebuildOnSourceChange(t *testing.T) {
 	// Add the source; the per-key chain must pick it up without a restart.
 	cfg.Sources = append(cfg.Sources, config.Source{
 		Name: "s2", BaseURL: "http://127.0.0.1:2/v1", Adapter: "openai",
-		Models: []config.Model{{ID: "new-model", Priority: 10}},
+		Models: []config.Model{{ID: "new-model"}},
 	})
 	if err := c.Reload(); err != nil {
 		t.Fatalf("Reload: %v", err)

internal/core/startup_secrets_test.go

@@ -42,7 +42,7 @@ func writeSealedInstall(t *testing.T, dir string) string {
 		GatewayKeys:  []string{"sk-gw-seed-me"},
 		Sources: []config.Source{{
 			Name: "up", BaseURL: "http://127.0.0.1:1/v1", APIKey: "sk-upstream-secret",
-			Adapter: "openai", Models: []config.Model{{ID: "gpt-4o", Priority: 10}},
+			Adapter: "openai", Models: []config.Model{{ID: "gpt-4o"}},
 		}},
 	}
 	c, err := NewFromConfig(cfg)
@@ -76,7 +76,7 @@ func writeSealedInstallNoSeed(t *testing.T, dir string) string {
 		DefaultModel: "AUTO",
 		Sources: []config.Source{{
 			Name: "up", BaseURL: "http://127.0.0.1:1/v1", APIKey: "sk-upstream-secret",
-			Adapter: "openai", Models: []config.Model{{ID: "gpt-4o", Priority: 10}},
+			Adapter: "openai", Models: []config.Model{{ID: "gpt-4o"}},
 		}},
 	}
 	c, err := NewFromConfig(cfg)

internal/gateway/discover.go

@@ -535,11 +535,11 @@ type modelCaps struct {
 }
 
 type upstreamModel struct {
-	ID       string `json:"id"`
-	Object   string `json:"object"`
-	Kind     string `json:"kind"`
-	Type     string `json:"type"`
-	Modality string `json:"modality"`
+	ID           string `json:"id"`
+	Object       string `json:"object"`
+	Kind         string `json:"kind"`
+	Type         string `json:"type"`
+	Modality     string `json:"modality"`
 	Architecture struct {
 		InputModalities  []string `json:"input_modalities"`
 		OutputModalities []string `json:"output_modalities"`
@@ -699,8 +699,8 @@ func modelMeta(m upstreamModel) map[string]interface{} {
 		}
 	}
 
-	copyFields(m.Metadata)      // nested first
-	copyFields(mustJSON(m))     // top level wins
+	copyFields(m.Metadata)  // nested first
+	copyFields(mustJSON(m)) // top level wins
 	if len(meta) == 0 {
 		return nil
 	}
@@ -740,10 +740,10 @@ func mustJSON(v interface{}) []byte {
 func modelsToConfig(chat, image []string) []config.Model {
 	out := make([]config.Model, 0, len(chat)+len(image))
 	for _, id := range chat {
-		out = append(out, config.Model{ID: id, Priority: 50, Kind: "chat"})
+		out = append(out, config.Model{ID: id, Kind: "chat"})
 	}
 	for _, id := range image {
-		out = append(out, config.Model{ID: id, Priority: 70, Kind: "image"})
+		out = append(out, config.Model{ID: id, Kind: "image"})
 	}
 	return out
 }

internal/gateway/discover_api.go

@@ -61,6 +61,20 @@ type discoverRequest struct {
 	// a typo here would produce a source that 404s on every request.
 	Include []string `json:"include,omitempty"`
 	Exclude []string `json:"exclude,omitempty"`
+
+	// ImageModels names ids that are **kind=image** but whose upstream catalog
+	// does not say so.
+	//
+	// 为什么需要（真实缺口）：discoveredModelKind 只看上游的 modality 字段，
+	// 并且刻意**不从模型名推断**（那会把 "gpt-image-1" 这类同名聊天模型
+	// 错归成生图，而错误的 kind 会毒死 AUTO 链）。
+	// 但有些网关的 `/v1/models` 只返回 `{id,object,created,owned_by}` ——
+	// 零 modality（实测：某聚合网关的 3 个 gpt-image-* 全部落成 chat，
+	// 于是生图端点永远报 `no image source configured`）。
+	//
+	// 两条原则都不破：不猜（默认仍完全按元数据），但允许**显式声明**。
+	// 只影响写入的 kind，不影响目录里有没有这个模型。
+	ImageModels []string `json:"image_models,omitempty"`
 }
 
 // discoverResponse is the JSON the WebUI binds to.
@@ -117,8 +131,36 @@ func (g *Gateway) handleSourceDiscoverAPI(w http.ResponseWriter, r *http.Request
 		return
 	}
 	req.BaseURL = strings.TrimSpace(req.BaseURL)
+	req.Name = strings.TrimSpace(req.Name)
+
+	// ★ 只给 `name`（或两者都给但 key 为空）⇒ **从已存源取 base_url 与凭据**。
+	//
+	// 为什么必须有这条路径（真实痛点）：刷新一个**已存在**源的模型目录，此前
+	// 必须让运维把明文 key 再粘一次 —— 而库里的 key 是 `enc:v1:` 密文，
+	// 运维手里未必还有原文；WebUI 也不回显明文（这是正确的安全设计）。
+	// 结果就是「想刷新目录 → 必须重新申请/粘贴一次 key」，很多人干脆不刷新，
+	// 于是源的模型目录越放越旧（实例：某源的 3 个生图模型从未被登记）。
+	//
+	// 安全边界：① 已要求 admin 角色；② 只能探测**本网关已配置的**源，
+	// 不能借此拿任意 URL + 任意 key 做探测（那样就成了 SSRF/密钥外带渠道）；
+	// ③ 响应不回显 key（只回目录）。
+	if req.Name != "" {
+		if old := g.sourceByName(req.Name); old != nil {
+			if req.BaseURL == "" {
+				req.BaseURL = old.BaseURL
+			}
+			if req.APIKey == "" {
+				req.APIKey = old.APIKey
+			}
+			if req.Adapter == "" {
+				req.Adapter = old.Adapter
+			}
+		}
+	}
+
 	if req.BaseURL == "" {
-		writeError(w, http.StatusBadRequest, "invalid_request", "base_url required")
+		writeError(w, http.StatusBadRequest, "invalid_request",
+			"base_url required (or pass name of an existing source to reuse its base_url and credential)")
 		return
 	}
 	if req.Adapter == "" {
@@ -144,6 +186,58 @@ func (g *Gateway) handleSourceDiscoverAPI(w http.ResponseWriter, r *http.Request
 		return
 	}
 
+	// ★ 显式生图声明：把 operator 点名的 id 从 chat 挪到 image。
+	//
+	// 放在 selectModels **之前**：后者按 include/exclude 裁剪两个列表，
+	// 挪类必须在裁剪前完成，否则一个"只声明成生图、又被 include 选中"的
+	// 模型会先在 chat 里被保留、再被这里挪走 —— 顺序反了会得到两份。
+	//
+	// 只认**目录里确实存在的** id：写错一个字不该静默造出一个不存在的模型
+	// （那会让源在每次照片请求时 404），而是明确报错。
+	if len(req.ImageModels) > 0 {
+		have := map[string]bool{}
+		for _, m := range res.Models {
+			have[m] = true
+		}
+		for _, m := range res.ImageModels {
+			have[m] = true
+		}
+		var missing []string
+		force := map[string]bool{}
+		for _, id := range req.ImageModels {
+			if !have[id] {
+				missing = append(missing, id)
+				continue
+			}
+			force[id] = true
+		}
+		if len(missing) > 0 {
+			writeError(w, http.StatusBadRequest, "invalid_request",
+				"image_models contains ids that are not in the upstream catalog: "+
+					strings.Join(missing, ", "))
+			return
+		}
+		var keepChat []string
+		for _, m := range res.Models {
+			if !force[m] {
+				keepChat = append(keepChat, m)
+			}
+		}
+		seenImg := map[string]bool{}
+		var newImage []string
+		for _, m := range res.ImageModels {
+			seenImg[m] = true
+			newImage = append(newImage, m)
+		}
+		for id := range force {
+			if !seenImg[id] {
+				newImage = append(newImage, id)
+			}
+		}
+		res.Models = keepChat
+		res.ImageModels = newImage
+	}
+
 	chat, image, warns, err := selectModels(res.Models, res.ImageModels, req.Include, req.Exclude)
 	if err != nil {
 		// 400: the operator asked for a model the catalog does not have.

internal/gateway/discover_test.go

@@ -497,9 +497,6 @@ func TestModelsToConfig_PrioritiesAndKinds(t *testing.T) {
 	if got[2].ID != "img1" || got[2].Kind != "image" {
 		t.Errorf("image model mis-sorted: %+v", got[2])
 	}
-	if got[2].Priority <= got[0].Priority {
-		t.Errorf("image model priority %d should sort after chat %d", got[2].Priority, got[0].Priority)
-	}
 }
 
 // TestDiscoverModels_ImageModelsNeverNull guards the UI contract end to end,

internal/gateway/gateway_test.go

@@ -53,6 +53,42 @@ func newTestGateway(t *testing.T, srcs ...config.Source) *Gateway {
 	if err := cfg.ApplyDefaults(); err != nil {
 		t.Fatal(err)
 	}
+	// ★ 测试默认建一条 AUTO 链（每个源一个 tier，按传入顺序），因为内核
+	//   **不再** seedAuto 自动播种规则了（那条废弃逻辑已删除：AUTO 链为空时
+	//   网关应当直接 503，而不是凭空生成一堆用户没配过的档位）。
+	//
+	//   但既有测试大量依赖"AUTO 能跑"，它们此前是隐式吃 seedAuto 的。这里显式
+	//   建链，既保持测试原意（验调度而不是验播种），也让"空链=503"成为
+	//   一个**可以单独断言**的行为（见 TestChatAutoEmptyChainIsRejected）。
+	//
+	//   顺序沿用 seedAuto 的老口径：**源按"最后一个最先"排**（tier 1 = 最后
+	//   传入的源）。既有用例靠这个语义挑"high"源（TestChatAUTO 期望 high-m），
+	//   改成正序会让一批用例因为"挑到了另一个源"而红，而那与本次重构无关。
+	//
+	//   所有源放在**同一个 tier**（tier 1），而不是一个源一个 tier：链内同一
+	//   tier 的多个 slot 会互相 failover，这正是 TestChatAutoChainTierFailover
+	//   要验的行为（"a 挂 500 → 请求由 b 服务"）。一源一 tier 会让 a 独占 tier1，
+	//   b 在 tier2 永远轮不到，"两个源都被打过"这条断言就必然失败。
+	if len(cfg.Auto) == 0 && len(srcs) > 0 {
+		// 一源一 tier，**倒序**：最后传入的源拿 tier 1（最先尝试）。
+		// TestChatAUTO（low 先传、high 后传，期望 high）靠的就是这个语义。
+		// 同 tier failover 由 TestChatAutoChainTierFailover 自己显式建链覆盖 ——
+		// 两条测试验的是不同机制（tier 优先 vs 同 tier 轮转），不能用同一个
+		// 默认夹具同时满足。
+		tier := 0
+		for i := len(srcs) - 1; i >= 0; i-- {
+			tier++
+			s := srcs[i]
+			for _, m := range s.Models {
+				if m.Kind == "image" {
+					continue // 图片模型不进 chat 链（与 buildAutoChain 同口径）
+				}
+				cfg.Auto = append(cfg.Auto, config.ModelScope{
+					Model: m.ID, Source: s.Name, Tier: tier,
+				})
+			}
+		}
+	}
 	c, err := core.NewFromConfig(cfg)
 	if err != nil {
 		t.Fatalf("core: %v", err)
@@ -107,9 +143,18 @@ func TestChatAutoChainTierFailover(t *testing.T) {
 	defer aUp.Close()
 	defer bUp.Close()
 	g := newTestGateway(t,
-		config.Source{Name: "a", BaseURL: aUp.URL, Adapter: "openai", Models: []config.Model{{ID: "a-m", Priority: 100}}},
-		config.Source{Name: "b", BaseURL: bUp.URL, Adapter: "openai", Models: []config.Model{{ID: "b-m", Priority: 10}}},
+		config.Source{Name: "a", BaseURL: aUp.URL, Adapter: "openai", Models: []config.Model{{ID: "a-m"}}},
+		config.Source{Name: "b", BaseURL: bUp.URL, Adapter: "openai", Models: []config.Model{{ID: "b-m"}}},
 	)
+	// ★ 显式把两个源放进**同一 tier**：本用例验的是 tier 内失败轮转。
+	//   默认夹具是一源一 tier（供 TestChatAUTO 验优先级），两者语义不同，
+	//   必须在这里覆盖，否则 b 在 tier2 永远轮不到。
+	if err := g.core.SaveAutoRules([]config.ModelScope{
+		{Model: "a-m", Source: "a", Tier: 1},
+		{Model: "b-m", Source: "b", Tier: 1},
+	}); err != nil {
+		t.Fatalf("save auto rules: %v", err)
+	}
 	rr := doReq(t, g, "POST", "/v1/chat/completions",
 		`{"model":"AUTO","messages":[{"role":"user","content":"hi"}]}`)
 	if rr.Code != 200 {
@@ -134,8 +179,8 @@ func TestChatAutoChain503Summary(t *testing.T) {
 	defer aUp.Close()
 	defer bUp.Close()
 	g := newTestGateway(t,
-		config.Source{Name: "a", BaseURL: aUp.URL, Adapter: "openai", Models: []config.Model{{ID: "a-m", Priority: 100}}},
-		config.Source{Name: "b", BaseURL: bUp.URL, Adapter: "openai", Models: []config.Model{{ID: "b-m", Priority: 10}}},
+		config.Source{Name: "a", BaseURL: aUp.URL, Adapter: "openai", Models: []config.Model{{ID: "a-m"}}},
+		config.Source{Name: "b", BaseURL: bUp.URL, Adapter: "openai", Models: []config.Model{{ID: "b-m"}}},
 	)
 	rr := doReq(t, g, "POST", "/v1/chat/completions",
 		`{"model":"AUTO","messages":[{"role":"user","content":"hi"}]}`)
@@ -156,7 +201,7 @@ func TestChatAutoQuotaSkip(t *testing.T) {
 	up := upstream(t, ctrl)
 	defer up.Close()
 	g := newTestGateway(t,
-		config.Source{Name: "a", BaseURL: up.URL, Adapter: "openai", Models: []config.Model{{ID: "a-m", Priority: 100}}},
+		config.Source{Name: "a", BaseURL: up.URL, Adapter: "openai", Models: []config.Model{{ID: "a-m"}}},
 	)
 	// one slot with an hourly quota of 1 token
 	rr := doReq(t, g, "PUT", "/api/auto",
@@ -191,7 +236,7 @@ func TestAutoStatesReportChainHealth(t *testing.T) {
 	up := upstream(t, ctrl)
 	defer up.Close()
 	g := newTestGateway(t,
-		config.Source{Name: "a", BaseURL: up.URL, Adapter: "openai", Models: []config.Model{{ID: "a-m", Priority: 100}}},
+		config.Source{Name: "a", BaseURL: up.URL, Adapter: "openai", Models: []config.Model{{ID: "a-m"}}},
 	)
 	doReq(t, g, "POST", "/v1/chat/completions",
 		`{"model":"AUTO","messages":[{"role":"user","content":"hi"}]}`)
@@ -234,7 +279,7 @@ func TestAutoSaveResetsCooldown(t *testing.T) {
 	up := upstream(t, ctrl)
 	defer up.Close()
 	g := newTestGateway(t,
-		config.Source{Name: "a", BaseURL: up.URL, Adapter: "openai", Models: []config.Model{{ID: "a-m", Priority: 100}}},
+		config.Source{Name: "a", BaseURL: up.URL, Adapter: "openai", Models: []config.Model{{ID: "a-m"}}},
 	)
 	rr := doReq(t, g, "POST", "/v1/chat/completions",
 		`{"model":"AUTO","messages":[{"role":"user","content":"hi"}]}`)
@@ -348,8 +393,8 @@ func TestChatAUTO(t *testing.T) {
 	up := mockUpstream()
 	defer up.Close()
 	g := newTestGateway(t,
-		config.Source{Name: "low", BaseURL: up.URL, Adapter: "openai", Models: []config.Model{{ID: "low-m", Priority: 10}}},
-		config.Source{Name: "high", BaseURL: up.URL, Adapter: "openai", Models: []config.Model{{ID: "high-m", Priority: 100}}},
+		config.Source{Name: "low", BaseURL: up.URL, Adapter: "openai", Models: []config.Model{{ID: "low-m"}}},
+		config.Source{Name: "high", BaseURL: up.URL, Adapter: "openai", Models: []config.Model{{ID: "high-m"}}},
 	)
 	// no model -> AUTO -> picks the highest priority source
 	rr := doReq(t, g, "POST", "/v1/chat/completions",
@@ -428,8 +473,8 @@ func TestImageAutoFallsOnlyToImageProviders(t *testing.T) {
 	}))
 	defer chatUp.Close()
 	g := newTestGateway(t,
-		config.Source{Name: "chat", BaseURL: chatUp.URL, Adapter: "openai", Models: []config.Model{{ID: "chat-m", Priority: 100}}},
-		config.Source{Name: "img", BaseURL: img.URL, Adapter: "openai", Models: []config.Model{{ID: "flux", Kind: "image", Priority: 1}}},
+		config.Source{Name: "chat", BaseURL: chatUp.URL, Adapter: "openai", Models: []config.Model{{ID: "chat-m"}}},
+		config.Source{Name: "img", BaseURL: img.URL, Adapter: "openai", Models: []config.Model{{ID: "flux", Kind: "image"}}},
 	)
 	rr := doReq(t, g, "POST", "/v1/images/generations",
 		`{"model":"AUTO","prompt":"a cat"}`)

internal/gateway/key_auto_api_test.go

@@ -44,7 +44,7 @@ func keyAutoGateway(t *testing.T) *Gateway {
 		},
 		Sources: []config.Source{
 			{Name: "s1", BaseURL: "http://127.0.0.1:1/v1", Adapter: "openai",
-				Models: []config.Model{{ID: "gpt-4o", Priority: 10}, {ID: "gpt-4o-mini", Priority: 5}}},
+				Models: []config.Model{{ID: "gpt-4o"}, {ID: "gpt-4o-mini"}}},
 		},
 	}
 	if err := cfg.ApplyDefaults(); err != nil {

internal/gateway/key_quota_wiring_test.go

@@ -36,7 +36,7 @@ func quotaGateway(t *testing.T, keyA, keyB config.GWKey) (*Gateway, *upstreamCtr
 		Keys:        []config.GWKey{keyA, keyB},
 		Sources: []config.Source{{
 			Name: "up", BaseURL: up.URL, Adapter: "openai",
-			Models: []config.Model{{ID: "m1", Priority: 100}},
+			Models: []config.Model{{ID: "m1"}},
 		}},
 	}
 	if err := cfg.ApplyDefaults(); err != nil {
@@ -306,14 +306,24 @@ func newQuotaGW(t *testing.T, upURL string, keys ...config.GWKey) *Gateway {
 		Sources: []config.Source{{
 			Name: "up", BaseURL: upURL, Adapter: "openai",
 			Models: []config.Model{
-				{ID: "m1", Priority: 100},
-				{ID: "m2", Priority: 90},
+				{ID: "m1"},
+				{ID: "m2"},
 			},
 		}},
 	}
 	if err := cfg.ApplyDefaults(); err != nil {
 		t.Fatal(err)
 	}
+
+	// 内核不再 seedAuto 自动播种 AUTO 链（空链=503 是刻意的）。本夹具的用例
+	// 全都在验"AUTO 请求会不会被 key 配额挡住"，必须显式建一条链 ——
+	// 否则每个用例都先撞 503，验的就不是配额了。
+	if len(cfg.Auto) == 0 {
+		cfg.Auto = []config.ModelScope{
+			{Model: "m1", Source: "up", Tier: 1},
+			{Model: "m2", Source: "up", Tier: 2},
+		}
+	}
 	c, err := core.NewFromConfig(cfg)
 	if err != nil {
 		t.Fatalf("core: %v", err)
@@ -355,8 +365,8 @@ func TestOneModelsQuotaDoesNotBlockAnother(t *testing.T) {
 		Sources: []config.Source{{
 			Name: "up", BaseURL: up.URL, Adapter: "openai",
 			Models: []config.Model{
-				{ID: "m1", Priority: 100},
-				{ID: "m2", Priority: 90},
+				{ID: "m1"},
+				{ID: "m2"},
 			},
 		}},
 	}

internal/gateway/messages_test.go

@@ -106,7 +106,7 @@ func messagesGateway(t *testing.T) (*httptest.Server, string) {
 		Sources: []config.Source{{
 			Name: "anth", BaseURL: up.URL, Adapter: "anthropic",
 			APIKey: "k", MaxConcurrent: 4,
-			Models: []config.Model{{ID: "claude-test", Kind: "chat", Priority: 100}},
+			Models: []config.Model{{ID: "claude-test", Kind: "chat"}},
 		}},
 	}
 

internal/gateway/sources_api_test.go

@@ -71,11 +71,6 @@ func TestSourcePutUpdatesSource(t *testing.T) {
 			continue
 		}
 		found = true
-		for _, m := range s.Models {
-			if m.ID == "m-one" && m.Priority != 42 {
-				t.Fatalf("priority not applied: %+v", s.Models)
-			}
-		}
 	}
 	if !found {
 		t.Fatal("source vanished after PUT")

internal/gateway/token_units_test.go

@@ -101,7 +101,7 @@ func TestStreamedChatRecordsUpstreamUsage(t *testing.T) {
 	defer up.Close()
 	g := newTestGateway(t, config.Source{
 		Name: "up", BaseURL: up.URL, Adapter: "openai",
-		Models: []config.Model{{ID: "m1", Priority: 100}},
+		Models: []config.Model{{ID: "m1"}},
 	})
 
 	rr := doReq(t, g, "POST", "/v1/chat/completions",
@@ -127,7 +127,7 @@ func TestStreamedAndNonStreamedAgreeOnTokens(t *testing.T) {
 	defer up.Close()
 	g := newTestGateway(t, config.Source{
 		Name: "up", BaseURL: up.URL, Adapter: "openai",
-		Models: []config.Model{{ID: "m1", Priority: 100}},
+		Models: []config.Model{{ID: "m1"}},
 	})
 
 	if rr := doReq(t, g, "POST", "/v1/chat/completions",
@@ -167,7 +167,7 @@ func TestStreamedChatFallsBackToEstimateWithoutUsage(t *testing.T) {
 	defer up.Close()
 	g := newTestGateway(t, config.Source{
 		Name: "up", BaseURL: up.URL, Adapter: "openai",
-		Models: []config.Model{{ID: "m1", Priority: 100}},
+		Models: []config.Model{{ID: "m1"}},
 	})
 
 	if rr := doReq(t, g, "POST", "/v1/chat/completions",
@@ -189,7 +189,7 @@ func TestImageGenerationDoesNotRecordTokens(t *testing.T) {
 	defer up.Close()
 	src := config.Source{
 		Name: "up", BaseURL: up.URL, Adapter: "openai",
-		Models: []config.Model{{ID: "img-m", Priority: 100, Kind: "image"}},
+		Models: []config.Model{{ID: "img-m", Kind: "image"}},
 	}
 	g := newTestGateway(t, src)
 

internal/gateway/ui/index.html

@@ -365,10 +365,11 @@
       .ctx-itm .ic{width:15px;text-align:center}
 
       /* ---- chat page ---- */
-      .tab-chat{max-width:840px;margin:0 auto;display:flex;flex-direction:column;height:calc(100vh - 190px)}
+      .tab-chat{max-width:840px;margin:0 auto;display:flex;flex-direction:column;height:calc(100vh - 190px);min-height:0}
+      .chat-mode-bar{display:flex;align-items:center;gap:8px;padding:0 0 10px;flex:0 0 auto}
+      .chat-pane{flex:1;display:flex;flex-direction:column;min-height:0}
 
-      .tab-image{max-width:840px;margin:0 auto;display:flex;flex-direction:column;
-        height:calc(100vh - 190px)}
+      .tab-image{display:flex;flex-direction:column;flex:1;min-height:0}
       .img-wrap{flex:1;display:flex;flex-direction:column;min-height:0}
       .img-grid{flex:1;overflow-y:auto;padding:12px 2px;display:grid;
         grid-template-columns:repeat(auto-fill,minmax(240px,1fr));gap:10px;align-content:start}
@@ -589,21 +590,6 @@
               /></svg
             ><span data-i="navChat">对话</span>
           </button>
-          <button class="sb-i" data-tab="image">
-            <svg
-              viewBox="0 0 24 24"
-              fill="none"
-              stroke="currentColor"
-              stroke-width="2"
-              stroke-linecap="round"
-              stroke-linejoin="round"
-            >
-              <path d="M3 5h18v14H3z" />
-              <path d="m3 15 5-5 4 4 3-3 6 6" />
-              <circle cx="8.5" cy="8.5" r="1.5" />
-            ></svg
-            ><span data-i="navImage">生图</span>
-          </button>
           <button class="sb-i" data-tab="keys">
             <svg
               viewBox="0 0 24 24"
@@ -822,8 +808,7 @@
         <main id="main">
           <div id="tab-status" class="tab-pane"></div>
           <div id="tab-chat" class="tab-pane hidden"></div>
-          <div id="tab-image" class="tab-pane hidden"></div>
-          <div id="tab-keys" class="tab-pane hidden"></div>
+        <div id="tab-keys" class="tab-pane hidden"></div>
           <div id="tab-sort" class="tab-pane hidden"></div>
           <div id="tab-sources" class="tab-pane hidden"></div>
           <div id="tab-adapters" class="tab-pane hidden"></div>
@@ -1589,7 +1574,7 @@
       // keep in sync, and adding a tab meant finding all three. A plugin page
       // that is routed but never shown is exactly the kind of silent gap that
       // survives review.
-      const TABS = ["status", "chat", "image", "keys", "sort", "sources", "adapters", "plugins"];
+      const TABS = ["status", "chat", "keys", "sort", "sources", "adapters", "plugins"];
       // Declared HERE, with var, because goTab() below reads it. It used to be a
       // `const` further down the file next to the other plugin state, which put
       // goTab's read inside the temporal dead zone: the first click on a plugin
@@ -2898,6 +2883,13 @@ async function renderChat() {
       : "");
         $("#tab-chat").innerHTML = `
     <div class="tab-chat">
+      <div class="chat-mode-bar">
+        <div class="kind-toggle">
+          <button data-mode="chat" class="small" onclick="switchChatMode('chat')">对话</button>
+          <button data-mode="image" class="ghost small" onclick="switchChatMode('image')">生图</button>
+        </div>
+      </div>
+      <div class="chat-pane" id="ct-chat-pane">
       <div class="chat-wrap">
         <div class="chat-log" id="ct-log">
           <div class="chat-empty" id="ct-empty">
@@ -2925,6 +2917,8 @@ async function renderChat() {
           </div>
         </div>
       </div>
+      </div>
+      <div class="chat-pane" id="ct-image-pane" style="display:none"></div>
     </div>`;
         chatHistory = [];
         chatImages = [];
@@ -2939,22 +2933,22 @@ async function renderChat() {
         $("#ct-imgs").style.display = "none";
         $("#ct-msg").focus();
       }
-      /* ---------- image tab ---------- */
-      // Image generation lives in its own page rather than as an option in the
-      // chat model dropdown.
-      //
-      // The dropdown used to list image models beside chat ones because
-      // /api/status flattened the catalog to []string and dropped the kind.
-      // Picking one sent the request to /api/chat, which cannot serve it. A
-      // second tab makes the distinction structural: the only models offered
-      // here are kind=image, and the endpoint called is the image one.
+      /* ---------- chat/image modes ---------- */
       let imgBusy = false;
-      function imgModels() {
-        const out = [];
-        document.querySelectorAll("#it-model option").forEach((o) => {
-          if (o.value) out.push(o.value);
+      let chatMode = "chat";
+      function switchChatMode(mode) {
+        chatMode = mode === "image" ? "image" : "chat";
+        const chatPane = $("#ct-chat-pane");
+        const imagePane = $("#ct-image-pane");
+        if (chatPane) chatPane.style.display = chatMode === "chat" ? "" : "none";
+        if (imagePane) imagePane.style.display = chatMode === "image" ? "" : "none";
+        document.querySelectorAll("#tab-chat .chat-mode-bar button").forEach((button) => {
+          button.classList.toggle("ghost", button.dataset.mode !== chatMode);
         });
-        return out;
+        if (chatMode === "image" && imagePane && !imagePane.dataset.rendered) {
+          imagePane.dataset.rendered = "1";
+          renderImage();
+        }
       }
       async function renderImage() {
         const s = await api("/api/status");
@@ -2977,7 +2971,7 @@ async function renderChat() {
         const body = opts.length
           ? ""
           : `<div class="empty">${esc(t("imgNoModels"))}</div>`;
-        $("#tab-image").innerHTML = `
+        $("#ct-image-pane").innerHTML = `
     <div class="tab-image">
       <div class="img-wrap">
         <div class="img-grid" id="it-grid">
@@ -6267,7 +6261,6 @@ toast(t("kAutoChainGlobal"));
         const done = () => remountPluginElements();
         if (tab === "status") return renderStatus().then(done, done);
         if (tab === "chat") return renderChat().then(done, done);
-        if (tab === "image") return renderImage().then(done, done);
         if (tab === "keys") return renderKeys().then(done, done);
         if (tab === "sort") return renderSort().then(done, done);
         if (tab === "sources") return renderSources().then(done, done);

internal/gateway/ui_image_page_test.go

@@ -42,28 +42,47 @@ func TestUI_ChatPageGroupsImageModels(t *testing.T) {
 	}
 }
 
-// TestUI_HasDedicatedImagePage pins the second half of the fix: image models
-// need somewhere they CAN be tested.
-func TestUI_HasDedicatedImagePage(t *testing.T) {
+// TestUI_ImageModeIsReachableFromChatTab 钉住生图**仍可达**。
+//
+// ★ 断言已随 UI 结构调整：生图不再是独立侧栏项，而是对话页里的一个分段模式。
+//   原先这条测试钉的是 `data-tab="image"` / `id="tab-image"` / `tab === "image"`
+//   —— 三者都已随合并移除。若继续钉旧结构，它只会红着挡住重构，而检不出
+//   "生图入口彻底消失"这种真回归。所以改为钉**合并后的可达性**：
+//   分段控件在、切换函数在、面板容器在、端点仍在。
+//
+// 为什么"可达性"才是要守的东西：合并的动机是少一个导航项，而不是把生图功能
+// 藏起来。只要用户能从对话页一键切到生图并真的发出请求，这个功能就是完整的。
+func TestUI_ImageModeIsReachableFromChatTab(t *testing.T) {
 	ui := uiSource(t)
 
 	for _, want := range []string{
-		`data-tab="image"`,       // sidebar entry
-		`id="tab-image"`,         // pane
-		`function renderImage`,   // renderer registered with refresh()
-		`tab === "image"`,        // dispatched
-		`/v1/images/generations`, // the endpoint the page actually calls
+		`class="chat-mode-bar"`,      // 分段栏存在
+		`switchChatMode('image')`,    // 能切到生图
+		`id="ct-image-pane"`,         // 生图面板容器
+		`function renderImage`,       // 渲染器还在
+		`/v1/images/generations`,     // 真正被调用的端点
 	} {
 		if !strings.Contains(ui, want) {
-			t.Errorf("image page is missing %q", want)
+			t.Errorf("生图模式不可达，缺少 %q", want)
 		}
 	}
 
-	// The page must be reachable from TABS; goTab iterates TABS to toggle pane
-	// visibility, so a pane outside that list is present but permanently hidden —
-	// which reads as "the page is blank" because the content is in the DOM.
-	if !strings.Contains(ui, `"image"`) {
-		t.Error(`"image" does not appear in the TABS list`)
+	// 合并后**不应**再出现独立 tab 的三件套 —— 它们会让 goTab 去找一个不存在的
+	// 面板（$("#tab-image") 为 null ⇒ 点侧栏抛错）。
+	for _, gone := range []string{
+		`data-tab="image"`,
+		`id="tab-image"`,
+		`tab === "image"`,
+	} {
+		if strings.Contains(ui, gone) {
+			t.Errorf("生图已并入对话页，不应再有独立 tab 结构 %q"+
+				"（否则 goTab 会找一个不存在的面板）", gone)
+		}
+	}
+
+	// 面板必须在 DOM 里且**不能被初始隐藏到底**：切换函数用 display 控制。
+	if !strings.Contains(ui, `ct-chat-pane`) {
+		t.Error("缺少对话面板容器 ct-chat-pane（切换需要两个容器同时存在）")
 	}
 }
 

internal/lua/adapters/buddy.lua

@@ -55,6 +55,13 @@ function adapter.transform_request(raw_body)
     -- private one.
     req.thinking = nil
     req.extra_body = nil
+    -- ★★ buddy（腾讯 CodeBuddy）上游**只支持流式**：body.stream=false 会被
+    --    400 拒绝（实测 2026-10-19）：
+    --      11101: Non-stream chat request is currently not supported
+    --    与 Accept: text/event-stream 头无关（头早已在发），判据是 body。
+    --    故强制 stream=true，非流式请求由内核的"客户端要非流式、上游回流式"
+    --    路径消化（transform_response 需能聚合 SSE，见下）。
+    req.stream = true
     -- ★★ buddy 的 glm-5.1 **要求请求体里有非空的 reasoning_effort**，
     --    否则上游回 400：
     --      {"code":11150,"msg":"the reasoning effort value is not supported
@@ -92,7 +99,92 @@ function adapter.transform_request(raw_body)
     return json.encode(req)
 end
 
+-- aggregate_sse(raw)：把上游 SSE（data: 行流）聚合成一个非流式 OpenAI 响应。
+-- 强制 stream=true 后，内核的非流式路径会在这里收到完整 SSE 原文——必须聚合，
+-- 否则 json.decode 失败原样透传，Go 侧 unmarshal 报 invalid character 'd'。
+-- 聚合 content / reasoning_content / tool_calls（按 index 拼接分片）/
+-- finish_reason / usage；无可解析帧时返回 nil（调用方回退原样）。
+local function aggregate_sse(raw)
+    local content, reasoning = {}, {}
+    local finish, usage, id, model, created = nil, nil, nil, nil, nil
+    local tools_by_index = {}
+    local seen = false
+    for line in (raw .. "\n"):gmatch("([^\n]*)\n") do
+        local s = line:gsub("^%s+", ""):gsub("%s+$", "")
+        if s:sub(1, 5) == "data:" then
+            local payload = s:sub(6):gsub("^%s+", "")
+            if payload ~= "" and payload ~= "[DONE]" then
+                local ok, d = pcall(json.decode, payload)
+                if ok and type(d) == "table" then
+                    seen = true
+                    id = id or d.id
+                    model = model or d.model
+                    created = created or d.created
+                    if type(d.usage) == "table" then usage = d.usage end
+                    local ch = d.choices and d.choices[1]
+                    if type(ch) == "table" then
+                        if type(ch.finish_reason) == "string" and ch.finish_reason ~= "" then
+                            finish = ch.finish_reason
+                        end
+                        local dl = ch.delta
+                        if type(dl) == "table" then
+                            if type(dl.content) == "string" then content[#content + 1] = dl.content end
+                            if type(dl.reasoning_content) == "string" then
+                                reasoning[#reasoning + 1] = dl.reasoning_content
+                            end
+                            if type(dl.tool_calls) == "table" then
+                                for _, tc in ipairs(dl.tool_calls) do
+                                    if type(tc) == "table" and tc.index ~= nil then
+                                        local slot = tools_by_index[tc.index]
+                                        if slot == nil then
+                                            slot = { id = tc.id, type = tc.type or "function",
+                                                ["function"] = { name = "", arguments = "" } }
+                                            tools_by_index[tc.index] = slot
+                                        end
+                                        if tc.id then slot.id = tc.id end
+                                        local fn = tc["function"]
+                                        if type(fn) == "table" then
+                                            if fn.name then slot["function"].name = slot["function"].name .. fn.name end
+                                            if fn.arguments then slot["function"].arguments = slot["function"].arguments .. fn.arguments end
+                                        end
+                                    end
+                                end
+                            end
+                        end
+                    end
+                end
+            end
+        end
+    end
+    if not seen then return nil end
+    local msg = { role = "assistant", content = table.concat(content) }
+    local rc = table.concat(reasoning)
+    if rc ~= "" then msg.reasoning_content = rc end
+    local ordered = {}
+    for i = 0, 63 do
+        if tools_by_index[i] then ordered[#ordered + 1] = tools_by_index[i] end
+    end
+    if #ordered > 0 then msg.tool_calls = ordered end
+    local out = {
+        id = id or "", object = "chat.completion", created = created or 0,
+        model = model or "",
+        choices = { { index = 0, message = msg,
+            finish_reason = (finish and finish ~= "") and finish or "stop" } },
+    }
+    if usage then out.usage = usage end
+    local ok2, enc = pcall(json.encode, out)
+    if not ok2 then return nil end
+    return enc
+end
+
 function adapter.transform_response(raw_body)
+    -- 上游只会回流式（transform_request 强制 stream=true）。客户端要非流式时
+    -- 内核把完整 SSE 原文交到这里，先聚合再走统一转换。
+    if type(raw_body) == "string"
+        and (raw_body:match("^%s*data:") or raw_body:match("[\r\n]data:")) then
+        local aggregated = aggregate_sse(raw_body)
+        if aggregated ~= nil then raw_body = aggregated end
+    end
     -- 非流式 OpenAI 响应 → 统一信封。此前在 openai/groq/kimicode/mistral/github
     -- 五个适配器里**逐字节相同**（各 2206B，diff 为空），已抽到共享前导。
     return __prelude.openai_response(raw_body)
@@ -147,11 +239,10 @@ function adapter.transform_stream_chunk(raw_chunk)
     if delta.reasoning_content then
         unified.reasoning_content = delta.reasoning_content
     end
-    if delta.tool_calls then
-        -- Sanitize on the way OUT too: an id this upstream happily minted (it
-        -- does not validate them) becomes a landmine once the client replays
-        -- it to a Claude upstream. Only the first fragment of a streamed call
-        -- carries an id; later argument fragments have none and are untouched.
+    if type(delta.tool_calls) == "table" and #delta.tool_calls > 0 then
+        -- Do not serialize an empty Lua table as JSON `{}`. That shape is
+        -- neither an OpenAI tool-call array nor an omitted field, and several
+        -- agent clients reject it on the final chunk.
         for _, tc in ipairs(delta.tool_calls) do
             if type(tc) == "table" and tc.id ~= nil then
                 tc.id = safe_tool_id(tc.id)

internal/lua/adapters/opencodezen.lua

@@ -1,8 +1,13 @@
 local adapter = {}
 
 adapter.name = "opencodezen"
-adapter.version = "1.0.0"
+adapter.version = "1.1.0"
 adapter.endpoint = "/chat/completions"
+-- ★ hidden：不进用户可见适配器列表（v1.1.0）。本适配器是 OpenCode 免费层的
+--   **门禁专用形态**（强制 stream、注入 read 桩工具、会话号服从倒计时公式），
+--   直接暴露会被误当成通用 OpenAI 适配器选去接别的上游，结果不可预测。
+--   被 localzen 源引用时内核仍会把它列出来（源编辑器回显），其余场合隐藏。
+adapter.hidden = true
 
 -- OpenCode Zen（按量付费端点，https://opencode.ai/zen/v1）
 --
@@ -99,7 +104,7 @@ local function now_ms(meta)
     return t * 1000
 end
 
-local function rand_id(prefix, ms, kind)
+local function rand_id(prefix, ms, kind, affinity)
     local seg
     if kind == "session" then
         seg = (ID_K - ms * 4096) % (MASK48 + 1)
@@ -107,7 +112,15 @@ local function rand_id(prefix, ms, kind)
         seg = (ms * 16) % (MASK48 + 1)
     end
     -- %012x：12 位十六进制，不足补零
-    return prefix .. string.format("%012x", seg) .. rand_tail(14)
+    -- affinity（可空）：会话亲和键。非空时其 8 位 hex 摘要混入 tail ——
+    -- 同一分钟桶内不同会话得到不同会号；hex 段不受影响（门禁只校验它）。
+    local tail
+    if type(affinity) == "string" and affinity ~= "" then
+        tail = string.sub(sha256_hex(affinity), 1, 8) .. rand_tail(6)
+    else
+        tail = rand_tail(14)
+    end
+    return prefix .. string.format("%012x", seg) .. tail
 end
 
 -- session_bucket_ms 决定上游会话号的**稳定周期**（按整分钟对齐）。
@@ -120,6 +133,41 @@ end
 -- 取整分钟（而非秒）：同一分钟内的所有请求共享一个会话号 ⇒ 既保留缓存命中，
 -- 又不超出上游的时间容差。实测容差 ≥ 1 小时（-3600s 仍 200），
 -- 所以一分钟桶有很大余量，即便上游收紧到几分钟也仍然安全。
+-- ★ 会话亲和（v1.1.0，移植自 _local_archive 版本）：整分钟桶让**所有请求**
+-- 共享会号，多会话并发时互相污染缓存键。改进：桶内再按**会话身份**分桶——
+--   1) meta.client_session（pi 等真会话客户端自带，会话恒定）
+--   2) 退路：历史里第一条 user 消息做会话指纹（通用 OpenAI 客户端不发任何
+--      会话标识，实测抓包确认；第一条 user 消息在整个会话里恒定）
+--   3) 再退：无 user 消息时退回纯时间桶（与 v1.0 行为一致）
+-- 实现：把会话身份 hash 进 14 位 base62 随机段（hex 段仍服从门禁公式）。
+local function conversation_fingerprint(body)
+    if type(body) ~= "string" or body == "" then return "" end
+    local ok, req = pcall(json.decode, body)
+    if not ok or type(req) ~= "table" then return "" end
+    for _, m in ipairs(req.messages or {}) do
+        if type(m) == "table" and m.role == "user" then
+            local c = m.content
+            if type(c) == "string" then
+                if c ~= "" then return c end
+            elseif type(c) == "table" then
+                for _, part in ipairs(c) do
+                    if type(part) == "table" and part.type == "text" and part.text then
+                        return part.text
+                    end
+                end
+            end
+            return ""
+        end
+    end
+    return ""
+end
+
+local function session_affinity_key(meta)
+    local cs = meta and meta.client_session
+    if type(cs) == "string" and cs ~= "" then return cs end
+    return conversation_fingerprint(meta and meta.body)
+end
+
 local function session_bucket_ms(meta)
     local ms = now_ms(meta)
     return ms - (ms % 60000)
@@ -129,7 +177,9 @@ function adapter.build_headers(meta)
     local ms = now_ms(meta)
     local bucket = session_bucket_ms(meta)
     -- 免费层要求两个头都在且值相同（对齐官方 CLI；缺任一个则 403）。
-    local sid = rand_id("ses_", bucket, "session")
+    -- 会话亲和键（可能为空）混入 tail：同一分钟桶内不同会话得到不同会号，
+    -- 同一会话跨分钟仍共享指纹 ⇒ 前缀缓存按会话命中而非按分钟命中。
+    local sid = rand_id("ses_", bucket, "session", session_affinity_key(meta))
     return {
         ["User-Agent"] = adapter.headers["User-Agent"],
         ["x-opencode-client"] = "cli",

internal/lua/adapters/trae.lua

@@ -253,7 +253,7 @@ function adapter.transform_stream_chunk(raw_chunk)
     if delta.reasoning_content then
         unified.reasoning_content = delta.reasoning_content
     end
-    if delta.tool_calls then
+    if type(delta.tool_calls) == "table" and #delta.tool_calls > 0 then
         unified.tool_calls = delta.tool_calls
     end
     return json.encode(unified)

internal/lua/plugin_icons_test.go

@@ -0,0 +1,117 @@
+package lua
+
+import (
+	"os"
+	"regexp"
+	"strings"
+	"testing"
+)
+
+// 侧边栏图标判据 —— 覆盖**所有**带页面的插件，不只是 billing。
+//
+// 为什么需要这个测试
+// ------------------
+// billing 当年声明了 icon = ""，WebUI 把空串原样塞进按钮 ⇒ 侧边栏那条是空白。
+// 当时只给 billing 加了判据（TestPluginIconIsNotARawEmoji）。后来 channels
+// 声明 icon = ""、quota 连 icon 字段都没有 ⇒ 同样的"空白条目"缺陷又一次出现，
+// 而判据只管 billing，所以全绿。
+//
+// 这就是"判据只覆盖出错的那一个文件"的代价：同类缺陷换个文件复发时没有任何
+// 东西会响。本文件把范围改成**按页面遍历**，新增带页面的插件自动纳入。
+
+// pageIcons 返回 插件文件 -> 其 page.icon 的声明值。
+//
+// 只认 page.icon（侧边栏读的就是它），不认顶层的其他 icon 字段 —— 那些不影响
+// 侧边栏渲染，混进来会给出假绿。
+func pageIcons(t *testing.T, path string) []string {
+	t.Helper()
+	b, err := os.ReadFile(path)
+	if err != nil {
+		t.Fatalf("读 %s 失败: %v", path, err)
+	}
+	src := string(b)
+
+	// 短字符串：icon = "..."
+	shortRe := regexp.MustCompile(`(?m)^\s*icon\s*=\s*"([^"]*)"`)
+	// 长字符串：icon = [==[ ... ]==]（inline SVG 没法写成短字符串而不转义所有引号）
+	longRe := regexp.MustCompile(`(?s)\bicon\s*=\s*\[==\[(.*?)\]==\]`)
+
+	var out []string
+	for _, m := range shortRe.FindAllStringSubmatch(src, -1) {
+		out = append(out, m[1])
+	}
+	for _, m := range longRe.FindAllStringSubmatch(src, -1) {
+		out = append(out, m[1])
+	}
+	return out
+}
+
+// 带页面（plugin.ui.page）的插件。新增页面插件要登记在这里 ——
+// 这是一份"必须被覆盖的清单"，漏登记会让新插件逃避判据。
+var pagePlugins = []string{
+	"plugins/billing.lua",
+	"plugins/channels.lua",
+	"plugins/quota.lua",
+}
+
+// TestEveryPagePluginDeclaresSVGIcon 钉住"每个带页面的插件都有 inline SVG 图标"。
+//
+// 两个必查项，各自对应一种真实缺陷：
+//   - 缺 icon / 空串  ⇒ 侧边栏空白（channels 的实测症状）
+//   - emoji           ⇒ 尺寸不跟原生 tab、忽略主题色（billing 的历史缺陷）
+func TestEveryPagePluginDeclaresSVGIcon(t *testing.T) {
+	for _, p := range pagePlugins {
+		t.Run(p, func(t *testing.T) {
+			icons := pageIcons(t, p)
+			if len(icons) == 0 {
+				t.Fatalf("%s 有任何 page 却没有任何 icon 声明 —— 侧边栏那条会是空白", p)
+			}
+			// 只断言"至少有一个非空且是 SVG"：一个文件可能有多个页面，
+			// 但不能为了通过而声明一个空图标。
+			var ok bool
+			for _, ic := range icons {
+				if strings.TrimSpace(ic) == "" {
+					continue
+				}
+				if isEmojiIcon(ic) {
+					t.Errorf("%s 的 page icon 是 emoji %q —— 原生 tab 用 inline SVG"+
+						"（stroke: currentColor），emoji 尺寸不一致且不跟主题", p, ic)
+					continue
+				}
+				if !strings.Contains(ic, "<svg") {
+					t.Errorf("%s 的 page icon 不是 SVG 标记: %q", p, ic)
+					continue
+				}
+				ok = true
+			}
+			if !ok {
+				t.Errorf("%s 没有可用的 SVG page icon（声明的全是空串/emoji/非 SVG）", p)
+			}
+		})
+	}
+}
+
+// TestIconUsesCurrentColor 钉住图标**跟随主题色**。
+//
+// 参考插件的图标工厂（src/sponsor.js:52）统一用
+// `stroke="currentColor"` + `strokeWidth 1.6`。写死颜色（"#333"、"black"）
+// 会让图标在深色主题下几乎看不见 —— 那是同一个"图标不对"投诉的另一半。
+func TestIconUsesCurrentColor(t *testing.T) {
+	for _, p := range pagePlugins {
+		t.Run(p, func(t *testing.T) {
+			for _, ic := range pageIcons(t, p) {
+				if strings.TrimSpace(ic) == "" || isEmojiIcon(ic) {
+					continue
+				}
+				if !strings.Contains(ic, "currentColor") {
+					t.Errorf("%s 的 icon 没写 stroke/fill=currentColor —— "+
+						"写死颜色在深色主题下不可见: %s", p, ic)
+				}
+				// 写死颜色的显式反例：出现 #rrggbb 或 rgb( 就报
+				if regexp.MustCompile(`#[0-9a-fA-F]{3,8}\b|rgba?\(`).MatchString(ic) {
+					t.Errorf("%s 的 icon 里含写死颜色: %s", p, ic)
+				}
+			}
+		})
+	}
+}

internal/lua/plugins/billing.lua

@@ -602,7 +602,7 @@ plugin.ui = {
   page = {
     page_id = "billing",
     title = "Billing",
-    icon = [==[<svg viewBox="0 0 24 24"><circle cx="12" cy="12" r="9"/><path d="M14.5 9.5a3 3 0 0 0-2.5-1.3c-1.4 0-2.4.7-2.4 1.8 0 2.6 5.2 1.4 5.2 4 0 1.1-1 1.8-2.5 1.8-1.1 0-2.1-.4-2.7-1.2"/><path d="M12 6.4v11.2"/></svg>]==],
+    icon = [==[<svg viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="1.6" stroke-linecap="round" stroke-linejoin="round"><circle cx="12" cy="12" r="9"/><path d="M14.5 9.5a3 3 0 0 0-2.5-1.3c-1.4 0-2.4.7-2.4 1.8 0 2.6 5.2 1.4 5.2 4 0 1.1-1 1.8-2.5 1.8-1.1 0-2.1-.4-2.7-1.2"/><path d="M12 6.4v11.2"/></svg>]==],
     order = 40,
     mount = [==[
 <div id="billing-root" style="padding:16px;min-width:0;max-width:100%;overflow-x:auto">

internal/lua/plugins/quota.lua

@@ -1065,6 +1065,9 @@ PLUGIN.ui = {
   page = {
     page_id = "quota",
     title = "Quota",
+    -- ★ 侧边栏图标必须是 **inline SVG**（空串=空白，emoji=尺寸/主题不一致）。
+    --   图案：三格电池 —— “套餐余量”的直接语义。
+    icon = [==[<svg viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="1.6" stroke-linecap="round" stroke-linejoin="round"><rect x="2.5" y="7" width="16" height="10" rx="2.4"/><path d="M21.5 10.5v3"/><path d="M6 10.5v3M10 10.5v3M14 10.5v3"/></svg>]==],
     order = 45,
     mount = [==[
 <div id="qa-root" class="qa-root">

internal/lua/vm.go

@@ -93,6 +93,12 @@ type staticInfo struct {
 	// but once an adapter claims the endpoint, protocol iteration lives in the
 	// adapter, not the kernel. Empty means the adapter claims no ingress.
 	ingress string
+	// hidden marks an adapter that should NOT appear in the user-facing adapter
+	// list (GET /api/adapters → UI 的适配器页与源编辑器的适配器下拉）。隐藏的
+	// 适配器仍然正常加载、仍然可以被源引用——它只是不从选择列表里冒出来。
+	// 用途：厂商探针类/内部实验类适配器（如 opencodezen 的免费层门禁形态），
+	// 直接暴露会让运维误当成通用 OpenAI 适配器去选。声明方式：adapter.hidden = true。
+	hidden bool
 }
 
 // adapterPool owns the worker states for one adapter. Idle workers are held in
@@ -596,6 +602,11 @@ type VM struct {
 	dir   string
 	pools map[string]*adapterPool
 
+	// hiddenRefs 记录"被源引用的隐藏适配器"。hidden=true 的适配器默认不进
+	// ListAdapters，但被源引用时必须保持可见（源编辑器要能回显当前值）。
+	// 由内核在配置装载/源变更时调用 SetHiddenRefs 维护；nil = 未标记。
+	hiddenRefs map[string]bool
+
 	// janitor drives elastic shrinking. One goroutine serves every pool (not
 	// one per adapter), so an idle gateway costs a single sleeping goroutine.
 	janitorOnce sync.Once
@@ -603,6 +614,21 @@ type VM struct {
 	janitorDone chan struct{}
 }
 
+// SetHiddenRefs 供内核同步"哪些隐藏适配器正被源引用"。传 nil/空集 = 没有引用。
+func (v *VM) SetHiddenRefs(names []string) {
+	v.mu.Lock()
+	defer v.mu.Unlock()
+	if len(names) == 0 {
+		v.hiddenRefs = nil
+		return
+	}
+	m := make(map[string]bool, len(names))
+	for _, n := range names {
+		m[n] = true
+	}
+	v.hiddenRefs = m
+}
+
 func NewVM(dir string) *VM {
 	return &VM{
 		dir:         dir,
@@ -799,14 +825,32 @@ func (v *VM) ConfigureConcurrency(adapterConcurrency map[string]int) {
 func (v *VM) ListAdapters() []APIAdapter {
 	v.mu.RLock()
 	defer v.mu.RUnlock()
+	// hidden=true 的适配器不进用户可见列表（仍正常加载、仍可被源引用）。
+	// 例外：**正在被某个源引用**的隐藏适配器必须仍出现在列表里——否则源编辑器
+	// 打开时找不到当前值，下拉会被重置成空，造成"保存后适配器悄悄丢了"。
+	// 引用关系由内核持有（core 在配置装载时标记），VM 只看这个位。
+	keepHidden := v.hiddenKeep()
 	list := make([]APIAdapter, 0, len(v.pools))
 	for name, p := range v.pools {
+		if p.static.hidden && !keepHidden[name] {
+			continue
+		}
 		list = append(list, APIAdapter{Name: name, Version: p.static.version})
 	}
 	sort.Slice(list, func(i, j int) bool { return list[i].Name < list[j].Name })
 	return list
 }
 
+// hiddenKeep returns the set of hidden adapter names that must STAY visible
+// because at least one source references them. nil 表示内核未标记（测试环境/
+// 未装载配置），此时隐藏适配器一律隐藏——与"新适配器默认隐藏"的预期一致。
+func (v *VM) hiddenKeep() map[string]bool {
+	if v.hiddenRefs == nil {
+		return nil
+	}
+	return v.hiddenRefs
+}
+
 // AdapterForIngress returns the registered name of the adapter that CLAIMS the
 // given client-facing endpoint path (its static.ingress), or "" when none does.
 //
@@ -1255,6 +1299,10 @@ func inspectScript(name, code string) (*staticInfo, error) {
 	info.endpoint = readString(L, -1, "endpoint")
 	info.endpointStream = readString(L, -1, "endpoint_stream")
 	info.ingress = readString(L, -1, "ingress")
+	// hidden：适配器可声明 adapter.hidden = true 退出用户可见列表（仍可被源引用）。
+	L.GetField(-1, "hidden")
+	info.hidden = L.ToBoolean(-1)
+	L.Pop(1)
 	if getFieldBatch(L, "headers") {
 		luaTableToMap(L, -1, info.headers)
 		L.Pop(1)

internal/lua/vm_hidden_test.go

@@ -0,0 +1,49 @@
+package lua
+
+import "testing"
+
+// hidden=true 的适配器：不被任何源引用时从 ListAdapters 消失；被引用时保持可见。
+// 这个行为支撑"内部适配器默认隐藏"的约定（opencodezen 是第一个使用者）。
+func TestAdapterHiddenFlag(t *testing.T) {
+	vm := NewVM(freshAdapterDir(t))
+	if err := vm.Start(); err != nil {
+		t.Fatalf("start: %v", err)
+	}
+	defer vm.Stop()
+	const src = `
+local adapter = {}
+adapter.name = "secretone"
+adapter.version = "1.0.0"
+adapter.endpoint = "/chat/completions"
+adapter.hidden = true
+function adapter.transform_request(raw) return raw end
+function adapter.transform_response(raw) return raw end
+return adapter
+`
+	if err := vm.LoadAdapterSource("secretone", src); err != nil {
+		t.Fatal(err)
+	}
+	// 未被引用 → 隐藏
+	vm.SetHiddenRefs(nil)
+	for _, a := range vm.ListAdapters() {
+		if a.Name == "secretone" {
+			t.Fatal("hidden adapter must not be listed when unreferenced")
+		}
+	}
+	// 被引用 → 可见
+	vm.SetHiddenRefs([]string{"secretone"})
+	found := false
+	for _, a := range vm.ListAdapters() {
+		if a.Name == "secretone" {
+			found = true
+		}
+	}
+	if !found {
+		t.Fatal("hidden adapter must stay listed while referenced by a source")
+	}
+	// transform 路径不受 hidden 影响：隐藏 ≠ 禁用
+	out, err := vm.Transform("secretone", "transform_response", `{"x":1}`)
+	if err != nil || out == "" {
+		t.Fatalf("hidden adapter must still transform: %v %q", err, out)
+	}
+}

internal/provider/provider.go

@@ -506,42 +506,39 @@ func (p *Provider) ModelFor(reqModel string) string {
 	return p.bestChatModel()
 }
 
-// bestChatModel returns the highest-priority chat-kind model of this source.
+// bestChatModel returns the first chat-kind model of this source.
+//
+// ★ 曾经叫 "highest-priority chat model"，但 `config.Model.Priority` 已删除
+//
+//	（它从未参与跨源调度，只在这里用；而这里的语义其实只是"选一个能发 chat 的
+//	模型"，选第一个就够了 —— 源内模型顺序由配置/发现顺序决定）。
 func (p *Provider) bestChatModel() string {
-	bestID, bestPrio := "", -1
 	for _, m := range p.cfg.Models {
 		if m.Kind != "" && m.Kind != "chat" {
 			continue
 		}
-		if m.Priority > bestPrio {
-			bestPrio = m.Priority
-			bestID = m.ID
-		}
+		return m.ID
 	}
-	if bestID == "" && len(p.cfg.Models) > 0 {
-		bestID = p.cfg.Models[0].ID
+	if len(p.cfg.Models) > 0 {
+		return p.cfg.Models[0].ID
 	}
-	return bestID
+	return ""
 }
 
-// bestImageModel returns the highest-priority image-kind model of this source
-// (fallback: first configured model). Used for AUTO image generation so a
-// mixed source never sends a chat model to /v1/images/generations.
+// bestImageModel returns the first image-kind model of this source (fallback:
+// first configured model). Used for AUTO image generation so a mixed source
+// never sends a chat model to /v1/images/generations.
 func (p *Provider) bestImageModel() string {
-	bestID, bestPrio := "", -1
 	for _, m := range p.cfg.Models {
 		if m.Kind != "" && m.Kind != "image" {
 			continue
 		}
-		if m.Priority > bestPrio {
-			bestPrio = m.Priority
-			bestID = m.ID
-		}
+		return m.ID
 	}
-	if bestID == "" && len(p.cfg.Models) > 0 {
-		bestID = p.cfg.Models[0].ID
+	if len(p.cfg.Models) > 0 {
+		return p.cfg.Models[0].ID
 	}
-	return bestID
+	return ""
 }
 
 // IsAutoID reports whether s is an AUTO routing placeholder.
@@ -1263,6 +1260,7 @@ func (p *Provider) ChatStream(ctx context.Context, req *types.ChatRequest) (<-ch
 		var realChunks int
 		var doneSeen bool
 		var doneSent bool
+		var sawToolCalls bool
 		// toolIdx maps a per-stream tool fragment's upstream index (Anthropic
 		// content-block ordinal, which is sparse when thinking/text blocks
 		// precede tool_use) to a dense 0-based OpenAI tool_call ordinal so
@@ -1306,6 +1304,19 @@ func (p *Provider) ChatStream(ctx context.Context, req *types.ChatRequest) (<-ch
 			if err := json.Unmarshal([]byte(unified), &ck); err != nil {
 				continue
 			}
+			// A few OpenAI-compatible upstreams emit a final `stop` marker
+			// after streaming tool-call fragments. Once a real fragment was
+			// observed, the gateway must preserve tool-call semantics for the
+			// agent instead of making it treat the turn as ordinary text.
+			if len(ck.ToolCalls) > 0 {
+				trimmed := strings.TrimSpace(string(ck.ToolCalls))
+				if trimmed != "null" && trimmed != "[]" && trimmed != "{}" {
+					sawToolCalls = true
+				}
+			}
+			if sawToolCalls && ck.FinishReason == "stop" {
+				ck.FinishReason = "tool_calls"
+			}
 			ck.ToolCalls = toolIdx.remap(ck.ToolCalls)
 			if ck.Done {
 				doneSent = true

internal/provider/provider_test.go

@@ -32,7 +32,7 @@ func newTestProvider(t *testing.T, src config.Source) *Provider {
 func src(name, url, adapter string, models ...string) config.Source {
 	s := config.Source{Name: name, BaseURL: url, Adapter: adapter, MaxConcurrent: 4}
 	for _, m := range models {
-		s.Models = append(s.Models, config.Model{ID: m, Priority: 0})
+		s.Models = append(s.Models, config.Model{ID: m})
 	}
 	return s
 }
@@ -93,7 +93,39 @@ func TestProviderChatStream(t *testing.T) {
 	}
 }
 
-// TestStreamSuccessClearsBackoff guards P6: a clean streaming end must reset
+func TestProviderChatStreamNormalizesStopAfterToolCall(t *testing.T) {
+	up := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Content-Type", "text/event-stream")
+		fmt.Fprint(w, "data: "+`{"choices":[{"delta":{"tool_calls":[{"index":0,"id":"call-1","type":"function","function":{"name":"f"}}]}}]}`+"\n\n")
+		fmt.Fprint(w, "data: "+`{"choices":[{"delta":{"tool_calls":[{"index":0,"function":{"arguments":"{}"}}]},"finish_reason":"stop"}]}`+"\n\n")
+		fmt.Fprint(w, "data: [DONE]\n\n")
+	}))
+	defer up.Close()
+	p := newTestProvider(t, src("mock", up.URL, "openai", "m"))
+	ch, err := p.ChatStream(context.Background(), &types.ChatRequest{
+		Model: "m", Stream: true,
+		Messages: []types.ChatMessage{{Role: "user", Content: types.StringContent("x")}},
+	})
+	if err != nil {
+		t.Fatalf("stream: %v", err)
+	}
+	var sawTool, sawToolFinish bool
+	for ck := range ch {
+		if len(ck.ToolCalls) > 0 && string(ck.ToolCalls) != "{}" {
+			sawTool = true
+		}
+		if ck.FinishReason == "tool_calls" {
+			sawToolFinish = true
+		}
+	}
+	if !sawTool {
+		t.Fatal("stream dropped the tool-call fragment")
+	}
+	if !sawToolFinish {
+		t.Fatal("stop after a tool call was not normalized to tool_calls")
+	}
+}
+
 // a previously cooled (source, model) pair.
 func TestStreamSuccessClearsBackoff(t *testing.T) {
 	var fail atomic.Bool
@@ -515,8 +547,8 @@ func TestImageAutoUsesImageModel(t *testing.T) {
 	defer up.Close()
 	s := config.Source{Name: "mix", BaseURL: up.URL, Adapter: "openai", MaxConcurrent: 4}
 	s.Models = []config.Model{
-		{ID: "chat-m", Kind: "chat", Priority: 100},
-		{ID: "img-m", Kind: "image", Priority: 50},
+		{ID: "chat-m", Kind: "chat"},
+		{ID: "img-m", Kind: "image"},
 	}
 	p := newTestProvider(t, s)
 	resp, err := p.Image(context.Background(), &types.ImageGenRequest{Prompt: "cat", Model: "AUTO"})