From e9d35b86e3b5f10c41d29506d322e1c6556b09e2 Mon Sep 17 00:00:00 2001
From: ymq <ymq@opencomputing.net>
Date: Fri, 4 Sep 2026 19:44:20 +0800
Subject: [PATCH] =?UTF-8?q?tmp:=20kb=5Fdiag3=E6=8A=93=E5=BA=94=E7=94=A8?=
 =?UTF-8?q?=E5=86=85=E8=87=AA=E8=B0=83=E7=94=A8=E8=AF=B7=E6=B1=82=E7=BB=86?=
 =?UTF-8?q?=E8=8A=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 wwwroot/api/kb_diag3.dspy | 36 ++++++++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)
 create mode 100644 wwwroot/api/kb_diag3.dspy

diff --git a/wwwroot/api/kb_diag3.dspy b/wwwroot/api/kb_diag3.dspy
new file mode 100644
index 0000000..7898085
--- /dev/null
+++ b/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)