agtrace-runtime 0.7.1

Internal runtime orchestration for the agtrace CLI. Not intended for direct use.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use crate::Result;
use agtrace_engine::export::{self, ExportStrategy};
use agtrace_index::Database;
use agtrace_types::AgentEvent;

use crate::storage::{LoadOptions, SessionRepository};

pub struct ExportService<'a> {
    db: &'a Database,
}

impl<'a> ExportService<'a> {
    pub fn new(db: &'a Database) -> Self {
        Self { db }
    }

    pub fn export_session(
        &self,
        session_id: &str,
        strategy: ExportStrategy,
    ) -> Result<Vec<AgentEvent>> {
        let loader = SessionRepository::new(self.db);
        let options = LoadOptions::default();
        let events = loader.load_events(session_id, &options)?;
        let processed_events = export::transform(&events, strategy);
        Ok(processed_events)
    }
}