aboutsummaryrefslogtreecommitdiff
path: root/stream/src/jhls.rs
diff options
context:
space:
mode:
Diffstat (limited to 'stream/src/jhls.rs')
-rw-r--r--stream/src/jhls.rs34
1 files changed, 17 insertions, 17 deletions
diff --git a/stream/src/jhls.rs b/stream/src/jhls.rs
index b222e39..2a2faec 100644
--- a/stream/src/jhls.rs
+++ b/stream/src/jhls.rs
@@ -24,24 +24,24 @@ pub async fn jhls_index(
mut b: DuplexStream,
perms: &PermissionSet,
) -> Result<()> {
- let local_track = local_tracks
- .first()
- .ok_or(anyhow!("track missing"))?
- .to_owned();
+ // let local_track = local_tracks
+ // .first()
+ // .ok_or(anyhow!("track missing"))?
+ // .to_owned();
- let fragments = tokio::task::spawn_blocking(move || {
- jellyremuxer::fragment::fragment_index(&CONF.media_path, &node, &local_track, spec.track[0])
- })
- .await??;
+ // let fragments = tokio::task::spawn_blocking(move || {
+ // jellyremuxer::fragment::fragment_index(&CONF.media_path, &node, &local_track, spec.track[0])
+ // })
+ // .await??;
- let out = serde_json::to_string(&JhlsTrackIndex {
- extra_profiles: if perms.check(&UserPermission::Transcode) {
- CONF.transcoding_profiles.clone()
- } else {
- vec![]
- },
- fragments,
- })?;
- tokio::spawn(async move { b.write_all(out.as_bytes()).await });
+ // let out = serde_json::to_string(&JhlsTrackIndex {
+ // extra_profiles: if perms.check(&UserPermission::Transcode) {
+ // CONF.transcoding_profiles.clone()
+ // } else {
+ // vec![]
+ // },
+ // fragments,
+ // })?;
+ // tokio::spawn(async move { b.write_all(out.as_bytes()).await });
Ok(())
}