27 Add mcp server

.cursor/mcp.json

@@ -15,12 +15,11 @@
       "disabled": false,
       "autoApprove": []
     },
-    "apidog": {
+    "API specification": {
       "command": "npx",
-      "args": ["-y", "apidog-mcp-server@latest", "--project-id=${env:APIDOG_PROJECT_ID}"],
+      "args": ["-y", "apidog-mcp-server@latest", "--project=1134437"],
       "env": {
-        "APIDOG_PROJECT_ID": "${env:APIDOG_PROJECT_ID}",
-        "APIDOG_ACCESS_TOKEN": "${env:APIDOG_ACCESS_TOKEN}"
+        "APIDOG_ACCESS_TOKEN": "${APIDOG_ACCESS_TOKEN}"
       }
     }
   }

.env.example

@@ -1,5 +1,5 @@
 # MCP
-APIDOG_PROJECT_ID=1058162
+APIDOG_ACCESS_TOKEN=
 
 # DB
 POSTGRES_USER=chatbot

backend/app/main.py

@@ -23,7 +23,7 @@
     validation_exception_handler,
 )
 from app.presentation.middleware.request_id import RequestIDMiddleware
-from app.presentation.routers import chat, health
+from app.presentation.routers import chat, health, sse
 
 # ログ設定
 configure_logging(log_level=settings.LOG_LEVEL, json_logs=settings.JSON_LOGS)
@@ -85,6 +85,7 @@ async def lifespan(app: FastAPI) -> AsyncIterator[None]:
 # ルーターの登録
 app.include_router(health.router, prefix="/api/health", tags=["health"])
 app.include_router(chat.router, prefix="/api/chat", tags=["chat"])
+app.include_router(sse.router, prefix="/api/sse", tags=["sse"])
 
 # MCPサーバーのマウント（有効な場合のみ）
 # Claude Desktop、VS Code等のMCPクライアントから /mcp エンドポイントで接続可能

backend/app/presentation/routers/sse.py

@@ -0,0 +1,74 @@
+"""
+SSE（Server-Sent Events）エンドポイント
+Apidogでのテスト用シンプル実装
+"""
+
+import asyncio
+from collections.abc import AsyncGenerator
+
+from fastapi import APIRouter
+from fastapi.responses import StreamingResponse
+
+router = APIRouter()
+
+
+async def event_generator() -> AsyncGenerator[str, None]:
+    """
+    SSEイベントを生成するジェネレーター
+    5回のイベントを1秒間隔で送信
+    """
+    for i in range(1, 6):
+        # SSEフォーマット: "data: メッセージ\n\n"
+        yield f"data: Message {i}: Hello from SSE!\n\n"
+        await asyncio.sleep(1)
+
+    # 完了イベント
+    yield "data: [DONE]\n\n"
+
+
+@router.get("/stream")
+async def sse_stream() -> StreamingResponse:
+    """
+    シンプルなSSEストリーミングエンドポイント
+    1秒間隔で5つのメッセージを送信し、最後に[DONE]を送信
+    """
+    return StreamingResponse(
+        event_generator(),
+        media_type="text/event-stream",
+        headers={
+            "Cache-Control": "no-cache",
+            "Connection": "keep-alive",
+            "X-Accel-Buffering": "no",  # Nginxのバッファリング無効化
+        },
+    )
+
+
+async def countdown_generator(count: int) -> AsyncGenerator[str, None]:
+    """
+    カウントダウンイベントを生成するジェネレーター
+    """
+    for i in range(count, 0, -1):
+        yield f"event: countdown\ndata: {i}\n\n"
+        await asyncio.sleep(1)
+
+    yield "event: complete\ndata: Countdown finished!\n\n"
+
+
+@router.get("/countdown/{count}")
+async def sse_countdown(count: int = 10) -> StreamingResponse:
+    """
+    カウントダウンSSEエンドポイント
+    指定した数からカウントダウン（デフォルト: 10）
+    """
+    # 最大60秒に制限
+    count = min(count, 60)
+
+    return StreamingResponse(
+        countdown_generator(count),
+        media_type="text/event-stream",
+        headers={
+            "Cache-Control": "no-cache",
+            "Connection": "keep-alive",
+            "X-Accel-Buffering": "no",
+        },
+    )