Upload 2 files

router_items.py

@@ -355,7 +355,9 @@ async def create_item(item: ItemCreate):
                         await precache_github_zip(link, token, new_item["id"], latest_hash)
                         print(f"[缓存刷新] 首次发布预缓存完成: {new_item['id']}")
                 except Exception as e:
+                    import traceback
                     print(f"[缓存刷新] 首次发布预缓存失败（不影响发布）: {e}")
+                    print(f"[缓存刷新] 详细堆栈: {traceback.format_exc()}")
             
             asyncio.create_task(_first_publish_precache())
     except Exception as e:
@@ -854,4 +856,62 @@ async def toggle_item_favorite(item_id: str, current_user: str = Depends(require
     # 🗂️ 清除排序缓存（收藏数变化可能影响排序）
     sort_cache.invalidate("items:")
     
-    return result_container[0]
+    return result_container[0]
+
+
+# ==========================================
+# 🔄 手动触发预缓存刷新接口
+# ==========================================
+@router.post("/api/items/{item_id}/refresh_cache")
+async def refresh_item_cache(item_id: str, current_user: str = Depends(require_auth)):
+    """手动触发指定资源的 ZIP 预缓存刷新，仅限作者调用"""
+    items_db = db.load_data("items.json", default_data=[])
+    
+    # 查找目标 item
+    target_item = None
+    for item in items_db:
+        if item["id"] == item_id:
+            target_item = item
+            break
+    
+    if not target_item:
+        raise HTTPException(status_code=404, detail="资源不存在")
+    
+    # 权限校验：仅作者可操作
+    if target_item.get("author") != current_user:
+        raise HTTPException(status_code=403, detail="仅作者可触发缓存刷新")
+    
+    # 仅支持 GitHub 仓库类型
+    link = target_item.get("link", "")
+    if "github.com" not in link:
+        raise HTTPException(status_code=400, detail="仅支持 GitHub 仓库类型的资源")
+    
+    try:
+        from 云端_定时版本检测引擎 import fetch_latest_github_hash, precache_github_zip
+    except ImportError:
+        raise HTTPException(status_code=500, detail="预缓存模块不可用")
+    
+    # 获取 token
+    token = target_item.get("github_token") or os.environ.get("GITHUB_PAT", "")
+    
+    # 获取最新 hash
+    latest_hash = await fetch_latest_github_hash(link, token)
+    if not latest_hash:
+        raise HTTPException(status_code=500, detail="获取最新版本号失败，请稍后重试")
+    
+    # 写入 versions.json
+    versions_db = db.load_data("versions.json", default_data={})
+    entry = versions_db.get(item_id, {})
+    if isinstance(entry, str):
+        entry = {"hash": entry}
+    entry["hash"] = latest_hash
+    versions_db[item_id] = entry
+    db.save_data("versions.json", versions_db)
+    
+    # 执行预缓存
+    success = await precache_github_zip(link, token, item_id, latest_hash)
+    
+    if success:
+        return {"status": "success", "message": "缓存刷新完成"}
+    else:
+        return {"status": "error", "message": "缓存刷新失败，请查看云端日志获取详细信息"}

云端_定时版本检测引擎.py

@@ -200,7 +200,7 @@ async def precache_github_zip(repo_url: str, token: Optional[str], item_id: str,
             "User-Agent": "ComfyUI-Hub"
         }
         if token:
-            headers["Authorization"] = f"token {token}"
+            headers["Authorization"] = f"Bearer {token}"
 
         hf_token = os.environ.get("HF_TOKEN")
         if not hf_token: