Update routes/support.py

routes/support.py

@@ -57,6 +57,74 @@ async def verify_user_token(user_token: str) -> str:
 class CreateTicketRequest(BaseModel):
     message: str
 
+@router.get("/ticket/user")
+async def get_user_tickets(user_id: str):
+    async with aiohttp.ClientSession() as session:
+        # 1. Buscar os últimos 50 tickets do usuário
+        async with session.get(
+            f"{SUPABASE_URL}/rest/v1/Tickets?user_id=eq.{user_id}&order=created_at.desc&limit=50",
+            headers=SUPABASE_ROLE_HEADERS
+        ) as ticket_resp:
+            if ticket_resp.status != 200:
+                error_detail = await ticket_resp.text()
+                raise HTTPException(status_code=500, detail=f"Erro ao buscar tickets: {error_detail}")
+
+            tickets = await ticket_resp.json()
+
+        # 2. Para cada ticket, buscar a última mensagem
+        ticket_results = []
+
+        for ticket in tickets:
+            ticket_id = ticket["id"]
+
+            async with session.get(
+                f"{SUPABASE_URL}/rest/v1/messages_tickets?ticket_id=eq.{ticket_id}&order=created_at.desc&limit=1",
+                headers=SUPABASE_ROLE_HEADERS
+            ) as msg_resp:
+                if msg_resp.status != 200:
+                    continue  # apenas ignora caso erro
+
+                messages = await msg_resp.json()
+                last_message = messages[0] if messages else None
+
+            ticket_results.append({
+                "ticket": ticket,
+                "last_message": last_message
+            })
+
+    return ticket_results
+
+@router.get("/ticket/detail")
+async def get_ticket_details(ticket_id: int):
+    async with aiohttp.ClientSession() as session:
+        # 1. Buscar ticket
+        async with session.get(
+            f"{SUPABASE_URL}/rest/v1/Tickets?id=eq.{ticket_id}",
+            headers=SUPABASE_ROLE_HEADERS
+        ) as ticket_resp:
+            if ticket_resp.status != 200:
+                raise HTTPException(status_code=404, detail="Ticket não encontrado")
+
+            ticket_data = await ticket_resp.json()
+            if not ticket_data:
+                raise HTTPException(status_code=404, detail="Ticket inexistente")
+
+            ticket = ticket_data[0]
+
+        # 2. Buscar últimas 50 mensagens
+        async with session.get(
+            f"{SUPABASE_URL}/rest/v1/messages_tickets?ticket_id=eq.{ticket_id}&order=created_at.desc&limit=50",
+            headers=SUPABASE_ROLE_HEADERS
+        ) as msg_resp:
+            if msg_resp.status != 200:
+                raise HTTPException(status_code=500, detail="Erro ao buscar mensagens")
+
+            messages = await msg_resp.json()
+
+    return {
+        "ticket": ticket,
+        "messages": messages
+    }
 
 @router.post("/ticket/create")
 async def create_ticket(