Update routes/logs.py

routes/logs.py

@@ -6,15 +6,18 @@ from typing import List, Dict, Any
 
 router = APIRouter()
 
+# Supabase configs
 SUPABASE_URL = "https://ussxqnifefkgkaumjann.supabase.co"
 SUPABASE_KEY = os.getenv("SUPA_KEY")
+SUPABASE_ROLE_KEY = os.getenv("SUPA_SERVICE_KEY")  # <- necessária para acessar logs
 
-if not SUPABASE_KEY:
-    raise ValueError("❌ SUPA_KEY não foi definido no ambiente!")
+if not SUPABASE_KEY or not SUPABASE_ROLE_KEY:
+    raise ValueError("❌ SUPA_KEY ou SUPA_SERVICE_KEY não foram definidos no ambiente!")
 
-SUPABASE_HEADERS = {
-    "apikey": SUPABASE_KEY,
-    "Authorization": f"Bearer {SUPABASE_KEY}",
+# Headers corretos para API de LOGS (precisa da role key!)
+SUPABASE_ROLE_HEADERS = {
+    "apikey": SUPABASE_ROLE_KEY,
+    "Authorization": f"Bearer {SUPABASE_ROLE_KEY}",
     "Content-Type": "application/json"
 }
 
@@ -28,7 +31,8 @@ async def get_onboarding_logs():
     """
     Retorna os últimos 10 logs de modificação na tabela Onboarding.
     """
-    log_api_url = f"https://api.supabase.com/v1/projects/ussxqnifefkgkaumjann/logs"
+    project_ref = SUPABASE_URL.split("//")[1].split(".")[0]
+    log_api_url = f"https://api.supabase.com/v1/projects/{project_ref}/logs"
 
     params = {
         "sql": """
@@ -48,17 +52,12 @@ async def get_onboarding_logs():
         """
     }
 
-    headers = {
-        "apikey": SUPABASE_KEY,
-        "Authorization": f"Bearer {SUPABASE_KEY}",
-        "Content-Type": "application/json"
-    }
-
     async with aiohttp.ClientSession() as session:
         try:
-            async with session.get(log_api_url, headers=headers, params=params) as response:
+            async with session.get(log_api_url, headers=SUPABASE_ROLE_HEADERS, params=params) as response:
                 if response.status != 200:
-                    logger.error(f"Erro ao consultar logs: {await response.text()}")
+                    body = await response.text()
+                    logger.error(f"Erro ao consultar logs: {body}")
                     raise HTTPException(status_code=500, detail="Erro ao buscar logs")
 
                 return await response.json()