(&mut self, node_id: &str)
| 444 | } |
| 445 | |
| 446 | fn del_kg_edges_for_node(&mut self, node_id: &str) -> PristineResult<usize> { |
| 447 | // Collect all edge keys for this node (both directions) |
| 448 | let outgoing = self.get_kg_edges_from(node_id)?; |
| 449 | let incoming = self.get_kg_edges_to(node_id)?; |
| 450 | |
| 451 | let mut count = 0; |
| 452 | for edge in outgoing.iter().chain(incoming.iter()) { |
| 453 | if self.del_kg_edge(&edge.from_id, &edge.to_id, &edge.kind)? { |
| 454 | count += 1; |
| 455 | } |
| 456 | } |
| 457 | Ok(count) |
| 458 | } |
| 459 | |
| 460 | fn init_kg(&mut self) -> PristineResult<()> { |
| 461 | self.txn.open_table(KG_NODES)?; |
no test coverage detected