Upload router_proxy.py

router_proxy.py

@@ -67,4 +67,46 @@ async def proxy_github_zip(req_data: ProxyGithubZipRequest, db: Session = Depend
                 async for chunk in response.aiter_bytes():
                     yield chunk
 
-    return StreamingResponse(stream_generator(), media_type="application/zip")
+    return StreamingResponse(stream_generator(), media_type="application/zip")
+
+# ==========================================
+# 新增：工作流/应用 (App) JSON 代理下载接口
+# ==========================================
+class ProxyDownloadRequest(BaseModel):
+    url: str
+    item_id: str
+    account: str
+
+@router.post("/api/proxy_download")
+async def proxy_download(req_data: ProxyDownloadRequest, db: Session = Depends(get_db)):
+    """云端代理：校验所有权后，拉取真实的工作流 JSON 文件并透传给本地"""
+    items_db = json_db.load_data("items.json", default_data=[])
+    item = next((i for i in items_db if i["id"] == req_data.item_id), None)
+    
+    if not item: 
+        return JSONResponse(content={"error": "云端记录中找不到该资源"}, status_code=404)
+    
+    # 1. 核心鉴权：验证用户是否购买/获取过该工作流
+    price = int(item.get("price", 0))
+    if price > 0 and req_data.account != item.get("author"):
+        owned = db.query(Ownership).filter(Ownership.account == req_data.account, Ownership.item_id == req_data.item_id).first()
+        if not owned:
+            return JSONResponse(content={"error": "您尚未获取该工作流，请先在社区页面点击获取"}, status_code=403)
+
+    target_url = req_data.url
+    
+    # 2. 异步拉取真实 JSON 数据并透传回客户端
+    try:
+        # 开启 follow_redirects=True 防止源地址有 302 重定向跳转
+        async with httpx.AsyncClient(follow_redirects=True) as client:
+            resp = await client.get(target_url, timeout=30.0)
+            
+            if resp.status_code != 200:
+                return JSONResponse(content={"error": f"源文件拉取失败，HTTP状态码: {resp.status_code}"}, status_code=resp.status_code)
+            
+            # 成功则直接将 JSON 二进制流原样返回给本地 ComfyUI 引擎
+            from fastapi.responses import Response
+            return Response(content=resp.content, media_type="application/json")
+            
+    except Exception as e:
+        return JSONResponse(content={"error": f"代理下载时发生网络异常: {str(e)}"}, status_code=500)