Update routes/logs.py

routes/logs.py

@@ -26,45 +26,42 @@ logger = logging.getLogger(__name__)
 @router.get("/logs", response_model=List[Dict[str, Any]])
 async def get_onboarding_logs():
     """
-    Retorna os últimos 10 logs relacionados à tabela Onboarding.
-    """
-    # SQL Query para buscar logs que envolvam a tabela Onboarding e sejam métodos de modificação
-    sql_query = """
-    select
-      cast(timestamp as text) as timestamp,
-      m.method,
-      m.status_code,
-      r.headers ->> 'x-client-info' as client_info,
-      r.headers ->> 'authorization' as auth_token,
-      r.url
-    from edge_logs
-      cross join unnest(metadata) as m
-      cross join unnest(m.request) as r
-    where
-      path like '%rest/v1/Onboarding%'
-      and m.method in ('POST', 'PATCH', 'PUT', 'DELETE')
-    order by
-      timestamp desc
-    limit 10;
+    Retorna os últimos 10 logs de modificação na tabela Onboarding.
     """
+    log_api_url = f"https://api.supabase.com/v1/projects/ussxqnifefkgkaumjann/logs"
+
+    params = {
+        "sql": """
+        select
+          cast(timestamp as text) as timestamp,
+          m.method,
+          m.status_code,
+          r.url
+        from edge_logs
+          cross join unnest(metadata) as m
+          cross join unnest(m.request) as r
+        where
+          path like '%rest/v1/Onboarding%'
+          and m.method in ('POST', 'PATCH', 'PUT', 'DELETE')
+        order by timestamp desc
+        limit 10
+        """
+    }
+
+    headers = {
+        "apikey": SUPABASE_KEY,
+        "Authorization": f"Bearer {SUPABASE_KEY}",
+        "Content-Type": "application/json"
+    }
 
     async with aiohttp.ClientSession() as session:
         try:
-            async with session.post(
-                f"{SUPABASE_URL}/rest/v1/rpc/execute_sql",
-                json={"sql": sql_query},
-                headers=SUPABASE_HEADERS,
-            ) as response:
+            async with session.get(log_api_url, headers=headers, params=params) as response:
                 if response.status != 200:
-                    error_detail = await response.text()
-                    logger.error(f"Erro ao consultar logs: {error_detail}")
-                    raise HTTPException(
-                        status_code=response.status,
-                        detail="Erro ao consultar os logs no Supabase",
-                    )
+                    logger.error(f"Erro ao consultar logs: {await response.text()}")
+                    raise HTTPException(status_code=500, detail="Erro ao buscar logs")
 
-                data = await response.json()
-                return data
+                return await response.json()
 
         except Exception as e:
             logger.exception("Erro inesperado ao consultar logs")