Struct SqliteFileIRRepository 

pub struct SqliteFileIRRepository { /* private fields */ }

SQLite-backed file IR repository.

Implementations

impl SqliteFileIRRepository

pub fn new(conn: Arc<Mutex<Connection>>) -> Self

Create a new repository backed by the given connection.

Trait Implementations

impl Clone for SqliteFileIRRepository

fn clone(&self) -> SqliteFileIRRepository

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SqliteFileIRRepository

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl FileIRRepository for SqliteFileIRRepository

fn upsert( &self, branch_id: &BranchId, file: &ProjectFile, last_commit_date: Option<i64>, ) -> Result<(), StorageError>

Insert or update a file IR record. Uses (branch_id, file_path) as the natural key — if a row already exists, it is replaced.

fn upsert_with_symbol_index( &self, branch_id: &BranchId, file: &ProjectFile, last_commit_date: Option<i64>, ) -> Result<(), StorageError>

Insert or update a file IR record and replace the matching symbol_definitions / symbol_imports rows in a single transaction.

fn get_by_path( &self, branch_id: &BranchId, file_path: &str, ) -> Result<ProjectFile, StorageError>

Get the IR for a file by its path within a branch.

fn get_by_branch( &self, branch_id: &BranchId, ) -> Result<Vec<ProjectFile>, StorageError>

Get all file IR records for the given branch.

fn get_file_hashes_by_branch( &self, branch_id: &BranchId, ) -> Result<HashMap<String, String>, StorageError>

Get all (file_path, content_hash) pairs for a branch.

fn delete_by_path( &self, branch_id: &BranchId, file_path: &str, ) -> Result<(), StorageError>

Delete the IR record for a file path within a branch.

fn delete_with_symbol_index( &self, branch_id: &BranchId, file_path: &str, ) -> Result<(), StorageError>

Delete the files_ir row and every matching symbol_definitions / symbol_imports row for (branch_id, file_path) in a single transaction. Pairs with Self::upsert_with_symbol_index so the watcher / scanner have one atomic write path for both add/modify and delete — readers cannot observe files_ir gone while symbol-index rows linger (or vice versa).

fn check_content_hash( &self, branch_id: &BranchId, file_path: &str, content_hash: &str, ) -> Result<bool, StorageError>

Check whether the stored content hash matches the given hash. Returns true if a record exists and the hash matches, false otherwise.

fn get_file_dates_by_branch( &self, branch_id: &BranchId, ) -> Result<HashMap<String, Option<i64>>, StorageError>

Get all (file_path, last_commit_date) pairs for a branch.

fn update_convention_compliance_counts( &self, branch_id: &BranchId, counts: &HashMap<String, u32>, ) -> Result<(), StorageError>

Update convention_compliance_count for multiple files in a single transaction.