Function connected_inspector_session

packages/server/src/api/routes.rs:3921–3963

(
    state: &AppState,
    udid: &str,
    frontmost_pid: Option<i64>,
)

}

async fn connected_inspector_session(
    state: &AppState,
    udid: &str,
    frontmost_pid: Option<i64>,
) -> Result<InspectorSession, String> {
    let mut probed_inspectors = Vec::new();
    let mut candidates = Vec::new();
    for inspector in state.inspectors.connected().await {
        if frontmost_pid.is_some_and(|pid| pid != inspector.process_identifier) {
            probed_inspectors.push(format!(
                "background process {}",
                inspector.process_identifier
            ));
            continue;
        }
        if inspector_process_belongs_to_udid(udid, inspector.process_identifier).await? {
            candidates.push(InspectorSession {
                transport: InspectorSessionTransport::Connected,
                available_sources: inspector_available_sources(&inspector.info),
                info: inspector.info,
                process_identifier: inspector.process_identifier,
            });
            continue;
        }

        probed_inspectors.push(format!("process {}", inspector.process_identifier));
    }

    if let Some(session) = best_inspector_session(candidates) {
        return Ok(session);
    }

    if probed_inspectors.is_empty() {
        Err(format!(
            "No connected WebSocket inspector found for simulator {udid}."
        ))
    } else {
        Err(format!(
            "No connected WebSocket inspector matched simulator {udid}. Found inspectors for {}.",
            probed_inspectors.join(", ")
        ))
    }
}

async fn registry_inspector_session(
    state: &AppState,