gstreamer-rs/gstreamer-play/src/play_message.rs

104 lines
4.4 KiB
Rust

use crate::{PlayMediaInfo, PlayMessageType, PlayState};
#[derive(Clone, PartialEq, Debug)]
#[non_exhaustive]
#[doc(alias = "GstPlayMessage")]
pub enum PlayMessage {
#[doc(alias = "GST_PLAY_MESSAGE_URI_LOADED")]
UriLoaded,
#[doc(alias = "GST_PLAY_MESSAGE_POSITION_UPDATED")]
PositionUpdated { position: Option<gst::ClockTime> },
#[doc(alias = "GST_PLAY_MESSAGE_DURATION_CHANGED")]
DurationChanged { duration: Option<gst::ClockTime> },
#[doc(alias = "GST_PLAY_MESSAGE_STATE_CHANGED")]
StateChanged { state: PlayState },
#[doc(alias = "GST_PLAY_MESSAGE_BUFFERING")]
Buffering { percent: u32 },
#[doc(alias = "GST_PLAY_MESSAGE_END_OF_STREAM")]
EndOfStream,
#[doc(alias = "GST_PLAY_MESSAGE_ERROR")]
Error {
error: glib::Error,
details: Option<gst::Structure>,
},
#[doc(alias = "GST_PLAY_MESSAGE_WARNING")]
Warning {
error: glib::Error,
details: Option<gst::Structure>,
},
#[doc(alias = "GST_PLAY_MESSAGE_VIDEO_DIMENSIONS_CHANGED")]
VideoDimensionsChanged { width: u32, height: u32 },
#[doc(alias = "GST_PLAY_MESSAGE_MEDIA_INFO_UPDATED")]
MediaInfoUpdated { info: PlayMediaInfo },
#[doc(alias = "GST_PLAY_MESSAGE_VOLUME_CHANGED")]
VolumeChanged { volume: f64 },
#[doc(alias = "GST_PLAY_MESSAGE_MUTE_CHANGED")]
MuteChanged { muted: bool },
#[doc(alias = "GST_PLAY_MESSAGE_SEEK_DONE")]
SeekDone,
}
impl PlayMessage {
#[doc(alias = "gst_play_message_parse_position_updated")]
#[doc(alias = "gst_play_message_parse_duration_updated")]
#[doc(alias = "gst_play_message_parse_state_changed")]
#[doc(alias = "gst_play_message_parse_buffering_percent")]
#[doc(alias = "gst_play_message_parse_error")]
#[doc(alias = "gst_play_message_parse_warning")]
#[doc(alias = "gst_play_message_parse_video_dimensions_changed")]
#[doc(alias = "gst_play_message_parse_media_info_updated")]
#[doc(alias = "gst_play_message_parse_muted_changed")]
#[doc(alias = "gst_play_message_parse_volume_changed")]
pub fn parse(msg: &gst::Message) -> Result<Self, glib::error::BoolError> {
skip_assert_initialized!();
if msg.type_() != gst::MessageType::Application {
return Err(glib::bool_error!("Invalid play message"));
}
match PlayMessageType::parse_type(msg) {
PlayMessageType::UriLoaded => Ok(Self::UriLoaded),
PlayMessageType::PositionUpdated => {
let position = PlayMessageType::parse_position_updated(msg);
Ok(Self::PositionUpdated { position })
}
PlayMessageType::DurationChanged => {
let duration = PlayMessageType::parse_duration_updated(msg);
Ok(Self::DurationChanged { duration })
}
PlayMessageType::StateChanged => {
let state = PlayMessageType::parse_state_changed(msg);
Ok(Self::StateChanged { state })
}
PlayMessageType::Buffering => {
let percent = PlayMessageType::parse_buffering_percent(msg);
Ok(Self::Buffering { percent })
}
PlayMessageType::EndOfStream => Ok(Self::EndOfStream),
PlayMessageType::Error => {
let (error, details) = PlayMessageType::parse_error(msg);
Ok(Self::Error { error, details })
}
PlayMessageType::Warning => {
let (error, details) = PlayMessageType::parse_warning(msg);
Ok(Self::Warning { error, details })
}
PlayMessageType::VideoDimensionsChanged => {
let (width, height) = PlayMessageType::parse_video_dimensions_changed(msg);
Ok(Self::VideoDimensionsChanged { width, height })
}
PlayMessageType::MediaInfoUpdated => {
let info = PlayMessageType::parse_media_info_updated(msg);
Ok(Self::MediaInfoUpdated { info })
}
PlayMessageType::VolumeChanged => {
let volume = PlayMessageType::parse_volume_changed(msg);
Ok(Self::VolumeChanged { volume })
}
PlayMessageType::MuteChanged => {
let muted = PlayMessageType::parse_muted_changed(msg);
Ok(Self::MuteChanged { muted })
}
PlayMessageType::SeekDone => Ok(Self::SeekDone),
_ => Err(glib::bool_error!("Invalid play message")),
}
}
}