feat(proxy): ANTHROPIC_MODEL as catch-all fallback for hot-switch model replacement

- resolveProfileModel: ANTHROPIC_MODEL now serves as default when family-specific
  fields are empty or the model family is unrecognized (incl. K3/kimi, third-party)
- Strip [1m] suffix from all profile model field values before comparison
- Symmetric strip1m on both target and oldModel for equality check
- Fix flaky sse-compression test (endsWith -> includes for brotli decompressor)

Author: weiesky.wangc

server/lib/interceptor-core.js

@@ -400,34 +400,45 @@ export function replaceTopLevelModel(jsonStr, oldModel, newModel) {
 // 家族用**大小写不敏感子串**匹配（/opus/i 等），只认这几个已知家族单词——
 // 因此 claude-opus-4-8、未来的 claude-opus-5 等任何版本都命中同一家族，版本升级无需重配。
 // 字段直接沿用 Claude Code 的环境变量名以保持一致：
-//   ANTHROPIC_MODEL              —— 主模型；body.model 含 "fable" / "mythos" 时映射到它
+//   ANTHROPIC_MODEL              —— 主模型（catch-all 兜底；body.model 含 "fable"/"mythos"
+//                                   及所有未识别家族均回落到它）
 //   ANTHROPIC_DEFAULT_OPUS_MODEL   —— body.model 含 "opus"
 //   ANTHROPIC_DEFAULT_SONNET_MODEL —— 含 "sonnet"
 //   ANTHROPIC_DEFAULT_HAIKU_MODEL  —— 含 "haiku"
-// 家族字段留空 = 该家族不改写（透传原始 model）。
-// 未识别家族（既不是 opus/sonnet/haiku 也不是 fable/mythos）不做兜底替换，原样透传。
+// 家族字段优先：opus/sonnet/haiku 各自命中专属字段；字段留空则回落到 ANTHROPIC_MODEL。
+// 未识别家族（既不是 opus/sonnet/haiku 也不是 fable/mythos）→ ANTHROPIC_MODEL 兜底。
 // 兼容旧数据：profile 未设任何新字段但有 activeModel（老结构）时，回退为旧的整体替换语义。
-// 返回目标模型字符串；无需改写（无目标 / 目标同旧值 / 入参非法 / 未识别家族）时返回 null。
+// 返回目标模型字符串；无需改写（无目标 / 目标同旧值 / 入参非法）时返回 null。
+// [1m] 后缀（Claude Code 1M context 标记）默认忽略：所有 profile 模型字段值在比较前先剥除。
 export function resolveProfileModel(oldModel, profile) {
   if (typeof oldModel !== 'string' || !oldModel || !profile || typeof profile !== 'object') return null;
-  const opus = typeof profile.ANTHROPIC_DEFAULT_OPUS_MODEL === 'string' ? profile.ANTHROPIC_DEFAULT_OPUS_MODEL.trim() : '';
-  const sonnet = typeof profile.ANTHROPIC_DEFAULT_SONNET_MODEL === 'string' ? profile.ANTHROPIC_DEFAULT_SONNET_MODEL.trim() : '';
-  const haiku = typeof profile.ANTHROPIC_DEFAULT_HAIKU_MODEL === 'string' ? profile.ANTHROPIC_DEFAULT_HAIKU_MODEL.trim() : '';
-  const primary = typeof profile.ANTHROPIC_MODEL === 'string' ? profile.ANTHROPIC_MODEL.trim() : '';
+
+  // Strip [1m] suffix (case-insensitive) from model names; Claude Code appends it
+  // for 1M-context variants and it should not affect model matching/replacement.
+  const strip1m = (s) => (typeof s === 'string' ? s.replace(/\[1m\]/gi, '').trim() : '');
+
+  const opus = strip1m(profile.ANTHROPIC_DEFAULT_OPUS_MODEL);
+  const sonnet = strip1m(profile.ANTHROPIC_DEFAULT_SONNET_MODEL);
+  const haiku = strip1m(profile.ANTHROPIC_DEFAULT_HAIKU_MODEL);
+  const primary = strip1m(profile.ANTHROPIC_MODEL);
   const hasNew = !!(primary || opus || sonnet || haiku);
 
   let target = '';
   if (hasNew) {
-    if (/opus/i.test(oldModel)) target = opus;
-    else if (/sonnet/i.test(oldModel)) target = sonnet;
-    else if (/haiku/i.test(oldModel)) target = haiku;
-    else if (/fable/i.test(oldModel) || /mythos/i.test(oldModel)) target = primary; // 显式家族 → 主模型
-    // 未识别家族：target 保持 ''，下方返回 null（不替换、原样透传）
+    // Family-specific fields take precedence; fall back to ANTHROPIC_MODEL when
+    // the family field is empty/unset. ANTHROPIC_MODEL itself acts as the
+    // catch-all default for any unrecognized family (including third-party models
+    // like gpt-4o, deepseek-v4, K3/kimi, etc.).
+    if (/opus/i.test(oldModel)) target = opus || primary;
+    else if (/sonnet/i.test(oldModel)) target = sonnet || primary;
+    else if (/haiku/i.test(oldModel)) target = haiku || primary;
+    else if (/fable/i.test(oldModel) || /mythos/i.test(oldModel)) target = primary;
+    else target = primary; // unrecognized family → ANTHROPIC_MODEL catch-all
   } else if (typeof profile.activeModel === 'string') {
-    target = profile.activeModel.trim(); // 旧数据整体替换语义
+    target = strip1m(profile.activeModel); // 旧数据整体替换语义
   }
 
-  if (!target || target === oldModel) return null;
+  if (!target || target === strip1m(oldModel)) return null;
   return target;
 }
 

test/interceptor-profile.test.js

@@ -243,15 +243,18 @@ describe('proxy 请求改写（通过真实 fetch hook）', () => {
     }
   });
 
-  it('家族字段留空 → 该家族不替换（透传原始 model）', async () => {
+  it('家族字段留空 → 回落到 ANTHROPIC_MODEL', async () => {
     writeProfile({ active: 'p1', profiles: [
       { id: 'p1', name: 'PartialFam', baseURL: 'https://m.example.com', apiKey: 'sk-m',
         ANTHROPIC_MODEL: 'PRIMARY', ANTHROPIC_DEFAULT_HAIKU_MODEL: 'HAIKU-T' },
     ] });
     mod._loadProxyProfile();
-    // opus 家族无字段 → 但有 ANTHROPIC_MODEL？不：家族命中 opus 走 opus 字段(空)→ 不替换
+    // opus 家族无字段 → ANTHROPIC_MODEL(PRIMARY) 兜底替换
     await postJson('https://api.anthropic.com/v1/messages', { model: 'claude-opus-4-8', messages: [] });
-    assert.equal(JSON.parse(lastFetchArgs[1].body).model, 'claude-opus-4-8', 'opus 字段空 → 不替换');
+    assert.equal(JSON.parse(lastFetchArgs[1].body).model, 'PRIMARY', 'opus 字段空 → PRIMARY 兜底');
+    // sonnet 家族也无字段 → PRIMARY 兜底
+    await postJson('https://api.anthropic.com/v1/messages', { model: 'claude-sonnet-4', messages: [] });
+    assert.equal(JSON.parse(lastFetchArgs[1].body).model, 'PRIMARY', 'sonnet 字段空 → PRIMARY 兜底');
     // haiku 家族有字段 → 替换
     await postJson('https://api.anthropic.com/v1/messages', { model: 'claude-3-5-haiku', messages: [] });
     assert.equal(JSON.parse(lastFetchArgs[1].body).model, 'HAIKU-T');

test/resolve-profile-model.test.js

@@ -2,7 +2,9 @@
  * resolveProfileModel + migrateProxyProfile 单测 —— proxy 热切换按家族映射模型 + 旧配置迁移。
  *
  * resolveProfileModel：按 body.model 家族（opus/sonnet/haiku）映射到 profile 对应字段，
- * fable/mythos/未识别 → ANTHROPIC_MODEL；无新字段但有 activeModel（旧数据）→ 整体替换回退。
+ * fable/mythos/未识别 → ANTHROPIC_MODEL 兜底；无新字段但有 activeModel（旧数据）→ 整体替换回退。
+ * 家族字段优先于 ANTHROPIC_MODEL；字段留空时回落到 ANTHROPIC_MODEL。
+ * [1m] 后缀默认忽略（剥除后比较）。
  * 目标为空 / 等于旧值 / 入参非法 → null（不改写）。
  * migrate*：老 { models, activeModel } → ANTHROPIC_MODEL，幂等。
  */
@@ -31,16 +33,60 @@ describe('resolveProfileModel', () => {
     assert.equal(resolveProfileModel('claude-fable-5', fam), 'PRIMARY');
     assert.equal(resolveProfileModel('mythos-1', fam), 'PRIMARY');
   });
-  it('未识别家族 → null（原样透传，不兜底替换）', () => {
-    assert.equal(resolveProfileModel('some-random-model', fam), null);
-    assert.equal(resolveProfileModel('gpt-4o', fam), null);
+  it('未识别家族 → ANTHROPIC_MODEL 兜底（热切换开启时）', () => {
+    assert.equal(resolveProfileModel('some-random-model', fam), 'PRIMARY');
+    assert.equal(resolveProfileModel('gpt-4o', fam), 'PRIMARY');
+    assert.equal(resolveProfileModel('K3', fam), 'PRIMARY'); // K3/kimi alias → PRIMARY
+    assert.equal(resolveProfileModel('deepseek-v4', fam), 'PRIMARY');
   });
-  it('家族字段留空 → 该家族不替换（null）', () => {
+  it('未识别家族 + 无 ANTHROPIC_MODEL → null（无兜底目标）', () => {
+    const noPrimary = { ANTHROPIC_DEFAULT_OPUS_MODEL: 'OPUS-T' };
+    assert.equal(resolveProfileModel('some-random-model', noPrimary), null);
+    assert.equal(resolveProfileModel('gpt-4o', noPrimary), null);
+  });
+  it('家族字段留空 → 回落到 ANTHROPIC_MODEL', () => {
     const partial = { ANTHROPIC_MODEL: 'PRIMARY', ANTHROPIC_DEFAULT_HAIKU_MODEL: 'HAIKU-T' };
-    assert.equal(resolveProfileModel('claude-opus-4-8', partial), null); // opus 空 → 不回落到 PRIMARY
-    assert.equal(resolveProfileModel('claude-3-5-haiku', partial), 'HAIKU-T');
+    assert.equal(resolveProfileModel('claude-opus-4-8', partial), 'PRIMARY');   // opus 空 → PRIMARY 兜底
+    assert.equal(resolveProfileModel('claude-sonnet-4', partial), 'PRIMARY');   // sonnet 空 → PRIMARY 兜底
+    assert.equal(resolveProfileModel('claude-3-5-haiku', partial), 'HAIKU-T');  // haiku 有专属字段
     assert.equal(resolveProfileModel('claude-fable-5', partial), 'PRIMARY');
   });
+  it('ANTHROPIC_MODEL 留空 + 家族字段留空 → 该家族不替换（null）', () => {
+    // Only HAIKU field set, no PRIMARY, opus/sonnet both empty → no fallback target
+    const haikuOnly = { ANTHROPIC_DEFAULT_HAIKU_MODEL: 'HAIKU-T' };
+    assert.equal(resolveProfileModel('claude-opus-4-8', haikuOnly), null);
+    assert.equal(resolveProfileModel('claude-sonnet-4', haikuOnly), null);
+    assert.equal(resolveProfileModel('claude-3-5-haiku', haikuOnly), 'HAIKU-T');
+  });
+  it('[1m] suffix in profile fields is stripped before comparison', () => {
+    const with1m = {
+      ANTHROPIC_MODEL: 'claude-sonnet-5[1m]',
+      ANTHROPIC_DEFAULT_OPUS_MODEL: 'claude-opus-4-8[1m]',
+    };
+    assert.equal(resolveProfileModel('claude-fable-5', with1m), 'claude-sonnet-5');
+    // opus field strips to 'claude-opus-4-8' which equals oldModel → null (no-op)
+    assert.equal(resolveProfileModel('claude-opus-4-8', with1m), null);
+  });
+  it('[1m] suffix case-insensitive strip', () => {
+    assert.equal(
+      resolveProfileModel('claude-opus-4-8', { ANTHROPIC_DEFAULT_OPUS_MODEL: 'CLAUDE-OPUS-4[1M]' }),
+      'CLAUDE-OPUS-4'
+    );
+  });
+  it('K3[1m] → strips to K3', () => {
+    assert.equal(
+      resolveProfileModel('gpt-4o', { ANTHROPIC_MODEL: 'K3[1m]' }),
+      'K3'
+    );
+  });
+  it('target equals oldModel after [1m] strip → null (no-op)', () => {
+    // Profile field carries [1m], oldModel doesn't → no-op
+    assert.equal(resolveProfileModel('my-model', { ANTHROPIC_MODEL: 'my-model[1m]' }), null);
+    // Both oldModel and profile field carry [1m] → symmetric strip → no-op
+    assert.equal(resolveProfileModel('claude-opus-4-8[1m]', { ANTHROPIC_DEFAULT_OPUS_MODEL: 'claude-opus-4-8[1m]' }), null);
+    // oldModel carries [1m], profile field doesn't → no-op (oldModel also stripped before compare)
+    assert.equal(resolveProfileModel('claude-opus-4-8[1m]', { ANTHROPIC_DEFAULT_OPUS_MODEL: 'claude-opus-4-8' }), null);
+  });
   it('目标等于旧值 → null（无需改写）', () => {
     // fable 命中 primary，且旧值已是 PRIMARY
     assert.equal(resolveProfileModel('PRIMARY', fam), null);
@@ -61,8 +107,8 @@ describe('resolveProfileModel', () => {
   it('新字段存在时忽略 legacy activeModel', () => {
     const mixed = { ANTHROPIC_MODEL: 'PRIMARY', activeModel: 'LEGACY-T' };
     assert.equal(resolveProfileModel('claude-fable-5', mixed), 'PRIMARY');
-    // opus 无字段 → 不替换（不回退到 legacy）
-    assert.equal(resolveProfileModel('claude-opus-4-8', mixed), null);
+    // opus 无字段 → PRIMARY 兜底（不回退到 legacy）
+    assert.equal(resolveProfileModel('claude-opus-4-8', mixed), 'PRIMARY');
   });
   it('空 profile / 空 model / 非法入参 → null', () => {
     assert.equal(resolveProfileModel('claude-opus-4-8', {}), null);

test/spawn-model-resolver.test.js

@@ -82,12 +82,12 @@ describe('resolveSpawnModel: 三方 profile', () => {
     assert.equal(resolveSpawnModel('/ws', {}, opts), 'deepseek-v4-pro');
   });
 
-  it('base 属 opus 家族 → 映射到 opus 槽位；家族槽位留空 → 透传 base', () => {
+  it('base 属 opus 家族 → 映射到 opus 槽位；家族槽位留空 → ANTHROPIC_MODEL 兜底', () => {
     const { logDir, opts } = mkRoots();
     writeProfiles(logDir, PROFILES);
     assert.equal(resolveSpawnModel('/ws', { ANTHROPIC_MODEL: 'claude-opus-4-8' }, opts), 'deepseek-v4-opus-slot');
-    // sonnet 槽位未配置 → resolveProfileModel 返回 null → 透传 base
-    assert.equal(resolveSpawnModel('/ws', { ANTHROPIC_MODEL: 'claude-sonnet-5' }, opts), 'claude-sonnet-5');
+    // sonnet 槽位未配置 → ANTHROPIC_MODEL(deepseek-v4-pro) 兜底
+    assert.equal(resolveSpawnModel('/ws', { ANTHROPIC_MODEL: 'claude-sonnet-5' }, opts), 'deepseek-v4-pro');
   });
 
   it('base 无信号 + profile 激活 → 用 profile 主模型；主模型空则回退旧 activeModel', () => {

test/sse-compression.test.js

@@ -166,7 +166,7 @@ describe('GET /events wire compression', () => {
     const plainTail = Buffer.concat(plainRes.chunks.slice(plainMark)).toString();
     assert.equal(plainTail, expected);
     const decoded = await decodeBr(brRes, (t) => t.includes(expected));
-    assert.ok(decoded.endsWith(expected), 'compressed client received the broadcast frame');
+    assert.ok(decoded.includes(expected), 'compressed client received the broadcast frame');
     plainRes.emit('close');
     brRes.emit('close');
   });