Update database table references for user personas

- Changed references from "personas" to "user_personas" in the `get_user_persona` and `update_user_persona` functions to align with the updated database schema.
- This modification ensures consistency in data handling and improves the accuracy of user persona management.

ai_chat.py

@@ -87,11 +87,21 @@ async def extract_and_update_persona(state):
     # c. Call the LLM
     response = await llm.ainvoke([{"role":"user","content":extraction_prompt}])
     import json
+    import re
     extracted = {}
     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 persona JSON:", response.content)
+        print("Error:", e)
 
     # d. Update DB and in-memory state for any changed values
     for field in persona_fields:

database.py

@@ -194,7 +194,7 @@ async def get_user_persona(wa_id: str) -> dict:
     
     try:
         resp = supabase\
-            .table("personas")\
+            .table("user_personas")\
             .select("*")\
             .eq("wa_id", wa_id)\
             .single()\
@@ -216,12 +216,12 @@ async def update_user_persona(wa_id: str, updates: dict):
         updates_with_ts = {**updates, "updated_at": datetime.utcnow().isoformat()}
         
         # First try to get existing persona
-        existing = supabase.table("personas").select("*").eq("wa_id", wa_id).execute()
+        existing = supabase.table("user_personas").select("*").eq("wa_id", wa_id).execute()
         
         if existing.data:
             # Update existing record
             supabase\
-                .table("personas")\
+                .table("user_personas")\
                 .update(updates_with_ts)\
                 .eq("wa_id", wa_id)\
                 .execute()
@@ -232,7 +232,7 @@ async def update_user_persona(wa_id: str, updates: dict):
                 "created_at": datetime.utcnow().isoformat(),
                 **updates_with_ts
             }
-            supabase.table("personas").insert(new_persona).execute()
+            supabase.table("user_personas").insert(new_persona).execute()
             
     except Exception as e:
         print(f"Error updating user persona: {e}")