43 lines
1.7 KiB
Rust
43 lines
1.7 KiB
Rust
use crate::{MainWindow, ProgressToSend};
|
|
|
|
use crossbeam_channel::Receiver;
|
|
use czkawka_core::common_dir_traversal::ProgressData;
|
|
use slint::{ComponentHandle, SharedString};
|
|
use std::thread;
|
|
|
|
pub fn connect_progress_gathering(app: &MainWindow, progress_receiver: Receiver<ProgressData>) {
|
|
let a = app.as_weak();
|
|
|
|
thread::spawn(move || loop {
|
|
let Ok(progress_data) = progress_receiver.recv() else {
|
|
return; // Channel closed
|
|
};
|
|
|
|
a.upgrade_in_event_loop(move |app| {
|
|
let (all_stages, current_stage) = common_get_data(&progress_data);
|
|
let to_send = ProgressToSend {
|
|
all_progress: (all_stages * 100.0) as i32,
|
|
current_progress: (current_stage * 100.0) as i32,
|
|
step_name: SharedString::from(format!("Checked {} folders", progress_data.entries_checked)),
|
|
};
|
|
|
|
app.set_progress_datas(to_send);
|
|
})
|
|
.unwrap();
|
|
});
|
|
}
|
|
fn common_get_data(item: &ProgressData) -> (f64, f64) {
|
|
if item.entries_to_check != 0 {
|
|
let all_stages = (item.current_stage as f64 + (item.entries_checked) as f64 / item.entries_to_check as f64) / (item.max_stage + 1) as f64;
|
|
let all_stages = if all_stages > 0.99 { 0.99 } else { all_stages };
|
|
|
|
let current_stage = (item.entries_checked) as f64 / item.entries_to_check as f64;
|
|
let current_stage = if current_stage > 0.99 { 0.99 } else { current_stage };
|
|
(all_stages, current_stage)
|
|
} else {
|
|
let all_stages = (item.current_stage as f64) / (item.max_stage + 1) as f64;
|
|
let all_stages = if all_stages > 0.99 { 0.99 } else { all_stages };
|
|
(all_stages, 0f64)
|
|
}
|
|
}
|