(&self)
| 298 | } |
| 299 | |
| 300 | pub async fn load_all_sessions(&self) -> Result<Vec<(String, Vec<serde_json::Value>)>> { |
| 301 | let sessions = self.list_sessions()?; |
| 302 | let mut all = Vec::new(); |
| 303 | |
| 304 | for session in sessions { |
| 305 | match streaming::read_jsonl_raw(&session.path).await { |
| 306 | Ok(entries) => all.push((session.session_id, entries)), |
| 307 | Err(e) => tracing::debug!("Failed to load session {}: {}", session.session_id, e), |
| 308 | } |
| 309 | } |
| 310 | |
| 311 | Ok(all) |
| 312 | } |
| 313 | |
| 314 | pub async fn search_in_sessions(&self, pattern: ®ex::Regex) -> Result<Vec<SearchResult>> { |
| 315 | let sessions = self.list_sessions()?; |
no test coverage detected