Struct SessionWatcher 

pub struct SessionWatcher { /* private fields */ }

Watches for session file changes and imports new messages.

Tracks the byte position in each file to enable incremental reading, avoiding the need to re-parse entire files on each modification.

Implementations

impl SessionWatcher

pub fn new() -> Result<Self>

Creates a new SessionWatcher.

Uses the default watcher registry to determine which directories to watch for session files.

Errors

Returns an error if the database configuration cannot be created.

pub fn watch_dirs(&self) -> &[PathBuf]

Returns the directories being watched.

This method is part of the public API for status reporting and may be used by CLI commands in the future.

pub async fn watch( &mut self, stats: Arc<RwLock<DaemonStats>>, shutdown_rx: Receiver<()>, ) -> Result<()>

Starts watching for file changes and processing them.

This function runs until the shutdown signal is received.

Arguments

• stats - Shared statistics to update on imports
• shutdown_rx - Receiver that signals when to stop watching

Errors

Returns an error if the watcher cannot be created or started.

pub fn tracked_file_count(&self) -> usize

Returns the number of files currently being tracked.

This method is part of the public API for status reporting and is used by tests.