Create logs.py

routes/logs.py

@@ -0,0 +1,71 @@
+import os
+import logging
+import aiohttp
+from fastapi import APIRouter, HTTPException
+from typing import List, Dict, Any
+
+router = APIRouter()
+
+SUPABASE_URL = "https://ussxqnifefkgkaumjann.supabase.co"
+SUPABASE_KEY = os.getenv("SUPA_KEY")
+
+if not SUPABASE_KEY:
+    raise ValueError("❌ SUPA_KEY não foi definido no ambiente!")
+
+SUPABASE_HEADERS = {
+    "apikey": SUPABASE_KEY,
+    "Authorization": f"Bearer {SUPABASE_KEY}",
+    "Content-Type": "application/json"
+}
+
+# Logging interno
+logging.basicConfig(level=logging.INFO)
+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;
+    """
+
+    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:
+                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",
+                    )
+
+                data = await response.json()
+                return data
+
+        except Exception as e:
+            logger.exception("Erro inesperado ao consultar logs")
+            raise HTTPException(status_code=500, detail=str(e))