change things

1 files changed, 65 insertions, 32 deletions

diff --git a/stream/src/webvtt.rs b/stream/src/webvtt.rs
index f78ac2f..fbd6382 100644
--- a/stream/src/webvtt.rs
+++ b/stream/src/webvtt.rs
@@ -25,39 +25,72 @@ pub async fn vtt_stream(
 
     // TODO should use fragments too? big films take too long...
 
-    let tracki = *spec.track.first().ok_or(anyhow!("no track selected"))?;
-    let local_track = local_tracks.first().ok_or(anyhow!("no tracks"))?.clone();
-    let track = &node.media.as_ref().unwrap().tracks[tracki];
-    let cp = local_track.codec_private.clone();
+    // let tracki = *spec.track.first().ok_or(anyhow!("no track selected"))?;
+    // let local_track = local_tracks.first().ok_or(anyhow!("no tracks"))?.clone();
+    // let track = &node.media.as_ref().unwrap().tracks[tracki];
+    // let cp = local_track.codec_private.clone();
 
-    let subtitles = async_cache_memory(
-        &[
-            "vtt",
-            &format!(
-                "{} {}",
-                local_track.path.to_str().unwrap(),
-                local_track.track
-            ),
-        ],
-        move || async move {
-            let blocks = tokio::task::spawn_blocking(move || {
-                extract_track(CONF.media_path.clone(), local_track)
-            })
-            .await??;
-            let subtitles = parse_subtitles(&track.codec, cp, blocks)?;
-            Ok(subtitles)
-        },
-    )
-    .await?;
+    // let subtitles = async_cache_memory(
+    //     &[
+    //         "vtt",
+    //         &format!(
+    //             "{} {}",
+    //             local_track.path.to_str().unwrap(),
+    //             local_track.track
+    //         ),
+    //     ],
+    //     move || async move {
+    //         let blocks = tokio::task::spawn_blocking(move || {
+    //             extract_track(CONF.media_path.clone(), local_track)
+    //         })
+    //         .await??;
+    //         let subtitles = parse_subtitles(&track.codec, cp, blocks)?;
+    //         Ok(subtitles)
+    //     },
+    // )spec.track.first().ok_or(anyhow!("no track selected"))?;
+    // let local_track = local_tracks.first().ok_or(anyhow!("no tracks"))?.clone();
+    // let track = &node.media.as_ref().unwrap().tracks[tracki];
+    // let cp = local_track.codec_private.clone();
 
-    let output = if json {
-        serde_json::to_string(subtitles.as_ref())?
-    } else {
-        write_webvtt(node.title.clone().unwrap_or_default(), subtitles.as_ref())
-            .context("writing webvtt")?
-    };
-    tokio::task::spawn(async move {
-        let _ = b.write_all(output.as_bytes()).await;
-    });
+    // let subtitles = async_cache_memory(
+    //     &[
+    //         "vtt",
+    //         &format!(
+    //             "{} {}",
+    //             local_track.path.to_str().unwrap(),
+    //             local_track.track
+    //         ),
+    //     ],
+    //     move || async move {
+    //         let blocks = tokio::task::spawn_blocking(move || {
+    //             extract_track(CONF.media_path.clone(), local_track)
+    //         })
+    //         .await??;
+    //         let subtitles = parse_subtitles(&track.codec, cp, blocks)?;
+    //         Ok(subtitles)
+    //     },
+    // )
+    // .await?;
+
+    // let output = if json {
+    //     serde_json::to_string(subtitles.as_ref())?
+    // } else {
+    //     write_webvtt(node.title.clone().unwrap_or_default(), subtitles.as_ref())
+    //         .context("writing webvtt")?
+    // };
+    // tokio::task::spawn(async move {
+    //     let _ = b.write_all(output.as_bytes()).await;
+    // });
+    // .await?;
+
+    // let output = if json {
+    //     serde_json::to_string(subtitles.as_ref())?
+    // } else {
+    //     write_webvtt(node.title.clone().unwrap_or_default(), subtitles.as_ref())
+    //         .context("writing webvtt")?
+    // };
+    // tokio::task::spawn(async move {
+    //     let _ = b.write_all(output.as_bytes()).await;
+    // });
     Ok(())
 }