Update app.py

app.py

@@ -690,58 +690,7 @@ class VisualConsensusEngine:
                     self.update_research_progress(f"OpenFloor HTTP response received - {len(result)} characters")
                 else:
                     result = f"Failed to get response from {agent_name} OpenFloor service"
-                
-            elif function_name == "multi_source_research":
-                self.update_research_progress("Starting multi-agent OpenFloor HTTP research...")
-                
-                # Use multiple agents via HTTP
-                results = []
-                agents_to_use = ["web_search", "wikipedia", "arxiv"]
-                
-                for i, agent_name in enumerate(agents_to_use, 1):
-                    if agent_name not in self.agent_servers:
-                        continue
-                        
-                    self.update_research_progress(f"Phase {i}: HTTP request to {agent_name.replace('_', ' ').title()}...")
-                    
-                    try:
-                        agent_server = self.agent_servers[agent_name]
-                        
-                        # Create OpenFloor request
-                        conversation = Conversation()
-                        request_dialog = DialogEvent(
-                            speakerUri=f"tag:consilium.ai,2025:{requesting_model_name or 'expert'}",
-                            features={"text": TextFeature(values=[query_param])}
-                        )
-                        
-                        request_envelope = Envelope(
-                            conversation=conversation,
-                            sender=Sender(speakerUri=f"tag:consilium.ai,2025:{requesting_model_name or 'expert'}"),
-                            events=[UtteranceEvent(
-                                dialogEvent=request_dialog,
-                                to=To(speakerUri=self.research_agents[agent_name].manifest.identification.speakerUri)
-                            )]
-                        )
-                        
-                        # Send HTTP request
-                        response = self._send_openfloor_request(agent_server['url'], request_envelope)
-                        
-                        if response:
-                            agent_result = self._extract_research_result_from_envelope(response)
-                            if agent_result and len(agent_result) > 100:
-                                results.append(f"**{agent_name.replace('_', ' ').title()} Results:**\n{agent_result}")
-                                
-                    except Exception as e:
-                        self.update_research_progress(f"Phase {i}: {agent_name} HTTP error - {str(e)[:50]}...")
-                        continue
-                
-                # Combine results
-                if results:
-                    result = f"**Multi-Source OpenFloor HTTP Research for: {query_param}**\n\n" + "\n\n---\n\n".join(results)
-                    self.update_research_progress(f"Multi-source HTTP research complete - {len(result)} characters")
-                else:
-                    result = f"Multi-source HTTP research failed for '{query_param}'"
-                    
+                      
             else:
                 result = f"Unknown research function: {function_name}"
             
@@ -897,8 +846,7 @@ class VisualConsensusEngine:
             "search_wikipedia": "15-30 seconds", 
             "search_academic": "2-5 minutes",
             "search_technology_trends": "1-2 minutes",
-            "search_financial_data": "1-3 minutes",
-            "multi_source_research": "3-7 minutes"
+            "search_financial_data": "1-3 minutes"
         }
         return time_estimates.get(function_name, "1-3 minutes")