Update app.py

app.py

@@ -192,29 +192,63 @@ async def send_to_slack(message: str):
 
 async def get_chatwoot_conversation(conversation_id: int) -> Optional[dict]:
     """Fetch conversation details and messages from Chatwoot"""
+    print(f"\n🔍 Starting to fetch conversation {conversation_id}")
+    print(f"Using base URL: {CHATWOOT_BASE_URL}")
+    print(f"Account ID: {CHATWOOT_ACCOUNT_ID}")
+    
     try:
         headers = {
-            "api_access_token": CHATWOOT_API_KEY,
+            "api_access_token": CHATWOOT_API_KEY[:5] + "..." if CHATWOOT_API_KEY else "None",  # Log first 5 chars of token for security
             "Content-Type": "application/json",
             "Accept": "application/json"
         }
+        print(f"Request headers: {headers}")
         
         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"
-            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")
+            print(f"\n🌐 Making request to: {msgs_url}")
+            print(f"Method: GET")
+            print(f"Full URL: {msgs_url}")
+            print(f"Headers: {headers}")
             
-            # Return the messages in the expected format
-            return {"payload": messages}
+            try:
+                msgs_resp = await http.get(msgs_url, headers=headers)
+                print(f"\n✅ Response received")
+                print(f"Status code: {msgs_resp.status_code}")
+                print(f"Response headers: {dict(msgs_resp.headers)}")
+                
+                # Log response body (truncated if too long)
+                response_text = msgs_resp.text
+                print(f"Response length: {len(response_text)} characters")
+                print(f"First 500 chars of response: {response_text[:500]}...")
+                
+                msgs_resp.raise_for_status()
+                
+                # The API returns the payload directly as an array of messages
+                messages = msgs_resp.json()
+                if not isinstance(messages, list):
+                    print(f"⚠️ Unexpected response format. Expected list, got: {type(messages)}")
+                    print(f"Response content: {messages}")
+                    return None
+                    
+                print(f"\n📩 Successfully parsed {len(messages)} messages")
+                if messages:
+                    print(f"First message: {messages[0].get('content', 'No content')[:100]}...")
+                
+                # Return the messages in the expected format
+                return {"payload": messages}
+                
+            except httpx.HTTPStatusError as e:
+                print(f"\n❌ HTTP Error: {e}")
+                print(f"Response: {e.response.text}")
+                return None
+                
     except Exception as e:
-        print(f"❌ Error fetching Chatwoot conversation: {e}")
+        import traceback
+        print(f"\n❌ Unexpected error: {str(e)}")
+        print("Stack trace:")
+        print(traceback.format_exc())
         return None
 
 def format_slack_message(conversation_data):