Function handle_incoming_message

packages/server/src/inspector.rs:739–775

(
    hub: &InspectorHub,
    handle: &InspectorAgentHandle,
    pending: &PendingResponses,
    process_identifier: &Arc<Mutex<Option<i64>>>,
    text: &str,
)

}

async fn handle_incoming_message(
    hub: &InspectorHub,
    handle: &InspectorAgentHandle,
    pending: &PendingResponses,
    process_identifier: &Arc<Mutex<Option<i64>>>,
    text: &str,
) {
    let Ok(value) = serde_json::from_str::<Value>(text) else {
        return;
    };

    if value.get("id").and_then(Value::as_u64).is_some() {
        complete_pending_response_value(pending, value).await;
        return;
    }

    let method = value
        .get("method")
        .or_else(|| value.get("event"))
        .and_then(Value::as_str);
    if method != Some("Inspector.ready") {
        return;
    }

    let info = value
        .get("params")
        .or_else(|| value.get("info"))
        .cloned()
        .unwrap_or(Value::Null);
    let Some(pid) = info.get("processIdentifier").and_then(Value::as_i64) else {
        warn!("NativeScript inspector ready event did not report processIdentifier.");
        return;
    };

    *process_identifier.lock().await = Some(pid);
    hub.register(pid, handle.with_info(info)).await;
}

async fn complete_pending_response_value(pending: &PendingResponses, value: Value) {
    let Some(id) = value.get("id").and_then(Value::as_u64) else {