|
| 1 | +use crate::process::{spawn_update_worker, InstallerConfig, InstallerEvent}; |
| 2 | +use eframe::egui; |
| 3 | +use egui::{Color32, Frame, Margin, RichText}; |
| 4 | +use std::sync::atomic::{AtomicI32, Ordering}; |
| 5 | +use std::sync::mpsc; |
| 6 | +use std::sync::Arc; |
| 7 | +use std::time::{Duration, Instant}; |
| 8 | + |
| 9 | +const BG: Color32 = Color32::from_rgb(26, 26, 46); |
| 10 | +const TEXT_PRIMARY: Color32 = Color32::from_rgb(226, 226, 234); |
| 11 | +const TEXT_SECONDARY: Color32 = Color32::from_rgb(136, 136, 160); |
| 12 | +const ACCENT: Color32 = Color32::from_rgb(96, 165, 250); |
| 13 | +const SUCCESS: Color32 = Color32::from_rgb(74, 222, 128); |
| 14 | +const ERROR: Color32 = Color32::from_rgb(248, 113, 113); |
| 15 | + |
| 16 | +fn configure_visuals(ctx: &egui::Context) { |
| 17 | + ctx.set_visuals(egui::Visuals { |
| 18 | + panel_fill: BG, |
| 19 | + window_fill: BG, |
| 20 | + override_text_color: Some(TEXT_PRIMARY), |
| 21 | + ..egui::Visuals::dark() |
| 22 | + }); |
| 23 | +} |
| 24 | + |
| 25 | +fn status_color(status: &str) -> Color32 { |
| 26 | + let s = status.to_ascii_lowercase(); |
| 27 | + if s.contains("fail") || s.contains("error") { |
| 28 | + ERROR |
| 29 | + } else if s.contains("installed") || s.contains("success") || s.contains("restart") || s.contains("done") { |
| 30 | + SUCCESS |
| 31 | + } else if s.contains("download") || s.contains("resolv") || s.contains("install") { |
| 32 | + ACCENT |
| 33 | + } else { |
| 34 | + TEXT_SECONDARY |
| 35 | + } |
| 36 | +} |
| 37 | + |
| 38 | +pub fn run_gui(config: InstallerConfig) -> i32 { |
| 39 | + let (tx, rx) = mpsc::channel::<InstallerEvent>(); |
| 40 | + let _worker = spawn_update_worker(config.clone(), tx); |
| 41 | + let exit_code = Arc::new(AtomicI32::new(1)); |
| 42 | + let exit_code_app = Arc::clone(&exit_code); |
| 43 | + |
| 44 | + let options = eframe::NativeOptions { |
| 45 | + viewport: egui::ViewportBuilder::default() |
| 46 | + .with_inner_size([480.0, 220.0]) |
| 47 | + .with_resizable(false), |
| 48 | + ..Default::default() |
| 49 | + }; |
| 50 | + |
| 51 | + let ver = config.version.clone(); |
| 52 | + let result = eframe::run_native( |
| 53 | + "CGS Updater", |
| 54 | + options, |
| 55 | + Box::new(move |cc| { |
| 56 | + configure_visuals(&cc.egui_ctx); |
| 57 | + Ok(Box::new(UpdaterApp::new(ver, rx, exit_code_app))) |
| 58 | + }), |
| 59 | + ); |
| 60 | + |
| 61 | + if result.is_err() { |
| 62 | + return 1; |
| 63 | + } |
| 64 | + exit_code.load(Ordering::Relaxed) |
| 65 | +} |
| 66 | + |
| 67 | +struct UpdaterApp { |
| 68 | + version: String, |
| 69 | + status: String, |
| 70 | + progress: u8, |
| 71 | + rx: mpsc::Receiver<InstallerEvent>, |
| 72 | + exit_code: Arc<AtomicI32>, |
| 73 | + close_at: Option<Instant>, |
| 74 | +} |
| 75 | + |
| 76 | +impl UpdaterApp { |
| 77 | + fn new( |
| 78 | + version: String, |
| 79 | + rx: mpsc::Receiver<InstallerEvent>, |
| 80 | + exit_code: Arc<AtomicI32>, |
| 81 | + ) -> Self { |
| 82 | + Self { |
| 83 | + version, |
| 84 | + status: "Preparing update...".into(), |
| 85 | + progress: 0, |
| 86 | + rx, |
| 87 | + exit_code, |
| 88 | + close_at: None, |
| 89 | + } |
| 90 | + } |
| 91 | + |
| 92 | + fn drain_events(&mut self) { |
| 93 | + while let Ok(ev) = self.rx.try_recv() { |
| 94 | + match ev { |
| 95 | + InstallerEvent::Progress { percent, status } => { |
| 96 | + self.progress = percent.min(100); |
| 97 | + self.status = status; |
| 98 | + } |
| 99 | + InstallerEvent::Finished { exit_code, message } => { |
| 100 | + self.exit_code.store(exit_code, Ordering::Relaxed); |
| 101 | + self.status = message; |
| 102 | + if exit_code == 0 { |
| 103 | + self.progress = 100; |
| 104 | + self.close_at = Some(Instant::now() + Duration::from_millis(1500)); |
| 105 | + } |
| 106 | + } |
| 107 | + InstallerEvent::Fatal { message } => { |
| 108 | + self.exit_code.store(1, Ordering::Relaxed); |
| 109 | + self.status = message; |
| 110 | + } |
| 111 | + } |
| 112 | + } |
| 113 | + } |
| 114 | +} |
| 115 | + |
| 116 | +impl eframe::App for UpdaterApp { |
| 117 | + fn update(&mut self, ctx: &egui::Context, _frame: &mut eframe::Frame) { |
| 118 | + self.drain_events(); |
| 119 | + |
| 120 | + if let Some(t) = self.close_at { |
| 121 | + if Instant::now() >= t { |
| 122 | + ctx.send_viewport_cmd(egui::ViewportCommand::Close); |
| 123 | + return; |
| 124 | + } |
| 125 | + ctx.request_repaint_after(Duration::from_millis(50)); |
| 126 | + } |
| 127 | + |
| 128 | + let panel = Frame::new() |
| 129 | + .inner_margin(Margin { left: 30, right: 30, top: 28, bottom: 20 }) |
| 130 | + .corner_radius(8.0) |
| 131 | + .fill(BG); |
| 132 | + |
| 133 | + egui::CentralPanel::default().frame(panel).show(ctx, |ui| { |
| 134 | + ui.label(RichText::new("CGS Updater").size(22.0).strong().color(TEXT_PRIMARY)); |
| 135 | + ui.add_space(4.0); |
| 136 | + ui.label(RichText::new(format!("v{}", self.version)).size(13.0).color(TEXT_SECONDARY)); |
| 137 | + ui.add_space(12.0); |
| 138 | + ui.separator(); |
| 139 | + ui.add_space(12.0); |
| 140 | + ui.label(RichText::new(&self.status).size(14.0).color(status_color(&self.status))); |
| 141 | + ui.add_space(16.0); |
| 142 | + ui.add( |
| 143 | + egui::ProgressBar::new(self.progress as f32 / 100.0) |
| 144 | + .fill(ACCENT) |
| 145 | + .show_percentage(), |
| 146 | + ); |
| 147 | + }); |
| 148 | + |
| 149 | + ctx.request_repaint_after(Duration::from_millis(100)); |
| 150 | + } |
| 151 | +} |
0 commit comments