Struct Database 

pub struct Database { /* private fields */ }

Database handle for queue and history persistence.

Implementations

impl Database

pub fn open(path: &Path) -> Result<Self, NzbError>

Open (or create) the database at the given path.

pub fn open_memory() -> Result<Self, NzbError>

Open an in-memory database (for testing).

pub fn get_setting(&self, key: &str) -> Option<String>

Read a setting by key.

pub fn set_setting(&self, key: &str, value: &str)

Write a setting (upsert).

pub fn queue_insert(&self, job: &NzbJob) -> Result<(), NzbError>

Insert a new job into the queue.

pub fn queue_update_progress( &self, id: &str, status: JobStatus, downloaded_bytes: u64, articles_downloaded: usize, articles_failed: usize, files_completed: usize, ) -> Result<(), NzbError>

Update job progress in the queue.

pub fn queue_update_priority( &self, id: &str, priority: i32, ) -> Result<(), NzbError>

Update job priority in the queue.

pub fn queue_remove(&self, id: &str) -> Result<(), NzbError>

Remove a job from the queue.

pub fn queue_list(&self) -> Result<Vec<NzbJob>, NzbError>

List all jobs in the queue, ordered by priority then add time.

pub fn history_insert(&self, entry: &HistoryEntry) -> Result<(), NzbError>

Move a completed/failed job to history.

pub fn history_list(&self, limit: usize) -> Result<Vec<HistoryEntry>, NzbError>

List history entries, most recent first.

pub fn history_get_nzb_data( &self, id: &str, ) -> Result<Option<Vec<u8>>, NzbError>

Get the raw NZB data for a history entry (for retry).

pub fn history_enforce_retention( &self, max_entries: usize, ) -> Result<(), NzbError>

Enforce history retention limit by deleting oldest entries.

pub fn history_get(&self, id: &str) -> Result<Option<HistoryEntry>, NzbError>

Get a single history entry by ID.

pub fn queue_store_job_data( &self, id: &str, data: &[u8], ) -> Result<(), NzbError>

Store serialized job file/article state for resume support.

pub fn queue_load_job_data(&self, id: &str) -> Result<Option<Vec<u8>>, NzbError>

Load serialized job file/article state for resume.

pub fn queue_store_nzb_data( &self, id: &str, nzb_data: &[u8], ) -> Result<(), NzbError>

Store raw NZB data for a queue job.

pub fn queue_get_nzb_data(&self, id: &str) -> Result<Option<Vec<u8>>, NzbError>

Get raw NZB data from a queue job.

pub fn history_count(&self) -> Result<usize, NzbError>

Count history entries.

pub fn history_remove(&self, id: &str) -> Result<(), NzbError>

Remove a history entry.

pub fn history_clear(&self) -> Result<(), NzbError>

Clear all history.

pub fn history_store_logs( &self, id: &str, logs_json: &str, ) -> Result<(), NzbError>

Store per-job logs for a history entry.

pub fn history_get_logs(&self, id: &str) -> Result<Option<String>, NzbError>

Get per-job logs for a history entry.

pub fn rss_item_upsert(&self, item: &RssItem) -> Result<(), NzbError>

Upsert an RSS feed item (insert or ignore if already exists).

pub fn rss_items_batch_upsert( &self, items: &[RssItem], ) -> Result<usize, NzbError>

Batch upsert RSS feed items in a single transaction. Returns the number of newly inserted items.

pub fn rss_item_exists(&self, id: &str) -> Result<bool, NzbError>

Check if an RSS item ID already exists in the database.

pub fn rss_items_list( &self, feed_name: Option<&str>, limit: usize, ) -> Result<Vec<RssItem>, NzbError>

List RSS items, optionally filtered by feed name, ordered by first_seen_at DESC.

pub fn rss_item_get(&self, id: &str) -> Result<Option<RssItem>, NzbError>

Get a single RSS item by ID.

pub fn rss_item_mark_downloaded( &self, id: &str, category: Option<&str>, ) -> Result<(), NzbError>

Mark an RSS item as downloaded.

pub fn rss_item_count(&self) -> Result<usize, NzbError>

Count total RSS items.

pub fn rss_items_prune(&self, keep: usize) -> Result<usize, NzbError>

Prune RSS items to keep only the N most recent (by first_seen_at).

pub fn rss_rule_insert(&self, rule: &RssRule) -> Result<(), NzbError>

Insert a new RSS download rule. feed_names is stored as comma-separated string in the DB.

pub fn rss_rule_list(&self) -> Result<Vec<RssRule>, NzbError>

List all RSS download rules.

pub fn rss_rule_update(&self, rule: &RssRule) -> Result<(), NzbError>

Update an RSS download rule.

pub fn rss_rule_delete(&self, id: &str) -> Result<(), NzbError>

Delete an RSS download rule.