Function encode_as_msgpack

nodedb-columnar/src/memtable/column_data/push.rs:19–36

Encode a `Value` as MessagePack bytes for JSON/Array/Set/Record storage. For `Value::String` input, the string is first parsed as JSON so that downstream JSON path operators see a real structure rather than an opaque string literal.

(value: &Value, col_name: &str)

/// downstream JSON path operators see a real structure rather than an opaque
/// string literal.
fn encode_as_msgpack(value: &Value, col_name: &str) -> Result<Vec<u8>, ColumnarError> {
    let to_encode: std::borrow::Cow<'_, Value> = match value {
        Value::String(s) => {
            let parsed = sonic_rs::from_str::<serde_json::Value>(s).map_err(|e| {
                ColumnarError::JsonParse {
                    column: col_name.to_string(),
                    source: e,
                }
            })?;
            std::borrow::Cow::Owned(Value::from(parsed))
        }
        other => std::borrow::Cow::Borrowed(other),
    };
    value_to_msgpack(&to_encode).map_err(|e| ColumnarError::MsgpackSerialize {
        column: col_name.to_string(),
        source: e,
    })
}

/// Parse a PostgreSQL range literal into a structured Value.
///