Update app.py

app.py

@@ -1,110 +1,27 @@
-import os
-import json
-import httpx
-from fastapi import FastAPI, HTTPException, APIRouter
-from datetime import datetime, timedelta
-from fastapi.middleware.cors import CORSMiddleware
-from fastmcp.server import FastMCP
+import time
+import datetime
 from contextlib import asynccontextmanager
-from typing import List, Dict, Optional
 
-# 初始化 MCP 服务器（必须在 FastAPI 之前）
-mcp_server = FastMCP(name="GitHubTrendingAPI")
+from fastapi import FastAPI
+from fastapi_utilities import repeat_every, repeat_at
+
+my_data = ['Ready?', 'Go!', ]
 
 @asynccontextmanager
 async def lifespan(app: FastAPI):
-    await fetch_github_trending()
+    # --- startup ---
+    test()
     yield
+    # --- shutdown ---
 
 app = FastAPI(lifespan=lifespan)
 
-# CORS 配置
-app.add_middleware(
-    CORSMiddleware,
-    allow_origins=["*"],
-    allow_credentials=True,
-    allow_methods=["*"],
-    allow_headers=["*"],
-)
-
-# 缓存变量
-cached_trending = []
-last_updated = None
-
-async def fetch_github_trending():
-    global cached_trending, last_updated
-    headers = {"Accept": "application/vnd.github.v3+json"}
-    if token := os.getenv("GITHUB_TOKEN"):
-        headers["Authorization"] = f"token {token}"
-    
-    try:
-        async with httpx.AsyncClient() as client:
-            r = await client.get(
-                "https://api.github.com/search/repositories",
-                params={"q": "stars:>1000", "sort": "stars", "per_page": 10},
-                headers=headers
-            )
-            r.raise_for_status()
-            cached_trending = [
-                {
-                    "name": repo["full_name"],
-                    "url": repo["html_url"],
-                    "stars": repo["stargazers_count"]
-                }
-                for repo in r.json()["items"]
-            ]
-            last_updated = datetime.now()
-    except Exception as e:
-        print(f"Fetch error: {e}")
-        if not cached_trending:
-            raise HTTPException(500, "Failed to fetch data")
-
-@mcp_server.tool()
-async def get_trending_repos(num: int = 10) -> dict:
-    if not last_updated or (datetime.now() - last_updated) > timedelta(minutes=30):
-        await fetch_github_trending()
-    return {"trending": cached_trending[:num]}
-
-# 关键修改：正确挂载MCP路由
-# 方案1：直接挂载整个MCP应用
-app.mount("/mcp", mcp_server.http_app())
-
-# 方案2：或者使用APIRouter（如果方案1不行）
-# mcp_router = APIRouter()
-# mcp_router.include_router(mcp_server.http_app().router, prefix="")
-# app.include_router(mcp_router, prefix="/mcp")
-
-# 添加MCP健康检查路由
-@app.get("/mcp/health")
-async def mcp_health_check():
-    return {"status": "ok", "mcp_version": "1.0"}
+@repeat_at(cron="* * * * *")
+def work():
+    now_dtime = datetime.datetime.fromtimestamp(time.time()).strftime('%Y-%m-%d %H:%M:%S')
+    my_data.append(now_dtime)
+    my_data.pop(0)  # trim old values
 
 @app.get("/")
-async def root():
-    # 添加更多有用的调试信息
-    return {
-        "message": "API is running",
-        "endpoints": {
-            "mcp_tool": "/mcp/tool/get_trending_repos",
-            "mcp_schema": "/mcp/schema",
-            "mcp_health": "/mcp/health",
-            "trending": "/trending"
-        }
-    }
-
-@app.get("/trending")
-async def get_trending(num: int = 10):
-    if not cached_trending:
-        await fetch_github_trending()
-    return {"trending": cached_trending[:num]}
-
-# 在app.py中添加
-@app.get("/mcp/")
-async def mcp_root():
-    return {
-        "message": "MCP API root",
-        "endpoints": {
-            "tools": "/mcp/tool",
-            "schema": "/mcp/schema"
-        }
-    }
+def read_root():
+    return {"my_data": my_data}