1 files changed, 49 insertions, 71 deletions
diff --git a/common/src/stream.rs b/common/src/stream.rs
index 3e227e1..46f6abc 100644
--- a/common/src/stream.rs
+++ b/common/src/stream.rs
@@ -1,82 +1,60 @@
-use bincode::{Decode, Encode};
 /*
     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>
 */
-#[cfg(feature = "rocket")]
-use rocket::{FromForm, FromFormField, UriDisplayQuery};
 use serde::{Deserialize, Serialize};
 
 #[derive(Debug, Clone, Deserialize, Serialize)]
-#[cfg_attr(feature = "rocket", derive(FromForm, UriDisplayQuery))]
-pub struct StreamSpec {
-    pub track: Vec<usize>,
-    pub format: StreamFormat,
-    pub webm: Option<bool>,
-    pub profile: Option<usize>,
-    pub index: Option<usize>,
+pub enum StreamSpec {
+    Whep {
+        track: u64,
+        seek: u64,
+    },
+    WhepControl {
+        token: String,
+    },
+    Remux {
+        track: Vec<u64>,
+        container: StreamContainer,
+    },
+    Original {
+        track: u64,
+    },
+    HlsSuperMultiVariant {
+        container: StreamContainer,
+    },
+    HlsMultiVariant {
+        segment: u64,
+        container: StreamContainer,
+    },
+    HlsVariant {
+        segment: u64,
+        track: u64,
+        container: StreamContainer,
+        format: usize,
+    },
+    Info {
+        segment: Option<u64>,
+    },
+    FragmentIndex {
+        segment: u64,
+        track: u64,
+    },
+    Fragment {
+        segment: u64,
+        track: u64,
+        index: u64,
+        container: StreamContainer,
+        format: usize,
+    },
 }
 
-#[rustfmt::skip]
-#[derive(Debug, Clone, Copy, Deserialize, Serialize, PartialEq, Eq, Hash, Encode, Decode)]
-#[serde(rename_all = "snake_case")]
-#[cfg_attr(feature = "rocket", derive(FromFormField, UriDisplayQuery))]
-pub enum StreamFormat {
-    #[cfg_attr(feature = "rocket", field(value = "original"))] Original,
-    #[cfg_attr(feature = "rocket", field(value = "matroska"))] Matroska,
-    #[cfg_attr(feature = "rocket", field(value = "hlsmaster"))] HlsMaster,
-    #[cfg_attr(feature = "rocket", field(value = "hlsvariant"))] HlsVariant,
-    #[cfg_attr(feature = "rocket", field(value = "jhlsi"))] JhlsIndex,
-    #[cfg_attr(feature = "rocket", field(value = "frag"))] Fragment,
-    #[cfg_attr(feature = "rocket", field(value = "webvtt"))] Webvtt,
-    #[cfg_attr(feature = "rocket", field(value = "jvtt"))] Jvtt,
-}
-
-impl Default for StreamSpec {
-    fn default() -> Self {
-        Self {
-            track: Vec::new(),
-            format: StreamFormat::Matroska,
-            webm: Some(true),
-            profile: None,
-            index: None,
-        }
-    }
-}
-
-impl StreamSpec {
-    pub fn to_query(&self) -> String {
-        use std::fmt::Write;
-        let mut u = String::new();
-        write!(u, "format={}", self.format.ident()).unwrap();
-        for t in &self.track {
-            write!(u, "&track={}", t).unwrap();
-        }
-        if let Some(profile) = self.profile {
-            write!(u, "&profile={profile}").unwrap();
-        }
-        if let Some(index) = self.index {
-            write!(u, "&index={index}").unwrap();
-        }
-        if let Some(webm) = self.webm {
-            write!(u, "&webm={webm}").unwrap();
-        }
-        u
-    }
-}
-
-impl StreamFormat {
-    pub fn ident(&self) -> &'static str {
-        match self {
-            StreamFormat::Jvtt => "jvtt",
-            StreamFormat::Original => "original",
-            StreamFormat::Matroska => "matroska",
-            StreamFormat::HlsMaster => "hlsmaster",
-            StreamFormat::HlsVariant => "hlsvariant",
-            StreamFormat::JhlsIndex => "jhlsi",
-            StreamFormat::Fragment => "frag",
-            StreamFormat::Webvtt => "webvtt",
-        }
-    }
+#[derive(Debug, Clone, Copy, Deserialize, Serialize)]
+#[serde(rename_all = "lowercase")]
+pub enum StreamContainer {
+    WebM,
+    Matroska,
+    WebVTT,
+    JVTT,
 }