lavalink_rs/player_context/
mod.rs

mod context;
mod inner;

use crate::model::*;

use std::collections::VecDeque;

pub use context::PlayerContext;
pub use context::QueueRef;
pub(crate) use inner::PlayerContextInner;

#[derive(PartialEq, Debug, Clone, Default)]
#[cfg_attr(feature = "python", pyo3::pyclass)]
/// A track that's inside the queue.
pub struct TrackInQueue {
    /// The track itself.
    pub track: track::TrackData,
    /// The time the track should start at.
    pub start_time: Option<std::time::Duration>,
    /// The time the track should end at.
    pub end_time: Option<std::time::Duration>,
    /// The volume the track should start at.
    pub volume: Option<u16>,
    /// The filters the track should start at.
    pub filters: Option<player::Filters>,
}

pub(crate) enum PlayerMessage {
    GetPlayer(oneshot::Sender<player::Player>),
    UpdatePlayer(player::Player),
    UpdatePlayerTrack(Option<track::TrackData>),
    UpdatePlayerState(player::State),

    QueueMessage(QueueMessage),

    TrackFinished(bool),
    StartTrack,
    Close,
}

#[derive(Debug)]
pub enum QueueMessage {
    /// Clone the entire queue and return it.
    GetQueue(oneshot::Sender<VecDeque<TrackInQueue>>),
    /// Get the track at a specific index.
    GetTrack(usize, oneshot::Sender<Option<TrackInQueue>>),
    /// Get the length of the queue
    GetCount(oneshot::Sender<usize>),
    /// Add a track to the end of the queue.
    PushToBack(TrackInQueue),
    /// Add a track to the start of the queue.
    PushToFront(TrackInQueue),
    /// Insert a track to a specific position in the queue.
    Insert(usize, TrackInQueue),
    /// Remove a track from the queue.
    Remove(usize),
    /// Clear the queue.
    Clear,
    /// Replace the entire queue with another one.
    Replace(VecDeque<TrackInQueue>),
    /// Append a queue to the end of the current one.
    Append(VecDeque<TrackInQueue>),
    /// Swap the track at the index with the new track.
    Swap(usize, TrackInQueue),
}

impl TrackInQueue {
    fn into_update_player(self) -> http::UpdatePlayer {
        http::UpdatePlayer {
            track: Some(http::UpdatePlayerTrack {
                encoded: self.track.encoded.into(),
                user_data: self.track.user_data,
                ..Default::default()
            }),
            position: self.start_time.map(|x| x.as_millis() as u64),
            end_time: self.end_time.map(|x| x.as_millis() as u64),
            volume: self.volume,
            filters: self.filters,
            ..Default::default()
        }
    }
}

impl From<track::TrackData> for TrackInQueue {
    fn from(track: track::TrackData) -> Self {
        Self {
            track,
            ..Default::default()
        }
    }
}
lavalink_rs/player_context/mod.rs

lavalink_rs/player_context/
mod.rs
