Function reformat_query_rows

crates/cli/src/subcommands/subscribe.rs:737–757

Convert v3 initial subscription rows to the normalized table output map.

(
    msg: &'a ws_v2::QueryRows,
    schema: &RawModuleDefV9,
)

/// Convert v3 initial subscription rows to the normalized table output map.
fn reformat_query_rows<'a>(
    msg: &'a ws_v2::QueryRows,
    schema: &RawModuleDefV9,
) -> anyhow::Result<HashMap<&'a str, SubscriptionTable>> {
    let mut formatted = HashMap::default();

    for table in &msg.tables {
        let table_ty = schema.typespace.resolve(
            schema
                .type_ref_for_table_like(&table.table)
                .context("table not found in schema")?,
        );
        let table_output = formatted.entry(&*table.table).or_insert_with(|| SubscriptionTable {
            deletes: Vec::new(),
            inserts: Vec::new(),
        });
        table_output.inserts.extend(reformat_bsatn_rows(&table.rows, table_ty)?);
    }

    Ok(formatted)
}

/// Convert a v3 transaction update to the normalized table output map.
fn reformat_transaction_update<'a>(