Update app.py

app.py

@@ -4,17 +4,18 @@ import requests
 from fastapi import FastAPI, Response
 from fastapi.responses import StreamingResponse
 from datetime import datetime, timedelta
-from starlette.routing import Mount 
+from starlette.routing import Mount  # 用于挂载
 from fastmcp.server import FastMCP
 from contextlib import asynccontextmanager
 
 @asynccontextmanager
 async def lifespan(app: FastAPI):
-    await fetch_github_trending()
+    await fetch_github_trending()  # 启动时初始化
     yield
 
 app = FastAPI(lifespan=lifespan)
 
+# 缓存最新获取的热门项目
 cached_trending = []
 last_updated = None
 
@@ -40,6 +41,7 @@ async def fetch_github_trending():
         response.raise_for_status()
         items = response.json().get("items", [])
         
+        # 简化项目信息
         trending_projects = []
         for item in items:
             trending_projects.append({
@@ -57,8 +59,8 @@ async def fetch_github_trending():
         print(f"Error fetching GitHub trending: {e}")
         return cached_trending if cached_trending else []
 
-#mcp_server = FastMCP(name="GithubTrending", stateless_http=True)
-mcp_server = FastMCP(name="GithubTrending")
+# 定义MCP服务器和工具
+mcp_server = FastMCP(name="GithubTrending", stateless_http=True)
 
 @mcp_server.tool()
 def get_trending_repos(num: int = 10) -> dict:
@@ -67,11 +69,11 @@ def get_trending_repos(num: int = 10) -> dict:
         fetch_github_trending()
     return {"trending": cached_trending[:num]}
 
-#app.mount("/mcp", mcp_server.streamable_http_app())
-app.mount("/mcp", mcp_server.http_app())
-#app.mount("/", mcp_server.http_app())
+mcp_app = mcp_server.http_app(path='/mcp')
+app.mount("/mcp", mcp_app)
 
 async def trending_generator():
+    """SSE 事件生成器"""
     while True:
         if not last_updated or (datetime.now() - last_updated) > timedelta(minutes=5):
             await fetch_github_trending()
@@ -80,13 +82,14 @@ async def trending_generator():
 
 @app.get("/trending")
 async def get_trending():
+    """原有端点"""
     if not cached_trending or (datetime.now() - last_updated) > timedelta(minutes=5):
         await fetch_github_trending()
     return {"trending": cached_trending, "last_updated": last_updated.isoformat() if last_updated else None}
 
-
 @app.get("/trending-sse")
 async def get_trending_sse():
+    """原有SSE端点"""
     return StreamingResponse(
         trending_generator(),
         media_type="text/event-stream",