Enhance intent field handling in AI chat

- Updated the `extract_and_update_intent` function to handle the "must_have" field as an array, converting string inputs into an appropriate array format for database storage.
- Improved logging to provide clarity on the conversion process and intent updates, ensuring better traceability during intent management.
- Refactored the `send_whatsapp_message` function to utilize an asynchronous HTTP client for sending messages, enhancing performance and reliability in message delivery.

ai_chat.py

@@ -194,8 +194,25 @@ async def extract_and_update_intent(state):
         
         if new_val is not None and new_val != old_val:
             print(f"Updating intent field {field}: {old_val} -> {new_val}")
-            await update_user_intent(session_id, {field: new_val})
-            intent[field] = new_val
+            
+            # Handle must_have field as array
+            if field == "must_have" and new_val:
+                # Convert string to array format for database
+                if isinstance(new_val, str):
+                    # Split by comma if multiple items, otherwise single item
+                    if "," in new_val:
+                        must_have_array = [item.strip() for item in new_val.split(",")]
+                    else:
+                        must_have_array = [new_val.strip()]
+                else:
+                    must_have_array = new_val if isinstance(new_val, list) else [str(new_val)]
+                
+                print(f"Converting must_have to array: {must_have_array}")
+                await update_user_intent(session_id, {field: must_have_array})
+                intent[field] = must_have_array
+            else:
+                await update_user_intent(session_id, {field: new_val})
+                intent[field] = new_val
         elif new_val is not None:
             print(f"Intent field {field} unchanged: {new_val}")
         else:

whatsapp.py

@@ -15,9 +15,10 @@ async def send_whatsapp_message(wa_id: str, message: str):
         "text": {"body": message}
     }
     try:
-        resp = await httpx.post(url, headers=headers, json=payload)
-        print(f"Sent message → {resp.status_code}: {resp.text}")
-        return resp.status_code == 200
+        async with httpx.AsyncClient() as client:
+            resp = await client.post(url, headers=headers, json=payload)
+            print(f"Sent message → {resp.status_code}: {resp.text}")
+            return resp.status_code == 200
     except Exception as e:
         print(f"Failed to send message: {e}")
         return False