Function query_rows

src/dashboard/util.rs:47–54

Runs a query and collects all rows as JSON objects. On SQL errors returns the error message so handlers can surface it in the payload's `error` field (mirroring the Python APIs, which never 500 on a bad/missing DB).

(
    conn: &Connection,
    sql: &str,
    params: impl libsql::params::IntoParams,
)

/// the error message so handlers can surface it in the payload's `error`
/// field (mirroring the Python APIs, which never 500 on a bad/missing DB).
pub(crate) async fn query_rows(
    conn: &Connection,
    sql: &str,
    params: impl libsql::params::IntoParams,
) -> std::result::Result<Vec<Value>, String> {
    let rows = conn.query(sql, params).await.map_err(|e| e.to_string())?;
    collect_rows(rows).await.map_err(|e| e.to_string())
}

/// Runs a scalar `SELECT COUNT(*)`-style query; errors and missing rows
/// collapse to 0 (these feed overview cards, not critical paths).