Function registry_inspector_session

packages/server/src/api/routes.rs:3965–4012

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

}

async fn registry_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.published_inspectors().await {
        if frontmost_pid.is_some_and(|pid| pid != inspector.process_identifier) {
            probed_inspectors.push(format!(
                "background registry process {}",
                inspector.process_identifier
            ));
            continue;
        }
        if !inspector_process_belongs_to_udid(udid, inspector.process_identifier).await? {
            probed_inspectors.push(format!("registry process {}", inspector.process_identifier));
            continue;
        }
        let session = inspector_session_from_published(inspector);
        if query_inspector_session(state, &session, "Runtime.ping", Value::Null)
            .await
            .is_err()
        {
            probed_inspectors.push(format!(
                "unreachable registry process {}",
                session.process_identifier
            ));
            continue;
        }
        candidates.push(session);
    }

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

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

fn inspector_session_from_published(inspector: PublishedInspector) -> InspectorSession {
    let mut available_sources = inspector_available_sources(&inspector.info);