Method upsert_kg_node

atomic-core/src/pristine/txn/write/triples.rs:201–226

(&mut self, node: &KgNode)

impl<'a> KgMutTxnT for WriteTxn<'a> {
    fn upsert_kg_node(&mut self, node: &KgNode) -> PristineResult<()> {
        let mut table = self.txn.open_table(KG_NODES)?;
        let bytes = serde_json::to_vec(node).map_err(|e| PristineError::Serialization {
            message: e.to_string(),
        })?;
        table.insert(node.id.as_str(), bytes.as_slice())?;
        drop(table);

        // Update FTS index: add new tokens (duplicates are harmless
        // in a multimap — the node_id appears multiple times but deduplication
        // happens at query time via HashMap).
        let mut fts_table = self.txn.open_multimap_table(KG_FTS)?;
        let mut text = String::with_capacity(node.id.len() + node.label.len() + 64);
        text.push_str(&node.id);
        text.push(' ');
        text.push_str(&node.label);
        if let Some(ref summary) = node.summary {
            text.push(' ');
            text.push_str(summary);
        }
        for token in tokenize_for_fts(&text) {
            fts_table.insert(token.as_str(), node.id.as_str())?;
        }

        Ok(())
    }

    fn upsert_kg_edge(&mut self, edge: &KgEdge) -> PristineResult<()> {
        let edge_key = encode_edge_key(&edge.from_id, &edge.to_id, &edge.kind);