Struct ProcessedFileRepository 

pub struct ProcessedFileRepository<'a> {
    pub pool: &'a SqlitePool,
}

Repository for processed file operations (inbox deduplication)

Fields

pool: &'a SqlitePool

Implementations

impl<'a> ProcessedFileRepository<'a>

pub fn new(pool: &'a SqlitePool) -> Self

pub async fn is_processed(&self, namespace_id: i64, path: &str) -> Result<bool>

Check if a file has been successfully processed

pub async fn get_completed_paths( &self, namespace_id: i64, ) -> Result<HashSet<String>>

Get all completed file paths for a namespace (for batch dedup checks)

pub async fn mark_processing( &self, namespace_id: i64, path: &str, content_hash: Option<&str>, ) -> Result<i64>

Mark a file as being processed

pub async fn mark_processed(&self, id: i64, memory_id: i64) -> Result<()>

Mark a file as successfully processed with memory reference

pub async fn mark_failed(&self, id: i64, error: &str) -> Result<()>

Mark a file as failed

pub async fn get_pending( &self, namespace_id: i64, limit: i32, ) -> Result<Vec<ProcessedFileRow>>

Get files pending processing

pub async fn clear_namespace(&self, namespace_id: i64) -> Result<u64>

Clear all processed files for a namespace