Method upsert_kg_node

atomic-core/src/pristine/txn/write/triples.rs:345–360

(&mut self, node: &KgNode)

impl<'a> KgMutTxnT for WriteTxn<'a> {
    fn upsert_kg_node(&mut self, node: &KgNode) -> PristineResult<()> {
        // Replacement semantics are important: old ID/label/summary tokens
        // must disappear before the same node ID is re-indexed.
        self.remove_kg_fts_entries(&node.id)?;

        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);

        self.add_kg_fts_entries(&node.id, &kg_node_fts_text(node))?;

        Ok(())
    }

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