update server to new schema

1 files changed, 18 insertions, 11 deletions

diff --git a/remuxer/src/import/mod.rs b/remuxer/src/import/mod.rs
index 4ccbd1c..1af74f6 100644
--- a/remuxer/src/import/mod.rs
+++ b/remuxer/src/import/mod.rs
@@ -12,11 +12,15 @@ use jellymatroska::{
     unflatten::{IterWithPos, Unflat, Unflatten},
 };
 use log::{debug, error, info, trace, warn};
-use std::{collections::HashMap, fs::File, path::PathBuf};
+use std::{collections::HashMap, path::PathBuf};
 
-pub fn import_read(path: &PathBuf, input: &mut EbmlReader) -> Result<()> {
+pub fn import_read(
+    path: &PathBuf,
+    input: &mut EbmlReader,
+) -> Result<(Vec<SourceTrack>, Vec<LocalTrack>, Vec<SeekIndex>)> {
     let mut iteminfo = Vec::new();
     let mut private = Vec::new();
+    let mut seek_index = Vec::new();
     while let Some(item) = input.next() {
         let item = match item {
             Ok(item) => item,
@@ -45,14 +49,20 @@ pub fn import_read(path: &PathBuf, input: &mut EbmlReader) -> Result<()> {
             MatroskaTag::Segment(_) => {
                 info!("segment start");
                 let mut children = Unflatten::new_with_end(input, item);
-                import_read_segment(path, &mut children, &mut iteminfo, &mut private)?;
+                import_read_segment(
+                    path,
+                    &mut children,
+                    &mut iteminfo,
+                    &mut private,
+                    &mut seek_index,
+                )?;
                 info!("segment end");
             }
             _ => debug!("(r) tag ignored: {item:?}"),
         }
     }
 
-    Ok(())
+    Ok((iteminfo, private, seek_index))
 }
 
 fn import_read_segment(
@@ -60,6 +70,7 @@ fn import_read_segment(
     segment: &mut Unflatten,
     iteminfo: &mut Vec<SourceTrack>,
     private: &mut Vec<LocalTrack>,
+    seek_index_out: &mut Vec<SeekIndex>,
 ) -> Result<Option<f64>> {
     let (mut timestamp_scale, mut duration) = (None, None);
     let mut seek_index = HashMap::new();
@@ -246,14 +257,10 @@ fn import_read_segment(
         };
     }
 
-    for (tn, index) in seek_index {
-        info!("writing index {tn} with {} blocks", index.blocks.len());
-        bincode::encode_into_std_write(
-            index,
-            &mut File::create(path.with_extension(&format!("si.{tn}")))?,
-            bincode::config::standard(),
-        )?;
+    for i in 0..iteminfo.len() {
+        seek_index_out.push(seek_index.get(&(i as u64)).unwrap().clone())
     }
+
     Ok(if let Some(duration) = duration {
         Some((duration * timestamp_scale.unwrap_or(1_000_000) as f64) / 1_000_000_000_f64)
     } else {