chore: api

Author: ayushkrtiwari

src/quant_research_starter/api/__init__.py

@@ -0,0 +1,11 @@
+"""API package for QuantResearchStarter backend."""
+
+__all__ = [
+    "main",
+    "db",
+    "models",
+    "schemas",
+    "auth",
+    "routers",
+    "tasks",
+]

src/quant_research_starter/api/main.py

@@ -0,0 +1,47 @@
+"""FastAPI application entrypoint for backend API."""
+from fastapi import FastAPI, APIRouter
+from fastapi.middleware.cors import CORSMiddleware
+import os
+import asyncio
+
+from .routers import auth as auth_router, backtest as backtest_router
+from .utils.ws_manager import redis_listener_loop
+
+app = FastAPI(title="QuantResearch API")
+
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=[os.getenv("CORS_ORIGINS", "*")],
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
+
+@app.on_event("startup")
+async def startup_event():
+    # Start background redis subscription for websocket broadcasting
+    loop = asyncio.get_event_loop()
+    loop.create_task(redis_listener_loop())
+
+
+@app.on_event("shutdown")
+async def shutdown_event():
+    # Nothing special for now
+    pass
+
+
+app.include_router(auth_router.router)
+app.include_router(backtest_router.router)
+app.include_router(assets_router.router)
+
+# Health / readiness
+router = APIRouter(prefix="/api")
+
+
+@router.get("/health")
+async def health():
+    return {"status": "ok"}
+
+
+app.include_router(router)