Struct SyncProcessor 

pub struct SyncProcessor {
    _db_service: Arc<RusqliteService>,
    _jellyfin_client: Arc<Mutex<Option<JellyfinClient>>>,
    _repository: Arc<dyn MediaRepository>,
    _processing: Arc<Mutex<bool>>,
    _cancelled: Arc<AtomicBool>,
    _config: SyncConfig,
}

Sync queue processor that handles retry logic with exponential backoff

This is a placeholder implementation. Full implementation will be added in a subsequent task following the plan.

Fields

_db_service: Arc<RusqliteService>

_jellyfin_client: Arc<Mutex<Option<JellyfinClient>>>

_repository: Arc<dyn MediaRepository>

_processing: Arc<Mutex<bool>>

_cancelled: Arc<AtomicBool>

_config: SyncConfig

Implementations

impl SyncProcessor

pub fn new( db_service: Arc<RusqliteService>, jellyfin_client: Arc<TokioMutex<Option<JellyfinClient>>>, repository: Arc<dyn MediaRepository>, ) -> Self

Creates a new SyncProcessor

pub async fn start(&self) -> Result<(), String>

Starts the sync processor

pub async fn stop(&self) -> Result<(), String>

Stops the sync processor

pub async fn process_queue(&self) -> Result<(), String>

Processes the sync queue once

fn _calculate_backoff(&self, retry_count: u32) -> Duration

Calculates exponential backoff delay