003c1d6ffc
- Extract shared route_utils.py (validate_symbol, safe decorator)
removing duplication from 6 route files
- Extract shared obb_utils.py (to_list, extract_single, safe_last)
removing duplication from calendar_service and market_service
- Fix _to_list dict mutation during iteration (use comprehension)
- Fix double vars() call and live __dict__ mutation risk
- Fix route ordering: /etf/search and /crypto/search now registered
before /{symbol} path params to prevent shadowing
- Add date format validation (YYYY-MM-DD pattern) on calendar routes
- Use timezone-aware datetime.now(tz=timezone.utc) in all services
- Add explicit type annotation for asyncio.gather results
29 lines
807 B
Python
29 lines
807 B
Python
"""Routes for macroeconomic data (FRED-powered)."""
|
|
|
|
from fastapi import APIRouter, Query
|
|
|
|
from models import ApiResponse
|
|
from route_utils import safe
|
|
import macro_service
|
|
|
|
router = APIRouter(prefix="/api/v1")
|
|
|
|
|
|
@router.get("/macro/overview", response_model=ApiResponse)
|
|
@safe
|
|
async def macro_overview():
|
|
"""Get key macro indicators: Fed rate, treasury yields, CPI, unemployment, GDP, VIX."""
|
|
data = await macro_service.get_macro_overview()
|
|
return ApiResponse(data=data)
|
|
|
|
|
|
@router.get("/macro/series/{series_id}", response_model=ApiResponse)
|
|
@safe
|
|
async def macro_series(
|
|
series_id: str,
|
|
limit: int = Query(default=30, ge=1, le=1000),
|
|
):
|
|
"""Get a specific FRED time series by ID."""
|
|
data = await macro_service.get_series(series_id, limit=limit)
|
|
return ApiResponse(data=data)
|