Update app.py

app.py

@@ -855,6 +855,93 @@ class VisualConsensusEngine:
         })
         time.sleep(0.3)
 
+    def invite_research_agent(self, agent_name: str, conversation_id: str, requesting_expert: str):
+        """Invite a research agent to join the conversation visually"""
+        
+        if agent_name in self.research_agents:
+            research_agent = self.research_agents[agent_name]
+            
+            # Research agent joins the conversation
+            research_agent.join_conversation(conversation_id)
+            
+            # Update visual state to show the research agent joining
+            session = get_or_create_session_state(self.session_id)
+            current_state = session["roundtable_state"]
+            
+            # Add research agent to participants if not already there
+            participants = list(current_state.get("participants", []))
+            agent_display_name = research_agent.manifest.identification.conversationalName
+            
+            if agent_display_name not in participants:
+                participants.append(agent_display_name)
+            
+            # Show join message
+            all_messages = list(current_state.get("messages", []))
+            join_message = {
+                "speaker": agent_display_name,
+                "text": f"🔗 **Joined Conversation**\nInvited by: {requesting_expert}\nSpecialty: {research_agent.manifest.identification.synopsis}\nReady to provide research assistance.",
+                "type": "agent_join"
+            }
+            all_messages.append(join_message)
+            
+            # Update visual state
+            existing_bubbles = list(current_state.get("showBubbles", []))
+            if agent_display_name not in existing_bubbles:
+                existing_bubbles.append(agent_display_name)
+            
+            self.update_visual_state({
+                "participants": participants,
+                "messages": all_messages,
+                "currentSpeaker": None,
+                "thinking": [],
+                "showBubbles": existing_bubbles
+            })
+            
+            return True
+        
+        return False
+    
+    def dismiss_research_agent(self, agent_name: str, conversation_id: str):
+        """Remove a research agent from the conversation visually"""
+        
+        if agent_name in self.research_agents:
+            research_agent = self.research_agents[agent_name]
+            
+            # Research agent leaves the conversation
+            research_agent.leave_conversation(conversation_id)
+            
+            # Update visual state
+            session = get_or_create_session_state(self.session_id)
+            current_state = session["roundtable_state"]
+            
+            agent_display_name = research_agent.manifest.identification.conversationalName
+            
+            # Show leave message
+            all_messages = list(current_state.get("messages", []))
+            leave_message = {
+                "speaker": agent_display_name,
+                "text": f"👋 **Leaving Conversation**\nResearch assistance complete. Agent dismissed.",
+                "type": "agent_leave"
+            }
+            all_messages.append(leave_message)
+            
+            # Remove from bubbles but keep in participants list for history
+            existing_bubbles = list(current_state.get("showBubbles", []))
+            if agent_display_name in existing_bubbles:
+                existing_bubbles.remove(agent_display_name)
+            
+            self.update_visual_state({
+                "participants": current_state.get("participants", []),
+                "messages": all_messages,
+                "currentSpeaker": None,
+                "thinking": [],
+                "showBubbles": existing_bubbles
+            })
+            
+            return True
+        
+        return False
+
     def call_model(self, model: str, prompt: str, context: str = "") -> Optional[str]:
         """Enhanced model calling with native function calling support"""
         if not self.models[model]['available']: