Update routes/approvals.py

routes/approvals.py

@@ -64,9 +64,9 @@ async def verify_admin_token(user_token: str) -> str:
     return user_id
 
 async def get_users_pending_approval() -> Dict[str, Any]:
-    """Obtém todos os usuários que ainda não foram aprovados mas completaram o onboarding"""
+    """Obtém todos os usuários que ainda não foram aprovados e suas respostas de onboarding"""
     try:
-        query = (
+        query_users = (
             f"{SUPABASE_URL}/rest/v1/User"
             "?select=id,name,avatar,role,blurhash"
             "&approved_account=eq.false"
@@ -79,16 +79,66 @@ async def get_users_pending_approval() -> Dict[str, Any]:
         headers["Accept"] = "application/json; charset=utf-8"
 
         async with aiohttp.ClientSession() as session:
-            async with session.get(query, headers=headers) as response:
+            # Busca os usuários pendentes
+            async with session.get(query_users, headers=headers) as response:
                 if response.status != 200:
-                    logger.error(f"❌ Erro ao buscar usuários pendentes de aprovação: {response.status}")
-                    raise HTTPException(status_code=500, detail="Erro ao consultar o Supabase")
-                
+                    logger.error(f"❌ Erro ao buscar usuários pendentes: {response.status}")
+                    raise HTTPException(status_code=500, detail="Erro ao consultar usuários")
+
                 users = await response.json()
-                return {"users": users, "count": len(users)}
+
+            # Se nenhum usuário, retornar vazio
+            if not users:
+                return {"users": [], "count": 0}
+
+            user_ids = [f"id=eq.{user['id']}" for user in users]
+            user_ids_query = ",".join(user_ids)
+
+            # Busca as respostas desses usuários
+            query_answers = (
+                f"{SUPABASE_URL}/rest/v1/User answers"
+                f"?select=user_id,question_id,answers"
+                f"&or=({user_ids_query})"
+            )
+
+            async with session.get(query_answers, headers=headers) as response:
+                if response.status != 200:
+                    logger.warning("⚠️ Erro ao buscar respostas de usuários")
+                    user_answers = []
+                else:
+                    user_answers = await response.json()
+
+            # Busca as perguntas
+            query_questions = f"{SUPABASE_URL}/rest/v1/Onboarding?select=id,title"
+            async with session.get(query_questions, headers=headers) as response:
+                if response.status != 200:
+                    logger.warning("⚠️ Erro ao buscar perguntas")
+                    questions = []
+                else:
+                    questions = await response.json()
+
+        # Mapeia perguntas por ID
+        question_map = {q["id"]: q["title"] for q in questions}
+
+        # Agrupa respostas por usuário
+        from collections import defaultdict
+        grouped_answers = defaultdict(list)
+
+        for answer in user_answers:
+            title = question_map.get(answer["question_id"], "Pergunta desconhecida")
+            grouped_answers[answer["user_id"]].append({
+                "question": title,
+                "answer": answer.get("answers", [])
+            })
+
+        # Enriquecer usuários com respostas
+        for user in users:
+            user["answers"] = grouped_answers.get(user["id"], [])
+
+        return {"users": users, "count": len(users)}
 
     except Exception as e:
-        logger.error(f"❌ Erro ao buscar usuários pendentes: {str(e)}")
+        logger.error(f"❌ Erro ao buscar usuários e respostas: {str(e)}")
         raise HTTPException(status_code=500, detail="Erro interno do servidor")
 
 @router.get("/admin/pending-approvals")
@@ -97,7 +147,7 @@ async def pending_approvals_endpoint(
 ):
     """
     Endpoint para listar usuários que ainda não foram aprovados,
-    mas já finalizaram o onboarding e o Stripe.
+    com respostas das perguntas de onboarding.
     """
     try:
         await verify_admin_token(user_token)