Function handle_android_control_socket

packages/server/src/api/routes.rs:2726–2753

(state: AppState, udid: String, socket: WebSocket)

}

async fn handle_android_control_socket(state: AppState, udid: String, socket: WebSocket) {
    let (mut sender, mut receiver) = socket.split();
    let _ = sender
        .send(Message::Text(
            json_value!({ "type": "ready", "udid": udid, "platform": "android-emulator" })
                .to_string()
                .into(),
        ))
        .await;
    while let Some(message) = receiver.next().await {
        let text = match message {
            Ok(Message::Text(text)) => text,
            Ok(Message::Binary(bytes)) => match String::from_utf8(bytes.to_vec()) {
                Ok(text) => text.into(),
                Err(_) => continue,
            },
            Ok(Message::Close(_)) => break,
            Ok(Message::Ping(_)) | Ok(Message::Pong(_)) => continue,
            Err(_) => break,
        };
        let Ok(control_message) = serde_json::from_str::<ControlMessage>(&text) else {
            continue;
        };
        let state = state.clone();
        let udid = udid.clone();
        let _ = run_android_control_message(state, udid, control_message).await;
    }
}

async fn run_android_control_message(
    state: AppState,