WIP

Author: MattiasBuelens

src/import/mod.rs

@@ -2,7 +2,7 @@ mod har;
 
 use crate::shared::url_file_extension;
 use har::Har;
-use std::io::Result;
+use std::io::{Error, Result};
 use std::path::Path;
 use tokio::fs;
 use url::Url;
@@ -13,10 +13,18 @@ pub async fn import_har(har: Har, dest: &Path) -> Result<()> {
     let spec = har.log;
 
     // Find the first .m3u8 request
-    let first_playlist_request = spec.entries.iter().find(|entry| {
-        let url = Url::parse(&entry.request.url).unwrap();
-        matches!(url_file_extension(&url), Some("m3u8"))
-    });
+    let first_playlist_request = spec
+        .entries
+        .iter()
+        .find(|entry| {
+            let url = Url::parse(&entry.request.url).unwrap();
+            matches!(url_file_extension(&url), Some("m3u8"))
+        })
+        .ok_or_else(|| Error::other("no playlist found"))?;
+
+    let first_playlist_response = first_playlist_request.response.content.as_bytes()?;
+
+    dbg!(&first_playlist_response);
 
     Ok(())
 }

src/record/mod.rs

@@ -590,21 +590,21 @@ fn media_applies_to_variant(media: &AlternativeMedia, variant_stream: &VariantSt
     }
 }
 
-struct RecordingFile {
+pub(crate) struct RecordingFile {
     recording: Recording,
     file: fs::File,
 }
 
 impl RecordingFile {
-    async fn new(path: &Path) -> io::Result<Self> {
+    pub(crate) async fn new(path: &Path) -> io::Result<Self> {
         let file = fs::File::create(path).await?;
         Ok(Self {
             recording: Recording::new(),
             file,
         })
     }
 
-    async fn add_and_save(
+    pub(crate) async fn add_and_save(
         &mut self,
         time: DateTime<Utc>,
         playlist_name: &str,
@@ -614,7 +614,7 @@ impl RecordingFile {
         self.save().await
     }
 
-    async fn save(&mut self) -> io::Result<()> {
+    pub(crate) async fn save(&mut self) -> io::Result<()> {
         let recording_json = serde_json::to_string_pretty(&self.recording)?;
         let recording_bytes = recording_json.as_bytes();
         self.file.rewind().await?;