Function decode_msgpack_array

nodedb/src/control/gateway/fuser.rs:86–101

Decode a MessagePack-encoded array into a `Vec `.

(bytes: &[u8])

/// Decode a MessagePack-encoded array into a `Vec<MpValue>`.
fn decode_msgpack_array(bytes: &[u8]) -> Result<Vec<MpValue>, Error> {
    if bytes.is_empty() {
        return Ok(Vec::new());
    }
    let mut cursor = std::io::Cursor::new(bytes);
    let value: MpValue =
        rmpv::decode::read_value(&mut cursor).map_err(|e| Error::Serialization {
            format: "msgpack".into(),
            detail: format!("fuser: decode failed: {e}"),
        })?;
    match value {
        MpValue::Array(rows) => Ok(rows),
        // A single non-array value is treated as a 1-element array.
        other => Ok(vec![other]),
    }
}

/// Re-encode a `Vec<MpValue>` as a MessagePack array.
fn encode_msgpack_array(rows: &[MpValue]) -> Result<Vec<u8>, rmpv::encode::Error> {