Function decode_variable_value

nodedb-strict/src/decode.rs:445–471

Decode a variable-length raw byte slice into a Value.

(col_type: &ColumnType, raw: &[u8])

/// Decode a variable-length raw byte slice into a Value.
fn decode_variable_value(col_type: &ColumnType, raw: &[u8]) -> Value {
    match col_type {
        ColumnType::String => {
            Value::String(std::str::from_utf8(raw).unwrap_or_default().to_string())
        }
        ColumnType::Bytes => Value::Bytes(raw.to_vec()),
        ColumnType::Geometry => {
            // Try JSON (native Geometry encoding), fall back to string (WKT passthrough).
            if let Ok(geom) = sonic_rs::from_slice::<nodedb_types::geometry::Geometry>(raw) {
                Value::Geometry(geom)
            } else {
                Value::String(std::str::from_utf8(raw).unwrap_or_default().to_string())
            }
        }
        ColumnType::Json => {
            // Deserialize MessagePack bytes back to Value.
            match nodedb_types::value_from_msgpack(raw) {
                Ok(val) => val,
                Err(e) => {
                    tracing::warn!(len = raw.len(), error = %e, "corrupted JSON msgpack in tuple");
                    Value::Null
                }
            }
        }
        _ => Value::Null,
    }
}

#[cfg(test)]
mod tests {