Update app.py

app.py

@@ -1,9 +1,9 @@
 import os
 import time
 import requests
-from fastapi import FastAPI, WebSocket, WebSocketDisconnect
-from fastapi.responses import StreamingResponse
+from fastapi import FastAPI
 from datetime import datetime, timedelta
+from starlette.routing import Mount
 from fastmcp.server import FastMCP
 from contextlib import asynccontextmanager
 
@@ -59,8 +59,13 @@ async def fetch_github_trending():
         return cached_trending if cached_trending else []
 
 # 定义MCP服务器和工具
+#mcp_server = FastMCP(name="GithubTrending", stateless_http=True)
 mcp_server = FastMCP(name="GithubTrending")
 
+app.mount("/mcp", mcp_server.http_app())
+#mcp_app = mcp_server.http_app(path='/mcp')
+#app.mount("/mcp", mcp_app)
+
 @mcp_server.tool()
 def get_trending_repos(num: int = 10) -> dict:
     """Tool to get top GitHub trending repositories with stars >1000"""
@@ -68,30 +73,16 @@ def get_trending_repos(num: int = 10) -> dict:
         fetch_github_trending()
     return {"trending": cached_trending[:num]}
 
-app.mount("/mcp", mcp_server.http_app())
-
 @app.get("/trending")
 async def get_trending():
-    """原有端点"""
+    """获取GitHub热门项目"""
+    # 如果缓存为空或超过5分钟未更新，则重新获取
     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.websocket("/trending-ws")
-async def websocket_endpoint(websocket: WebSocket):
-    """WebSocket 端点替代 SSE"""
-    await websocket.accept()
-    try:
-        while True:
-            if not last_updated or (datetime.now() - last_updated) > timedelta(minutes=5):
-                await fetch_github_trending()
-            await websocket.send_json({
-                "trending": cached_trending,
-                "last_updated": last_updated.isoformat() if last_updated else None
-            })
-            await asyncio.sleep(30)  # 使用 asyncio.sleep 而不是 time.sleep
-    except WebSocketDisconnect:
-        print("Client disconnected")
-    except Exception as e:
-        print(f"WebSocket error: {e}")
-        await websocket.close(code=1011)
+    
+    return {
+        "trending": cached_trending,
+        "last_updated": last_updated.isoformat() if last_updated else None,
+        "cache_expires_in": 300,  # 告诉客户端缓存有效期(秒)
+        "suggested_polling_interval": 60  # 建议客户端轮询间隔(秒)
+    }