use anyhow::{anyhow, bail, Result}; use jellymatroska::{block::Block, read::EbmlReader, unflatten::IterWithPos, MatroskaTag}; use log::{debug, trace}; // pub struct AbsoluteBlock { // pub pts_base: u64, // pub inner: Block, // } // impl AbsoluteBlock { // pub fn pts(&self) -> u64 { // self.inner.timestamp_off as u64 + self.pts_base // } // } pub struct SegmentExtractIter<'a> { segment: &'a mut EbmlReader, extract: u64, } impl<'a> SegmentExtractIter<'a> { pub fn new(segment: &'a mut EbmlReader, extract: u64) -> Self { Self { segment, extract } } pub fn next(&mut self) -> Result { loop { let item = self.segment.next().ok_or(anyhow!("eof"))??; match item { MatroskaTag::Void(_) => (), MatroskaTag::Crc32(_) => (), MatroskaTag::Cluster(_) => (), MatroskaTag::Timestamp(_) => (), MatroskaTag::SimpleBlock(buf) | MatroskaTag::Block(buf) => { let block = Block::parse(&buf)?; if block.track == self.extract { trace!("block: track={} tso={}", block.track, block.timestamp_off); return Ok(block); } } MatroskaTag::Cues(_) => bail!("reached cues, this is the end"), _ => debug!("(rs) tag ignored: {item:?}"), } } } }