use crate::error::Result;
use crate::macros::decode_err;
use crate::ogg::find_last_page;
use crate::properties::FileProperties;
use std::io::{Read, Seek, SeekFrom};
use std::time::Duration;
use byteorder::{LittleEndian, ReadBytesExt};
use ogg_pager::{Packets, PageHeader};
#[derive(Debug, Copy, Clone, PartialEq, Eq, Default)]
#[non_exhaustive]
pub struct SpeexProperties {
pub(crate) duration: Duration,
pub(crate) version: u32,
pub(crate) sample_rate: u32,
pub(crate) mode: u32,
pub(crate) channels: u8,
pub(crate) vbr: bool,
pub(crate) overall_bitrate: u32,
pub(crate) audio_bitrate: u32,
pub(crate) nominal_bitrate: i32,
}
impl From<SpeexProperties> for FileProperties {
fn from(input: SpeexProperties) -> Self {
Self {
duration: input.duration,
overall_bitrate: Some(input.overall_bitrate),
audio_bitrate: Some(input.audio_bitrate),
sample_rate: Some(input.sample_rate),
bit_depth: None,
channels: Some(input.channels),
channel_mask: None,
}
}
}
impl SpeexProperties {
pub fn duration(&self) -> Duration {
self.duration
}
pub fn version(&self) -> u32 {
self.version
}
pub fn sample_rate(&self) -> u32 {
self.sample_rate
}
pub fn mode(&self) -> u32 {
self.mode
}
pub fn channels(&self) -> u8 {
self.channels
}
pub fn vbr(&self) -> bool {
self.vbr
}
pub fn overall_bitrate(&self) -> u32 {
self.overall_bitrate
}
pub fn audio_bitrate(&self) -> u32 {
self.audio_bitrate
}
pub fn nominal_bitrate(&self) -> i32 {
self.nominal_bitrate
}
}
pub(in crate::ogg) fn read_properties<R>(
data: &mut R,
first_page_header: &PageHeader,
packets: &Packets,
) -> Result<SpeexProperties>
where
R: Read + Seek,
{
let identification_packet = packets.get(0).unwrap();
if identification_packet.len() < 80 {
decode_err!(@BAIL Speex, "Header packet too small");
}
let mut properties = SpeexProperties::default();
let identification_packet_reader = &mut &identification_packet[28..];
properties.version = identification_packet_reader.read_u32::<LittleEndian>()?;
let _header_size = identification_packet_reader.read_u32::<LittleEndian>()?;
properties.sample_rate = identification_packet_reader.read_u32::<LittleEndian>()?;
properties.mode = identification_packet_reader.read_u32::<LittleEndian>()?;
let _mode_bitstream_version = identification_packet_reader.read_u32::<LittleEndian>()?;
let channels = identification_packet_reader.read_u32::<LittleEndian>()?;
if channels != 1 && channels != 2 {
decode_err!(@BAIL Speex, "Found invalid channel count, must be mono or stereo");
}
properties.channels = channels as u8;
properties.nominal_bitrate = identification_packet_reader.read_i32::<LittleEndian>()?;
let _frame_size = identification_packet_reader.read_u32::<LittleEndian>()?;
properties.vbr = identification_packet_reader.read_u32::<LittleEndian>()? == 1;
let last_page = find_last_page(data);
let file_length = data.seek(SeekFrom::End(0))?;
let mut length = 1000;
if let Ok(last_page) = last_page {
let first_page_abgp = first_page_header.abgp;
let last_page_abgp = last_page.header().abgp;
if properties.sample_rate > 0 {
let total_samples = last_page_abgp.saturating_sub(first_page_abgp);
if total_samples > 0 {
length = total_samples * 1000 / u64::from(properties.sample_rate);
properties.duration = Duration::from_millis(length);
} else {
log::debug!(
"Speex: The file contains invalid PCM values, unable to calculate length"
);
}
} else {
log::debug!("Speex: Sample rate = 0, unable to calculate length");
}
}
if properties.nominal_bitrate > 0 {
properties.overall_bitrate = (file_length.saturating_mul(8) / length) as u32;
properties.audio_bitrate = (properties.nominal_bitrate as u64 / 1000) as u32;
}
Ok(properties)
}