auto-sync: 2026-05-17 00:46:55
This commit is contained in:
@@ -0,0 +1,17 @@
|
||||
"""SSE 推送路由(占位,F17 完善)"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
from fastapi import APIRouter, Request
|
||||
from fastapi.responses import StreamingResponse
|
||||
|
||||
router = APIRouter(prefix="/api/events", tags=["sse"])
|
||||
|
||||
|
||||
@router.get("")
|
||||
async def event_stream(request: Request):
|
||||
"""SSE 端点(占位,F17 实现真实推送)"""
|
||||
async def generate():
|
||||
yield f"data: {{"}}\"type\":\"connected\"}}\n\n"
|
||||
|
||||
return StreamingResponse(generate(), media_type="text/event-stream")
|
||||
+14
@@ -95,6 +95,20 @@ app.add_middleware(
|
||||
allow_headers=["*"],
|
||||
)
|
||||
|
||||
# ---------------------------------------------------------------------------
|
||||
# API 路由注册
|
||||
# ---------------------------------------------------------------------------
|
||||
|
||||
from src.api.blackboard_routes import router as blackboard_router
|
||||
from src.api.daemon_routes import router as daemon_router
|
||||
from src.api.project_routes import router as project_router
|
||||
from src.api.sse_routes import router as sse_router
|
||||
|
||||
app.include_router(blackboard_router)
|
||||
app.include_router(daemon_router)
|
||||
app.include_router(project_router)
|
||||
app.include_router(sse_router)
|
||||
|
||||
# ---------------------------------------------------------------------------
|
||||
# 健康端点
|
||||
# ---------------------------------------------------------------------------
|
||||
|
||||
Reference in New Issue
Block a user