tmp: kb_diag3抓应用内自调用请求细节

wwwroot/api/kb_diag3.dspy

@@ -0,0 +1,36 @@
+# kb_diag3.dspy - 抓应用内自调用 401 的请求细节：对比外部成功调用的差异
+import json as _j
+
+uid = await get_user()
+if not uid:
+    return _j.dumps({"ok": False, "error": "未登录"}, ensure_ascii=False)
+
+out = {}
+try:
+    from pipeline_service.rag_client import resolve_project_owner, get_owner_apikey
+    pid = "d9jE6l8vx-yHO6-_pIWnY"
+    owner, _e = await resolve_project_owner(pid)
+    key, err = await get_owner_apikey(owner)
+    out["key_repr"] = repr(key)
+
+    # 完全复刻 _rag_call 的请求，打印实际发送的 URL/headers/响应
+    import aiohttp
+    base = "http://127.0.0.1:9090/rag/api"
+    url = base + "/kb_list.dspy"
+    headers = {"Authorization": "***" + key, "Content-Type": "application/json"}
+    out["send_headers"] = {k: (v if k != "Authorization" else v[:12] + "...len=" + str(len(v))) for k, v in headers.items()}
+    async with aiohttp.ClientSession(timeout=aiohttp.ClientTimeout(total=30, connect=10)) as session:
+        async with session.post(url, headers=headers, json={}) as resp:
+            body = await resp.read()
+            out["status"] = resp.status
+            out["resp_headers_ct"] = resp.headers.get("Content-Type", "")
+            out["body_head"] = body[:120].decode("utf-8", "replace")
+
+    # 对照组：同一进程内用 requests 风格的简单 GET（不带 body）
+    async with aiohttp.ClientSession(timeout=aiohttp.ClientTimeout(total=30)) as session:
+        async with session.get("http://127.0.0.1:9090/") as resp:
+            out["root_status"] = resp.status
+except Exception as e:
+    import traceback
+    out["traceback"] = traceback.format_exc()[-700:]
+return _j.dumps(out, ensure_ascii=False, default=str)