start media processing refactor

1 files changed, 38 insertions, 0 deletions

diff --git a/remuxer/src/bin/average_cluster_duration.rs b/remuxer/src/bin/average_cluster_duration.rs
new file mode 100644
index 0000000..69bb79c
--- /dev/null
+++ b/remuxer/src/bin/average_cluster_duration.rs
@@ -0,0 +1,38 @@
+/*
+    This file is part of jellything (https://codeberg.org/metamuffin/jellything)
+    which is licensed under the GNU Affero General Public License (version 3); see /COPYING.
+    Copyright (C) 2025 metamuffin <metamuffin.org>
+*/
+
+use anyhow::{Result, anyhow};
+use jellyremuxer::demuxers::{Demuxer, DemuxerNew, matroska::MatroskaDemuxer};
+use std::{env::args, fs::File};
+
+fn main() -> Result<()> {
+    env_logger::init_from_env("LOG");
+    let path = args().nth(1).ok_or(anyhow!("first arg is input path"))?;
+    let file = File::open(path)?;
+    let mut reader = MatroskaDemuxer::new(Box::new(file));
+
+    let info = reader.info()?;
+
+    reader.seek_cluster(None)?;
+    let mut num_clusters = 0;
+    let mut last_ts = 0;
+    let mut total_size = 0;
+    while let Some((_, cluster)) = reader.read_cluster()? {
+        last_ts = cluster.timestamp * info.timestamp_scale;
+        num_clusters += 1;
+        total_size += cluster
+            .simple_blocks
+            .iter()
+            .map(|b| b.data.len())
+            .sum::<usize>() as u64
+    }
+
+    let average_duration = (last_ts / num_clusters) as f64 / 1_000_000_000.;
+    let average_size = (total_size / num_clusters) as f64 / 1_000_000.;
+    println!("{average_duration:>6.02}s {average_size:>6.02}MB");
+
+    Ok(())
+}