diff options
Diffstat (limited to 'Rpmdrake/edit_urpm_sources.pm')
| -rwxr-xr-x | Rpmdrake/edit_urpm_sources.pm | 1081 |
1 files changed, 1081 insertions, 0 deletions
diff --git a/Rpmdrake/edit_urpm_sources.pm b/Rpmdrake/edit_urpm_sources.pm new file mode 100755 index 00000000..04aa1cc0 --- /dev/null +++ b/Rpmdrake/edit_urpm_sources.pm @@ -0,0 +1,1081 @@ +package Rpmdrake::edit_urpm_sources; +#***************************************************************************** +# +# Copyright (c) 2002 Guillaume Cottenceau +# Copyright (c) 2002-2007 Thierry Vignaud <tvignaud@mandriva.com> +# Copyright (c) 2002-2007 Mandriva Linux +# +# This program is free software; you can redistribute it and/or modify +# it under the terms of the GNU General Public License version 2, as +# published by the Free Software Foundation. +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program; if not, write to the Free Software +# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. +# +#***************************************************************************** +# +# $Id$ + + +use strict; +use lib qw(/usr/lib/libDrakX); +use common; +use rpmdrake; +use URPM::Signature; +use POSIX qw(_exit); +use MDK::Common qw(max); +use urpm::media; +use urpm::download; +use urpm::lock; + +use Exporter; +our @ISA = qw(Exporter); +our @EXPORT = qw(check_if_first_run run); + +use mygtk2 qw(gtknew gtkset); +use ugtk2 qw(:all); + +my $urpm; +my ($mainw, $list_tv); + +sub selrow { + my ($o_list_tv) = @_; + defined $o_list_tv or $o_list_tv = $list_tv; + my ($model, $iter) = $o_list_tv->get_selection->get_selected; + $model && $iter or return -1; + my $path = $model->get_path($iter); + my $row = $path->to_string; + return $row; +} + +sub remove_row { + my ($model, $path_str) = @_; + my $iter = $model->get_iter_from_string($path_str); + $iter or return; + $model->remove($iter); +} + +sub easy_add_callback() { + #- cooker and community don't have update sources + my $want_base_distro = distro_type(0) eq 'updates' ? interactive_msg( + N("Choose media type"), +N("This step enables you to add sources from a Mandriva Linux web or FTP mirror. + +There are two kinds of official mirrors. You can choose to add sources that +contain the complete set of packages of your distribution (usually a superset +of what comes on the standard installation CDs), or sources that provide the +official updates for your distribution. (You can add both, but you'll have +to do this in two steps.)"), + transient => $::main_window, + yesno => 1, text => { yes => N("Distribution sources"), no => N("Official updates") }, + ) : 1; + my ($mirror) = choose_mirror(message => +N("This will attempt to install all official sources corresponding to your +distribution (%s). + +I need to contact the Mandriva website to get the mirror list. +Please check that your network is currently running. + +Is it ok to continue?", $rpmdrake::mandrake_release), + want_base_distro => $want_base_distro, + transient => $::main_window, + ) or return 0; + ref $mirror or return; + my $m = $mirror->{url}; + my $is_update = $mirror->{type} eq 'updates'; + $m = make_url_mirror($m) if $is_update; # because updates media do not provide media.cfg yet + my $wait = wait_msg(N("Please wait, adding media...")); + my $url = $m; + my $medium_name; + if ($want_base_distro && !$is_update) { + if ($rpmdrake::mandrake_release =~ /(\d+\.\d+) \((\w+)\)/) { + $medium_name = $2 . $1 . '-'; + } else { + $medium_name = 'distrib'; + } + #- ensure a unique medium name + my $initial_number = 1 + max map { $_->{name} =~ /\(\Q$medium_name\E(\d+)\b/ ? $1 : 0 } @{$urpm->{media}}; + add_medium_and_check( + $urpm, + { nolock => 1, distrib => 1 }, + $medium_name, $url, probe_with => 'synthesis', initial_number => $initial_number, + usedistrib => 1, + ); + } else { + $medium_name = 'update_source'; + #- ensure a unique medium name + my $nb_sources = max map { $_->{name} =~ /^\Q$medium_name\E(\d*)$/ ? $1 || 1 : 0 } @{$urpm->{media}}; + if ($nb_sources) { $medium_name .= $nb_sources + 1 } + add_medium_and_check( + $urpm, + { nolock => 1, probe_with => 1 }, + $medium_name, $url, '', update => 1, + ); + } + remove_wait_msg($wait); + return 1; +} + +sub add_callback() { + my $w = ugtk2->new(N("Add a medium"), grab => 1, center => 1, transient => $::main_window); + my $prev_main_window = $::main_window; + local $::main_window = $w->{real_window}; + my %radios_infos = ( + local => { name => N("Local files"), url => N("Path:"), dirsel => 1 }, + ftp => { name => N("FTP server"), url => N("URL:"), loginpass => 1 }, + rsync => { name => N("RSYNC server"), url => N("URL:") }, + http => { name => N("HTTP server"), url => N("URL:") }, + removable => { name => N("Removable device"), url => N("Path or mount point:"), dirsel => 1 }, + ); + my @radios_names_ordered = qw(local ftp rsync http removable); + # TODO: replace NoteBook by sensitive widgets and Label->set() + my $notebook = gtknew('Notebook'); + $notebook->set_show_tabs(0); $notebook->set_show_border(0); + my ($count_nbs, %pages); + my $size_group = Gtk2::SizeGroup->new('horizontal'); + my ($cb1, $cb2); + foreach (@radios_names_ordered) { + my $info = $radios_infos{$_}; + my $url_entry = sub { + gtkpack_( + gtknew('HBox'), + 1, $info->{url_entry} = gtkentry(), + if_( + $info->{dirsel}, + 0, gtksignal_connect( + gtknew('Button', text => but(N("Browse..."))), + clicked => sub { $info->{url_entry}->set_text(ask_dir()) }, + ) + ), + ); + }; + my $checkbut_entry = sub { + my ($name, $label, $visibility, $callback, $tip) = @_; + my $w = [ gtksignal_connect( + $info->{$name . '_check'} = gtkset(gtknew('CheckButton', text => $label), tip => $tip), + clicked => sub { + $info->{$name . '_entry'}->set_sensitive($_[0]->get_active); + $callback and $callback->(@_); + }, + ), + gtkset_visibility(gtkset_sensitive($info->{$name . '_entry'} = gtkentry(), 0), $visibility) ]; + $size_group->add_widget($info->{$name . '_check'}); + $w; + }; + my $loginpass_entries = sub { + map { + $checkbut_entry->( + @$_, sub { + $info->{pass_check}->set_active($_[0]->get_active); + $info->{login_check}->set_active($_[0]->get_active); + } + ); + } ([ 'login', N("Login:"), 1 ], [ 'pass', N("Password:"), 0 ]); + }; + $pages{$info->{name}} = $count_nbs++; + my $with_hdlist_checkbut_entry; + $with_hdlist_checkbut_entry = $checkbut_entry->( + 'hdlist', N("Relative path to synthesis/hdlist:"), 1, + sub { $info->{distrib_check} and $_[0]->get_active and $info->{distrib_check}->set_active(0) }, + N("If left blank, synthesis/hdlist will be automatically probed"), + ); + $notebook->append_page( + gtkshow(create_packtable( + { xpadding => 0, ypadding => 0 }, + [ gtkset_alignment(gtknew('Label', text => N("Name:")), 0, 0.5), + $info->{name_entry} = gtkentry('') ], + [ gtkset_alignment(gtknew('Label', text => $info->{url}), 0, 0.5), + $url_entry->() ], + $with_hdlist_checkbut_entry, + if_($info->{loginpass}, $loginpass_entries->()), + sub { + [ gtksignal_connect( + $info->{distrib_check} = $cb1 = gtknew('CheckButton', text => N("Create media for a whole distribution")), + clicked => sub { + if ($_[0]->get_active) { + $info->{hdlist_entry}->set_sensitive(0); + $info->{hdlist_check}->set_active(0); + } + }, + ) + ]; + }->(), + sub { + [ $info->{update_check} = $cb2 = gtknew('CheckButton', text => N("Search this media for updates")) ]; + }->(), + )) + ); + } + $size_group->add_widget($_) foreach $cb1, $cb2; + + my $checkok = sub { + my $info = $radios_infos{$radios_names_ordered[$notebook->get_current_page]}; + my ($name, $url) = map { $info->{$_ . '_entry'}->get_text } qw(name url); + $name eq '' || $url eq '' and interactive_msg('rpmdrake', N("You need to fill up at least the two first entries.")), return 0; + if (member($name, map { $_->{name} } @{$urpm->{media}})) { + $info->{name_entry}->select_region(0, -1); + interactive_msg('rpmdrake', +N("There is already a medium by that name, do you +really want to replace it?"), yesno => 1) or return 0; + } + 1; + }; + + my $type = 'local'; + my ($probe, %i, %make_url); + gtkadd( + $w->{window}, + gtkpack( + gtknew('VBox', spacing => 5), + gtknew('Title2', label => N("Adding a medium:")), + gtknew('HBox', children_tight => [ + Gtk2::Label->new(but(N("Type of medium:"))), + gtknew('ComboBox', text_ref => \$type, + list => \@radios_names_ordered, + format => sub { $radios_infos{$_[0]}{name} }, + changed => sub { $notebook->set_current_page($pages{$_[0]->get_text}) }) + ]), + $notebook, + gtknew('HSeparator'), + gtkpack( + gtknew('HButtonBox'), + gtknew('Button', text => N("Cancel"), clicked => sub { $w->{retval} = 0; Gtk2->main_quit }), + gtksignal_connect( + gtknew('Button', text => N("Ok")), clicked => sub { + if ($checkok->()) { + $w->{retval} = { nb => $notebook->get_current_page }; + my $info = $radios_infos{$type}; + %i = ( + name => $info->{name_entry}->get_text, + url => $info->{url_entry}->get_text, + hdlist => $info->{hdlist_entry}->get_text, + distrib => $info->{distrib_check} ? $info->{distrib_check}->get_active : 0, + update => $info->{update_check}->get_active ? 1 : undef, + ); + %make_url = ( + local => "file:/$i{url}", + http => $i{url}, + rsync => $i{url}, + removable => "removable:/$i{url}", + ); + $i{url} =~ s|^ftp://||; + $make_url{ftp} = sprintf "ftp://%s%s", + $info->{login_check}->get_active + ? ($info->{login_entry}->get_text . ':' . $info->{pass_entry}->get_text . '@') + : '', + $i{url}; + $probe = $info->{hdlist_check}->get_active == 0 || $i{hdlist} eq ''; + Gtk2->main_quit; + } + }, + ), + ), + ), + ); + + if ($w->main) { + $::main_window = $prev_main_window; + if ($i{distrib}) { + add_medium_and_check( + $urpm, + { nolock => 1, distrib => 1 }, + $i{name}, $make_url{$type}, probe_with => 'synthesis', update => $i{update}, + ); + } else { + if (member($i{name}, map { $_->{name} } @{$urpm->{media}})) { + urpm::media::select_media($urpm, $i{name}); + urpm::media::remove_selected_media($urpm); + } + add_medium_and_check( + $urpm, + { probe_with => $probe, nolock => 1 }, + $i{name}, $make_url{$type}, $i{hdlist}, update => $i{update}, + ); + } + return 1; + } + return 0; +} + +sub options_callback() { + my $w = ugtk2->new(N("Global options for package installation"), grab => 1, center => 1, transient => $::main_window); + local $::main_window = $w->{real_window}; + my @verif_radio_infos = ( + { name => N("always"), value => 1 }, + { name => N("never"), value => 0 }, + ); + my @verif_radio = gtkradio($verif_radio_infos[$urpm->{options}{'verify-rpm'} ? 0 : 1]{name}, map { $_->{name} } @verif_radio_infos); + my @avail_downloaders = urpm::download::available_ftp_http_downloaders(); + my @downl_radio = gtkradio($urpm->{options}{downloader} || $avail_downloaders[0], @avail_downloaders); + gtkadd( + $w->{window}, + gtkpack( + gtknew('VBox', spacing => 5), + gtknew('HBox', children_loose => [ gtknew('Label', text => N("Verify RPMs to be installed:")), @verif_radio ]), + gtknew('HBox', children_loose => [ gtknew('Label', text => N("Download program to use:")), @downl_radio ]), + gtkpack( + gtknew('HButtonBox'), + gtknew('Button', text => N("Cancel"), clicked => sub { Gtk2->main_quit }), + gtksignal_connect( + gtknew('Button', text => N("Ok")), clicked => sub { + foreach my $i (0 .. $#verif_radio) { + $verif_radio[$i]->get_active + and $urpm->{global_config}{'verify-rpm'} = $verif_radio_infos[$i]{value}; + } + foreach my $i (0 .. $#downl_radio) { + $downl_radio[$i]->get_active + and $urpm->{global_config}{downloader} = $avail_downloaders[$i]; + } + urpm::media::write_config($urpm); + $urpm = urpm->new; + urpm::media::read_config($urpm); + Gtk2->main_quit; + }, + ), + ), + ), + ); + $w->main; +} + +sub remove_callback() { + my $row = selrow(); + $row == -1 and return; + interactive_msg( + N("Source Removal"), + N("Are you sure you want to remove source \"%s\"?", to_utf8($urpm->{media}[$row]{name})), + yesno => 1, + transient => $::main_window, + ) or return; + + my $wait = wait_msg(N("Please wait, removing medium...")); + urpm::media::remove_media($urpm, [ $urpm->{media}[$row] ]); + urpm::media::write_urpmi_cfg($urpm); + remove_wait_msg($wait); + return 1; +} + +sub renum_media ($$$) { + my ($model, @iters) = @_; + my @rows = map { $model->get_path($_)->to_string } @iters; + my @media = map { $urpm->{media}[$_] } @rows; + $urpm->{media}[$rows[$_]] = $media[1 - $_] foreach 0, 1; + $model->swap(@iters); + urpm::media::write_config($urpm); $urpm = urpm->new; urpm::media::read_config($urpm); +} + +sub upwards_callback() { + my ($model, $iter) = $list_tv->get_selection->get_selected; $model && $iter or return; + my $prev = $model->get_iter_from_string($model->get_path($iter)->to_string - 1); + defined $prev and renum_media($model, $iter, $prev); +} + +sub downwards_callback() { + my ($model, $iter) = $list_tv->get_selection->get_selected; $model && $iter or return; + my $next = $model->iter_next($iter); + defined $next and renum_media($model, $iter, $next); +} + +#- returns the name of the media for which edition failed, or undef on success +sub edit_callback() { + my $row = selrow(); + $row == -1 and return; + my $medium = $urpm->{media}[$row]; + my $config = urpm::cfg::load_config_raw($urpm->{config}, 1); + my ($verbatim_medium) = grep { $medium->{name} eq $_->{name} } @$config; + my $w = ugtk2->new(N("Edit a medium"), grab => 1, center => 1, transient => $::main_window); + local $::main_window = $w->{real_window}; + my ($url_entry, $hdlist_entry, $downloader_entry, $url, $with_hdlist, $downloader); + gtkadd( + $w->{window}, + gtkpack_( + gtknew('VBox', spacing => 5), + 0, gtknew('Title2', label => N("Editing medium \"%s\":", $medium->{name})), + 0, create_packtable( + {}, + [ gtknew('Label_Left', text => N("URL:")), $url_entry = gtkentry($verbatim_medium->{url}) ], + [ gtknew('Label_Left', text => N("Relative path to synthesis/hdlist:")), $hdlist_entry = gtkentry($verbatim_medium->{with_hdlist}) ], + [ gtknew('Label_Left', text => N("Downloader:")), + my $download_combo = Gtk2::ComboBox->new_with_strings([ urpm::download::available_ftp_http_downloaders() ], + $verbatim_medium->{downloader} || '') ], + ), + 0, gtknew('HSeparator'), + 0, gtkpack( + gtknew('HButtonBox'), + gtksignal_connect( + gtknew('Button', text => N("Cancel")), + clicked => sub { $w->{retval} = 0; Gtk2->main_quit }, + ), + gtksignal_connect( + gtknew('Button', text => N("Save changes")), + clicked => sub { + $w->{retval} = 1; + ($url, $with_hdlist) = ($url_entry->get_text, $hdlist_entry->get_text); + $downloader = $downloader_entry->get_text; + Gtk2->main_quit; + }, + ), + gtksignal_connect( + gtknew('Button', text => N("Proxy...")), + clicked => sub { proxy_callback($medium) }, + ), + ) + ) + ); + $downloader_entry = $download_combo->entry; + $w->{rwindow}->set_size_request(600, -1); + if ($w->main) { + my ($name, $update) = map { $medium->{$_} } qw(name update); + $url =~ m|^removable://| and ( + interactive_msg( + N("You need to insert the medium to continue"), + N("In order to save the changes, you need to insert the medium in the drive."), + yesno => 1, text => { yes => N("Ok"), no => N("Cancel") } + ) or return 0 + ); + my $saved_proxy = urpm::download::get_proxy($name); + undef $saved_proxy if !defined $saved_proxy->{http_proxy} && !defined $saved_proxy->{ftp_proxy}; + urpm::media::select_media($urpm, $name); + urpm::media::remove_selected_media($urpm); + add_medium_and_check($urpm, { nolock => 1, proxy => $saved_proxy }, $name, $url, $with_hdlist, update => $update, if_($downloader, downloader => $downloader)); + return $name; + } + return undef; +} + +sub update_callback() { + update_sources_interactive($urpm, transient => $::main_window, nolock => 1); +} + +sub proxy_callback { + my ($medium) = @_; + my $medium_name = $medium ? $medium->{name} : ''; + my $w = ugtk2->new(N("Configure proxies"), grab => 1, center => 1, transient => $::main_window); + local $::main_window = $w->{real_window}; + my ($proxy, $proxy_user) = curl_download::readproxy($medium_name); + my ($user, $pass) = $proxy_user =~ /^([^:]*):(.*)$/; + my ($proxybutton, $proxyentry, $proxyuserbutton, $proxyuserentry, $proxypasswordentry); + my $sg = Gtk2::SizeGroup->new('horizontal'); + gtkadd( + $w->{window}, + gtkpack__( + gtknew('VBox', spacing => 5), + gtknew('Title2', label => + $medium_name + ? N("Proxy settings for media \"%s\"", $medium_name) + : N("Global proxy settings") + ), + gtknew('Label_Left', text => N("If you need a proxy, enter the hostname and an optional port (syntax: <proxyhost[:port]>):")), + gtkpack_( + gtknew('HBox', spacing => 10), + 1, gtkset_active($proxybutton = gtknew('CheckButton', text => N("Proxy hostname:")), to_bool($proxy)), + 0, gtkadd_widget($sg, gtkset_sensitive($proxyentry = gtkentry($proxy), to_bool($proxy))), + ), + gtkset_active($proxyuserbutton = gtknew('CheckButton', text => N("You may specify a user/password for the proxy authentication:")), to_bool($proxy_user)), + gtkpack_( + my $hb_user = gtknew('HBox', spacing => 10, sensitive => to_bool($proxy_user)), + 1, gtknew('Label_Left', text => N("User:")), + 0, gtkadd_widget($sg, $proxyuserentry = gtkentry($user)), + ), + gtkpack_( + my $hb_pswd = gtknew('HBox', spacing => 10, sensitive => to_bool($proxy_user)), + 1, gtknew('Label_Left', text => N("Password:")), + 0, gtkadd_widget($sg, gtkset_visibility($proxypasswordentry = gtkentry($pass), 0)), + ), + gtknew('HSeparator'), + gtkpack( + gtknew('HButtonBox'), + gtksignal_connect( + gtknew('Button', text => N("Ok")), + clicked => sub { + $w->{retval} = 1; + $proxy = $proxybutton->get_active ? $proxyentry->get_text : ''; + $proxy_user = $proxyuserbutton->get_active + ? ($proxyuserentry->get_text . ':' . $proxypasswordentry->get_text) : ''; + Gtk2->main_quit; + }, + ), + gtksignal_connect( + gtknew('Button', text => N("Cancel")), + clicked => sub { $w->{retval} = 0; Gtk2->main_quit }, + ) + ) + ) + ); + $sg->add_widget($_) foreach $proxyentry, $proxyuserentry, $proxypasswordentry; + $proxybutton->signal_connect( + clicked => sub { + $proxyentry->set_sensitive($_[0]->get_active); + $_[0]->get_active and return; + $proxyuserbutton->set_active(0); + $hb_user->set_sensitive(0); + $hb_pswd->set_sensitive(0); + } + ); + $proxyuserbutton->signal_connect(clicked => sub { $_->set_sensitive($_[0]->get_active) foreach $hb_user, $hb_pswd; + $proxypasswordentry->set_sensitive($_[0]->get_active) }); + + $w->main and curl_download::writeproxy($proxy, $proxy_user, $medium_name); +} + +sub parallel_read_sysconf() { + my @conf; + foreach (cat_('/etc/urpmi/parallel.cfg')) { + my ($name, $protocol, $command) = /([^:]+):([^:]+):(.*)/ or print STDERR "Warning, unrecognized line in /etc/urpmi/parallel.cfg:\n$_"; + my $medias = $protocol =~ s/\(([^\)]+)\)$// ? [ split /,/, $1 ] : []; + push @conf, { name => $name, protocol => $protocol, medias => $medias, command => $command }; + } + \@conf; +} + +sub parallel_write_sysconf { + my ($conf) = @_; + output '/etc/urpmi/parallel.cfg', + map { my $m = @{$_->{medias}} ? '(' . join(',', @{$_->{medias}}) . ')' : ''; + "$_->{name}:$_->{protocol}$m:$_->{command}\n" } @$conf; +} + +sub remove_parallel { + my ($num, $conf) = @_; + if ($num != -1) { + splice @$conf, $num, 1; + parallel_write_sysconf($conf); + } +} + +sub edit_parallel { + my ($num, $conf) = @_; + my $edited = $num == -1 ? {} : $conf->[$num]; + my $w = ugtk2->new($num == -1 ? N("Add a parallel group") : N("Edit a parallel group"), grab => 1, center => 1, transient => $::main_window); + local $::main_window = $w->{real_window}; + my $name_entry; + + my $medias_ls = Gtk2::ListStore->new("Glib::String"); + my $medias = Gtk2::TreeView->new_with_model($medias_ls); + $medias->append_column(Gtk2::TreeViewColumn->new_with_attributes(undef, Gtk2::CellRendererText->new, 'text' => 0)); + $medias->set_headers_visible(0); + $medias->get_selection->set_mode('browse'); + $medias_ls->append_set([ 0 => $_ ]) foreach @{$edited->{medias}}; + + my $add_media = sub { + my $w = ugtk2->new(N("Add a medium limit"), grab => 1, transient => $mainw->{real_window}); + local $::main_window = $w->{real_window}; + my $medias_list_ls = Gtk2::ListStore->new("Glib::String"); + my $medias_list = Gtk2::TreeView->new_with_model($medias_list_ls); + $medias_list->append_column(Gtk2::TreeViewColumn->new_with_attributes(undef, Gtk2::CellRendererText->new, 'text' => 0)); + $medias_list->set_headers_visible(0); + $medias_list->get_selection->set_mode('browse'); + $medias_list_ls->append_set([ 0 => $_->{name} ]) foreach @{$urpm->{media}}; + my $sel; + gtkadd( + $w->{window}, + gtkpack__( + gtknew('VBox', spacing => 5), + gtknew('Label', text => N("Choose a medium for adding in the media limit:")), + $medias_list, + gtknew('HSeparator'), + gtkpack( + gtknew('HButtonBox'), + gtksignal_connect( + gtknew('Button', text => N("Ok")), + clicked => sub { $w->{retval} = 1; $sel = selrow($medias_list); Gtk2->main_quit }, + ), + gtknew('Button', text => N("Cancel"), clicked => sub { $w->{retval} = 0; Gtk2->main_quit }) + ) + ) + ); + if ($w->main && $sel != -1) { + my $media = ${$urpm->{media}}[$sel]{name}; + $medias_ls->append_set([ 0 => $media ]); + push @{$edited->{medias}}, $media; + } + }; + my $remove_media = sub { + my $row = selrow($medias); + if ($row != -1) { + splice @{$edited->{medias}}, $row, 1; + remove_row($medias_ls, $row); + } + }; + + my $hosts_ls = Gtk2::ListStore->new("Glib::String"); + my $hosts = Gtk2::TreeView->new_with_model($hosts_ls); + $hosts->append_column(Gtk2::TreeViewColumn->new_with_attributes(undef, Gtk2::CellRendererText->new, 'text' => 0)); + $hosts->set_headers_visible(0); + $hosts->get_selection->set_mode('browse'); + my $hosts_list; + if ($edited->{protocol} eq 'ssh') { $hosts_list = [ split /:/, $edited->{command} ] } + elsif ($edited->{protocol} eq 'ka-run') { push @$hosts_list, $1 while $edited->{command} =~ /-m (\S+)/g } + $hosts_ls->append_set([ 0 => $_ ]) foreach @$hosts_list; + my $add_host = sub { + my $w = ugtk2->new(N("Add a host"), grab => 1, transient => $mainw->{real_window}); + local $::main_window = $w->{real_window}; + my ($entry, $value); + gtkadd( + $w->{window}, + gtkpack__( + gtknew('VBox', spacing => 5), + gtknew('Label', text => N("Type in the hostname or IP address of the host to add:")), + $entry = gtkentry(), + gtknew('HSeparator'), + gtkpack( + gtknew('HButtonBox'), + gtknew('Button', text => N("Ok"), clicked => sub { $w->{retval} = 1; $value = $entry->get_text; Gtk2->main_quit }), + gtknew('Button', text => N("Cancel"), clicked => sub { $w->{retval} = 0; Gtk2->main_quit }) + ) + ) + ); + if ($w->main) { + $hosts_ls->append_set([ 0 => $value ]); + push @$hosts_list, $value; + } + }; + my $remove_host = sub { + my $row = selrow($hosts); + if ($row != -1) { + splice @$hosts_list, $row, 1; + remove_row($hosts_ls, $row); + } + }; + + my @protocols_names = qw(ka-run ssh); + my @protocols; + gtkadd( + $w->{window}, + gtkpack_( + gtknew('VBox', spacing => 5), + if_( + $num != -1, + 0, gtknew('Label', text => N("Editing parallel group \"%s\":", $edited->{name})) + ), + 1, create_packtable( + {}, + [ N("Group name:"), $name_entry = gtkentry($edited->{name}) ], + [ N("Protocol:"), gtknew('HBox', children_tight => [ + @protocols = gtkradio($edited->{protocol}, @protocols_names) ]) ], + [ N("Media limit:"), + gtknew('HBox', spacing => 5, children => [ + 1, gtknew('Frame', shadow_type => 'in', child => + gtknew('ScrolledWindow', h_policy => 'never', child => $medias)), + 0, gtknew('VBox', children_tight => [ + gtksignal_connect(Gtk2::Button->new(but(N("Add"))), clicked => sub { $add_media->() }), + gtksignal_connect(Gtk2::Button->new(but(N("Remove"))), clicked => sub { $remove_media->() }) ]) ]) ], + [ N("Hosts:"), + gtknew('HBox', spacing => 5, children => [ + 1, gtknew('Frame', shadow_type => 'in', child => + gtknew('ScrolledWindow', h_policy => 'never', child => $hosts)), + 0, gtknew('VBox', children_tight => [ + gtksignal_connect(Gtk2::Button->new(but(N("Add"))), clicked => sub { $add_host->() }), + gtksignal_connect(Gtk2::Button->new(but(N("Remove"))), clicked => sub { $remove_host->() }) ]) ]) ] + ), + 0, gtknew('HSeparator'), + 0, gtkpack( + gtknew('HButtonBox'), + gtksignal_connect( + gtknew('Button', text => N("Ok")), clicked => sub { + $w->{retval} = 1; + $edited->{name} = $name_entry->get_text; + mapn { $_[0]->get_active and $edited->{protocol} = $_[1] } \@protocols, \@protocols_names; + Gtk2->main_quit; + } + ), + gtknew('Button', text => N("Cancel"), clicked => sub { $w->{retval} = 0; Gtk2->main_quit })) + ) + ); + $w->{rwindow}->set_size_request(600, -1); + if ($w->main) { + $num == -1 and push @$conf, $edited; + if ($edited->{protocol} eq 'ssh') { $edited->{command} = join(':', @$hosts_list) } + if ($edited->{protocol} eq 'ka-run') { $edited->{command} = "-c ssh " . join(' ', map { "-m $_" } @$hosts_list) } + parallel_write_sysconf($conf); + return 1; + } + return 0; +} + +sub parallel_callback() { + my $w = ugtk2->new(N("Configure parallel urpmi (distributed execution of urpmi)"), grab => 1, center => 1, transient => $mainw->{real_window}); + local $::main_window = $w->{real_window}; + my $list_ls = Gtk2::ListStore->new("Glib::String", "Glib::String", "Glib::String", "Glib::String"); + my $list = Gtk2::TreeView->new_with_model($list_ls); + each_index { $list->append_column(Gtk2::TreeViewColumn->new_with_attributes($_, Gtk2::CellRendererText->new, 'text' => $::i)) } N("Group"), N("Protocol"), N("Media limit"); + $list->append_column(my $commandcol = Gtk2::TreeViewColumn->new_with_attributes(N("Command"), Gtk2::CellRendererText->new, 'text' => 3)); + $commandcol->set_max_width(200); + + my $conf; + my $reread = sub { + $list_ls->clear; + $conf = parallel_read_sysconf(); + foreach (@$conf) { + $list_ls->append_set([ 0 => $_->{name}, + 1 => $_->{protocol}, + 2 => @{$_->{medias}} ? join(', ', @{$_->{medias}}) : N("(none)"), + 3 => $_->{command} ]); + } + }; + $reread->(); + + gtkadd( + $w->{window}, + gtkpack_( + gtknew('VBox', spacing => 5), + 1, gtkpack_( + gtknew('HBox', spacing => 10), + 1, $list, + 0, gtkpack__( + gtknew('VBox', spacing => 5), + gtksignal_connect( + Gtk2::Button->new(but(N("Remove"))), + clicked => sub { remove_parallel(selrow($list), $conf); $reread->() }, + ), + gtksignal_connect( + Gtk2::Button->new(but(N("Edit..."))), + clicked => sub { + my $row = selrow($list); + $row != -1 and edit_parallel($row, $conf); + $reread->(); + }, + ), + gtksignal_connect( + Gtk2::Button->new(but(N("Add..."))), + clicked => sub { edit_parallel(-1, $conf) and $reread->() }, + ) + ) + ), + 0, gtknew('HSeparator'), + 0, gtkpack( + gtknew('HButtonBox'), + gtknew('Button', text => N("Ok"), clicked => sub { Gtk2->main_quit }) + ) + ) + ); + $w->main; +} + +sub keys_callback() { + my $w = ugtk2->new(N("Manage keys for digital signatures of packages"), grab => 1, center => 1, transient => $mainw->{real_window}); + local $::main_window = $w->{real_window}; + $w->{real_window}->set_size_request(600, 300); + + my $media_list_ls = Gtk2::ListStore->new("Glib::String"); + my $media_list = Gtk2::TreeView->new_with_model($media_list_ls); + $media_list->append_column(Gtk2::TreeViewColumn->new_with_attributes(N("Medium"), Gtk2::CellRendererText->new, 'text' => 0)); + $media_list->get_selection->set_mode('browse'); + + my $key_col_size = 200; + my $keys_list_ls = Gtk2::ListStore->new("Glib::String", "Glib::String"); + my $keys_list = Gtk2::TreeView->new_with_model($keys_list_ls); + $keys_list->append_column(my $col = Gtk2::TreeViewColumn->new_with_attributes(N("_:cryptographic keys\nKeys"), my $renderer = Gtk2::CellRendererText->new, 'text' => 0)); + $col->set_sizing('fixed'); + $col->set_fixed_width($key_col_size); + $renderer->set_property('width' => 1); + $renderer->set_property('wrap-width', $key_col_size); + $keys_list->get_selection->set_mode('browse'); + + my ($current_medium, $current_medium_nb, @keys); + + my $read_conf = sub { + $urpm->parse_pubkeys(root => $urpm->{root}); + @keys = map { [ split /[,\s]+/, $_->{'key-ids'} ] } @{$urpm->{media}}; + }; + my $write = sub { + urpm::media::write_config($urpm); + $urpm = urpm->new; + urpm::media::read_config($urpm); + $read_conf->(); + $media_list->get_selection->signal_emit('changed'); + }; + $read_conf->(); + my $key_name = sub { + exists $urpm->{keys}{$_[0]} ? $urpm->{keys}{$_[0]}{name} + : N("no name found, key doesn't exist in rpm keyring!"); + }; + $media_list_ls->append_set([ 0 => $_->{name} ]) foreach @{$urpm->{media}}; + $media_list->get_selection->signal_connect(changed => sub { + my ($model, $iter) = $_[0]->get_selected; + $model && $iter or return; + $current_medium = $model->get($iter, 0); + $current_medium_nb = $model->get_path($iter)->to_string; + $keys_list_ls->clear; + $keys_list_ls->append_set([ 0 => sprintf("%s (%s)", $_, $key_name->($_)), 1 => $_ ]) foreach @{$keys[$current_medium_nb]}; + }); + + my $add_key = sub { + my $w_add = ugtk2->new(N("Add a key"), grab => 1, transient => $w->{real_window}); + local $::main_window = $w->{real_window}; + my $available_keyz_ls = Gtk2::ListStore->new("Glib::String", "Glib::String"); + my $available_keyz = Gtk2::TreeView->new_with_model($available_keyz_ls); + $available_keyz->append_column(Gtk2::TreeViewColumn->new_with_attributes(undef, Gtk2::CellRendererText->new, 'text' => 0)); + $available_keyz->set_headers_visible(0); + $available_keyz->get_selection->set_mode('browse'); + $available_keyz_ls->append_set([ 0 => sprintf("%s (%s)", $_, $key_name->($_)), 1 => $_ ]) foreach keys %{$urpm->{keys}}; + my $key; + gtkadd( + $w_add->{window}, + gtkpack__( + gtknew('VBox', spacing => 5), + gtknew('Label', text => N("Choose a key for adding to the medium %s", $current_medium)), + $available_keyz, + gtknew('HSeparator'), + gtkpack( + gtknew('HButtonBox'), + gtksignal_connect( + gtknew('Button', text => N("Close")), + clicked => sub { + my ($model, $iter) = $available_keyz->get_selection->get_selected; + $model && $iter and $key = $model->get($iter, 1); + Gtk2->main_quit; + }, + ), + gtknew('Button', text => N("Cancel"), clicked => sub { Gtk2->main_quit }) + ) + ) + ); + $w_add->main; + if (defined $key) { + $urpm->{media}[$current_medium_nb]{'key-ids'} = join(',', sort(uniq(@{$keys[$current_medium_nb]}, $key))); + $write->(); + } + }; + + my $remove_key = sub { + my ($model, $iter) = $keys_list->get_selection->get_selected; + $model && $iter or return; + my $key = $model->get($iter, 1); + interactive_msg(N("Remove a key"), + N("Are you sure you want to remove the key %s from medium %s?\n(name of the key: %s)", + $key, $current_medium, $key_name->($key)), + yesno => 1, transient => $w->{real_window}) or return; + $urpm->{media}[$current_medium_nb]{'key-ids'} = join(',', difference2(\@{$keys[$current_medium_nb]}, [ $key ])); + $write->(); + }; + + gtkadd( + $w->{window}, + gtkpack_( + gtknew('VBox', spacing => 5), + 1, gtkpack_( + gtknew('HBox', spacing => 10), + 1, create_scrolled_window($media_list), + 1, create_scrolled_window($keys_list), + 0, gtkpack__( + gtknew('VBox', spacing => 5), + gtksignal_connect( + Gtk2::Button->new(but(N("Add a key..."))), + clicked => \&$add_key, + ), + gtksignal_connect( + Gtk2::Button->new(but(N("Remove key"))), + clicked => \&$remove_key, + ) + ) + ), + 0, gtknew('HSeparator'), + 0, gtkpack( + gtknew('HButtonBox'), + gtknew('Button', text => N("Ok"), clicked => sub { Gtk2->main_quit }) + ), + ), + ); + $w->main; +} + +sub mainwindow() { + $mainw = ugtk2->new(N("Configure media"), center => 1); + $::main_window = $mainw->{real_window}; + + my $list = Gtk2::ListStore->new("Glib::Boolean", "Glib::Boolean", "Glib::String"); + $list_tv = Gtk2::TreeView->new_with_model($list); + $list_tv->get_selection->set_mode('browse'); + my ($up_button, $dw_button); + $list_tv->get_selection->signal_connect(changed => sub { + my ($model, $iter) = $_[0]->get_selected; + return if !$iter; + my $curr_path = $model->get_path($iter); + my $first_path = $model->get_path($model->get_iter_first); + $up_button->set_sensitive($first_path && $first_path->compare($curr_path)); + + $curr_path->next; + my $next_item = $model->get_iter($curr_path); + $dw_button->set_sensitive($next_item); # && !$model->get($next_item, 0) + }); + + $list_tv->set_rules_hint(1); + $list_tv->set_reorderable(1); + + my $reorder_ok = 1; + $list->signal_connect( + row_deleted => sub { + $reorder_ok or return; + my ($model) = @_; + my @media; + $model->foreach( + sub { + my (undef, undef, $iter) = @_; + my $name = $model->get($iter, 2); + push @media, urpm::media::name2medium($urpm, $name); + 0; + }, undef); + @{$urpm->{media}} = @media; + }, + ); + + $list_tv->append_column(Gtk2::TreeViewColumn->new_with_attributes(N("Enabled?"), my $tr = Gtk2::CellRendererToggle->new, 'active' => 0)); + $list_tv->append_column(Gtk2::TreeViewColumn->new_with_attributes(N("Updates?"), my $cu = Gtk2::CellRendererToggle->new, 'active' => 1)); + $list_tv->append_column(Gtk2::TreeViewColumn->new_with_attributes(N("Medium"), Gtk2::CellRendererText->new, 'text' => 2)); + + my $reread_media; #- closure defined later + $tr->signal_connect( + toggled => sub { + my (undef, $path) = @_; + my $iter = $list->get_iter_from_string($path); + $urpm->{media}[$path]{ignore} = !$urpm->{media}[$path]{ignore} || undef; + $list->set($iter, 0, !$urpm->{media}[$path]{ignore}); + urpm::media::write_config($urpm); + my $ignored = $urpm->{media}[$path]{ignore}; + $reread_media->(); + if (!$ignored && $urpm->{media}[$path]{ignore}) { + #- Enabling this media failed, force update + interactive_msg('rpmdrake', + N("This medium needs to be updated to be usable. Update it now ?"), + yesno => 1, + ) and $reread_media->($urpm->{media}[$path]{name}); + } + }, + ); + + $cu->signal_connect( + toggled => sub { + my (undef, $path) = @_; + my $iter = $list->get_iter_from_string($path); + $urpm->{media}[$path]{update} = !$urpm->{media}[$path]{update} || undef; + $list->set($iter, 1, ! !$urpm->{media}[$path]{update}); + }, + ); + + $reread_media = sub { + my ($name) = @_; + $reorder_ok = 0; + $urpm = urpm->new; + urpm::media::read_config($urpm); + if (defined $name) { + #- this media must be reconstructed since editing it failed + if (my $medium = urpm::media::name2medium($urpm, $name)) { + delete $medium->{ignore}; + } + urpm::media::select_media($urpm, $name); + update_sources_check( + $urpm, + { nolock => 1 }, + N_("Unable to update medium, errors reported:\n\n%s"), + $name, + ); + } + $list->clear; + $list->append_set(0 => !$_->{ignore}, 1 => ! !$_->{update}, 2 => $_->{name}) foreach grep { ! $_->{external} } @{$urpm->{media}}; + $reorder_ok = 1; + }; + $reread_media->(); + + gtkadd( + $mainw->{window}, + gtkpack_( + gtknew('VBox', spacing => 5), + 1, gtkpack_( + gtknew('HBox', spacing => 10), + 1, gtknew('ScrolledWindow', child => $list_tv), + 0, gtkpack__( + gtknew('VBox', spacing => 5), + gtksignal_connect( + Gtk2::Button->new(but(N("Remove"))), + clicked => sub { remove_callback() and $reread_media->() }, + ), + gtksignal_connect( + Gtk2::Button->new(but(N("Edit..."))), + clicked => sub { + my $name = edit_callback(); defined $name and $reread_media->($name); + } + ), + gtksignal_connect( + Gtk2::Button->new(but(N("Add..."))), + clicked => sub { easy_add_callback() and $reread_media->() }, + ), + gtksignal_connect( + Gtk2::Button->new(but(N("Add custom..."))), + clicked => sub { add_callback() and $reread_media->() }, + ), + gtksignal_connect( + Gtk2::Button->new(but(N("Update..."))), + clicked => sub { update_callback() and $reread_media->() }, + ), + gtksignal_connect(Gtk2::Button->new(but(N("Manage keys..."))), clicked => \&keys_callback), + gtksignal_connect(Gtk2::Button->new(but(N("Proxy..."))), clicked => \&proxy_callback), + gtksignal_connect(Gtk2::Button->new(but(N("Parallel..."))), clicked => \¶llel_callback), + gtksignal_connect(Gtk2::Button->new(but(N("Global options..."))), clicked => \&options_callback), + gtkpack( + gtknew('HBox'), + gtksignal_connect($up_button = gtknew('Button', child => Gtk2::Arrow->new("up", "none")), clicked => \&upwards_callback), + gtksignal_connect($dw_button = gtknew('Button', child => Gtk2::Arrow->new("down", "none")), clicked => \&downwards_callback), + ), + ) + ), + 0, gtknew('HSeparator'), + 0, gtknew('HButtonBox', layout => 'edge', children_loose => [ + gtksignal_connect(Gtk2::Button->new(but(N("Help"))), clicked => sub { rpmdrake::open_help('sources') }), + gtksignal_connect(Gtk2::Button->new(but(N("Ok"))), clicked => sub { Gtk2->main_quit }) + ]) + ) + ); + $mainw->{rwindow}->set_size_request(600, -1); + $mainw->main; +} + + +sub check_if_first_run() { + if (!member(basename($0), @$already_splashed)) { + interactive_msg('rpmdrake', + N("%s + +Is it ok to continue?", + N("Welcome to the Software Media Manager! + +This tool will help you configure the packages media you wish to use on +your computer. They will then be available to install new software package +or to perform updates.")), yesno => 1) or myexit -1; + push @$already_splashed, basename($0); + } +} + +sub run() { + local $ugtk2::wm_icon = "title-install"; + my $lock; + { + $urpm = urpm->new; + local $urpm->{fatal} = sub { + interactive_msg('rpmdrake', + N("Packages database is locked. Please close other applications +working with packages database (do you have another media +manager on another desktop, or are you currently installing +packages as well?).")); + myexit -1; + }; + # lock urpmi DB + $lock = urpm::lock::urpmi_db($urpm, 'exclusive'); + } + + mainwindow(); + urpm::media::write_config($urpm); + + writeconf(); + + undef $lock; +} + + +1; |