fix: CodeBuddy body 归一 developer 角色（PI 11128 的最终根因）

新增请求体 dump 诊断开关（DUMP_REQUEST_BODIES=1）后拿到 PI 真实
请求体，逐字段二分定位：

- PI 对 reasoning 模型把 system 消息转成 OpenAI 的
  role: "developer"（convertMessages: useDeveloperRole）
- 腾讯 CB 后端不认 developer 角色，直接判 11128 渠道风控
- 实测：原样 body=11128；仅把 developer 改回 system=200；
  去掉 reasoning_effort/store/max_completion_tokens/stream_options/
  tools.strict 均仍 11128（全部排除）

修复：CB stream_chat 归一 messages 中 developer → system。

端到端验证：PI 原始 body（含 developer、tool 历史、7 个工具）
经服务请求 → 200 正常流式回复。后端 640 测试 / 覆盖 100%。

Author: RobbsLuo

src/config.py

@@ -43,6 +43,8 @@ class Settings(BaseSettings):
     # CodeBuddy 聊天最小间隔：腾讯频率风控（11128）在连续快速请求时触发，
     # 实测 ≥5s 间隔稳定避开；0 关闭节流
     codebuddy_chat_min_interval: float = 5
+    # 诊断：把 /v1 入口的原始请求体落到 data/dumps/（排查客户端差异用）
+    dump_request_bodies: bool = False
 
     @cached_property
     def admin_set(self) -> frozenset[str]:

src/main.py

@@ -3,6 +3,7 @@
 from __future__ import annotations
 
 import asyncio
+import json
 import logging
 import time
 from contextlib import asynccontextmanager
@@ -286,6 +287,11 @@ async def health():
     @app.post("/v1/chat/completions")
     async def chat_completions(request: Request, user: str = Depends(api_key_user)):
         body = await request.json()
+        if config.dump_request_bodies:
+            dump_dir = Path(config.data_dir) / "dumps"
+            dump_dir.mkdir(parents=True, exist_ok=True)
+            (dump_dir / f"{int(time.time() * 1000)}.json").write_text(
+                json.dumps(body, ensure_ascii=False, indent=1), encoding="utf-8")
         chat_request = parse_chat_request(body)
         if chat_request.stream:
             return StreamingResponse(executor.stream(chat_request, username=user),

src/provider/codebuddy/client.py

@@ -87,6 +87,13 @@ async def stream_chat(self, credential: CodeBuddyCredential, payload: dict[str,
         body = dict(payload)
         body["model"] = model
         body["stream"] = True
+        # PI 等客户端对 reasoning 模型会把 system 转成 OpenAI 的 developer
+        # 角色；腾讯后端不认 developer，实测直接判 11128 渠道风控 → 归一为 system
+        messages = body.get("messages")
+        if isinstance(messages, list):
+            for message in messages:
+                if isinstance(message, dict) and message.get("role") == "developer":
+                    message["role"] = "system"
         # 官方 CLI 请求的标准特征字段；缺失会被渠道风控判定非官方调用（11128）
         body.setdefault("enable_thinking", True)
         stream_options = body.get("stream_options")

tests/test_m15_operations.py

@@ -2474,3 +2474,40 @@ def test_authorize_without_pending_login_still_rejected(tmp_path):
         response = client.get("/authorize?refreshToken=RT")
     assert response.status_code == 400
     assert response.json()["error"]["code"] == "invalid_request"
+
+
+def test_dump_request_bodies_writes_file(tmp_path):
+    """诊断开关：dump_request_bodies=True 时 /v1 请求体落盘（main 291-293）。"""
+    import json as _json
+
+    from fastapi.testclient import TestClient
+
+    from src.config import Settings
+    from src.main import build_app
+
+    settings = Settings(_env_file=None, APP_SECRET="s", DATA_DIR=str(tmp_path),
+                        dump_request_bodies=True)
+
+    class P:
+        id = "p1"
+
+        async def list_models(self, _data):
+            from src.provider.base import Model
+
+            return [Model(id="m")]
+
+        def import_credential(self, raw):  # pragma: no cover
+            return raw
+
+    app = build_app(settings, providers={"p1": P()})
+    key = app.state.api_keys.create("root")["api_key"]
+    with TestClient(app) as client:
+        r = client.post("/v1/chat/completions",
+                        headers={"Authorization": f"Bearer {key}"},
+                        json={"model": "m", "stream": False,
+                              "messages": [{"role": "user", "content": "hi"}]})
+        assert r.status_code in (200, 400, 503)  # body 是否合法不影响 dump
+        dumps = list((tmp_path / "dumps").glob("*.json"))
+        assert dumps, "应产生 dump 文件"
+        body = _json.loads(dumps[0].read_text(encoding="utf-8"))
+        assert body["model"] == "m"

tests/test_m1b_codebuddy.py

@@ -1230,3 +1230,23 @@ async def stream_chat(self, _cred, _payload, _model):
     rows = [tuple(r) for r in db.connect().execute(
         "SELECT err_count, cooling_until FROM credentials ORDER BY provider")]
     assert rows == [(0, None), (0, None)]       # TRAE 4001 不冷却
+
+
+async def test_stream_chat_normalizes_developer_role():
+    """PI 的 developer 角色归一为 system（腾讯实测 developer → 11128）。"""
+    import json as _json
+
+    captured: dict = {}
+
+    def capture_handler(request: httpx.Request) -> httpx.Response:
+        captured["body"] = _json.loads(request.read())
+        return httpx.Response(200, text=fixture("chat-basic.sse"))
+
+    provider = CodeBuddyProvider(client=_client(capture_handler))
+    payload = {"messages": [
+        {"role": "developer", "content": "You are PI."},
+        {"role": "user", "content": "hi"},
+    ]}
+    _ = [e async for e in provider.stream_chat({"bearer_token": "t"}, payload, "m")]
+    roles = [m["role"] for m in captured["body"]["messages"]]
+    assert roles == ["system", "user"]