Update app.py

app.py

@@ -190,32 +190,29 @@ async def send_to_slack(message: str):
     except Exception as e:
         print("❌ Slack Send Error:", e)
 
-async def get_chatwoot_conversation(conversation_id: str):
-    """Fetch conversation details from Chatwoot"""
+async def get_chatwoot_conversation(conversation_id: int) -> Optional[dict]:
+    """Fetch conversation details and messages from Chatwoot"""
     try:
-        async with httpx.AsyncClient() as http:
-            # Get conversation details
-            conv_url = f"{CHATWOOT_BASE_URL}/api/v1/accounts/{CHATWOOT_ACCOUNT_ID}/conversations/{conversation_id}"
-            conv_resp = await http.get(
-                conv_url,
-                headers={"api_access_token": CHATWOOT_API_KEY}
-            )
-            conv_resp.raise_for_status()
-            conversation = conv_resp.json()
-            
-            # Get conversation messages
+        headers = {
+            "api_access_token": CHATWOOT_API_KEY,
+            "Content-Type": "application/json",
+            "Accept": "application/json"
+        }
+        
+        async with httpx.AsyncClient(timeout=30.0) as http:
+            # Get conversation messages directly since that's what we need
             msgs_url = f"{CHATWOOT_BASE_URL}/api/v1/accounts/{CHATWOOT_ACCOUNT_ID}/conversations/{conversation_id}/messages"
-            msgs_resp = await http.get(
-                msgs_url,
-                headers={"api_access_token": CHATWOOT_API_KEY}
-            )
+            print(f"Fetching messages from: {msgs_url}")
+            
+            msgs_resp = await http.get(msgs_url, headers=headers)
             msgs_resp.raise_for_status()
+            
+            # The API returns the payload directly as an array of messages
             messages = msgs_resp.json()
+            print(f"Fetched {len(messages) if messages else 0} messages")
             
-            return {
-                "conversation": conversation,
-                "messages": messages
-            }
+            # Return the messages in the expected format
+            return {"payload": messages}
     except Exception as e:
         print(f"❌ Error fetching Chatwoot conversation: {e}")
         return None