Function node_payload

src/dashboard/lcm_service.rs:535–626

(
    state: &DashboardState,
    node_id: &str,
)

}

pub(crate) async fn node_payload(
    state: &DashboardState,
    node_id: &str,
) -> LcmServiceResult<Map<String, Value>> {
    let mut payload = json_object(json!({
        "path": state.lcm_db_path,
        "storage_scope": state.lcm_scope,
        "exists": state.lcm_conn.is_some(),
        "node_id": node_id,
        "node": null,
        "sources": { "type": null, "ids": [], "messages": [], "nodes": [] },
    }));
    let Some(conn) = state.lcm_conn.as_ref() else {
        return Ok(payload);
    };
    ensure_valid_summary_metadata(state, conn, "node").await?;

    let Some(node_row) =
        map_query_error("node lookup", lcm_queries::node_row(conn, node_id).await)?
    else {
        return Err((
            StatusCode::NOT_FOUND,
            Json(http_detail(&format!("summary node not found: {node_id}"))),
        ));
    };
    payload.insert("node".into(), node_row);

    let source_rows = map_query_error(
        "node sources",
        lcm_queries::node_source_rows(conn, node_id).await,
    )?;
    let mut message_ids: Vec<i64> = Vec::new();
    let mut child_node_ids: Vec<String> = Vec::new();
    for row in &source_rows {
        let kind = row.get("source_kind").and_then(Value::as_str).unwrap_or("");
        let id = row.get("source_id").and_then(Value::as_str).unwrap_or("");
        match kind {
            "raw_message" => {
                if let Ok(store_id) = id.parse::<i64>() {
                    message_ids.push(store_id);
                }
            }
            "summary_node" => child_node_ids.push(id.to_string()),
            _ => {}
        }
    }

    let source_type = if child_node_ids.is_empty() {
        "messages"
    } else {
        "nodes"
    };
    let ids: Vec<Value> = if source_type == "nodes" {
        child_node_ids.iter().map(|id| json!(id)).collect()
    } else {
        message_ids.iter().map(|id| json!(id)).collect()
    };