## 2. services/api-gateway/api.py

from fastapi import APIRouter
from pydantic import BaseModel, Field
from datetime import datetime
from typing import Dict

router = APIRouter()

class RiskTelemetry(BaseModel):
    timestamp: datetime = Field(default_factory=datetime.utcnow)
    segment_id: str
    exposure_usd: float
    confidence_score: float

@router.post("/telemetry/ingest")
async def ingest_risk_data(telemetry: RiskTelemetry):
    return {"status": "ingested", "id": "tx-882"}