group_fqcd_jr/app/api/controllers/onboarding.py

"""Mandatory customer onboarding endpoints."""

from fastapi import APIRouter, Depends, Header, Query, status

from app.api.dependencies.auth import build_request_context
from app.api.schemas.risk_questionnaire import RiskQuestionnaireSubmission
from app.core.contracts import RequestContext
from app.service.risk_questionnaire_service import RiskQuestionnaireService

router = APIRouter(prefix="/api/v1/onboarding", tags=["customer-onboarding"])


@router.get("/risk-questionnaire")
async def get_risk_questionnaire(
    retake: bool = Query(default=False),
    context: RequestContext = Depends(build_request_context),  # noqa: B008
) -> dict[str, object]:
    return await RiskQuestionnaireService().questionnaire(context, retake=retake)


@router.post("/risk-questionnaire/submissions", status_code=status.HTTP_201_CREATED)
async def submit_risk_questionnaire(
    payload: RiskQuestionnaireSubmission,
    context: RequestContext = Depends(build_request_context),  # noqa: B008
    key: str | None = Header(default=None, alias="Idempotency-Key"),
) -> dict[str, object]:
    return await RiskQuestionnaireService().submit(payload, context, key)