Update routes/onboarding.py

routes/onboarding.py

@@ -1,11 +1,19 @@
 import os
 import logging
 import aiohttp
+from pydantic import BaseModel
 from fastapi import APIRouter, HTTPException
-from typing import List, Dict, Any
+from typing import List, Dict, Any, Optional
 
 router = APIRouter()
 
+class UpdateOnboardingQuestion(BaseModel):
+    id: int
+    title: Optional[str] = None
+    question_type: Optional[str] = None
+    optional: Optional[bool] = None
+    options: Optional[List[str]] = None
+    
 # Supabase configs
 SUPABASE_URL = "https://ussxqnifefkgkaumjann.supabase.co"
 SUPABASE_KEY = os.getenv("SUPA_KEY")
@@ -30,6 +38,44 @@ SUPABASE_ROLE_HEADERS = {
 logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)
 
+@router.patch("/onboarding/update-question")
+async def update_onboarding_question(payload: UpdateOnboardingQuestion = Body(...)):
+    """
+    Atualiza uma pergunta de onboarding com base no ID.
+    Apenas os campos enviados no payload serão atualizados.
+    """
+    try:
+        update_data = {}
+
+        if payload.title is not None:
+            update_data["title"] = payload.title
+        if payload.question_type is not None:
+            update_data["question_type"] = payload.question_type
+        if payload.optional is not None:
+            update_data["optional"] = payload.optional
+        if payload.options is not None:
+            update_data["options"] = payload.options
+
+        if not update_data:
+            raise HTTPException(status_code=400, detail="Nenhum campo para atualizar foi fornecido.")
+
+        query_url = f"{SUPABASE_URL}/rest/v1/Onboarding?id=eq.{payload.id}"
+        headers = SUPABASE_ROLE_HEADERS.copy()
+        headers["Prefer"] = "return=representation"
+
+        async with aiohttp.ClientSession() as session:
+            async with session.patch(query_url, json=update_data, headers=headers) as response:
+                if response.status != 200:
+                    detail = await response.text()
+                    logger.error(f"❌ Erro ao atualizar pergunta: {detail}")
+                    raise HTTPException(status_code=response.status, detail="Erro ao atualizar pergunta")
+
+                updated = await response.json()
+                return {"message": "✅ Pergunta atualizada com sucesso!", "updated": updated}
+
+    except Exception as e:
+        logger.error(f"❌ Erro interno ao atualizar pergunta: {str(e)}")
+        raise HTTPException(status_code=500, detail="Erro interno do servidor")
 
 @router.get("/onboarding/questions")
 async def get_onboarding_questions() -> Dict[str, List[Dict[str, Any]]]: