(&self, session_id: &str)
| 285 | } |
| 286 | |
| 287 | pub async fn load_session(&self, session_id: &str) -> Result<Vec<serde_json::Value>> { |
| 288 | let path = discover_transcript_files(&self.config) |
| 289 | .into_iter() |
| 290 | .find(|f| f.source_file.trim_end_matches(".jsonl") == session_id) |
| 291 | .map(|f| f.path) |
| 292 | .unwrap_or_else(|| { |
| 293 | self.config |
| 294 | .transcripts_dir() |
| 295 | .join(format!("{}.jsonl", session_id)) |
| 296 | }); |
| 297 | streaming::read_jsonl_raw(path).await |
| 298 | } |
| 299 | |
| 300 | pub async fn load_all_sessions(&self) -> Result<Vec<(String, Vec<serde_json::Value>)>> { |
| 301 | let sessions = self.list_sessions()?; |
nothing calls this directly
no test coverage detected