(&mut self, node_id: &str)
| 292 | } |
| 293 | |
| 294 | fn del_kg_edges_for_node(&mut self, node_id: &str) -> PristineResult<usize> { |
| 295 | // Collect all edge keys for this node (both directions) |
| 296 | let outgoing = self.get_kg_edges_from(node_id)?; |
| 297 | let incoming = self.get_kg_edges_to(node_id)?; |
| 298 | |
| 299 | let mut count = 0; |
| 300 | for edge in outgoing.iter().chain(incoming.iter()) { |
| 301 | if self.del_kg_edge(&edge.from_id, &edge.to_id, &edge.kind)? { |
| 302 | count += 1; |
| 303 | } |
| 304 | } |
| 305 | Ok(count) |
| 306 | } |
| 307 | |
| 308 | fn init_kg(&mut self) -> PristineResult<()> { |
| 309 | self.txn.open_table(KG_NODES)?; |
no test coverage detected