(&self, table_name: &str)
| 568 | } |
| 569 | |
| 570 | async fn scan_data(&self, table_name: &str) -> Result<RowIter<'_>> { |
| 571 | if self.is_virtual_table(table_name) { |
| 572 | let rows = match table_name { |
| 573 | "jhistory" | "codex_history" => self.scan_jhistory()?, |
| 574 | "transcripts" => self.scan_transcripts()?, |
| 575 | "sessions" => self.scan_sessions()?, |
| 576 | "todos" => self.scan_todos()?, |
| 577 | _ => Vec::new(), |
| 578 | }; |
| 579 | |
| 580 | Ok(rows_to_iter(rows)) |
| 581 | } else { |
| 582 | self.json_storage.scan_data(table_name).await |
| 583 | } |
| 584 | } |
| 585 | } |
| 586 | |
| 587 | // Implement StoreMut (delegate to JsonStorage for non-virtual tables) |
no test coverage detected