Update routes/support.py

routes/support.py

@@ -112,12 +112,9 @@ GMAIL_CLIENT_ID = "784687789817-3genmmvps11ip3a6fkbkkd8dm3bstgdc.apps.googleuser
 GMAIL_CLIENT_SECRET = "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"
 GMAIL_REFRESH_TOKEN = "1//04ZOO_chVwlYiCgYIARAAGAQSNwF-L9IrhQO1ij79thk-DTjiMudl_XQshuU5CDTDYtt8rrOTMbz_rL8ECGjNfEN9da6W-mnjhZA"
 
-class SendEmailRequest(BaseModel):
-    to: str
-    subject: str
-    body: str
-    sender_name: Optional[str] = "Ameddes"
-    sender_email: Optional[str] = "[email protected]"
+class TicketResponseRequest(BaseModel):
+    ticket_id: int
+    content: str
 
 
 async def get_gmail_access_token() -> str:
@@ -141,16 +138,56 @@ def encode_message(raw_message: str) -> str:
     return base64.urlsafe_b64encode(raw_message.encode("utf-8")).decode("utf-8").replace("=", "")
 
 
-@router.post("/send-email")
-async def send_email(payload: SendEmailRequest = Body(...)):
+@router.post("/ticket/respond")
+async def respond_ticket(
+    payload: TicketResponseRequest,
+    user_token: str = Header(None, alias="User-key")
+):
+    # 1. Verifica o token do remetente (quem está respondendo)
+    support_id = await verify_user_token(user_token)
+    created_at = datetime.utcnow().isoformat()
+
+    # 2. Busca o ticket
+    async with aiohttp.ClientSession() as session:
+        async with session.get(
+            f"{SUPABASE_URL}/rest/v1/Tickets?id=eq.{payload.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 não existe")
+
+            ticket = ticket_data[0]
+            user_id = ticket["user_id"]
+
+    # 3. Pega o e-mail do usuário
+    async with aiohttp.ClientSession() as session:
+        async with session.get(
+            f"{SUPABASE_URL}/rest/v1/User?id=eq.{user_id}",
+            headers=SUPABASE_ROLE_HEADERS
+        ) as user_resp:
+            if user_resp.status != 200:
+                raise HTTPException(status_code=404, detail="Usuário não encontrado")
+
+            user_data = await user_resp.json()
+            if not user_data:
+                raise HTTPException(status_code=404, detail="Usuário não existe")
+
+            user_email = user_data[0]["email"]
+
+    # 4. Envia o e-mail
     access_token = await get_gmail_access_token()
+    subject = f"Suporte ClosetCoach - Caso {payload.ticket_id}"
 
-    raw_message = f"""To: {payload.to}
-From: "{payload.sender_name}" <{payload.sender_email}>
-Subject: {payload.subject}
+    raw_message = f"""To: {user_email}
+From: "ClosetCoach Support" <streamify@ameddes.com>
+Subject: {subject}
 Content-Type: text/html; charset="UTF-8"
 
-{payload.body}
+{payload.content}
 """
 
     encoded_message = encode_message(raw_message)
@@ -163,10 +200,33 @@ Content-Type: text/html; charset="UTF-8"
                 "Content-Type": "application/json"
             },
             json={"raw": encoded_message}
-        ) as resp:
-            if resp.status != 200:
-                error_detail = await resp.text()
-                raise HTTPException(status_code=resp.status, detail=f"Erro ao enviar e-mail: {error_detail}")
-            response_data = await resp.json()
+        ) as gmail_resp:
+            if gmail_resp.status != 200:
+                error_detail = await gmail_resp.text()
+                raise HTTPException(status_code=500, detail=f"Erro ao enviar e-mail: {error_detail}")
+            gmail_data = await gmail_resp.json()
+
+    # 5. Salva resposta em messages_tickets
+    message_payload = {
+        "user": support_id,
+        "content": payload.content,
+        "created_at": created_at,
+        "ticket_id": payload.ticket_id
+    }
 
-    return {"status": "email sent", "message_id": response_data.get("id")}
+    async with aiohttp.ClientSession() as session:
+        async with session.post(
+            f"{SUPABASE_URL}/rest/v1/messages_tickets",
+            headers=SUPABASE_ROLE_HEADERS,
+            json=message_payload
+        ) as msg_resp:
+            if msg_resp.status != 201:
+                error_detail = await msg_resp.text()
+                raise HTTPException(status_code=500, detail=f"Erro ao registrar resposta: {error_detail}")
+
+    return {
+        "status": "resposta enviada com sucesso",
+        "ticket_id": payload.ticket_id,
+        "email_to": user_email,
+        "message_id": gmail_data.get("id")
+    }