Update app.py

app.py

@@ -225,19 +225,41 @@ async def get_chatwoot_conversation(conversation_id: int) -> Optional[dict]:
                 
                 msgs_resp.raise_for_status()
                 
-                # The API returns the payload directly as an array of messages
-                messages = msgs_resp.json()
+                # The API returns the payload with meta and messages
+                response_data = msgs_resp.json()
+                
+                # Extract messages from the response
+                messages = response_data.get('payload', [])
                 if not isinstance(messages, list):
-                    print(f"⚠️ Unexpected response format. Expected list, got: {type(messages)}")
-                    print(f"Response content: {messages}")
+                    print(f"⚠️ Unexpected messages format. Expected list, got: {type(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}
+                # Filter out system messages and format for Slack
+                filtered_messages = []
+                for msg in messages:
+                    # Only include messages with content and from known senders
+                    if msg.get('content') and msg.get('sender') and msg.get('sender').get('type') in ['contact', 'user']:
+                        filtered_msg = {
+                            'id': msg.get('id'),
+                            'content': msg.get('content'),
+                            'created_at': msg.get('created_at'),
+                            'sender': {
+                                'type': msg.get('sender', {}).get('type'),
+                                'name': msg.get('sender', {}).get('name', 'Unknown')
+                            },
+                            'message_type': msg.get('message_type')
+                        }
+                        filtered_messages.append(filtered_msg)
+                
+                # Return the filtered messages with metadata
+                return {
+                    'meta': response_data.get('meta', {}),
+                    'payload': filtered_messages
+                }
                 
             except httpx.HTTPStatusError as e:
                 print(f"\n❌ HTTP Error: {e}")