Function json_to_msgpack

nodedb/src/engine/document/store/extract.rs:98–126

Convert serde_json::Value to rmpv::Value for MessagePack serialization.

(val: &serde_json::Value)

/// Convert serde_json::Value to rmpv::Value for MessagePack serialization.
pub fn json_to_msgpack(val: &serde_json::Value) -> rmpv::Value {
    match val {
        serde_json::Value::Null => rmpv::Value::Nil,
        serde_json::Value::Bool(b) => rmpv::Value::Boolean(*b),
        serde_json::Value::Number(n) => {
            if let Some(i) = n.as_i64() {
                rmpv::Value::Integer(rmpv::Integer::from(i))
            } else if let Some(u) = n.as_u64() {
                rmpv::Value::Integer(rmpv::Integer::from(u))
            } else {
                rmpv::Value::F64(n.as_f64().unwrap_or(0.0))
            }
        }
        serde_json::Value::String(s) => rmpv::Value::String(rmpv::Utf8String::from(s.as_str())),
        serde_json::Value::Array(arr) => {
            rmpv::Value::Array(arr.iter().map(json_to_msgpack).collect())
        }
        serde_json::Value::Object(obj) => rmpv::Value::Map(
            obj.iter()
                .map(|(k, v)| {
                    (
                        rmpv::Value::String(rmpv::Utf8String::from(k.as_str())),
                        json_to_msgpack(v),
                    )
                })
                .collect(),
        ),
    }
}

/// Convert rmpv::Value back to serde_json::Value.
pub(crate) fn rmpv_to_json(val: &rmpv::Value) -> serde_json::Value {