File size: 1,735 Bytes
590a501 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 | import logging
from contextlib import asynccontextmanager
from fastapi import FastAPI
from fastapi.middleware.cors import CORSMiddleware
from app.api.platform_routes import router as platform_router
from app.api.research_routes import router as research_router
from app.api.routes import router
from app.api.websocket import ws_router
from app.core.config import settings
from app.core.contracts import CONTRACTS
from app.models.database import init_db
from app.services.market_data import market_data_service
logging.basicConfig(level=logging.INFO, format="%(asctime)s [%(levelname)s] %(name)s: %(message)s")
logger = logging.getLogger(__name__)
@asynccontextmanager
async def lifespan(app: FastAPI):
logger.info("Starting %s v%s", settings.APP_NAME, settings.APP_VERSION)
await init_db()
await market_data_service.start()
logger.info("Market data service started for %d contracts", len(CONTRACTS))
yield
await market_data_service.stop()
logger.info("Shutdown complete")
app = FastAPI(
title=settings.APP_NAME,
version=settings.APP_VERSION,
description="Personal Trading System V1 - Futures Trading with Quantitative Strategies",
lifespan=lifespan,
)
app.add_middleware(
CORSMiddleware,
allow_origins=["*"],
allow_credentials=True,
allow_methods=["*"],
allow_headers=["*"],
)
app.include_router(router, prefix="/api")
app.include_router(platform_router, prefix="/api")
app.include_router(research_router, prefix="/api")
app.include_router(ws_router)
@app.get("/")
async def root():
return {
"name": settings.APP_NAME,
"version": settings.APP_VERSION,
"description": "Personal Trading System V1 API",
"docs": "/docs",
}
|