Send current status to a client
(session_id: str, websocket: WebSocket)
| 393 | |
| 394 | |
| 395 | async def send_status(session_id: str, websocket: WebSocket): |
| 396 | """Send current status to a client""" |
| 397 | session = session_manager.get_session(session_id) |
| 398 | if session: |
| 399 | await websocket.send_json({ |
| 400 | 'type': |
| 401 | 'status', |
| 402 | 'session': |
| 403 | session, |
| 404 | 'messages': |
| 405 | session_manager.get_messages(session_id) |
| 406 | }) |
| 407 | |
| 408 | |
| 409 | async def on_agent_output(session_id: str, message: Dict[str, Any]): |
no test coverage detected