Spaces:
Sleeping
Sleeping
BolyosCsaba commited on
Commit Β·
2b0318e
1
Parent(s): d85305e
extend logs
Browse files- src/floor_manager.py +19 -2
src/floor_manager.py
CHANGED
|
@@ -191,20 +191,37 @@ class FloorManager:
|
|
| 191 |
# Try to parse and log agent's response
|
| 192 |
try:
|
| 193 |
response_data = response.json()
|
|
|
|
|
|
|
|
|
|
| 194 |
logger.info(f"π₯ Response from {speaker_uri}")
|
| 195 |
logger.debug(f"π₯ Full response: {response_data}")
|
| 196 |
|
| 197 |
# Check if agent sent any events back
|
| 198 |
if "openFloor" in response_data:
|
| 199 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 200 |
if events:
|
| 201 |
logger.info(f"π Agent {speaker_uri} sent {len(events)} event(s) in response")
|
| 202 |
-
|
|
|
|
|
|
|
| 203 |
event_type = event.get("eventType")
|
| 204 |
to_info = event.get("to", {})
|
| 205 |
is_private = to_info.get("private", False)
|
| 206 |
target_uri = to_info.get("speakerUri")
|
| 207 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 208 |
logger.info(f" - Event type: {event_type}")
|
| 209 |
if is_private and target_uri:
|
| 210 |
logger.info(f" - Private message to: {target_uri}")
|
|
|
|
| 191 |
# Try to parse and log agent's response
|
| 192 |
try:
|
| 193 |
response_data = response.json()
|
| 194 |
+
print(f"\n{'='*80}")
|
| 195 |
+
print(f"π₯ AGENT RESPONSE FROM: {speaker_uri}")
|
| 196 |
+
print(f"{'='*80}")
|
| 197 |
logger.info(f"π₯ Response from {speaker_uri}")
|
| 198 |
logger.debug(f"π₯ Full response: {response_data}")
|
| 199 |
|
| 200 |
# Check if agent sent any events back
|
| 201 |
if "openFloor" in response_data:
|
| 202 |
+
response_envelope = response_data.get("openFloor", {})
|
| 203 |
+
response_sender = response_envelope.get("sender", {})
|
| 204 |
+
events = response_envelope.get("events", [])
|
| 205 |
+
|
| 206 |
+
print(f"Response Sender: {response_sender.get('speakerUri')}")
|
| 207 |
+
print(f"Number of Events: {len(events)}")
|
| 208 |
+
print(f"-" * 80)
|
| 209 |
+
|
| 210 |
if events:
|
| 211 |
logger.info(f"π Agent {speaker_uri} sent {len(events)} event(s) in response")
|
| 212 |
+
|
| 213 |
+
for idx, event in enumerate(events, 1):
|
| 214 |
+
print(f"\nπ Event #{idx}:")
|
| 215 |
event_type = event.get("eventType")
|
| 216 |
to_info = event.get("to", {})
|
| 217 |
is_private = to_info.get("private", False)
|
| 218 |
target_uri = to_info.get("speakerUri")
|
| 219 |
|
| 220 |
+
print(f" Type: {event_type}")
|
| 221 |
+
if to_info:
|
| 222 |
+
print(f" To: {target_uri or 'all'}")
|
| 223 |
+
print(f" Private: {is_private}")
|
| 224 |
+
|
| 225 |
logger.info(f" - Event type: {event_type}")
|
| 226 |
if is_private and target_uri:
|
| 227 |
logger.info(f" - Private message to: {target_uri}")
|