Enhance property suggestion formatting and message handling

- Updated `process_message` to include visual separators in property suggestion responses, improving readability and user engagement.
- Implemented message splitting in `send_whatsapp_message` to handle long messages, ensuring compliance with WhatsApp's character limits.
- Added a helper function `_split_message` to efficiently divide lengthy messages while preserving content structure, enhancing overall message delivery experience.

ai_chat.py

@@ -436,7 +436,17 @@ async def process_message(user_message: str, user_info: dict = None, session_id:
             for msg in property_msgs:
                 print(f"Property suggestion: {msg}")
             if property_msgs:
-                return "\n\n".join(property_msgs)
+                # Add some visual separators to make it more readable
+                formatted_messages = []
+                for i, msg in enumerate(property_msgs):
+                    if i == 0:  # Intro message
+                        formatted_messages.append(msg)
+                    elif i == len(property_msgs) - 1:  # Last message (follow-up)
+                        formatted_messages.append(f"\n{msg}")
+                    else:  # Property descriptions
+                        formatted_messages.append(f"\n🏢 **Property {i}**\n{msg}")
+                
+                return "\n\n".join(formatted_messages)
             return "Let me know if you'd like to see images or more details!"
     
     # Check if user is asking about property suggestions/results in general
@@ -446,7 +456,17 @@ async def process_message(user_message: str, user_info: dict = None, session_id:
         for msg in property_msgs:
             print(f"Property suggestion: {msg}")
         if property_msgs:
-            return "\n\n".join(property_msgs)
+            # Add some visual separators to make it more readable
+            formatted_messages = []
+            for i, msg in enumerate(property_msgs):
+                if i == 0:  # Intro message
+                    formatted_messages.append(msg)
+                elif i == len(property_msgs) - 1:  # Last message (follow-up)
+                    formatted_messages.append(f"\n{msg}")
+                else:  # Property descriptions
+                    formatted_messages.append(f"\n🏢 **Property {i}**\n{msg}")
+            
+            return "\n\n".join(formatted_messages)
         return "Let me know if you'd like to see images or more details!"
     
     # Handle confusion or clarification requests
@@ -465,10 +485,20 @@ async def process_message(user_message: str, user_info: dict = None, session_id:
         for msg in property_msgs:
             # Send each property message (simulate WhatsApp message send)
             print(f"Property suggestion: {msg}")
-        # Return all messages as a single response (they will be sent sequentially)
-        if property_msgs:
-            return "\n\n".join(property_msgs)
-        return "Let me know if you'd like to see images or more details!"
+            # Return all messages as a single response (they will be sent sequentially)
+    if property_msgs:
+        # Add some visual separators to make it more readable
+        formatted_messages = []
+        for i, msg in enumerate(property_msgs):
+            if i == 0:  # Intro message
+                formatted_messages.append(msg)
+            elif i == len(property_msgs) - 1:  # Last message (follow-up)
+                formatted_messages.append(f"\n{msg}")
+            else:  # Property descriptions
+                formatted_messages.append(f"\n🏢 **Property {i}**\n{msg}")
+        
+        return "\n\n".join(formatted_messages)
+    return "Let me know if you'd like to see images or more details!"
     
     # Handle greetings with persona context
     if is_greeting and updated_persona.get("location_preference"):
@@ -502,7 +532,17 @@ async def process_message(user_message: str, user_info: dict = None, session_id:
                 for msg in property_msgs:
                     print(f"Property suggestion: {msg}")
                 if property_msgs:
-                    return "\n\n".join(property_msgs)
+                    # Add some visual separators to make it more readable
+                    formatted_messages = []
+                    for i, msg in enumerate(property_msgs):
+                        if i == 0:  # Intro message
+                            formatted_messages.append(msg)
+                        elif i == len(property_msgs) - 1:  # Last message (follow-up)
+                            formatted_messages.append(f"\n{msg}")
+                        else:  # Property descriptions
+                            formatted_messages.append(f"\n🏢 **Property {i}**\n{msg}")
+                    
+                    return "\n\n".join(formatted_messages)
                 return "Let me know if you'd like to see images or more details!"
             
             elif any(word in user_response_lower for word in negative_words):

whatsapp.py

@@ -3,6 +3,23 @@ from config import PHONE_NUMBER_ID, WHATSAPP_API_TOKEN
 
 async def send_whatsapp_message(wa_id: str, message: str):
     """Send a message via WhatsApp Business API"""
+    # Split message if it's too long (WhatsApp limit is ~4096 characters)
+    max_length = 3000  # Leave some buffer
+    
+    if len(message) <= max_length:
+        # Single message
+        return await _send_single_message(wa_id, message)
+    else:
+        # Split into multiple messages
+        messages = _split_message(message, max_length)
+        success = True
+        for msg in messages:
+            if not await _send_single_message(wa_id, msg):
+                success = False
+        return success
+
+async def _send_single_message(wa_id: str, message: str):
+    """Send a single message via WhatsApp Business API"""
     url = f"https://graph.facebook.com/v18.0/{PHONE_NUMBER_ID}/messages"
     headers = {
         "Authorization": f"Bearer {WHATSAPP_API_TOKEN}",
@@ -21,4 +38,31 @@ async def send_whatsapp_message(wa_id: str, message: str):
         return resp.status_code == 200
     except Exception as e:
         print(f"Failed to send message: {e}")
-        return False 
+        return False
+
+def _split_message(message: str, max_length: int):
+    """Split a long message into smaller chunks"""
+    if len(message) <= max_length:
+        return [message]
+    
+    # Split by double newlines first (to preserve property separations)
+    parts = message.split('\n\n')
+    messages = []
+    current_message = ""
+    
+    for part in parts:
+        # If adding this part would exceed limit, start a new message
+        if len(current_message) + len(part) + 2 > max_length and current_message:
+            messages.append(current_message.strip())
+            current_message = part
+        else:
+            if current_message:
+                current_message += '\n\n' + part
+            else:
+                current_message = part
+    
+    # Add the last message
+    if current_message:
+        messages.append(current_message.strip())
+    
+    return messages