Update app.py

app.py

@@ -128,41 +128,3 @@ async def get_trending(num: int = 10):
         "cache_expires_in": CACHE_EXPIRY.total_seconds(),
         "rate_limit_info": "Consider adding a GitHub token for higher rate limits"
     }
-
-@app.get("/trending/stream")
-async def stream_trending(interval: int = 60, client_id: str = None):
-    """增强版 SSE 端点"""
-    async def event_generator():
-        try:
-            while True:
-                # 发送心跳
-                yield "event: heartbeat\ndata: \n\n"
-                
-                # 获取数据
-                if not last_updated or (datetime.now() - last_updated) > timedelta(seconds=interval):
-                    await fetch_github_trending()
-                
-                data = {
-                    "trending": cached_trending[:10],
-                    "last_updated": last_updated.isoformat() if last_updated else None,
-                    "client_id": client_id,
-                    "next_update": (datetime.now() + timedelta(seconds=interval)).isoformat()
-                }
-                yield f"event: update\ndata: {json.dumps(data)}\n\n"
-                
-                await asyncio.sleep(interval)
-                
-        except asyncio.CancelledError:
-            print(f"客户端断开连接: {client_id}")
-        except Exception as e:
-            print(f"SSE 错误: {e}")
-
-    return StreamingResponse(
-        event_generator(),
-        media_type="text/event-stream",
-        headers={
-            "Cache-Control": "no-cache",
-            "Connection": "keep-alive",
-            "X-Accel-Buffering": "no"
-        }
-    )