luft_storage/
lib.rs

1//! # luft-storage
2//!
3//! **SQLite-backed structured persistence for Luft.**
4//!
5//! Replaces the JSONL `events.jsonl` + `checkpoint.json` pair with a queryable,
6//! relational store. Provides a UI-ready query API for listing runs, inspecting
7//! agent turns, and searching event spans.
8//!
9//! ## Module Layout
10//!
11//! | Module | Responsibility |
12//! |--------|---------------|
13//! | [`db`] | Connection pool (`DbPool`) + schema migration |
14//! | [`writer`] | `AgentEvent` → SQL write path ([`EventWriter`]) |
15//! | [`reader`] | UI-ready query API: [`get_run_overview`], [`get_agent_turns`], etc. |
16//! | [`error`] | Unified [`StorageError`] type |
17//!
18//! ## Usage
19//!
20//! ```no_run
21//! use luft_storage::{open_db, EventWriter};
22//! use std::path::Path;
23//!
24//! # tokio::runtime::Runtime::new().unwrap().block_on(async {
25//! let pool = open_db(Path::new("./.luft/runs/latest/luft.db")).await?;
26//! let writer = EventWriter::new(pool.clone());
27//! // writer.write_event(&event).await?;
28//! # Ok::<(), Box<dyn std::error::Error>>(())
29//! # });
30//! ```
31
32pub mod db;
33pub mod error;
34pub mod reader;
35pub mod writer;
36
37pub use db::{open_db, DbPool, DEFAULT_DB_PATH};
38pub use error::StorageError;
39pub use reader::{
40    get_agent_overview, get_agent_turns, get_run_agents, get_run_overview, get_run_spans,
41    get_run_tree, list_runs, search_turns, AgentOverview, RunOverview, RunSummary, SpanRow,
42    TurnKindCount, TurnRow,
43};
44pub use writer::EventWriter;
45
46#[cfg(test)]
47mod tests {
48    use super::*;
49
50    #[test]
51    fn default_db_path_is_luft_db_filename() {
52        let p = DEFAULT_DB_PATH;
53        assert_eq!(p, "luft.db");
54        assert!(p.ends_with(".db"));
55    }
56
57    #[test]
58    fn storage_error_re_export_matches_crate_path() {
59        let _e: StorageError = StorageError::Invalid("ping".into());
60        let msg = _e.to_string();
61        assert!(msg.contains("invalid input"));
62    }
63
64    #[test]
65    fn submodules_are_publicly_accessible() {
66        // Compile-time check: each module path resolves through the crate root.
67        let _: db::__DbProbe = ();
68        let _: error::__ErrorProbe = ();
69        let _: reader::__ReaderProbe = ();
70        let _: writer::__WriterProbe = ();
71        // The above consts are injected by the macros below for compile checks.
72        // If this test compiles, the module surface is exposed.
73    }
74
75    // Each submodule declares a `pub const __Probe: () = ();` only under cfg(test)
76    // so we can reference them generically above. Implemented inline below.
77    mod db {
78        #[cfg(test)]
79        pub type __DbProbe = ();
80    }
81    mod error {
82        #[cfg(test)]
83        pub type __ErrorProbe = ();
84    }
85    mod reader {
86        #[cfg(test)]
87        pub type __ReaderProbe = ();
88    }
89    mod writer {
90        #[cfg(test)]
91        pub type __WriterProbe = ();
92    }
93}
luft_storage/lib.rs

luft_storage/
lib.rs
