web_socket_connect.py

  async def connect(self, websocket: WebSocket, client_id: str) -> None:
        """
        Connect the WebSocket
        Args:
            websocket: WebSocket
            id: Client ID
        Returns:
            None
        """
        print(f"Read Flag: {read_flag()}")
        if read_flag():  # Check if the flag is True for the server to accept connections
            await websocket.accept()
            await websocket.send_text(get_pod_name())
            self.active_connections[client_id] = websocket
        else:
            await websocket.close(code=1000)  # Close the connection without accepting