zenaight commited on
Commit ·
45c2c48
1
Parent(s): 2169ed9
debugging
Browse files- ai_chat.py +11 -0
ai_chat.py
CHANGED
|
@@ -133,6 +133,11 @@ async def extract_and_update_persona(state):
|
|
| 133 |
return {"response": None}
|
| 134 |
|
| 135 |
async def extract_and_update_intent(state):
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 136 |
intent_fields = ["location_preference", "budget", "size_preference_sqm", "must_have"]
|
| 137 |
user_message = state["user_message"]
|
| 138 |
session_id = state["session_id"]
|
|
@@ -166,14 +171,20 @@ async def extract_and_update_intent(state):
|
|
| 166 |
content = content.strip()
|
| 167 |
|
| 168 |
extracted = json.loads(content)
|
|
|
|
| 169 |
except Exception as e:
|
| 170 |
print("Failed to parse intent JSON:", response.content)
|
| 171 |
print("Error:", e)
|
| 172 |
extracted = {}
|
| 173 |
|
|
|
|
|
|
|
|
|
|
| 174 |
for field in intent_fields:
|
| 175 |
new_val = extracted.get(field)
|
| 176 |
old_val = intent.get(field)
|
|
|
|
|
|
|
| 177 |
if new_val is not None and new_val != old_val:
|
| 178 |
print(f"Updating intent field {field}: {old_val} -> {new_val}")
|
| 179 |
await update_user_intent(session_id, {field: new_val})
|
|
|
|
| 133 |
return {"response": None}
|
| 134 |
|
| 135 |
async def extract_and_update_intent(state):
|
| 136 |
+
print(f"=== Starting extract_and_update_intent ===")
|
| 137 |
+
print(f"Session ID: {state.get('session_id')}")
|
| 138 |
+
print(f"User message: {state.get('user_message')}")
|
| 139 |
+
print(f"Current intent: {state.get('intent')}")
|
| 140 |
+
|
| 141 |
intent_fields = ["location_preference", "budget", "size_preference_sqm", "must_have"]
|
| 142 |
user_message = state["user_message"]
|
| 143 |
session_id = state["session_id"]
|
|
|
|
| 171 |
content = content.strip()
|
| 172 |
|
| 173 |
extracted = json.loads(content)
|
| 174 |
+
print(f"Successfully parsed intent JSON: {extracted}")
|
| 175 |
except Exception as e:
|
| 176 |
print("Failed to parse intent JSON:", response.content)
|
| 177 |
print("Error:", e)
|
| 178 |
extracted = {}
|
| 179 |
|
| 180 |
+
print(f"Starting field update loop. Extracted: {extracted}")
|
| 181 |
+
print(f"Current intent state: {intent}")
|
| 182 |
+
|
| 183 |
for field in intent_fields:
|
| 184 |
new_val = extracted.get(field)
|
| 185 |
old_val = intent.get(field)
|
| 186 |
+
print(f"Processing field {field}: new_val={new_val}, old_val={old_val}")
|
| 187 |
+
|
| 188 |
if new_val is not None and new_val != old_val:
|
| 189 |
print(f"Updating intent field {field}: {old_val} -> {new_val}")
|
| 190 |
await update_user_intent(session_id, {field: new_val})
|