Method handle_client

backend/termnet/main.py:147–202

Handle a WebSocket client connection

(self, websocket, path=None)

                pass

    async def handle_client(self, websocket, path=None):
        """Handle a WebSocket client connection"""
        try:
            self.connected_clients.add(websocket)
            client_id = id(websocket)
            
            # Initialize TermNet for this client
            await self.initialize_termnet()
            
            # Send welcome message
            welcome_msg = {
                "type": "system",
                "message": "TermNet v1.2 ready - WebSocket connection established",
                "timestamp": time.time()
            }
            try:
                await websocket.send(json.dumps(welcome_msg))
            except:
                return
            
            async for message in websocket:
                try:
                    data = json.loads(message)
                    user_input = data.get("message", "").strip()
                    
                    if not user_input:
                        continue
                        
                    if user_input.lower() in ("exit", "quit", "close"):
                        break
                    
                    # Stream the response back to client
                    await self.stream_agent_response(websocket, user_input)
                    
                except json.JSONDecodeError:
                    try:
                        error_msg = {
                            "type": "error",
                            "message": "Invalid JSON format",
                            "timestamp": time.time()
                        }
                        await websocket.send(json.dumps(error_msg))
                    except:
                        pass
                except Exception:
                    # Silently ignore all other exceptions
                    pass
                    
        except Exception:
            # Silently handle all connection exceptions
            pass
        finally:
            try:
                self.connected_clients.discard(websocket)
            except:
                pass

    async def start_server(self):