Update app.py

app.py

@@ -4,18 +4,17 @@ 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
 
@@ -41,7 +40,6 @@ async def fetch_github_trending():
         response.raise_for_status()
         items = response.json().get("items", [])
         
-        # 简化项目信息
         trending_projects = []
         for item in items:
             trending_projects.append({
@@ -59,8 +57,8 @@ async def fetch_github_trending():
         print(f"Error fetching GitHub trending: {e}")
         return cached_trending if cached_trending else []
 
-# 定义MCP服务器和工具
-mcp_server = FastMCP(name="GithubTrending", stateless_http=True)
+#mcp_server = FastMCP(name="GithubTrending", stateless_http=True)
+mcp_server = FastMCP(name="GithubTrending")
 
 @mcp_server.tool()
 def get_trending_repos(num: int = 10) -> dict:
@@ -69,10 +67,10 @@ 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.streamable_http_app())
+app.mount("/mcp", mcp_server.http_app())
 
 async def trending_generator():
-    """SSE 事件生成器"""
     while True:
         if not last_updated or (datetime.now() - last_updated) > timedelta(minutes=5):
             await fetch_github_trending()
@@ -81,14 +79,12 @@ 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",