Update routes/users.py

routes/users.py

@@ -2,9 +2,9 @@ import os
 import logging
 import asyncio
 import aiohttp
-from fastapi import APIRouter, HTTPException, Header, Depends, Query
+from fastapi import APIRouter, HTTPException, Header, Query
 from functools import lru_cache
-from typing import List, Dict, Any
+from typing import List, Dict, Any, Optional
 
 router = APIRouter()
 
@@ -64,17 +64,23 @@ async def verify_admin_token(user_token: str) -> str:
     
     return user_id
 
-async def get_recent_users(limit: int = 50) -> List[Dict[str, Any]]:
-    """Obtém os usuários mais recentes da plataforma"""
+async def get_recent_users(limit: int = 50, search: Optional[str] = None) -> List[Dict[str, Any]]:
+    """Obtém os usuários mais recentes da plataforma, com filtro opcional por nome"""
     try:
-        users_url = f"{SUPABASE_URL}/rest/v1/User?select=name&order=created_at.desc&limit={limit}"
+        query = f"{SUPABASE_URL}/rest/v1/User?select=name&order=created_at.desc&limit={limit}"
+        
+        if search:
+            # Escape aspas simples e adicionar operador ILIKE para busca parcial
+            search_term = search.replace("'", "''")
+            query += f"&name=ilike.*{search_term}*"
+        
         headers = SUPABASE_HEADERS.copy()
         headers["Accept"] = "application/json; charset=utf-8"
         
         async with aiohttp.ClientSession() as session:
-            async with session.get(users_url, headers=headers) as response:
+            async with session.get(query, headers=headers) as response:
                 if response.status != 200:
-                    logger.error(f"❌ Erro ao obter usuários recentes: {response.status}")
+                    logger.error(f"❌ Erro ao obter usuários: {response.status}")
                     return []
                 
                 text = await response.text(encoding='utf-8')
@@ -84,20 +90,21 @@ async def get_recent_users(limit: int = 50) -> List[Dict[str, Any]]:
         return users_data
         
     except Exception as e:
-        logger.error(f"❌ Erro ao obter usuários recentes: {str(e)}")
+        logger.error(f"❌ Erro ao obter usuários: {str(e)}")
         return []
 
 @router.get("/admin/users")
 async def get_recent_users_endpoint(
     user_token: str = Header(None, alias="User-key"),
-    limit: int = Query(50, ge=1, le=100)
+    limit: int = Query(50, ge=1, le=100),
+    search: Optional[str] = Query(None)
 ):
     """
-    Endpoint para obter os usuários mais recentes da plataforma
+    Endpoint para obter os usuários mais recentes da plataforma, com suporte a busca por nome
     """
     try:
         user_id = await verify_admin_token(user_token)
-        users = await get_recent_users(limit)
+        users = await get_recent_users(limit, search)
         
         return {
             "users": users,
@@ -108,5 +115,5 @@ async def get_recent_users_endpoint(
         raise he
         
     except Exception as e:
-        logger.error(f"❌ Erro ao obter usuários recentes: {str(e)}")
-        raise HTTPException(status_code=500, detail=str(e))
+        logger.error(f"❌ Erro ao obter usuários: {str(e)}")
+        raise HTTPException(status_code=500, detail=str(e))