Spaces:
Running
Running
Update app.py
Browse files
app.py
CHANGED
@@ -254,34 +254,6 @@ class OpenFloorAgentServer:
|
|
254 |
print(f"🚀 OpenFloor agent '{self.agent.manifest.identification.conversationalName}' started on port {self.port}")
|
255 |
return True
|
256 |
|
257 |
-
def start_openfloor_research_agents(self):
|
258 |
-
"""Start all research agents as proper OpenFloor services"""
|
259 |
-
|
260 |
-
agent_ports = {
|
261 |
-
'web_search': 8001,
|
262 |
-
'wikipedia': 8002,
|
263 |
-
'arxiv': 8003,
|
264 |
-
'github': 8004,
|
265 |
-
'sec_edgar': 8005
|
266 |
-
}
|
267 |
-
|
268 |
-
self.agent_servers = {}
|
269 |
-
|
270 |
-
for agent_name, port in agent_ports.items():
|
271 |
-
agent = self.research_agents[agent_name]
|
272 |
-
server = OpenFloorAgentServer(agent, port)
|
273 |
-
|
274 |
-
if server.start_server():
|
275 |
-
self.agent_servers[agent_name] = {
|
276 |
-
'server': server,
|
277 |
-
'port': port,
|
278 |
-
'url': f"http://localhost:{port}/openfloor/conversation",
|
279 |
-
'manifest_url': f"http://localhost:{port}/openfloor/manifest"
|
280 |
-
}
|
281 |
-
|
282 |
-
# Small delay between starting servers
|
283 |
-
time.sleep(0.5)
|
284 |
-
|
285 |
def get_session_id(request: gr.Request = None) -> str:
|
286 |
"""Generate or retrieve session ID"""
|
287 |
if request and hasattr(request, 'session_hash'):
|
@@ -433,6 +405,34 @@ class VisualConsensusEngine:
|
|
433 |
'language': 'bridge-building dialogue'
|
434 |
}
|
435 |
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
436 |
|
437 |
def update_visual_state(self, state_update: Dict[str, Any]):
|
438 |
"""Update the visual roundtable state for this session"""
|
|
|
254 |
print(f"🚀 OpenFloor agent '{self.agent.manifest.identification.conversationalName}' started on port {self.port}")
|
255 |
return True
|
256 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
257 |
def get_session_id(request: gr.Request = None) -> str:
|
258 |
"""Generate or retrieve session ID"""
|
259 |
if request and hasattr(request, 'session_hash'):
|
|
|
405 |
'language': 'bridge-building dialogue'
|
406 |
}
|
407 |
}
|
408 |
+
|
409 |
+
def start_openfloor_research_agents(self):
|
410 |
+
"""Start all research agents as proper OpenFloor services"""
|
411 |
+
|
412 |
+
agent_ports = {
|
413 |
+
'web_search': 8001,
|
414 |
+
'wikipedia': 8002,
|
415 |
+
'arxiv': 8003,
|
416 |
+
'github': 8004,
|
417 |
+
'sec_edgar': 8005
|
418 |
+
}
|
419 |
+
|
420 |
+
self.agent_servers = {}
|
421 |
+
|
422 |
+
for agent_name, port in agent_ports.items():
|
423 |
+
agent = self.research_agents[agent_name]
|
424 |
+
server = OpenFloorAgentServer(agent, port)
|
425 |
+
|
426 |
+
if server.start_server():
|
427 |
+
self.agent_servers[agent_name] = {
|
428 |
+
'server': server,
|
429 |
+
'port': port,
|
430 |
+
'url': f"http://localhost:{port}/openfloor/conversation",
|
431 |
+
'manifest_url': f"http://localhost:{port}/openfloor/manifest"
|
432 |
+
}
|
433 |
+
|
434 |
+
# Small delay between starting servers
|
435 |
+
time.sleep(0.5)
|
436 |
|
437 |
def update_visual_state(self, state_update: Dict[str, Any]):
|
438 |
"""Update the visual roundtable state for this session"""
|