Upload 3 files

router_proxy.py

@@ -150,7 +150,21 @@ async def proxy_github_zip(req_data: ProxyGithubZipRequest, db: Session = Depend
             stream=True
         )
 
-        # 获取 Content-Length 并透传给客户端，使本地端能计算下载进度
+        # 非 200 直接返回错误，避免 Content-Length 不匹配导致 h11 协议错误
+        if response.status_code != 200:
+            error_body = ""
+            try:
+                error_body = (await response.aread()).decode('utf-8', errors='ignore')[:200]
+            except Exception:
+                pass
+            await response.aclose()
+            await client.aclose()
+            status_map = {404: "仓库不存在或无权访问", 401: "Token 无效或已过期", 403: "访问被拒绝（可能触发速率限制）"}
+            err_msg = status_map.get(response.status_code, f"GitHub API 返回 HTTP {response.status_code}")
+            print(f"[proxy_github_zip] ❌ GitHub API 失败: {response.status_code}, repo: {github_zip_api}, body: {error_body[:100]}")
+            return JSONResponse(content={"error": f"GITHUB_DOWNLOAD_FAILED: {err_msg}"}, status_code=502)
+
+        # 成功时才透传 Content-Length 和流式响应
         content_length = response.headers.get('content-length', '')
         resp_headers = {}
         if content_length:
@@ -158,9 +172,6 @@ async def proxy_github_zip(req_data: ProxyGithubZipRequest, db: Session = Depend
 
         async def stream_generator():
             try:
-                if response.status_code != 200:
-                    yield b"GITHUB_DOWNLOAD_FAILED"
-                    return
                 async for chunk in response.aiter_bytes():
                     yield chunk
             except Exception: