custom-gui-packages/pikman-update-manager
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ref installer

Browse Source
This commit is contained in:
Ward from fusion-voyager-3 2024-10-02 16:06:34 +03:00
parent 23fc06078e
commit a74b53d6c8
2 changed files with 488 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

487
src/bin/gui/flatpak_manage_page/install_ref_dialog.rs Normal file
View File

@ -0,0 +1,487 @@
use crate::apt_package_row::AptPackageRow;
use adw::gio::SimpleAction;
use adw::prelude::*;
use apt_deb822_tools::Deb822Repository;
use libflatpak::builders::RemoteRefBuilder;
use regex::{bytes, Regex};
use gtk::glib::{property::PropertyGet, clone, BoxedAnyObject, MainContext};
use gtk::*;
use std::cell::Ref;
use std::ops::Deref;
use pika_unixsocket_tools::pika_unixsocket_tools::*;
use rust_apt::cache::*;
use rust_apt::new_cache;
use rust_apt::records::RecordField;
use std::cell::RefCell;
use std::process::Command;
use std::rc::Rc;
use std::thread;
use tokio::runtime::Runtime;
use libflatpak::prelude::*;
use std::io::Write;
use libflatpak::InstalledRef;
use std::fs::OpenOptions;
use pretty_bytes::converter::convert;
pub fn install_ref_dialog_fn(
window: adw::ApplicationWindow,
reload_action: &gio::SimpleAction,
flatpak_retry_signal_action: &SimpleAction,
)
{
let flatpak_ref_install_dialog_child_box = Box::builder()
.hexpand(true)
.orientation(Orientation::Vertical)
.build();
let flatpak_ref_install_name_entry = gtk::Entry::builder()
.placeholder_text("Flathub")
.build();
let flatpak_ref_install_name_prefrencesgroup = adw::PreferencesGroup::builder()
.title(t!("flatpak_ref_install_name_prefrencesgroup_title"))
.build();
flatpak_ref_install_name_prefrencesgroup.add(&flatpak_ref_install_name_entry);
let flatpak_ref_install_url_entry = gtk::Entry::builder()
.placeholder_text("https://dl.flathub.org/repo/flathub.flatpakrepo")
.build();
let flatpak_ref_install_url_prefrencesgroup = adw::PreferencesGroup::builder()
.title(t!("flatpak_ref_install_url_prefrencesgroup_title"))
.build();
flatpak_ref_install_url_prefrencesgroup.add(&flatpak_ref_install_url_entry);
let flatpak_ref_install_box2 = gtk::Box::builder()
.margin_top(10)
.orientation(Orientation::Horizontal)
.hexpand(true)
.spacing(5)
.build();
let flatpak_remote_user_togglebutton = gtk::ToggleButton::builder()
.valign(Align::Center)
.hexpand(true)
.label(t!("flatpak_remotes_columnview_user"))
.active(true)
.build();
let flatpak_remote_system_togglebutton = gtk::ToggleButton::builder()
.valign(Align::Center)
.hexpand(true)
.label(t!("flatpak_remotes_columnview_system"))
.group(&flatpak_remote_user_togglebutton)
.build();
//
let flatpak_ref_install_dialog_child_clamp = adw::Clamp::builder()
.child(&flatpak_ref_install_dialog_child_box)
.maximum_size(500)
.build();
let flatpak_ref_install_viewport = gtk::ScrolledWindow::builder()
.hexpand(true)
.vexpand(true)
.child(&flatpak_ref_install_dialog_child_clamp)
.hscrollbar_policy(PolicyType::Never)
.build();
let flatpak_ref_install_dialog = adw::MessageDialog::builder()
.transient_for(&window)
.extra_child(&flatpak_ref_install_viewport)
.heading(t!("flatpak_ref_install_dialog_heading"))
.width_request(700)
.height_request(400)
.build();
flatpak_ref_install_dialog.add_response(
"flatpak_ref_install_dialog_add",
&t!("flatpak_ref_install_dialog_add_label").to_string(),
);
flatpak_ref_install_dialog.add_response(
"flatpak_ref_install_dialog_cancel",
&t!("flatpak_ref_install_dialog_cancel_label").to_string(),
);
flatpak_ref_install_dialog.set_response_enabled("flatpak_ref_install_dialog_add", false);
flatpak_ref_install_dialog.set_response_appearance(
"flatpak_ref_install_dialog_cancel",
adw::ResponseAppearance::Destructive,
);
flatpak_ref_install_dialog.set_response_appearance(
"flatpak_ref_install_dialog_add",
adw::ResponseAppearance::Suggested,
);
//
let flatpak_ref_install_dialog_clone0 = flatpak_ref_install_dialog.clone();
let flatpak_ref_install_name_entry_clone0 = flatpak_ref_install_name_entry.clone();
let flatpak_ref_install_url_entry_clone0 = flatpak_ref_install_url_entry.clone();
let add_button_update_state = move || {
if
!flatpak_ref_install_name_entry_clone0.text().is_empty() &&
!flatpak_ref_install_url_entry_clone0.text().is_empty()
{
flatpak_ref_install_dialog_clone0.set_response_enabled("flatpak_ref_install_dialog_add", true);
} else {
flatpak_ref_install_dialog_clone0.set_response_enabled("flatpak_ref_install_dialog_add", false);
}
};
//
for entry in [
&flatpak_ref_install_name_entry,
&flatpak_ref_install_url_entry,
] {
entry.connect_text_notify(clone!(
#[strong]
add_button_update_state,
move |_|
{
add_button_update_state();
}
)
);
}
//
flatpak_ref_install_box2.append(&flatpak_remote_user_togglebutton);
flatpak_ref_install_box2.append(&flatpak_remote_system_togglebutton);
flatpak_ref_install_dialog_child_box.append(&flatpak_ref_install_name_prefrencesgroup);
flatpak_ref_install_dialog_child_box.append(&flatpak_ref_install_url_prefrencesgroup);
flatpak_ref_install_dialog_child_box.append(&flatpak_ref_install_box2);
let reload_action_clone0 = reload_action.clone();
let flatpak_retry_signal_action_clone0 = flatpak_retry_signal_action.clone();
flatpak_ref_install_dialog.clone()
.choose(None::<&gio::Cancellable>, move |choice| {
match choice.as_str() {
"flatpak_ref_install_dialog_add" => {
/*let cancellable_no = libflatpak::gio::Cancellable::NONE;
let flatpak_installation = match flatpak_remote_system_togglebutton.is_active() {
true => libflatpak::Installation::new_system(cancellable_no).unwrap(),
false => libflatpak::Installation::new_user(cancellable_no).unwrap(),
};
match libflatpak::Remote::from_file(&flatpak_ref_install_name_entry.text(), &get_data_from_url(&flatpak_ref_install_url_entry.text()).unwrap()) {
Ok(remote) => {
match libflatpak::Installation::add_remote(&flatpak_installation, &remote, true, cancellable_no) {
Ok(_) => {
reload_action_clone0.activate(None);
}
Err(e) => {
let flatpak_ref_install_error_dialog = adw::MessageDialog::builder()
.heading(t!("flatpak_ref_install_error_dialog_heading"))
.body(e.to_string())
.build();
flatpak_ref_install_error_dialog.add_response(
"flatpak_ref_install_error_dialog_ok",
&t!("flatpak_ref_install_error_dialog_ok_label").to_string(),
);
flatpak_ref_install_error_dialog.present();
}
}
}
Err(e) => {
let flatpak_ref_install_error_dialog = adw::MessageDialog::builder()
.heading(t!("flatpak_ref_install_error_dialog_heading"))
.body(e.to_string())
.build();
flatpak_ref_install_error_dialog.add_response(
"flatpak_ref_install_error_dialog_ok",
&t!("flatpak_ref_install_error_dialog_ok_label").to_string(),
);
}
}*/
/*let flatpak_installation = match flatpak_remote_system_togglebutton.is_active() {
true => "--system",
false => "--user"
};
match duct::cmd!("flatpak", "remote-add", "--if-not-exists", &flatpak_installation, &flatpak_ref_install_name_entry.text(), &flatpak_ref_install_url_entry.text()).run() {
Ok(_) => {
reload_action_clone0.activate(None);
flatpak_retry_signal_action_clone0.activate(None);
}
Err(e) => {
let flatpak_ref_install_error_dialog = adw::MessageDialog::builder()
.heading(t!("flatpak_ref_install_error_dialog_heading"))
.body(e.to_string())
.build();
flatpak_ref_install_error_dialog.add_response(
"flatpak_ref_install_error_dialog_ok",
&t!("flatpak_ref_install_error_dialog_ok_label").to_string(),
);
flatpak_ref_install_error_dialog.present();
}
}*/
}
_ => {}
}
});
}
pub fn run_flatpak_ref_install_transaction(retry_signal_action: &gio::SimpleAction, is_system: bool, window: adw::ApplicationWindow, flatref_path: &str) {
let (transaction_percent_sender, transaction_percent_receiver) =
async_channel::unbounded::<u32>();
let transaction_percent_sender = transaction_percent_sender.clone();
let (transaction_status_sender, transaction_status_receiver) =
async_channel::unbounded::<String>();
let transaction_status_sender = transaction_status_sender.clone();
let flatref_path_clone0 = flatref_path.clone().to_owned();
thread::spawn(move || {
let cancellable_no = libflatpak::gio::Cancellable::NONE;
let transaction_status_sender0 = transaction_status_sender.clone();
let transaction_percent_sender0 = transaction_percent_sender.clone();
let transaction_run_closure =
move |transaction: &libflatpak::Transaction,
transaction_operation: &libflatpak::TransactionOperation,
transaction_progress: &libflatpak::TransactionProgress| {
let transaction_status_sender = transaction_status_sender0.clone();
let transaction_percent_sender = transaction_percent_sender0.clone();
transaction_progress.connect_changed(clone!(@strong transaction_progress, @strong transaction_operation => move |_| {
let status_message = format!("{}: {}\n{}: {}\n{}: {}/{}\n{}: {}", t!("flatpak_ref"), transaction_operation.get_ref().unwrap_or(libflatpak::glib::GString::from_string_unchecked("Unknown".to_owned())), t!("flatpak_status") ,transaction_progress.status().unwrap_or(libflatpak::glib::GString::from_string_unchecked("Unknown".to_owned())), t!("flatpak_transaction_bytes_transferred"), convert(transaction_progress.bytes_transferred() as f64), convert(transaction_operation.download_size() as f64), t!("flatpak_transaction_installed_size"), convert(transaction_operation.installed_size() as f64));
transaction_status_sender.send_blocking(status_message).expect("transaction_status_receiver closed!");
transaction_percent_sender.send_blocking(transaction_progress.progress().try_into().unwrap_or(0)).expect("transaction_percent_receiver closed!");
}));
};
//
let (flatpak_installation, flatpak_transaction) = match is_system {
true => {
let installation = libflatpak::Installation::new_system(cancellable_no).unwrap();
let transaction = libflatpak::Transaction::for_installation(&installation, cancellable_no).unwrap();
(installation, transaction)
}
false => {
let installation = libflatpak::Installation::new_user(cancellable_no).unwrap();
let transaction = libflatpak::Transaction::for_installation(&installation, cancellable_no).unwrap();
(installation, transaction)
}
};
flatpak_transaction.connect_new_operation(transaction_run_closure.clone());
match get_data_from_filepath(&flatref_path_clone0) {
Ok(t) => {
flatpak_transaction.add_install_flatpakref(&t).unwrap();
}
Err(e) => {
transaction_status_sender
.send_blocking(e.to_string())
.expect("transaction_sync_status_receiver closed");
transaction_status_sender
.send_blocking("FN_OVERRIDE_FAILED".to_owned())
.expect("transaction_sync_status_receiver closed");
panic!("{}", e);
}
}
//
match flatpak_transaction.run(cancellable_no) {
Ok(_) => {
transaction_status_sender
.send_blocking("FN_OVERRIDE_SUCCESSFUL".to_owned())
.expect("transaction_sync_status_receiver closed");
}
Err(e) => {
transaction_status_sender
.send_blocking(e.to_string())
.expect("transaction_sync_status_receiver closed");
transaction_status_sender
.send_blocking("FN_OVERRIDE_FAILED".to_owned())
.expect("transaction_sync_status_receiver closed");
panic!("{}", e);
}
}
});
let log_file_path = format!(
"/tmp/pika-flatpak-transaction_{}.log",
chrono::offset::Local::now().format("%Y-%m-%d_%H:%M")
);
let log_file_path_clone0 = log_file_path.clone();
if !std::path::Path::new(&log_file_path).exists() {
match std::fs::File::create(&log_file_path) {
Ok(_) => {}
Err(_) => {
eprintln!("Warning: {} file couldn't be created", log_file_path);
}
};
}
let flatpak_transaction_dialog_child_box =
Box::builder().orientation(Orientation::Vertical).build();
let flatpak_transaction_dialog_progress_bar =
ProgressBar::builder().show_text(true).hexpand(true).build();
let flatpak_transaction_dialog_spinner = Spinner::builder()
.hexpand(true)
.valign(Align::Start)
.halign(Align::Center)
.spinning(true)
.height_request(128)
.width_request(128)
.build();
flatpak_transaction_dialog_child_box.append(&flatpak_transaction_dialog_spinner);
flatpak_transaction_dialog_child_box.append(&flatpak_transaction_dialog_progress_bar);
let flatpak_transaction_dialog =
adw::MessageDialog::builder()
.transient_for(&window)
.extra_child(&flatpak_transaction_dialog_child_box)
.heading(t!("flatpak_transaction_dialog_heading"))
.width_request(500)
.build();
flatpak_transaction_dialog.add_response(
"flatpak_transaction_dialog_ok",
&t!("flatpak_transaction_dialog_ok_label").to_string(),
);
let flatpak_transaction_dialog_child_box_done =
Box::builder().orientation(Orientation::Vertical).build();
let flatpak_transaction_log_image = Image::builder()
.pixel_size(128)
.halign(Align::Center)
.build();
let flatpak_transaction_log_button = Button::builder()
.label(t!("flatpak_transaction_dialog_open_log_file_label"))
.halign(Align::Center)
.margin_start(15)
.margin_end(15)
.margin_top(15)
.margin_bottom(15)
.build();
flatpak_transaction_dialog_child_box_done.append(&flatpak_transaction_log_image);
flatpak_transaction_dialog_child_box_done.append(&flatpak_transaction_log_button);
flatpak_transaction_dialog.set_response_enabled("flatpak_transaction_dialog_ok", false);
flatpak_transaction_dialog.set_close_response("flatpak_transaction_dialog_ok");
let transaction_percent_server_context = MainContext::default();
// The main loop executes the asynchronous block
transaction_percent_server_context.spawn_local(clone!(
#[weak]
flatpak_transaction_dialog_progress_bar,
async move {
while let Ok(state) = transaction_percent_receiver.recv().await {
flatpak_transaction_dialog_progress_bar.set_fraction((state as f32 / 100.0).into());
}
}
));
let transaction_status_server_context = MainContext::default();
// The main loop executes the asynchronous block
transaction_status_server_context.spawn_local(clone!(
#[weak]
flatpak_transaction_dialog,
#[weak]
flatpak_transaction_dialog_child_box,
#[strong]
flatpak_transaction_dialog_child_box_done,
#[strong]
flatpak_transaction_log_image,
async move {
while let Ok(state) = transaction_status_receiver.recv().await {
match state.as_ref() {
"FN_OVERRIDE_SUCCESSFUL" => {
flatpak_transaction_dialog_child_box.set_visible(false);
flatpak_transaction_log_image.set_icon_name(Some("face-cool-symbolic"));
flatpak_transaction_dialog
.set_extra_child(Some(&flatpak_transaction_dialog_child_box_done));
flatpak_transaction_dialog.set_title(Some(
&t!("flatpak_transaction_dialog_status_successful").to_string(),
));
flatpak_transaction_dialog
.set_response_enabled("flatpak_transaction_dialog_ok", true);
}
"FN_OVERRIDE_FAILED" => {
flatpak_transaction_dialog_child_box.set_visible(false);
flatpak_transaction_log_image.set_icon_name(Some("dialog-error-symbolic"));
flatpak_transaction_dialog
.set_extra_child(Some(&flatpak_transaction_dialog_child_box_done));
flatpak_transaction_dialog.set_title(Some(
&t!("flatpak_transaction_dialog_status_failed").to_string(),
));
flatpak_transaction_dialog
.set_response_enabled("flatpak_transaction_dialog_ok", true);
flatpak_transaction_dialog
.set_response_enabled("flatpak_transaction_dialog_open_log_file", true);
}
_ => {
flatpak_transaction_dialog.set_body(&state);
let mut log_file = OpenOptions::new()
.write(true)
.append(true)
.open(&log_file_path)
.unwrap();
if let Err(e) = writeln!(
log_file,
"[{}] {}",
chrono::offset::Local::now().format("%Y/%m/%d_%H:%M"),
state
) {
eprintln!("Couldn't write to file: {}", e);
}
}
}
}
}
));
let retry_signal_action0 = retry_signal_action.clone();
flatpak_transaction_log_button.connect_clicked(move |_| {
let _ = Command::new("xdg-open")
.arg(log_file_path_clone0.to_owned())
.spawn();
});
flatpak_transaction_dialog.choose(None::<&gio::Cancellable>, move |choice| {
match choice.as_str() {
"flatpak_transaction_dialog_ok" => {
retry_signal_action0.activate(None);
}
_ => {}
}
});
}
fn get_data_from_filepath(filepath: &str) -> Result<libflatpak::glib::Bytes, std::io::Error> {
let data = std::fs::read_to_string(filepath)?;
let bytes = data.as_bytes();
let glib_bytes = libflatpak::glib::Bytes::from(bytes);
Ok(glib_bytes)
}

1
src/bin/gui/flatpak_manage_page/mod.rs
View File

@ -24,6 +24,7 @@ use libflatpak::prelude::*;
use libflatpak::InstalledRef; use libflatpak::InstalledRef;
mod add_dialog; mod add_dialog;
mod install_ref_dialog;
enum FlatpakRemote { enum FlatpakRemote {
System(libflatpak::Remote), System(libflatpak::Remote),