Update routes/support.py

routes/support.py

@@ -3,6 +3,7 @@ import logging
 import aiohttp
 import pytz
 import base64
+import asyncio
 
 from fastapi import APIRouter, HTTPException, Header, Body
 from pydantic import BaseModel
@@ -263,14 +264,13 @@ class RespondTicketRequest(BaseModel):
     
 @router.post("/ticket/respond")
 async def respond_ticket(
-    body: RespondTicketRequest,  # Recebendo o body como um modelo
+    body: RespondTicketRequest,
     user_token: str = Header(None, alias="User-key")
 ):
-    # 1. Verificar se o usuário está autenticado com o token
     user_id = await verify_user_token(user_token)
     created_at = datetime.utcnow().isoformat()
 
-    # 2. Buscar dados do ticket
+    # 1. Buscar dados do ticket
     async with aiohttp.ClientSession() as session:
         async with session.get(
             f"{SUPABASE_URL}/rest/v1/Tickets?id=eq.{body.ticket_id}",
@@ -287,9 +287,9 @@ async def respond_ticket(
 
     support_id = ticket.get("support_id")
 
-    # 3. Verificar se o suporte está atribuído
+    # 2. Verificar/Atribuir suporte
     if support_id is None:
-        # Checar se o usuário é admin
+        # Verifica se usuário é admin
         async with aiohttp.ClientSession() as session:
             async with session.get(
                 f"{SUPABASE_URL}/rest/v1/User?id=eq.{user_id}",
@@ -302,7 +302,7 @@ async def respond_ticket(
                 if not user_data or not user_data[0].get("is_admin", False):
                     raise HTTPException(status_code=403, detail="Apenas administradores podem assumir tickets")
 
-        # Atribuir ticket ao suporte (usuário atual)
+        # Atualiza support_id
         async with aiohttp.ClientSession() as session:
             async with session.patch(
                 f"{SUPABASE_URL}/rest/v1/Tickets?id=eq.{body.ticket_id}",
@@ -315,7 +315,10 @@ async def respond_ticket(
         if support_id != user_id:
             raise HTTPException(status_code=403, detail="Ticket já está atribuído a outro suporte")
 
-    # 4. Criar a mensagem de resposta
+    # 3. Espera 1 segundo antes de enviar a mensagem
+    await asyncio.sleep(1)
+
+    # 4. Criar mensagem
     message_payload = {
         "user": user_id,
         "content": body.content,
@@ -323,7 +326,6 @@ async def respond_ticket(
         "ticket_id": body.ticket_id
     }
 
-    # 5. Salvar a mensagem no banco
     async with aiohttp.ClientSession() as session:
         async with session.post(
             f"{SUPABASE_URL}/rest/v1/messages_tickets",
@@ -336,14 +338,13 @@ async def respond_ticket(
 
             message_data = await message_resp.json()
 
-    # 6. Retornar confirmação
     return {
         "status": "response sent successfully",
         "ticket_id": body.ticket_id,
         "message_id": message_data[0]["id"],
         "message_content": body.content
     }
-
+    
 @router.post("/ticket/create")
 async def create_ticket(
     body: CreateTicketRequest,