indicatrix-cut 0.6.2

//! Wiring for switching the browsed library source (`switch_library_source`) and
//! driving a pull-mirror sync (`start_mirror_sync`/`cancel_mirror_sync`).
//!
//! Everything that actually decides "local or remote" and "how to mirror" lives in
//! `bridge::library_source`/`bridge::library_client`/`bridge::library_mirror` -- this
//! module is purely the Slint-callback glue, following the same shape
//! `gui::remote::worker_callbacks` already uses for "Test connection" (a blocking call
//! on its own `std::thread::spawn` worker, result marshalled back via
//! `Weak::upgrade_in_event_loop`) and `gui::mod`'s export wiring (an `Rc<RefCell<Option<_>>>`
//! held on the UI thread so a running sync's handle can be reached by a later "Cancel"
//! click).

use crate::{
    LibraryModel, MainWindow, RemoteWorkerModel,
    bridge::library::{
        client as library_client,
        mirror::{self as library_mirror, MirrorHandle, MirrorOutcome, MirrorProgress},
        source::{LibrarySource, spawn_library_request},
    },
    gui::show_toast,
    settings::{SettingsPersister, WorkerSettings},
};
use indicatrix_net::library::{AttributeRangesWire, LibraryRequest, LibraryResponse};
use indicatrix_vault::db::sqlite::Database;
use slint::{ComponentHandle, ModelRc, SharedString, VecModel, Weak};
use std::{
    cell::RefCell,
    rc::Rc,
    sync::{Arc, Mutex, PoisonError},
};

/// Wires the "Local"/"Browse library" switch (see `remote_worker_dialog.slint`).
///
/// Switching to a worker first PROBES it (handshake only, no data request -- mirrors
/// `bridge::remote::remote_render::test_connection`'s own shape) on a background thread, and
/// only commits `source` to [`LibrarySource::Remote`] -- updating the always-visible
/// badge (`header.slint`) and loading that worker's filter options + initial list -- if
/// the probe succeeds and the worker actually advertises library capacity
/// (`ConnectionInfo::library`). A failure (unreachable, wrong certs, library-less
/// worker) shows a clear toast and leaves `source`/the badge exactly as they were --
/// the viewer stays on whatever it was already showing (local, on a fresh app with
/// nothing configured yet), never a half-switched, unusable state.
pub fn setup_library_source_callbacks(
    ui: &MainWindow,
    db: &Arc<Mutex<Database>>,
    source: &Arc<Mutex<LibrarySource>>,
    settings_store: &Arc<SettingsPersister>,
) {
    let db_switch = Arc::clone(db);
    let source_switch = Arc::clone(source);
    let settings_switch = settings_store.clone();
    let ui_weak = ui.as_weak();
    ui.global::<RemoteWorkerModel>().on_switch_library_source(move |idx: i32| {
        let Some(ui) = ui_weak.upgrade() else {
            return;
        };

        if idx < 0 {
            // Invalidates any in-flight remote search reply from BEFORE
            // this switch -- `load_filter_options_and_initial_list` below also bumps
            // (via `refresh_diagram_list`), but that happens only once its own
            // synchronous query finishes; this closes the window between the click and
            // that point too.
            crate::gui::library::search::bump_search_seq();
            *source_switch
                .lock()
                .unwrap_or_else(PoisonError::into_inner) = LibrarySource::Local;
            apply_source_badge(&ui, &LibrarySource::Local);
            ui.global::<RemoteWorkerModel>().set_library_source_worker_index(-1);
            crate::gui::library::diagram_list::load_filter_options_and_initial_list(&ui, &db_switch);
            show_toast(&ui, "Switched to the local library.", "info");
            return;
        }

        // Any non-negative index is the one remote endpoint (only one can be configured).
        let Some(worker) = settings_switch.snapshot().settings.remote_worker() else {
            show_toast(&ui, "No remote coordinator is configured.", "error");
            return;
        };

        ui.global::<LibraryModel>().set_status_message(format!("Connecting to {}...", worker_display_name(&worker)).into());
        // Captured BEFORE the probe is even dispatched (matching
        // `search::refresh_diagram_list_remote`'s own "bump before the async work
        // starts" rule): a second switch clicked while this probe is still in flight
        // bumps the sequence again, so THIS reply -- whichever of the two lands last --
        // can tell it has been superseded and must never commit
        // `LibrarySource::Remote`.
        let switch_seq = crate::gui::library::search::bump_search_seq();
        let source_probe = Arc::clone(&source_switch);
        let ui_weak_result = ui.as_weak();
        let worker_for_probe = worker;
        std::thread::spawn(move || {
            let result = library_client::probe(&worker_for_probe);
            let _ = ui_weak_result.upgrade_in_event_loop(move |ui| {
                if !crate::gui::library::search::is_current_search(switch_seq) {
                    // A newer switch (to Local, or to this-or-another remote worker)
                    // already owns the display -- this probe reply is stale and must
                    // never touch `source`/the UI, success or not.
                    return;
                }
                match result {
                Ok(info) if info.library => {
                    // Invalidates any in-flight LOCAL (or previous remote
                    // worker's) search reply from before this switch -- see the `idx <
                    // 0` branch's own comment above for why this can't just wait for
                    // `load_filter_options_and_initial_list_remote`'s own bump.
                    crate::gui::library::search::bump_search_seq();
                    let new_source = LibrarySource::Remote(worker_for_probe);
                    *source_probe.lock().unwrap_or_else(PoisonError::into_inner) =
                        new_source.clone();
                    apply_source_badge(&ui, &new_source);
                    ui.global::<RemoteWorkerModel>().set_library_source_worker_index(0);
                    if let Some(w) = new_source.worker() {
                        load_filter_options_and_initial_list_remote(&ui, w.clone());
                    }
                    show_toast(&ui, &format!("Now browsing: {}", new_source.label()), "success");
                    // The sort selector and tag chips reach the remote
                    // worker's own search (`LibraryRequest::Search::order`/`tag_filter`,
                    // see `gui::library::search::refresh_diagram_list_remote`) and are not
                    // greyed out. "My designs" and the just-imported restriction
                    // still are (see `filter_panel.slint`/`diagram_list.slint`'s own
                    // `RemoteWorkerModel.library_is_remote` bindings) -- both name local
                    // entry ids/the local import scheme, which have no meaning against a
                    // remote catalogue. Say why, once, rather than leaving a cutter to
                    // wonder why those two stopped reacting.
                    ui.global::<LibraryModel>().set_status_message(
                        "\"My designs\" and the just-imported filter apply to the local \
                         library only."
                            .into(),
                    );
                }
                Ok(_) => {
                    show_toast(
                        &ui,
                        "That remote is reachable but does not serve a design library -- staying on the current library.",
                        "error",
                    );
                    ui.global::<LibraryModel>().set_status_message("Ready.".into());
                }
                Err(e) => {
                    show_toast(&ui, &format!("Could not switch library: {e}"), "error");
                    ui.global::<LibraryModel>().set_status_message("Ready.".into());
                }
                }
            });
        });
    });
}

/// Sets the header badge's label/remote-ness (`library_source_label`/`library_is_remote`)
/// to reflect `source`. `library_source_worker_index` is set separately at each call
/// site (the row index a click came from, or `-1` for local) -- `LibrarySource` itself
/// doesn't carry a worker-list index, only the resolved `WorkerSettings`.
fn apply_source_badge(ui: &MainWindow, source: &LibrarySource) {
    ui.global::<RemoteWorkerModel>()
        .set_library_source_label(source.label().into());
    ui.global::<RemoteWorkerModel>()
        .set_library_is_remote(source.is_remote());
    crate::gui::rough_plan::refresh_links_enabled();
}

/// Loads `worker`'s filter options (shapes/gears/attribute ranges) and initial diagram
/// list -- the remote counterpart of `gui::diagram_list::load_filter_options_and_initial_list`,
/// run when a switch to that worker just succeeded.
fn load_filter_options_and_initial_list_remote(ui: &MainWindow, worker: WorkerSettings) {
    // Captured before this request is dispatched -- see
    // `search::refresh_diagram_list_remote`'s own doc comment for why. Without this,
    // a slow `FilterOptions` reply landing after the cutter switched away (back to
    // Local, or to browsing a different remote worker) would still reset the
    // shape/gear dropdowns and chain into `refresh_diagram_list_remote` -- which would
    // itself mint a FRESH seq for a search against a worker the UI is no longer even
    // showing, making that stale search look current again.
    let seq = crate::gui::library::search::bump_search_seq();
    let worker_for_search = worker.clone();
    crate::bridge::library::source::spawn_library_request(
        ui.as_weak(),
        worker,
        LibraryRequest::FilterOptions,
        move |ui, result| {
            if !crate::gui::library::search::is_current_search(seq) {
                return;
            }
            match result {
                Ok(LibraryResponse::FilterOptions {
                    shapes,
                    gears,
                    ranges,
                }) => {
                    apply_shape_gear_options(ui, &shapes, &gears);
                    apply_range_wire_to_ui(ui, &ranges);
                    // The box, tag chip filter and just-imported
                    // restriction don't come from this reply at all (unlike shape/gear,
                    // which `apply_shape_gear_options` above already resets), so they'd
                    // otherwise still show whatever the previous library left behind
                    // while the query below runs against the literal `""`/"All
                    // Shapes"/"All Gears" it's about to be called with.
                    crate::gui::library::diagram_list::reset_search_and_filter_ui_inputs(ui);
                }
                Ok(_) => {
                    ui.global::<LibraryModel>().set_status_message(
                        "Unexpected reply loading remote filter options.".into(),
                    );
                }
                Err(e) => ui.global::<LibraryModel>().set_status_message(
                    format!("Could not load remote filter options: {e}").into(),
                ),
            }
            // Chained rather than parallel: both requests each pay their own connect
            // cost (see `bridge::library_client`'s module doc comment -- one connect+
            // handshake per request in this phase), and the initial list only needs to
            // exist once filter options have already populated the dropdowns/bounds
            // it's rendered alongside.
            crate::gui::library::search::refresh_diagram_list_remote(
                ui,
                worker_for_search,
                "",
                "All Shapes",
                "All Gears",
            );
        },
    );
}

/// A worker's display name for a status message -- its `name` if set, else its
/// `address`. The same fallback [`LibrarySource::label`] uses internally, but without
/// that method's `"Remote: "` prefix (not appropriate mid-sentence, as in "Connecting
/// to X...").
fn worker_display_name(worker: &WorkerSettings) -> &str {
    if worker.name.trim().is_empty() {
        &worker.address
    } else {
        &worker.name
    }
}

fn apply_shape_gear_options(ui: &MainWindow, shapes: &[String], gears: &[String]) {
    let mut shape_opts = vec!["All Shapes".to_string()];
    shape_opts.extend(shapes.iter().cloned());
    let shape_model: Vec<SharedString> = shape_opts.into_iter().map(Into::into).collect();
    ui.global::<LibraryModel>()
        .set_shape_options(ModelRc::new(VecModel::from(shape_model)));

    let mut gear_opts = vec!["All Gears".to_string()];
    gear_opts.extend(gears.iter().cloned());
    let gear_model: Vec<SharedString> = gear_opts.into_iter().map(Into::into).collect();
    ui.global::<LibraryModel>()
        .set_gear_options(ModelRc::new(VecModel::from(gear_model)));
    ui.global::<LibraryModel>().set_selected_shape_index(0);
    ui.global::<LibraryModel>().set_selected_gear_index(0);
}

fn apply_range_wire_to_ui(ui: &MainWindow, ranges: &AttributeRangesWire) {
    ui.global::<LibraryModel>()
        .set_ri_bounds_min(ranges.ri.0 as f32);
    ui.global::<LibraryModel>()
        .set_ri_bounds_max(ranges.ri.1 as f32);
    ui.global::<LibraryModel>()
        .set_ri_filter_min(ranges.ri.0 as f32);
    ui.global::<LibraryModel>()
        .set_ri_filter_max(ranges.ri.1 as f32);
    ui.global::<LibraryModel>()
        .set_lw_bounds_min(ranges.lw_ratio.0 as f32);
    ui.global::<LibraryModel>()
        .set_lw_bounds_max(ranges.lw_ratio.1 as f32);
    ui.global::<LibraryModel>()
        .set_lw_filter_min(ranges.lw_ratio.0 as f32);
    ui.global::<LibraryModel>()
        .set_lw_filter_max(ranges.lw_ratio.1 as f32);
    ui.global::<LibraryModel>()
        .set_volume_bounds_min(ranges.volume.0 as f32);
    ui.global::<LibraryModel>()
        .set_volume_bounds_max(ranges.volume.1 as f32);
    ui.global::<LibraryModel>()
        .set_volume_filter_min(ranges.volume.0 as f32);
    ui.global::<LibraryModel>()
        .set_volume_filter_max(ranges.volume.1 as f32);
    ui.global::<LibraryModel>()
        .set_facets_bounds_min(ranges.facets.0 as f32);
    ui.global::<LibraryModel>()
        .set_facets_bounds_max(ranges.facets.1 as f32);
    ui.global::<LibraryModel>()
        .set_facets_filter_min(ranges.facets.0 as f32);
    ui.global::<LibraryModel>()
        .set_facets_filter_max(ranges.facets.1 as f32);
}

/// Wires "Mirror to local" / "Cancel" (see `remote_worker_dialog.slint`).
///
/// One sync at a time, enforced by the UI itself: a second row's "Mirror to local"
/// button is disabled while `mirror_in_progress` is set (see that `.slint` file) --
/// the same division of responsibility `gui::render_export::setup_render_export_callbacks`
/// already uses for exports (the Rust side here never even inspects `handle` before
/// starting a new sync; it simply overwrites it, exactly as that module's own
/// `export_handle` does).
pub fn setup_mirror_sync_callbacks(
    ui: &MainWindow,
    db: &Arc<Mutex<Database>>,
    settings_store: &Arc<SettingsPersister>,
) {
    let handle: Rc<RefCell<Option<MirrorHandle>>> = Rc::new(RefCell::new(None));

    let db_start = Arc::clone(db);
    let settings_start = settings_store.clone();
    let handle_start = handle.clone();
    let ui_weak_start = ui.as_weak();
    ui.global::<RemoteWorkerModel>()
        .on_start_mirror_sync(move || {
            let Some(ui) = ui_weak_start.upgrade() else {
                return;
            };
            let Some(worker) = settings_start.snapshot().settings.remote_worker() else {
                show_toast(&ui, "No remote coordinator is configured.", "error");
                return;
            };

            ui.global::<RemoteWorkerModel>()
                .set_mirror_in_progress(true);
            ui.global::<RemoteWorkerModel>()
                .set_mirror_progress_fraction(0.0);
            ui.global::<RemoteWorkerModel>().set_mirror_has_error(false);
            ui.global::<RemoteWorkerModel>()
                .set_mirror_status_text("Listing the remote library...".into());

            let new_handle = library_mirror::spawn_mirror_sync(
                ui.as_weak(),
                Arc::clone(&db_start),
                worker,
                library_mirror::MirrorOptions::default(),
                |ui, progress| on_mirror_progress(ui, &progress),
                |ui, outcome| on_mirror_done(ui, &outcome),
            );
            *handle_start.borrow_mut() = Some(new_handle);
        });

    let handle_cancel = handle;
    ui.global::<RemoteWorkerModel>()
        .on_cancel_mirror_sync(move || {
            if let Some(h) = handle_cancel.borrow().as_ref() {
                h.cancel();
            }
        });
}

fn on_mirror_progress(ui: &MainWindow, progress: &MirrorProgress) {
    let total = progress.counts.total_found.max(1);
    let fraction = progress.processed as f32 / total as f32;
    ui.global::<RemoteWorkerModel>()
        .set_mirror_progress_fraction(fraction);
    ui.global::<RemoteWorkerModel>().set_mirror_status_text(
        format!(
            "{}/{} -- {} (new {}, updated {}, unchanged {}, local conflicts {}, failed {})",
            progress.processed,
            progress.counts.total_found,
            progress.current_title,
            progress.counts.new_count,
            progress.counts.updated_count,
            progress.counts.skipped_unchanged,
            progress.counts.local_conflicts_skipped,
            progress.counts.failed,
        )
        .into(),
    );
}

/// A trailing `" (N designs skipped -- deleted locally.)"` clause for the mirror
/// summary, or empty when `orphaned_mirror_states` is `0` -- see
/// `MirrorCounts::orphaned_mirror_states`'s own doc comment for what this counts
/// (owner decision: "local delete wins", so these never come back on their own).
fn orphaned_mirror_states_suffix(orphaned: u64) -> String {
    if orphaned == 0 {
        String::new()
    } else {
        format!(" ({orphaned} design(s) skipped -- deleted locally.)")
    }
}

fn on_mirror_done(ui: &MainWindow, outcome: &MirrorOutcome) {
    ui.global::<RemoteWorkerModel>()
        .set_mirror_in_progress(false);
    let (text, is_error, toast_kind) = match outcome {
        MirrorOutcome::Completed(c) => (
            format!(
                "Mirror complete: {} new, {} updated, {} unchanged, {} deleted locally \
                 (skipped), {} local conflicts skipped, {} failed (of {} found).{}",
                c.new_count,
                c.updated_count,
                c.skipped_unchanged,
                c.skipped_deleted,
                c.local_conflicts_skipped,
                c.failed,
                c.total_found,
                orphaned_mirror_states_suffix(c.orphaned_mirror_states),
            ),
            c.failed > 0,
            if c.failed > 0 { "error" } else { "success" },
        ),
        MirrorOutcome::Cancelled(c) => (
            format!(
                "Mirror cancelled after {} new, {} updated, {} unchanged, {} deleted \
                 locally (skipped), {} local conflicts skipped (of {} found so far).{}",
                c.new_count,
                c.updated_count,
                c.skipped_unchanged,
                c.skipped_deleted,
                c.local_conflicts_skipped,
                c.total_found,
                orphaned_mirror_states_suffix(c.orphaned_mirror_states),
            ),
            false,
            "info",
        ),
        MirrorOutcome::Failed(msg) => (format!("Mirror failed: {msg}"), true, "error"),
    };
    ui.global::<RemoteWorkerModel>()
        .set_mirror_has_error(is_error);
    ui.global::<RemoteWorkerModel>()
        .set_mirror_status_text(text.clone().into());
    show_toast(ui, &text, toast_kind);
}

/// One remote design's original `.asc` cutting-instructions text, fetched via
/// [`fetch_remote_design_source`] -- the exact bytes/text a locally-attached `.asc`
/// file would carry (never the placeholder angle-table reconstruction), so
/// `gui::editor::loading::design_from_full_record`'s own `indicatrix_formats::asc::parse_asc` +
/// `Design::from_asc_schedule` path can build an identical [`indicatrix_cut_core::Design`]
/// from it.
///
/// This module deliberately stops at "fetch the text off the UI thread and hand it
/// back" -- building the `Design` itself (preform sizing, angle-table fallback, etc.)
/// stays `gui::editor`'s job, which already owns that logic for the local path. See
/// [`fetch_remote_design_source`]'s own doc comment for the one remaining call site
/// this crate's file-ownership split leaves outside this module's reach.
#[derive(Debug)]
pub struct RemoteDesignSource {
    /// The attachment's own bare file name (e.g. `"round-brilliant.asc"`) -- feeds
    /// `EditorState::asc_filename` exactly like the local load path's own
    /// `LoadedDesign::asc_filename`, for `save_paired`-style "Save"
    /// round-tripping later.
    pub file_name: String,
    /// The attachment's exact original text -- feeds both
    /// `indicatrix_formats::asc::parse_asc` (to build the `Design`) and
    /// `EditorState::original_asc_text` (so a later "Export .asc" can round-trip the
    /// exact bytes, not a re-serialization).
    pub asc_text: String,
}

/// Fetches `entry_id`'s original `.asc` text from `worker` via
/// `LibraryRequest::FetchDesignSource`, off the UI thread (wraps
/// `bridge::library::source::spawn_library_request`, the same one-connect-per-request
/// pattern every other remote library call in this crate uses), delivering the result
/// to `on_done` on the Slint event loop.
///
/// `on_done`'s `Err(String)` is always a ready-to-toast, human-readable message,
/// covering: a transport failure; `LibraryResponse::NotFound` (the entry no longer
/// exists on that worker); `LibraryResponse::DesignSourceNotAvailable` (a real entry
/// with no attached `.asc` -- loading it even locally would only ever reach the
/// placeholder angle-table reconstruction, so there is nothing genuine here to fetch);
/// a server-side `LibraryResponse::Error`; and any other unexpected reply shape.
///
/// # The one remaining wiring step
///
/// `gui::editor::callbacks::tier_actions::setup_load_selected_callback` currently
/// refuses "Load Selected" outright whenever the active `LibrarySource` is remote (see
/// that guard's own comment: a remote `DesignRecord` never carries attachment bytes, so
/// there was nothing to load). This function is what removes that limitation, but
/// `gui/editor/callbacks/**` is outside this module's ownership -- wiring it in is a
/// one-line guard-replacement call into this function, left to `gui/editor/callbacks`
/// to make since it is outside this module's ownership.
pub fn fetch_remote_design_source(
    ui_weak: Weak<MainWindow>,
    worker: WorkerSettings,
    entry_id: i64,
    on_done: impl FnOnce(&MainWindow, Result<RemoteDesignSource, String>) + Send + 'static,
) {
    spawn_library_request(
        ui_weak,
        worker,
        LibraryRequest::FetchDesignSource { entry_id },
        move |ui, result| on_done(ui, map_design_source_response(result)),
    );
}

/// [`fetch_remote_design_source`]'s reply-to-outcome mapping, pulled out as its own
/// pure function purely so it's unit-testable without a live network round trip --
/// see the tests below.
fn map_design_source_response(
    result: Result<LibraryResponse, library_client::LibraryClientError>,
) -> Result<RemoteDesignSource, String> {
    match result {
        Ok(LibraryResponse::DesignSource {
            file_name,
            asc_text,
            ..
        }) => Ok(RemoteDesignSource {
            file_name,
            asc_text,
        }),
        Ok(LibraryResponse::NotFound) => {
            Err("That design no longer exists on the remote library.".to_string())
        }
        Ok(LibraryResponse::DesignSourceNotAvailable) => Err(
            "This design has no attached .asc, .gem or .gcs file on the remote library -- \
             nothing to load."
                .to_string(),
        ),
        Ok(LibraryResponse::Error(e)) => Err(e.message),
        Ok(_) => Err("Unexpected reply fetching the remote design source.".to_string()),
        Err(e) => Err(format!("Could not reach the remote library: {e}")),
    }
}

#[cfg(test)]
mod remote_design_source_tests {
    use super::{RemoteDesignSource, map_design_source_response};
    use indicatrix_net::{library::LibraryResponse, messages::ErrorMsg};

    #[test]
    fn a_design_source_reply_maps_to_ok() {
        let result = map_design_source_response(Ok(LibraryResponse::DesignSource {
            entry_id: 7,
            file_name: "round-brilliant.asc".to_string(),
            asc_text: "GemCad 5.0\n".to_string(),
        }));
        let RemoteDesignSource {
            file_name,
            asc_text,
        } = result.expect("DesignSource must map to Ok");
        assert_eq!(file_name, "round-brilliant.asc");
        assert_eq!(asc_text, "GemCad 5.0\n");
    }

    #[test]
    fn not_found_maps_to_a_distinct_message_from_not_available() {
        let not_found = map_design_source_response(Ok(LibraryResponse::NotFound))
            .expect_err("NotFound must map to Err");
        let not_available =
            map_design_source_response(Ok(LibraryResponse::DesignSourceNotAvailable))
                .expect_err("DesignSourceNotAvailable must map to Err");
        assert_ne!(
            not_found, not_available,
            "the two failure reasons must not read the same to the user"
        );
    }

    #[test]
    fn a_server_error_reply_surfaces_its_own_message() {
        let err = map_design_source_response(Ok(LibraryResponse::Error(ErrorMsg {
            code: indicatrix_net::messages::error_codes::LIBRARY_FAILED,
            message: "internal error serving the design library".to_string(),
            request_id: None,
        })))
        .expect_err("Error must map to Err");
        assert_eq!(err, "internal error serving the design library");
    }

    #[test]
    fn an_unexpected_reply_shape_is_reported_rather_than_panicking() {
        let err = map_design_source_response(Ok(LibraryResponse::FilterOptions {
            shapes: Vec::new(),
            gears: Vec::new(),
            ranges: indicatrix_net::library::AttributeRangesWire {
                ri: (0.0, 0.0),
                lw_ratio: (0.0, 0.0),
                volume: (0.0, 0.0),
                facets: (0, 0),
            },
        }))
        .expect_err("an unrelated reply shape must map to Err, not panic");
        assert!(err.contains("Unexpected reply"));
    }
}