Merge pull request '🔧refactor: separate download logic from AppImage struct' (#11) from feat/issue-7 into main

Reviewed-on: https://git.ch-naseem.com/ndpm13/zap-rs/pulls/11

1 files changed, 58 insertions, 0 deletions

diff --git a/src/downloader.rs b/src/downloader.rs
new file mode 100644
index 0000000..2196e25
--- /dev/null
+++ b/src/downloader.rs
@@ -0,0 +1,58 @@
+use futures_util::StreamExt;
+use std::path::PathBuf;
+use tokio::{fs, io::AsyncWriteExt};
+
+use crate::{appimages_dir, make_progress_bar};
+
+#[derive(Debug, Default)]
+pub struct Downloader {}
+
+impl Downloader {
+    pub fn new() -> Self {
+        Self {}
+    }
+    pub fn prepare_path(&self, url: &str, executable: &str) -> PathBuf {
+        // Try to extract filename from URL or use default
+        let filename = match url.split('/').next_back() {
+            Some(name) => name.to_string(),
+            None => format!("{executable}.AppImage"),
+        };
+
+        appimages_dir().join(filename)
+    }
+    pub async fn download_with_progress(
+        &self,
+        url: &str,
+        path: &PathBuf,
+    ) -> Result<(), Box<dyn std::error::Error>> {
+        fs::create_dir_all(&appimages_dir()).await?;
+
+        let resp = reqwest::get(&url.to_string()).await?;
+        let total_size = resp.content_length().unwrap_or(0);
+
+        let bar = make_progress_bar(total_size);
+        let mut out = tokio::fs::File::create(&path).await?;
+
+        // Stream download with progress updates
+        let mut stream = resp.bytes_stream();
+        while let Some(chunk) = stream.next().await {
+            let chunk = chunk?;
+            let len = chunk.len() as u64;
+            out.write_all(&chunk).await?;
+            bar.inc(len);
+        }
+
+        bar.finish_with_message("Download complete!");
+
+        // Make executable
+        #[cfg(unix)]
+        {
+            use std::os::unix::fs::PermissionsExt;
+            let mut perms = fs::metadata(&path).await?.permissions();
+            perms.set_mode(0o755);
+            fs::set_permissions(&path, perms).await?;
+        }
+
+        Ok(())
+    }
+}