(self, session_id: str)
| 122 | await self.send_message(session_id, message) |
| 123 | |
| 124 | async def handle_heartbeat(self, session_id: str) -> None: |
| 125 | if session_id in self.active_connections: |
| 126 | await self.send_message( |
| 127 | session_id, |
| 128 | {"type": "pong", "data": {"timestamp": time.time()}}, |
| 129 | ) |
| 130 | else: |
| 131 | logging.warning("Heartbeat request from disconnected session: %s", session_id) |
| 132 | |
| 133 | async def handle_message(self, session_id: str, message: str) -> None: |
| 134 | try: |
no test coverage detected