Struct PlaybackReporter 

pub struct PlaybackReporter {
    db_service: Arc<RusqliteService>,
    jellyfin_client: Arc<Mutex<Option<JellyfinClient>>>,
    user_id: String,
}

Main playback reporter that handles dual sync (local DB + server)

Fields

db_service: Arc<RusqliteService>

jellyfin_client: Arc<Mutex<Option<JellyfinClient>>>

user_id: String

Implementations

impl PlaybackReporter

pub fn new( db_service: Arc<RusqliteService>, jellyfin_client: Arc<TokioMutex<Option<JellyfinClient>>>, user_id: String, ) -> Self

Creates a new PlaybackReporter

pub async fn report( &self, operation: PlaybackOperation, is_online: bool, ) -> Result<(), String>

Reports a playback operation (dual sync: local DB + server)

Always updates local DB first, then attempts server sync if online. If server sync fails, operation is queued for retry.

async fn update_local_db( &self, operation: &PlaybackOperation, ) -> Result<(), String>

Updates local database with playback info

async fn sync_to_server( &self, operation: &PlaybackOperation, ) -> Result<(), String>

Syncs to Jellyfin server

async fn queue_for_sync( &self, operation: &PlaybackOperation, ) -> Result<(), String>

Queues operation for later sync

async fn mark_synced(&self, item_id: &str) -> Result<(), String>

Marks an item as synced in the local database

fn get_item_id(&self, operation: &PlaybackOperation) -> Option<String>

Extracts item_id from operation

Trait Implementations

impl Clone for PlaybackReporter

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.