(&mut self, node_id: &str)
| 426 | } |
| 427 | |
| 428 | fn del_kg_edges_for_node(&mut self, node_id: &str) -> PristineResult<usize> { |
| 429 | // Collect all edge keys for this node (both directions) |
| 430 | let outgoing = self.get_kg_edges_from(node_id)?; |
| 431 | let incoming = self.get_kg_edges_to(node_id)?; |
| 432 | |
| 433 | let mut count = 0; |
| 434 | for edge in outgoing.iter().chain(incoming.iter()) { |
| 435 | if self.del_kg_edge(&edge.from_id, &edge.to_id, &edge.kind)? { |
| 436 | count += 1; |
| 437 | } |
| 438 | } |
| 439 | Ok(count) |
| 440 | } |
| 441 | |
| 442 | fn init_kg(&mut self) -> PristineResult<()> { |
| 443 | self.txn.open_table(KG_NODES)?; |
no test coverage detected