feat: verbose toggle, info tab, many misc fixes

rust/src/download_handler.rs

@@ -1,4 +1,6 @@
 use std::{collections::HashSet, path::PathBuf};
+use futures::Stream;
+use serde::{Deserialize, Serialize};
 use tauri::{AppHandle, Emitter};
 use tokio::fs::File;
 use anyhow::{anyhow, Result};
@@ -6,14 +8,20 @@ use anyhow::{anyhow, Result};
 use crate::pkg::{Package, PkgKey, Remote};
 
 pub struct DownloadHandler {
-    set: HashSet<String>,
+    paths: HashSet<PathBuf>,
     app: AppHandle
 }
 
+#[derive(Serialize, Deserialize, Clone)]
+pub struct DownloadTick {
+    pkg_key: PkgKey,
+    ratio: f32
+}
+
 impl DownloadHandler {
     pub fn new(app: AppHandle) -> DownloadHandler {
         DownloadHandler {
-            set: HashSet::new(),
+            paths: HashSet::new(),
             app
         }
     }
@@ -22,11 +30,11 @@ impl DownloadHandler {
         let rmt = pkg.rmt.as_ref()
             .ok_or_else(|| anyhow!("Attempted to download a package without remote data"))?
             .clone();
-        if self.set.contains(zip_path.to_string_lossy().as_ref()) {
-            // Todo when there is a clear cache button, it should clear the set
-            Err(anyhow!("Already downloading"))
+        if self.paths.contains(zip_path) {
+            Ok(())
         } else {
-            self.set.insert(zip_path.to_string_lossy().to_string());
+            // TODO clear cache button should clear this
+            self.paths.insert(zip_path.clone());
             tauri::async_runtime::spawn(Self::download_zip_proc(self.app.clone(), zip_path.clone(), pkg.key(), rmt));
             Ok(())
         }
@@ -42,10 +50,15 @@ impl DownloadHandler {
 
         let mut cache_file_w = File::create(&zip_path_part).await?;
         let mut byte_stream = reqwest::get(&rmt.download_url).await?.bytes_stream();
+        let first_hint = byte_stream.size_hint().0 as f32;
 
         log::info!("downloading: {}", rmt.download_url);
         while let Some(item) = byte_stream.next().await {
             let i = item?;
+            app.emit("download-tick", DownloadTick {
+                pkg_key: pkg_key.clone(),
+                ratio: 1.0f32 - (byte_stream.size_hint().0 as f32) / first_hint
+            })?;
             cache_file_w.write_all(&mut i.as_ref()).await?;
         }
         cache_file_w.sync_all().await?;