Function extract_key_value

nodedb/src/event/cdc/buffer.rs:237–256

(event: &CdcEvent, key_field: &str)

}

fn extract_key_value(event: &CdcEvent, key_field: &str) -> String {
    let value = event.new_value.as_ref().or(event.old_value.as_ref());

    if let Some(obj) = value.and_then(|v| v.as_object())
        && let Some(val) = obj.get(key_field)
    {
        return match val {
            serde_json::Value::String(s) => s.clone(),
            other => other.to_string(),
        };
    }

    tracing::warn!(
        collection = %event.collection,
        row_id = %event.row_id,
        key_field,
        "compaction key field not found in event, falling back to row_id"
    );
    event.row_id.clone()
}

#[cfg(test)]
mod tests {