Method get

nodedb/src/engine/document/store/engine/get.rs:10–29

Get a document and deserialize from MessagePack to JSON.

(&self, collection: &str, doc_id: &str)

impl<'a> DocumentEngine<'a> {
    /// Get a document and deserialize from MessagePack to JSON.
    pub fn get(&self, collection: &str, doc_id: &str) -> crate::Result<Option<serde_json::Value>> {
        let bytes_opt = if self.is_bitemporal(collection) {
            self.sparse
                .versioned_get_current(self.tenant_id, collection, doc_id)?
        } else {
            self.sparse.get(self.tenant_id, collection, doc_id)?
        };
        match bytes_opt {
            Some(bytes) => {
                let rmpv_val = rmpv::decode::read_value(&mut bytes.as_slice()).map_err(|e| {
                    crate::Error::Serialization {
                        format: "msgpack".into(),
                        detail: format!("decode: {e}"),
                    }
                })?;
                Ok(Some(rmpv_to_json(&rmpv_val)))
            }
            None => Ok(None),
        }
    }

    /// Get raw MessagePack bytes (zero-copy path for DataFusion UDFs).
    pub fn get_raw(&self, collection: &str, doc_id: &str) -> crate::Result<Option<Vec<u8>>> {