feat(gui): add mount subcommand to browse snapshots via WebDAV

Surface vykar mount in the GUI with buttons on Overview (mount whole
repo) and Snapshots (mount a single snapshot). On click the worker
binds 127.0.0.1:0, emits the bound URL, opens the default browser,
and shows a footer banner with a clickable link and a Stop button.

Core changes: run_with_progress takes an Option<Arc<Notify>> for
programmatic shutdown, and Serving is emitted from
listener.local_addr() so ephemeral ports resolve.

Author: m3nu

Cargo.lock

@@ -38,6 +38,7 @@ pub(crate) fn run_mount(
             cache_size,
             source_filter,
             Some(&mut on_progress),
+            None,
         )
         .map_err(|e| -> Box<dyn std::error::Error> { Box::new(e) })
     })?;

crates/vykar-cli/src/cmd/mount.rs

@@ -76,7 +76,7 @@ percent-encoding = { version = "2", optional = true }
 [features]
 default = []
 backend-sftp = ["vykar-storage/backend-sftp"]
-mount = ["dav-server", "tokio/rt-multi-thread", "tokio/macros", "tokio/signal", "tokio/net", "hyper", "hyper-util", "lru", "bytes", "futures-util", "percent-encoding"]
+mount = ["dav-server", "tokio/rt-multi-thread", "tokio/macros", "tokio/signal", "tokio/net", "tokio/sync", "hyper", "hyper-util", "lru", "bytes", "futures-util", "percent-encoding"]
 
 [dev-dependencies]
 proptest = { workspace = true }

crates/vykar-core/Cargo.toml

@@ -794,9 +794,11 @@ pub fn run(
         cache_size,
         source_filter,
         None,
+        None,
     )
 }
 
+#[allow(clippy::too_many_arguments)]
 pub fn run_with_progress(
     config: &VykarConfig,
     passphrase: Option<&str>,
@@ -805,6 +807,7 @@ pub fn run_with_progress(
     cache_size: usize,
     source_filter: &[String],
     mut progress: Option<&mut dyn FnMut(MountProgressEvent)>,
+    shutdown: Option<Arc<tokio::sync::Notify>>,
 ) -> Result<()> {
     let mut repo = open_repo(
         config,
@@ -877,7 +880,17 @@ pub fn run_with_progress(
         .map_err(|e| VykarError::Other(format!("failed to create tokio runtime: {e}")))?;
 
     let is_multi_snapshot = snapshot_name.is_none();
-    rt.block_on(async { serve(handler, tree, address, is_multi_snapshot, &mut progress).await })
+    rt.block_on(async {
+        serve(
+            handler,
+            tree,
+            address,
+            is_multi_snapshot,
+            &mut progress,
+            shutdown,
+        )
+        .await
+    })
 }
 
 async fn serve(
@@ -886,6 +899,7 @@ async fn serve(
     address: &str,
     is_multi_snapshot: bool,
     progress: &mut Option<&mut dyn FnMut(MountProgressEvent)>,
+    shutdown: Option<Arc<tokio::sync::Notify>>,
 ) -> Result<()> {
     let addr: std::net::SocketAddr = address
         .parse()
@@ -894,10 +908,13 @@ async fn serve(
     let listener = TcpListener::bind(addr)
         .await
         .map_err(|e| VykarError::Other(format!("failed to bind to {addr}: {e}")))?;
+    let bound = listener
+        .local_addr()
+        .map_err(|e| VykarError::Other(format!("local_addr failed: {e}")))?;
 
     if let Some(cb) = progress.as_deref_mut() {
         cb(MountProgressEvent::Serving {
-            address: format!("{addr}"),
+            address: format!("{bound}"),
         });
     }
 
@@ -959,6 +976,17 @@ async fn serve(
                 }
                 break;
             }
+            _ = async {
+                match shutdown.as_ref() {
+                    Some(n) => n.notified().await,
+                    None => std::future::pending::<()>().await,
+                }
+            } => {
+                if let Some(cb) = progress.as_deref_mut() {
+                    cb(MountProgressEvent::ShuttingDown);
+                }
+                break;
+            }
         }
     }
 

crates/vykar-core/src/commands/mount.rs

@@ -14,9 +14,11 @@ path = "src/main.rs"
 workspace = true
 
 [dependencies]
-vykar-core = { workspace = true, features = ["backend-sftp"] }
+vykar-core = { workspace = true, features = ["backend-sftp", "mount"] }
 vykar-common.workspace = true
 vykar-types.workspace = true
+tokio = { workspace = true, features = ["sync"] }
+opener = "0.8"
 slint = { version = "1.15", default-features = false, features = ["std", "compat-1-2", "backend-winit", "renderer-skia", "accessibility"] }
 tray-icon = "0.22"
 crossbeam-channel.workspace = true

crates/vykar-gui/Cargo.toml

@@ -335,6 +335,67 @@ pub(crate) fn wire_callbacks(
         });
     }
 
+    {
+        let tx = app_tx.clone();
+        let ui_weak = ui.as_weak();
+        ui.on_mount_selected_snapshot_clicked(move |row| {
+            let Some(ui) = ui_weak.upgrade() else {
+                return;
+            };
+            let r = row as usize;
+            let ids = ui.global::<AppData>().get_snapshot_ids();
+            let rnames = ui.global::<AppData>().get_snapshot_repo_names();
+            let (snap_name, rname) = match (ids.row_data(r), rnames.row_data(r)) {
+                (Some(id), Some(rn)) => (id.to_string(), rn.to_string()),
+                _ => return,
+            };
+            // Optimistically mark active so the Mount buttons disable immediately.
+            // MountStarted will set the real URL; MountFailed will clear this.
+            ui.set_is_mount_active(true);
+            let _ = tx.send(AppCommand::StartMount {
+                repo_name: rname,
+                snapshot_name: Some(snap_name),
+            });
+        });
+    }
+
+    {
+        let tx = app_tx.clone();
+        let ui_weak = ui.as_weak();
+        ui.on_mount_repo_clicked(move |idx| {
+            let Some(ui) = ui_weak.upgrade() else {
+                return;
+            };
+            let labels = ui.global::<AppData>().get_repo_labels();
+            if let Some(name) = labels.row_data(idx as usize) {
+                ui.set_is_mount_active(true);
+                let _ = tx.send(AppCommand::StartMount {
+                    repo_name: name.to_string(),
+                    snapshot_name: None,
+                });
+            }
+        });
+    }
+
+    {
+        let tx = app_tx.clone();
+        ui.on_stop_mount_clicked(move || {
+            let _ = tx.send(AppCommand::StopMount);
+        });
+    }
+
+    {
+        let ui_weak = ui.as_weak();
+        ui.on_open_mount_url_clicked(move || {
+            if let Some(ui) = ui_weak.upgrade() {
+                let url = ui.get_mount_url().to_string();
+                if !url.is_empty() {
+                    let _ = opener::open_browser(&url);
+                }
+            }
+        });
+    }
+
     {
         let tx = app_tx;
         let ui_weak = ui.as_weak();

crates/vykar-gui/src/controllers/main_window.rs

@@ -389,6 +389,8 @@ pub(crate) fn spawn(
                                 *last = Some(s);
                             }
                         }
+                        // Best-effort: stop any active mount so the listener is released cleanly.
+                        let _ = app_tx.send(AppCommand::StopMount);
                         let _ = slint::quit_event_loop();
                     }
                     UiEvent::ShowWindow => {
@@ -410,6 +412,34 @@ pub(crate) fn spawn(
                             }
                         }
                     }
+                    UiEvent::MountStarted { url } => {
+                        ui.set_is_mount_active(true);
+                        ui.set_mount_url(url.clone().into());
+                        if opener::open_browser(&url).is_err() {
+                            let now = chrono::Local::now();
+                            append_log_row(
+                                &ui,
+                                &now.format("%b %d").to_string(),
+                                &now.format("%H:%M:%S").to_string(),
+                                &format!("Mount running at {url} — open it manually"),
+                            );
+                        }
+                    }
+                    UiEvent::MountStopped => {
+                        ui.set_is_mount_active(false);
+                        ui.set_mount_url("".into());
+                    }
+                    UiEvent::MountFailed { message } => {
+                        ui.set_is_mount_active(false);
+                        ui.set_mount_url("".into());
+                        let now = chrono::Local::now();
+                        append_log_row(
+                            &ui,
+                            &now.format("%b %d").to_string(),
+                            &now.format("%H:%M:%S").to_string(),
+                            &format!("Mount failed: {message}"),
+                        );
+                    }
                     UiEvent::TriggerSnapshotRefresh => {
                         let idx = ui.get_current_repo_index();
                         if idx >= 0 {

crates/vykar-gui/src/event_consumer.rs

@@ -55,6 +55,11 @@ pub(crate) enum AppCommand {
     SaveAndApplyConfig {
         yaml_text: String,
     },
+    StartMount {
+        repo_name: String,
+        snapshot_name: Option<String>,
+    },
+    StopMount,
 }
 
 // ── Data transfer structs ──
@@ -154,4 +159,11 @@ pub(crate) enum UiEvent {
     Quit,
     ShowWindow,
     TriggerSnapshotRefresh,
+    MountStarted {
+        url: String,
+    },
+    MountStopped,
+    MountFailed {
+        message: String,
+    },
 }

crates/vykar-gui/src/messages.rs

@@ -15,6 +15,7 @@ use crate::view_models::send_structured_data;
 mod actions;
 mod backup;
 mod config_cmds;
+mod mount;
 mod repo_info;
 mod shared;
 
@@ -33,6 +34,8 @@ pub(super) struct WorkerContext {
 
     pub(super) scheduler_lock_held: bool,
     pub(super) schedule_paused: bool,
+
+    pub(super) mount: Option<mount::MountHandle>,
 }
 
 fn startup(ctx: &mut WorkerContext) {
@@ -108,6 +111,7 @@ pub(crate) fn run_worker(
         cancel_requested,
         scheduler_lock_held,
         schedule_paused: !scheduler_lock_held,
+        mount: None,
     };
 
     startup(&mut ctx);
@@ -152,6 +156,14 @@ pub(crate) fn run_worker(
             AppCommand::SaveAndApplyConfig { yaml_text } => {
                 config_cmds::handle_save_and_apply_config(&mut ctx, yaml_text)
             }
+            AppCommand::StartMount {
+                repo_name,
+                snapshot_name,
+            } => mount::handle_start_mount(&mut ctx, repo_name, snapshot_name),
+            AppCommand::StopMount => mount::handle_stop_mount(&mut ctx),
         }
     }
+
+    // On worker shutdown, stop any active mount so we don't leak a listener.
+    mount::handle_stop_mount(&mut ctx);
 }