Player

pub struct Selected {
    pub stream: Stream,
    pub stream_request: Option<ResourceRequest>,
    pub meta_request: Option<ResourceRequest>,
    pub subtitles_path: Option<ResourcePath>,
}

pub struct VideoParams {
    pub hash: Option<String>,
    pub size: Option<u64>,
    pub filename: Option<String>,
}

pub struct AnalyticsContext {
    pub id: Option<String>,
    pub r#type: Option<String>,
    pub name: Option<String>,
    pub video_id: Option<String>,
    pub time: Option<u64>,
    pub duration: Option<u64>,
    pub device_type: Option<String>,
    pub device_name: Option<String>,
    pub player_duration: Option<u64>,
    pub player_video_width: u64,
    pub player_video_height: u64,
    pub has_trakt: bool,
}

fn push_to_library<E: Env + 'static>(
    push_library_item_time: &mut DateTime<Utc>,
    library_item: &mut LibraryItem,
) -> Effects {
    if E::now() - *push_library_item_time >= *PUSH_TO_LIBRARY_EVERY {
        *push_library_item_time = E::now();
        Effects::msg(Msg::Internal(Internal::UpdateLibraryItem(
            library_item.to_owned(),
        )))
        .unchanged()
    } else {
        Effects::none().unchanged()
    }
}

use stremio_core::models::player::{Player, Selected};
use stremio_core::types::resource::Stream;
use stremio_core::runtime::UpdateWithCtx;

let mut player = Player::default();

// Load a stream
let selected = Selected {
    stream: stream,  // Stream from catalog
    stream_request: Some(stream_request),
    meta_request: Some(meta_request),
    subtitles_path: Some(subtitles_path),
};

let effects = player.update(
    &Msg::Action(Action::Load(ActionLoad::Player(Box::new(selected)))),
    &ctx
);

// Time changed (called periodically, e.g., every second)
let effects = player.update(
    &Msg::Action(Action::Player(ActionPlayer::TimeChanged {
        time: 125000,      // 125 seconds
        duration: 3600000, // 1 hour
        device: "web".to_string(),
    })),
    &ctx
);

// User seeks
let effects = player.update(
    &Msg::Action(Action::Player(ActionPlayer::Seek {
        time: 300000,  // 5 minutes
        duration: 3600000,
        device: "web".to_string(),
    })),
    &ctx
);

// Pause/resume
let effects = player.update(
    &Msg::Action(Action::Player(ActionPlayer::PausedChanged {
        paused: true,
    })),
    &ctx
);

// Set video params for subtitles and skip gaps
let effects = player.update(
    &Msg::Action(Action::Player(ActionPlayer::VideoParamsChanged {
        video_params: Some(VideoParams {
            hash: Some("0123456789abcdef".to_string()),
            size: Some(1_500_000_000),
            filename: Some("Video.mkv".to_string()),
        }),
    })),
    &ctx
);

// Play next episode
let effects = player.update(
    &Msg::Action(Action::Player(ActionPlayer::NextVideo)),
    &ctx
);

// Check if next video is available
if player.next_video.is_some() {
    println!("Next video: {:?}", player.next_video);
    if let Some(stream) = &player.next_stream {
        println!("Recommended stream: {:?}", stream);
    }
}