communication

src/floor_manager.py

@@ -191,7 +191,8 @@ class FloorManager:
                 # Try to parse and log agent's response
                 try:
                     response_data = response.json()
-                    logger.info(f"📥 Response from {speaker_uri}: {response_data}")
+                    logger.info(f"📥 Response from {speaker_uri}")
+                    logger.debug(f"📥 Full response: {response_data}")
                     
                     # Check if agent sent any events back
                     if "openFloor" in response_data:
@@ -200,7 +201,13 @@ class FloorManager:
                             logger.info(f"🔔 Agent {speaker_uri} sent {len(events)} event(s) in response")
                             for event in events:
                                 event_type = event.get("eventType")
+                                to_info = event.get("to", {})
+                                is_private = to_info.get("private", False)
+                                target_uri = to_info.get("speakerUri")
+                                
                                 logger.info(f"  - Event type: {event_type}")
+                                if is_private and target_uri:
+                                    logger.info(f"  - Private message to: {target_uri}")
                                 
                                 # Extract utterance content if present
                                 if event_type == "utterance":
@@ -214,18 +221,29 @@ class FloorManager:
                                         text_content = " ".join([
                                             t.get("value", t.get("token", "")) for t in tokens
                                         ])
-                                        logger.info(f"  💬 Agent says: {text_content}")
                                         
-                                        # Store response for retrieval
+                                        if is_private:
+                                            logger.info(f"  🔒 Private message: {text_content}")
+                                        else:
+                                            logger.info(f"  💬 Agent says: {text_content}")
+                                        
+                                        # Store response for retrieval (include private messages too)
                                         if not hasattr(self, '_agent_responses'):
                                             self._agent_responses = {}
                                         if session_id not in self._agent_responses:
                                             self._agent_responses[session_id] = []
+                                        
+                                        agent_name = agent_info.manifest.get("conversationalName", speaker_uri) if agent_info.manifest else speaker_uri
+                                        if is_private and target_uri:
+                                            agent_name = f"{agent_name} (private to {target_uri})"
+                                        
                                         self._agent_responses[session_id].append({
                                             "agent_uri": speaker_uri,
-                                            "agent_name": agent_info.manifest.get("conversationalName", speaker_uri) if agent_info.manifest else speaker_uri,
+                                            "agent_name": agent_name,
                                             "message": text_content,
-                                            "timestamp": datetime.now()
+                                            "timestamp": datetime.now(),
+                                            "is_private": is_private,
+                                            "target_uri": target_uri
                                         })
                 except ValueError:
                     logger.debug(f"Response from {speaker_uri} is not JSON: {response.text[:200]}")