webm and mpeg4 fragments semi fixedrewrite-stream

1 files changed, 11 insertions, 3 deletions

diff --git a/stream/src/fragment.rs b/stream/src/fragment.rs
index 2ce3c78..dfe101e 100644
--- a/stream/src/fragment.rs
+++ b/stream/src/fragment.rs
@@ -6,7 +6,7 @@
 use crate::{stream_info, SMediaInfo};
 use anyhow::{anyhow, bail, Result};
 use jellybase::common::stream::StreamContainer;
-use jellyremuxer::matroska_to_mpeg4;
+use jellyremuxer::{matroska_to_mpeg4, matroska_to_webm::matroska_to_webm};
 use jellytranscoder::fragment::transcode;
 use log::warn;
 use std::sync::Arc;
@@ -72,10 +72,18 @@ pub async fn fragment_stream(
             },
         )
         .await?;
-        eprintln!("{:?}", location.abs());
+
         let mut frag = File::open(location.abs()).await?;
         match container {
-            StreamContainer::WebM => {}
+            StreamContainer::WebM => {
+                tokio::task::spawn_blocking(move || {
+                    if let Err(err) =
+                        matroska_to_webm(SyncIoBridge::new(frag), SyncIoBridge::new(b))
+                    {
+                        warn!("webm transmux failed: {err}");
+                    }
+                });
+            }
             StreamContainer::Matroska => {
                 tokio::task::spawn(async move {
                     if let Err(err) = tokio::io::copy(&mut frag, &mut b).await {