Update routes/users.py

routes/users.py

@@ -129,6 +129,82 @@ async def get_recent_users_endpoint(
         logger.error(f"❌ Erro ao obter usuários: {str(e)}")
         raise HTTPException(status_code=500, detail=str(e))
 
+@router.post("/admin/update-user")
+async def update_user(
+    request: Dict[str, Any],
+    user_token: str = Header(None, alias="User-key")
+):
+    """
+    Endpoint para atualizar informações de um usuário específico.
+    Atualmente suporta atualização de name e fee.
+    """
+    try:
+        # Verificar se o usuário é um administrador
+        admin_id = await verify_admin_token(user_token)
+        
+        # Validar os parâmetros da requisição
+        user_id = request.get("user_id")
+        name = request.get("name")
+        fee = request.get("fee")
+        
+        if not user_id:
+            raise HTTPException(status_code=400, detail="ID do usuário é obrigatório")
+        
+        if name is None and fee is None:
+            raise HTTPException(status_code=400, detail="Pelo menos um campo para atualização (name ou fee) deve ser fornecido")
+        
+        # Verificar se o usuário existe
+        user_query = f"{SUPABASE_URL}/rest/v1/User?select=name,fee&id=eq.{user_id}"
+        
+        async with aiohttp.ClientSession() as session:
+            async with session.get(user_query, headers=SUPABASE_HEADERS) as response:
+                if response.status != 200:
+                    logger.error(f"❌ Erro ao verificar usuário: {response.status}")
+                    raise HTTPException(status_code=response.status, detail="Erro ao consultar usuário")
+                
+                user_data = await response.json()
+                
+                if not user_data:
+                    raise HTTPException(status_code=404, detail="Usuário não encontrado")
+                
+                current_user = user_data[0]
+                
+                # Preparar os campos para atualização, apenas se forem diferentes
+                update_fields = {}
+                
+                if name is not None and name != current_user.get("name"):
+                    update_fields["name"] = name
+                
+                if fee is not None and isinstance(fee, int) and fee != current_user.get("fee"):
+                    update_fields["fee"] = fee
+                
+                # Se não há campos para atualizar, retornar sem modificar
+                if not update_fields:
+                    return {"message": "Nenhuma alteração necessária", "user_id": user_id}
+                
+                # Atualizar o usuário no Supabase
+                update_url = f"{SUPABASE_URL}/rest/v1/User?id=eq.{user_id}"
+                
+                async with session.patch(update_url, json=update_fields, headers=SUPABASE_HEADERS) as update_response:
+                    if update_response.status != 204:
+                        logger.error(f"❌ Erro ao atualizar usuário: {update_response.status}")
+                        raise HTTPException(status_code=update_response.status, detail="Erro ao atualizar usuário")
+                    
+                    # Retornar resultado da operação
+                    return {
+                        "message": "Usuário atualizado com sucesso",
+                        "user_id": user_id,
+                        "updated_fields": update_fields,
+                        "updated_by": admin_id
+                    }
+    
+    except HTTPException as he:
+        raise he
+    
+    except Exception as e:
+        logger.error(f"❌ Erro ao atualizar usuário: {str(e)}")
+        raise HTTPException(status_code=500, detail="Erro interno do servidor")
+        
 @router.get("/admin/user")
 async def get_user_name(
     user_id: str = Query(..., description="ID do usuário"),