Enhance debugging and property search logic in AI chat

- Added debug print statements in `chat_with_session_memory` and `extract_and_search_properties` to log the number of properties found, specific property details, and search filters applied, improving traceability during the property search process.
- Implemented logic to clear restrictive filters for general area searches, enhancing the flexibility of property recommendations based on user intent.
- Refined the property search query in `search_properties` to prioritize city matches before falling back to location searches, optimizing the search process and improving user experience.

ai_chat.py

@@ -39,7 +39,9 @@ def chat_with_session_memory(state):
     
     # Direct listing summary (bypass LLM when properties are found)
     props = state.get("properties", [])
+    print(f"DEBUG - chat_with_session_memory: {len(props)} properties in state")
     if props:
+        print(f"DEBUG - first property: {props[0].get('title')} in {props[0].get('city')}")
         # a) Build a direct summary string
         response_text = ""
         # include any search status
@@ -247,10 +249,24 @@ async def extract_and_update_intent(state):
     except Exception as e:
         extracted = {}
 
+    # Check if this is a general area search (like "what do you have in [area]")
+    is_general_area_search = (
+        "what do you have" in user_message.lower() and 
+        any(word in user_message.lower() for word in ["in ", "area", "jhb", "johannesburg", "cape town", "durban"])
+    )
+    
     for field in intent_fields:
         new_val = extracted.get(field)
         old_val = intent.get(field)
         
+        # For general area searches, clear restrictive filters
+        if is_general_area_search and field in ["budget", "size_preference_sqm", "must_have"]:
+            if old_val is not None:
+                print(f"DEBUG - Clearing restrictive field {field} for general area search")
+                await update_user_intent(session_id, {field: None})
+                intent[field] = None
+            continue
+        
         if new_val is not None and new_val != old_val:
             # Handle must_have field as array (LLM decides the logic)
             if field == "must_have" and new_val:
@@ -289,12 +305,14 @@ async def extract_and_search_properties(state):
     Search for properties based on user intent and store results in state.
     """
     intent = state.get("intent", {})
+    print(f"DEBUG - extract_and_search_properties intent: {intent}")
     
     # Check if we have the minimum required field for property search
     location = intent.get("location_preference")
     
     if not location:
         # Missing location, skip property search
+        print("DEBUG - No location found, skipping property search")
         return {"response": None}
     
     # Prepare filters for property search
@@ -314,11 +332,14 @@ async def extract_and_search_properties(state):
         filters["must_have"] = must_have
     
     # Search for properties
+    print(f"DEBUG - Searching with filters: {filters}")
     properties = await search_properties(filters)
     state["properties"] = properties
+    print(f"DEBUG - Found {len(properties)} properties with strict filters")
     
     # Pass 1: strict filters
     if properties:
+        print("DEBUG - Properties found, returning None to continue to chat")
         return {"response": None}
 
     # Pass 2: drop must-haves

database.py

@@ -294,18 +294,21 @@ async def search_properties(filters: dict) -> list:
         return []
     
     try:
+        # Start with base query
         query = supabase.table("properties").select("*").eq("is_active", True)
         
         # a. Location: try city first, then location field
         loc = filters.get("location_preference")
         if loc:
-            query = query.ilike("city", f"%{loc}%")
-            resp = query.execute()
-            if not resp.data:
-                # fallback to suburb/area match
-                query = supabase.table("properties").select("*")\
-                    .eq("is_active", True)\
-                    .ilike("location", f"%{loc}%")
+            # Try city match first
+            city_query = query.ilike("city", f"%{loc}%")
+            city_resp = city_query.execute()
+            
+            if city_resp.data:
+                query = city_query
+            else:
+                # Fallback to location field
+                query = supabase.table("properties").select("*").eq("is_active", True).ilike("location", f"%{loc}%")
         
         # b. Budget cap
         budget = filters.get("budget")
@@ -327,7 +330,12 @@ async def search_properties(filters: dict) -> list:
         
         # f. Execute and return
         resp = query.execute()
+        print(f"DEBUG - search_properties filters: {filters}")
+        print(f"DEBUG - properties returned: {len(resp.data) if resp.data else 0}")
+        if resp.data:
+            print(f"DEBUG - first property: {resp.data[0].get('title')} in {resp.data[0].get('city')}")
         return resp.data or []
         
     except Exception as e:
+        print(f"DEBUG - search_properties error: {e}")
         return []