Method get_kg_node

atomic-core/src/pristine/txn/read.rs:934–951

(&self, id: &str)

impl KgTxnT for ReadTxn {
    fn get_kg_node(&self, id: &str) -> PristineResult<Option<KgNode>> {
        let table = match self.txn.open_table(KG_NODES) {
            Ok(t) => t,
            Err(redb::TableError::TableDoesNotExist(_)) => return Ok(None),
            Err(e) => return Err(PristineError::from(e)),
        };
        match table.get(id)? {
            Some(value) => {
                let node: KgNode = serde_json::from_slice(value.value()).map_err(|e| {
                    PristineError::Serialization {
                        message: e.to_string(),
                    }
                })?;
                Ok(Some(node))
            }
            None => Ok(None),
        }
    }

    fn get_kg_edges_from(&self, node_id: &str) -> PristineResult<Vec<KgEdge>> {
        let from_table = match self.txn.open_multimap_table(KG_EDGES_FROM) {