Struct IndexDb 

pub struct IndexDb { /* private fields */ }

SQLite-backed symbol and import index for a single project.

Implementations

impl IndexDb

pub fn get_fresh_file_by_mtime( &self, relative_path: &str, mtime_ms: i64, ) -> Result<Option<FileRow>>

Fast mtime-only freshness check. Avoids content hashing entirely.

pub fn get_fresh_file( &self, relative_path: &str, mtime_ms: i64, content_hash: &str, ) -> Result<Option<FileRow>>

Returns the file row if it exists and is fresh (same mtime and hash).

pub fn get_file(&self, relative_path: &str) -> Result<Option<FileRow>>

Returns the file row by path (regardless of freshness).

pub fn upsert_file( &self, relative_path: &str, mtime_ms: i64, content_hash: &str, size_bytes: i64, language: Option<&str>, ) -> Result<i64>

Upsert a file record. Returns the file id. Deletes old symbols/imports on update.

pub fn delete_file(&self, relative_path: &str) -> Result<()>

Delete a file and its associated symbols/imports.

pub fn file_count(&self) -> Result<usize>

Count indexed files.

pub fn all_file_paths(&self) -> Result<Vec<String>>

Return all indexed file paths.

pub fn files_with_symbol_kinds(&self, kinds: &[&str]) -> Result<Vec<String>>

Return file paths containing symbols of given kinds.

pub fn dir_stats(&self) -> Result<Vec<DirStats>>

pub fn insert_symbols( &self, file_id: i64, symbols: &[NewSymbol<'_>], ) -> Result<Vec<i64>>

Bulk insert symbols for a file. Returns the inserted symbol ids.

pub fn find_symbols_by_name( &self, name: &str, file_path: Option<&str>, exact: bool, max_results: usize, ) -> Result<Vec<SymbolRow>>

Query symbols by name (exact or substring match).

pub fn find_symbols_with_path( &self, name: &str, exact: bool, max_results: usize, ) -> Result<Vec<(SymbolRow, String)>>

Query symbols by name with file path resolved via JOIN (no N+1). Returns (SymbolRow, file_path) tuples.

pub fn get_file_symbols(&self, file_id: i64) -> Result<Vec<SymbolRow>>

Get all symbols for a file, ordered by start_byte.

pub fn search_symbols_fts( &self, query: &str, max_results: usize, ) -> Result<Vec<(SymbolRow, String, f64)>>

Full-text search symbols via FTS5 index. Returns (SymbolRow, file_path, rank). Falls back to LIKE search if FTS5 table doesn’t exist (pre-v4 DB).

pub fn get_symbols_for_directory( &self, prefix: &str, ) -> Result<Vec<(String, Vec<SymbolRow>)>>

Get all symbols for files under a directory prefix in a single JOIN query. Returns (file_path, Vec) grouped by file. Eliminates N+1 queries.

pub fn all_symbol_names( &self, ) -> Result<Vec<(String, String, String, i64, String, String)>>

Return all symbols as (name, kind, file_path, line, signature, name_path).

pub fn all_symbols_with_bytes(&self) -> Result<Vec<SymbolWithFile>>

Get all symbols with byte offsets and file paths, ordered by file for batch processing.

pub fn for_each_symbol_with_bytes<F>(&self, callback: F) -> Result<usize>

where F: FnMut(SymbolWithFile) -> Result<()>,

Stream all symbols with bytes via callback — avoids loading entire Vec into memory. Symbols are ordered by file_path then start_byte (same as all_symbols_with_bytes).

pub fn for_each_file_symbols_with_bytes<F>(&self, callback: F) -> Result<usize>

where F: FnMut(String, Vec<SymbolWithFile>) -> Result<()>,

Stream symbols grouped by file path via callback — avoids loading the entire symbol table into memory and gives deterministic file-wise order.

pub fn symbols_for_files( &self, file_paths: &[&str], ) -> Result<Vec<SymbolWithFile>>

Get symbols with bytes for specific files only (for incremental embedding).

pub fn get_file_path(&self, file_id: i64) -> Result<Option<String>>

Get file path for a file_id.

pub fn insert_imports(&self, file_id: i64, imports: &[NewImport]) -> Result<()>

Bulk insert imports for a file.

pub fn get_importers(&self, target_path: &str) -> Result<Vec<String>>

Get files that import the given file path (reverse dependencies).

pub fn get_imports_of(&self, relative_path: &str) -> Result<Vec<String>>

Get files that the given file imports (forward dependencies).

pub fn build_import_graph( &self, ) -> Result<HashMap<String, (Vec<String>, Vec<String>)>>

Build the full import graph from the database.

pub fn insert_calls(&self, file_id: i64, calls: &[NewCall]) -> Result<()>

Bulk insert call edges for a file (clears old edges first).

pub fn get_callers_cached( &self, callee_name: &str, max_results: usize, ) -> Result<Vec<(String, String, i64)>>

Find all callers of a function name (from DB cache).

pub fn get_callees_cached( &self, caller_name: &str, file_path: Option<&str>, max_results: usize, ) -> Result<Vec<(String, i64)>>

Find all callees of a function name (from DB cache).

pub fn has_call_data(&self) -> Result<bool>

Check if calls table has any data.

pub fn record_index_failure( &self, file_path: &str, error_type: &str, error_message: &str, ) -> Result<()>

Record an indexing failure for a file. Updates retry_count on conflict.

pub fn clear_index_failure(&self, file_path: &str) -> Result<()>

Clear a failure record when a file is successfully indexed.

pub fn invalidate_fts(&self) -> Result<()>

Invalidate FTS index cache so next search triggers a lazy rebuild.

pub fn index_failure_count(&self) -> Result<usize>

Get the number of files with indexing failures.

pub fn prune_missing_index_failures(&self, project_root: &Path) -> Result<usize>

Remove failure records for files that no longer exist on disk.

pub fn index_failure_summary( &self, recent_window_secs: i64, ) -> Result<IndexFailureSummary>

Summarize unresolved index failures by recency and persistence.

pub fn get_persistent_failures( &self, min_retries: i64, ) -> Result<Vec<(String, String, i64)>>

Get files that have failed more than min_retries times.

impl IndexDb

pub fn open(db_path: &Path) -> Result<Self>

Open or create the index database at the given path.

pub fn open_readonly(db_path: &Path) -> Result<Option<Self>>

Open existing database in read-only mode (no migration, no WAL creation). Returns None if the DB file does not exist.

pub fn open_memory() -> Result<Self>

Open an in-memory database (for testing).

pub fn with_transaction<F, T>(&mut self, f: F) -> Result<T>

where F: FnMut(&Connection) -> Result<T>,

Execute a closure within an RAII transaction. Automatically rolls back on error or panic; commits only on success.