Verificación de email para el onboarding en fintech

import hashlib
import os
from datetime import datetime
from mailbeam import Client
from fastapi import HTTPException

mb = Client(api_key=os.environ["MAILBEAM_KEY"])

async def verify_onboarding_email(
    email: str,
    user_id: str,
    consent_given: bool,
) -> dict:
    if not consent_given:
        raise HTTPException(
            status_code=400,
            detail="Se requiere consentimiento RGPD antes de verificar el email."
        )

    result = verifyEmail(email)

    # Registra el evento de auditoría: hash del email para minimizar datos (RGPD)
    await audit_log.write({
        "event": "email_verification",
        "user_id": user_id,
        "email_sha256": hashlib.sha256(email.lower().encode()).hexdigest(),
        "result": result.status,
        "score": result.score,
        "timestamp": datetime.utcnow().isoformat() + "Z",
        # NOTA: el email en claro NO se guarda en la pista de auditoría
    })

    if not result.valid:
        raise HTTPException(
            status_code=422,
            detail={
                "code": "EMAIL_INVALID",
                "message": "No se puede alcanzar esta dirección de email.",
                "suggestion": result.suggestion,
            }
        )

    if result.role:
        raise HTTPException(
            status_code=422,
            detail={
                "code": "ROLE_EMAIL",
                "message": "Usa una dirección personal, no un buzón compartido.",
            }
        )

    return {"verified": True, "score": result.score}