Enhance intent extraction and update logging in AI chat

- Added detailed logging for LLM responses and intent field updates in the `extract_and_update_intent` function to improve traceability and debugging.
- Implemented content cleanup for JSON responses to handle markdown formatting, ensuring robust parsing of intent data.
- Updated the `update_user_intent` function to include checks for session validity and added logging for successful updates and errors, enhancing error handling and user intent management.

ai_chat.py

@@ -148,6 +148,7 @@ async def extract_and_update_intent(state):
     """
 
     response = await llm.ainvoke([{"role":"user","content":extraction_prompt}])
+    print(f"LLM response for intent extraction: {response.content}")
     
     # Check if response is an explanatory answer rather than JSON
     if not response.content.strip().startswith("{"):
@@ -156,17 +157,31 @@ async def extract_and_update_intent(state):
     
     import json
     try:
-        extracted = json.loads(response.content)
-    except:
+        # Clean up the response content (remove markdown formatting if present)
+        content = response.content.strip()
+        if content.startswith('```json'):
+            content = content[7:]  # Remove ```json
+        if content.endswith('```'):
+            content = content[:-3]  # Remove ```
+        content = content.strip()
+        
+        extracted = json.loads(content)
+    except Exception as e:
         print("Failed to parse intent JSON:", response.content)
+        print("Error:", e)
         extracted = {}
 
     for field in intent_fields:
         new_val = extracted.get(field)
         old_val = intent.get(field)
         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
+        elif new_val is not None:
+            print(f"Intent field {field} unchanged: {new_val}")
+        else:
+            print(f"Intent field {field} not extracted")
 
     state["intent"] = intent
 

database.py

@@ -272,9 +272,18 @@ async def update_user_intent(session_id: str, updates: dict):
     """
     Patch the intent record with any changed fields.
     """
-    updates_with_ts = { **updates, "updated_at": datetime.utcnow().isoformat() }
-    supabase \
-        .table("user_intents") \
-        .update(updates_with_ts) \
-        .eq("session_id", session_id) \
-        .execute() 
+    if not supabase or session_id == "local_session":
+        print(f"Skipping intent update for session {session_id} (no supabase or local session)")
+        return
+    
+    try:
+        updates_with_ts = { **updates, "updated_at": datetime.utcnow().isoformat() }
+        print(f"Updating user_intents table for session {session_id} with: {updates_with_ts}")
+        supabase \
+            .table("user_intents") \
+            .update(updates_with_ts) \
+            .eq("session_id", session_id) \
+            .execute()
+        print(f"Successfully updated intent for session {session_id}")
+    except Exception as e:
+        print(f"Error updating user intent: {e}")