fix

src/floor_manager.py

@@ -201,6 +201,29 @@ class FloorManager:
                             for event in events:
                                 event_type = event.get("eventType")
                                 logger.info(f"  - Event type: {event_type}")
+                                
+                                # Extract utterance content if present
+                                if event_type == "utterance":
+                                    params = event.get("parameters", {})
+                                    dialog_event = params.get("dialogEvent", {})
+                                    features = dialog_event.get("features", {})
+                                    text_feature = features.get("text", {})
+                                    tokens = text_feature.get("tokens", [])
+                                    if tokens:
+                                        text_content = " ".join([t.get("token", "") for t in tokens])
+                                        logger.info(f"  💬 Agent says: {text_content}")
+                                        
+                                        # Store response for retrieval
+                                        if not hasattr(self, '_agent_responses'):
+                                            self._agent_responses = {}
+                                        if session_id not in self._agent_responses:
+                                            self._agent_responses[session_id] = []
+                                        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,
+                                            "message": text_content,
+                                            "timestamp": datetime.now()
+                                        })
                 except ValueError:
                     logger.debug(f"Response from {speaker_uri} is not JSON: {response.text[:200]}")
                 
@@ -369,3 +392,22 @@ class FloorManager:
         )
         
         return any(results.values())
+    
+    def get_agent_responses(self, session_id: str) -> List[Dict[str, Any]]:
+        """
+        Get agent responses for a session
+        
+        Args:
+            session_id: Session identifier
+        
+        Returns:
+            List of agent response dictionaries
+        """
+        if not hasattr(self, '_agent_responses'):
+            return []
+        return self._agent_responses.get(session_id, [])
+    
+    def clear_agent_responses(self, session_id: str):
+        """Clear agent responses for a session"""
+        if hasattr(self, '_agent_responses') and session_id in self._agent_responses:
+            self._agent_responses[session_id] = []

test_app.py

@@ -299,8 +299,30 @@ def send_message(agent_name: str, message: str):
             
             print(f"✅ Broadcast complete: {sum(1 for r in results.values() if r)}/{len(results)} successful")
             
+            # Check for agent responses
+            agent_responses = floor_manager.get_agent_responses(current_session.session_id)
+            if agent_responses:
+                print(f"📥 Received {len(agent_responses)} agent response(s)")
+                for response in agent_responses:
+                    # Add agent response to UI
+                    agent_name = response["agent_name"]
+                    agent_msg = response["message"]
+                    print(f"  💬 {agent_name}: {agent_msg}")
+                    
+                    # Add to mock session as a system message
+                    current_session.messages.append({
+                        "role": agent_name,
+                        "content": agent_msg,
+                        "timestamp": response["timestamp"].strftime("%H:%M:%S")
+                    })
+                
+                # Clear responses after displaying
+                floor_manager.clear_agent_responses(current_session.session_id)
+            
         except Exception as e:
             print(f"❌ Error broadcasting message: {e}")
+            import traceback
+            traceback.print_exc()
     
     return (
         current_session.format_chat_history(),