aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rwxr-xr-xRpmdrake/pkg.pm702
-rwxr-xr-xrpmdrake658
2 files changed, 704 insertions, 656 deletions
diff --git a/Rpmdrake/pkg.pm b/Rpmdrake/pkg.pm
new file mode 100755
index 00000000..d99ee2bd
--- /dev/null
+++ b/Rpmdrake/pkg.pm
@@ -0,0 +1,702 @@
+package Rpmdrake::pkg;
+#*****************************************************************************
+#
+# Copyright (c) 2002 Guillaume Cottenceau
+# Copyright (c) 2002-2007 Thierry Vignaud <tvignaud@mandriva.com>
+# Copyright (c) 2003, 2004, 2005 MandrakeSoft SA
+# Copyright (c) 2005-2007 Mandriva SA
+#
+# 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 MDK::Common::Func 'any';
+use lib qw(/usr/lib/libDrakX);
+use common;
+use POSIX qw(_exit);
+use URPM;
+use utf8;
+use Rpmdrake::gurpm;
+use Rpmdrake::formatting;
+use Rpmdrake::rpmnew;
+
+use rpmdrake;
+use urpm::lock;
+use urpm::install;
+use urpm::signature;
+use urpm::get_pkgs;
+use urpm::select;
+
+
+use Exporter;
+our @ISA = qw(Exporter);
+our @EXPORT = qw(extract_header find_installed_version formatlistpkg get_pkgs open_db parse_compssUsers_flat perform_installation perform_removal run_rpm $db);
+
+use mygtk2 qw(gtknew);
+use ugtk2 qw(:all);
+use Gtk2::Pango;
+use Gtk2::Gdk::Keysyms;
+
+our $db;
+
+sub parse_compssUsers_flat() {
+ my (%compssUsers, $category);
+ my $compss = '/var/lib/urpmi/compssUsers.flat';
+ -r $compss or $compss = '/usr/share/rpmdrake/compssUsers.flat.default';
+ -r $compss or do {
+ print STDERR "No compssUsers.flat file found\n";
+ return undef;
+ };
+ foreach (cat_($compss)) {
+ s/#.*//;
+ /^\s*$/ and next;
+ if (/^\S/) {
+ if (/^(.+?) \[icon=.+?\] \[path=(.+?)\]/) {
+ $category = translate($2) . '|' . translate($1);
+ } else {
+ print STDERR "Malformed category in compssUsers.flat: <$_>\n";
+ }
+ } elsif (/^\t(\d) (\S+)\s*$/) {
+ $category or print STDERR "Entry without category <$_>\n";
+ push @{$compssUsers{$2}}, $category . ($1 <= 3 ? '|' . N("Other") : '');
+ }
+ }
+ \%compssUsers;
+}
+
+sub run_rpm {
+ foreach (qw(LANG LC_CTYPE LC_NUMERIC LC_TIME LC_COLLATE LC_MONETARY LC_MESSAGES LC_PAPER LC_NAME LC_ADDRESS LC_TELEPHONE LC_MEASUREMENT LC_IDENTIFICATION LC_ALL)) {
+ local $ENV{$_} = $ENV{$_} . '.UTF-8' if !/UTF-8/;
+ }
+ my @l = map { to_utf8($_) } `@_`;
+ wantarray() ? @l : join('', @l);
+}
+
+
+sub extract_header {
+ my ($pkg, $urpm) = @_;
+ my $chg_prepro = sub {
+ #- preprocess changelog for faster TextView insert reaction
+ [ map { [ "$_\n", if_(/^\*/, { 'weight' => Gtk2::Pango->PANGO_WEIGHT_BOLD }) ] } split("\n", $_[0]) ];
+ };
+ my $name = urpm_name($pkg->{pkg});
+ if ($pkg->{pkg}->flag_installed && !$pkg->{pkg}->flag_upgrade) {
+ add2hash($pkg, { files => [ split /\n/, chomp_(scalar(run_rpm("rpm -ql $name"))) || N("(none)") ],
+ changelog => $chg_prepro->(scalar(run_rpm("rpm -q --changelog $name"))) });
+ } else {
+ my ($p, $medium) = ($pkg->{pkg}, pkg2medium($pkg->{pkg}, $urpm));
+ my $hdlist = urpm::media::any_hdlist($urpm, $medium);
+ $hdlist =~ s!^file:/+!!;
+ if (-r $hdlist) {
+ my $packer;
+ require MDV::Packdrakeng;
+ eval { $packer = MDV::Packdrakeng->open(archive => $hdlist, quiet => 1) } or do {
+ warn "Warning, hdlist $hdlist seems corrupted ($@)\n";
+ goto header_non_available;
+ };
+ my ($headersdir, $retries);
+ while (!-d $headersdir && $retries < 5) {
+ $headersdir = chomp_(`mktemp -d /tmp/rpmdrake.XXXXXXXX`);
+ $retries++;
+ -d $headersdir or warn qq(Could not create temporary directory "$headersdir");
+ }
+ -d $headersdir or do {
+ warn "Warning, could not extract header!";
+ goto header_non_available;
+ };
+ $packer->extract($headersdir, $p->header_filename);
+ $p->update_header("$headersdir/" . $p->header_filename) or do {
+ warn "Warning, could not extract header!";
+ goto header_non_available;
+ };
+ rm_rf($headersdir);
+ add2hash($pkg, { summary => rpm_summary($p->summary), description => rpm_description($p->description) });
+ add2hash($pkg, {
+ files => scalar($p->files) ? [ $p->files ] : [ N("(none)") ],
+ changelog => $chg_prepro->(join("\n", mapn { "* " . localtime2changelog($_[2]) . " $_[0]\n\n$_[1]\n" }
+ [ $p->changelog_name ], [ $p->changelog_text ], [ $p->changelog_time ])) });
+ $p->pack_header;
+ } else {
+ header_non_available:
+ add2hash($pkg, { summary => $p->summary || N("(Not available)"), description => undef });
+ }
+ }
+}
+
+my %options;
+
+sub open_db {
+ my ($o_force) = @_;
+ my $host;
+ log::explanations("opening the RPM database");
+ if ($options{parallel} && ((undef, $host) = @{$options{parallel}})) {
+ my $done if 0;
+ my $dblocation = "/var/cache/urpmi/distantdb/$host";
+ if (!$done || $o_force) {
+ print "syncing db from $host to $dblocation...";
+ mkdir_p "$dblocation/var/lib/rpm";
+ system "rsync -Sauz -e ssh $host:/var/lib/rpm/ $dblocation/var/lib/rpm";
+ $? == 0 or die "Couldn't sync db from $host to $dblocation";
+ $done = 1;
+ print "done.\n";
+ }
+ $db = URPM::DB::open($dblocation) or die "Couldn't open RPM DB";
+ } else {
+ $db = URPM::DB::open or die "Couldn't open RPM DB";
+ }
+}
+
+
+sub find_installed_version {
+ my ($p) = @_;
+ my @version;
+ $db->traverse_tag('name', [ $p->name ], sub { push @version, $_[0]->version . '-' . $_[0]->release });
+ @version ? join(',', sort @version) : N("(none)");
+}
+
+sub formatlistpkg { join("\n", sort { uc($a) cmp uc($b) } @_) }
+
+
+# -=-=-=---=-=-=---=-=-=-- install packages -=-=-=---=-=-=---=-=-=-
+
+
+sub get_pkgs {
+ my ($urpm, $opts) = @_;
+ my $update_name = 'update_source';
+ my %update_descr;
+ my @update_medias;
+ my $w = $::main_window;
+
+ my $error_happened;
+ my $fatal_handler = sub {
+ $error_happened = 1;
+ interactive_msg(N("Fatal error"),
+ N("A fatal error occurred: %s.", $_[1]));
+ myexit(-1) if 0; #FIXME
+ };
+
+ Rpmdrake::gurpm::init(1 ? N("Please wait") : N("Package installation..."), N("Initializing..."), transient => $::w->{real_window});
+ my $_guard = before_leaving { Rpmdrake::gurpm::end() };
+
+ if (!$urpm) {
+ $urpm ||= urpm->new;
+ $urpm->{fatal} = $fatal_handler;
+ my $media = ref $::options{media} ? join(',', @{$::options{media}}) : '';
+ urpm::media::configure($urpm, media => $media);
+ if ($error_happened) {
+ touch('/etc/urpmi/urpmi.cfg');
+ exec('edit-urpm-sources.pl');
+ }
+ }
+ my $_lock = urpm::lock::urpmi_db($urpm);
+ my $statedir = $urpm->{statedir};
+ @update_medias = grep { !$_->{ignore} && $_->{update} } @{$urpm->{media}};
+
+
+ $urpm->{fatal} = $fatal_handler;
+ if (member($::default_list_mode, qw(all_updates security bugfix normal))) {
+ unless ($::options{'no-media-update'}) {
+ if (@update_medias > 0) {
+ if (!$opts->{skip_updating_mu}) {
+ $::options{'no-confirmation'} or interactive_msg_with_banner(N("Confirmation"),
+N("I need to contact the mirror to get latest update packages.
+Please check that your network is currently running.
+
+Is it ok to continue?"), yesno => 1) or myexit(-1);
+ urpm::media::select_media($urpm, map { $_->{name} } @update_medias);
+ update_sources($urpm, noclean => 1, banner => $::isEmbedded);
+ }
+ } else {
+ if (any { $_->{update} } @{$urpm->{media}}) {
+ interactive_msg(N("Already existing update media"),
+N("You already have at least one update medium configured, but
+all of them are currently disabled. You should run the Software
+Media Manager to enable at least one (check it in the Enabled?
+column).
+
+Then, restart %s.", $rpmdrake::myname_update));
+ myexit(-1);
+ }
+ mu_retry_another_mirror:
+ my ($mirror) = choose_mirror(if_(exists $w->{real_window}, transient => $w->{real_window}));
+ my $m = ref($mirror) ? $mirror->{url} : '';
+ $m or interactive_msg(N("How to choose manually your mirror"),
+N("You may also choose your desired mirror manually: to do so,
+launch the Software Media Manager, and then add a `Security
+updates' medium.
+
+Then, restart %s.", $rpmdrake::myname_update)), myexit(-1);
+ add_medium_and_check(
+ $urpm, {},
+ $update_name, make_url_mirror($m), 'media_info/synthesis.hdlist.cz', update => 1,
+ );
+ @update_medias = { name => $update_name }; #- hack to simulate a medium for parsing of descriptions
+ }
+ }
+ }
+
+ Rpmdrake::gurpm::label(N("Reading updates description"));
+ Rpmdrake::gurpm::progress(0.05);
+ my ($cur, $section);
+ #- parse the description file
+ foreach my $medium (@update_medias) {
+ foreach (cat_("$statedir/descriptions.$medium->{name}")) {
+ /^%package +(.+)/ and do {
+ my @pkg_list = split /\s+/, $1;
+ exists $cur->{importance} && $cur->{importance} !~ /^(?:security|bugfix)\z/
+ and $cur->{importance} = 'normal';
+ $update_descr{$_} = $cur foreach @{$cur->{pkgs} || []};
+ $cur = { pkgs => \@pkg_list, medium => $medium->{name} };
+ $section = 'pkg';
+ next;
+ };
+ /^%(pre|description)/ and do { $section = $1; next };
+ /^Updated?: +(.+)/ && $section eq 'pkg'
+ and do { $cur->{update} = $1; next };
+ /^Importance: +(.+)/ && $section eq 'pkg'
+ and do { $cur->{importance} = $1; next };
+ /^(ID|URL): +(.+)/ && $section eq 'pkg'
+ and do { $cur->{$1} = $2; next };
+ $section =~ /^(pre|description)\z/ and $cur->{$1} .= $_;
+ }
+ }
+
+ my $_unused = N("Please wait, finding available packages...");
+
+ # find out installed packages:
+
+ #$urpm = urpm->new;
+ #$urpm->read_config;
+ my $level = 0.05;
+ my $total = @{$urpm->{depslist}};
+ Rpmdrake::gurpm::label(N("Please wait, listing base packages..."));
+ Rpmdrake::gurpm::progress($level);
+
+ my ($count, $prev_stage, $new_stage, $limit);
+
+ my $reset_update = sub { undef $prev_stage; $count = 0; $limit = $_[0] };
+ my $update = sub {
+ $count++;
+ $new_stage = $level+($limit-$level)*$count/$total;
+ if ($prev_stage + 0.01 < $new_stage) {
+ $prev_stage = $new_stage;
+ Rpmdrake::gurpm::progress($new_stage);
+ }
+ };
+
+ my @base = ("basesystem", split /,\s*/, $urpm->{global_config}{'prohibit-remove'});
+ my (%base, %basepackages);
+ my $db = $db;
+ my $sig_handler = sub { undef $db; exit 3 };
+ local $SIG{INT} = $sig_handler;
+ local $SIG{QUIT} = $sig_handler;
+ $reset_update->(0.33);
+ while (defined(local $_ = shift @base)) {
+ exists $basepackages{$_} and next;
+ $db->traverse_tag(m|^/| ? 'path' : 'whatprovides', [ $_ ], sub {
+ $update->();
+ push @{$basepackages{$_}}, urpm_name($_[0]);
+ push @base, $_[0]->requires_nosense;
+ });
+ }
+ foreach (values %basepackages) {
+ my $n = @$_; #- count number of times it's provided
+ foreach (@$_) {
+ $base{$_} = \$n;
+ }
+ }
+ Rpmdrake::gurpm::label(N("Please wait, finding installed packages..."));
+ Rpmdrake::gurpm::progress($level = 0.33);
+ $reset_update->(0.66);
+ my %installed_pkgs;
+ $db->traverse(sub {
+ my ($pkg) = @_;
+ $update->();
+ my $fullname = urpm_name($pkg);
+ #- Extract summary and description since they'll be lost when the header is packed
+ $installed_pkgs{$fullname} = {
+ selected => 0, pkg => $pkg, urpm_name => urpm_name($pkg),
+ summary => rpm_summary($pkg->summary),
+ description => rpm_description($pkg->description),
+ } if !($installed_pkgs{$fullname} && $installed_pkgs{$fullname}{description});
+ if (my $name = $base{$fullname}) {
+ $installed_pkgs{$fullname}{base} = \$name;
+ $pkg->set_flag_base(1) if $$name == 1;
+ }
+ $pkg->pack_header;
+ });
+ my $group;
+ if ($::options{parallel} && (($group) = @{$::options{parallel}})) {
+ urpm::media::configure($urpm, parallel => $group);
+ }
+
+ # find out availlable packages:
+
+ #$urpm = urpm->new;
+ $urpm->{state} = {};
+ my %installable_pkgs;
+ my %updates;
+
+ Rpmdrake::gurpm::label(N("Please wait, finding available packages..."));
+ Rpmdrake::gurpm::progress($level = 0.66);
+
+ @update_medias = grep { !$_->{ignore} && $_->{update} } @{$urpm->{media}};
+ check_update_media_version($urpm, @update_medias);
+
+ my $requested = {};
+ my $state = {};
+ $urpm->request_packages_to_upgrade(
+ $db,
+ $state,
+ $requested,
+ start => 0,
+ end => $#{$urpm->{depslist}},
+ );
+ $urpm->compute_installed_flags($db); # TODO/FIXME: not for updates
+ $urpm->{depslist}[$_]->set_flag_installed foreach keys %$requested; #- pretend it's installed
+ $urpm->{rpmdrake_state} = $state; #- Don't forget it
+ Rpmdrake::gurpm::progress($level = 0.7);
+
+ my %pkg_sel = map { $_ => 1 } @{$::options{'pkg-sel'} || []};
+ my %pkg_nosel = map { $_ => 1 } @{$::options{'pkg-nosel'} || []};
+ my @updates_media_names = map { $_->{name} } @update_medias;
+ $reset_update->(1);
+ foreach my $pkg (@{$urpm->{depslist}}) {
+ $update->();
+ $pkg->flag_upgrade or next;
+ my $selected = 0;
+
+ if (member(pkg2medium($pkg, $urpm)->{name}, @updates_media_names) && $pkg->flag_installed) { # TODO/FIXME: for updates
+ any { $pkg->id >= $_->{start} && $pkg->id <= $_->{end} } @update_medias or next;
+ if ($::options{'pkg-sel'} || $::options{'pkg-nosel'}) {
+ my $n = urpm_name($pkg);
+ $pkg_sel{$n} || $pkg_nosel{$n} or next;
+ $pkg_sel{$n} and $selected = 1;
+ } else {
+ # selecting updates by default:
+ $selected = 1;
+ }
+ $updates{urpm_name($pkg)} = { selected => $selected, pkg => $pkg };
+ } else {
+ $installable_pkgs{urpm_name($pkg)} = { selected => $selected, pkg => $pkg };
+ }
+ }
+ if ($::options{'pkg-sel'} && $::options{'pkg-nosel'}) {
+ push @{$::options{'pkg-nosel'}}, @{$::options{'pkg-sel'}};
+ delete $::options{'pkg-sel'};
+ }
+
+ $_->{pkg}->set_flag_installed foreach values %installed_pkgs;
+
+ +{ urpm => $urpm,
+ installed => \%installed_pkgs,
+ installable => \%installable_pkgs,
+ updates => \%updates,
+ update_descr => \%update_descr,
+ };
+}
+
+
+sub perform_installation { #- (partially) duplicated from /usr/sbin/urpmi :-(
+ my ($urpm, $pkgs) = @_;
+
+ my $fatal_msg;
+ my @error_msgs;
+ my %Readmes;
+ my $statusbar_msg_id;
+ local $urpm->{fatal} = sub { printf STDERR "Fatal: %s\n", $_[1]; $fatal_msg = $_[1]; goto fatal_error };
+ local $urpm->{error} = sub { printf STDERR "Error: %s\n", $_[0]; push @error_msgs, $_[0] };
+
+ my $w = $::main_window;
+ $w->set_sensitive(0);
+
+ my $group;
+ if ($::options{parallel} && (($group) = @{$::options{parallel}})) {
+ my $pkgs = join(' ', map { if_($_->flag_requested, urpm_name($_)) } @{$urpm->{depslist}});
+ system("urpmi -v --X --parallel $group $pkgs");
+ if ($? == 0) {
+ $statusbar_msg_id = statusbar_msg(
+ #N("Everything installed successfully"),
+ N("All requested packages were installed successfully."),
+ );
+ } else {
+ interactive_msg(
+ N("Problem during installation"),
+ N("There was a problem during the installation:\n\n%s", join("\n", @error_msgs)),
+ scroll => 1,
+ );
+ }
+ open_db('force_sync');
+ $w->set_sensitive(1);
+ return 0;
+ }
+
+ my $_lock = urpm::lock::urpmi_db($urpm);
+ my $_rpm_lock = urpm::lock::rpm_db($urpm, 'exclusive');
+ my %pkgs = map { $_->id => undef } grep { $_->flag_selected } @{$urpm->{depslist}};
+ my ($local_sources, $list, $local_to_removes) = urpm::get_pkgs::selected2list($urpm,
+ \%pkgs,
+ clean_all => 1,
+ );
+ my $distant_number = scalar keys %pkgs;
+ if (!$local_sources && (!$list || !@$list)) {
+ interactive_msg(
+ N("Unable to get source packages."),
+ N("Unable to get source packages, sorry. %s",
+ @error_msgs ? N("\n\nError(s) reported:\n%s", join("\n", @error_msgs)) : ''),
+ scroll => 1,
+ );
+ goto return_with_error;
+ }
+ foreach (@$local_to_removes) {
+ unlink $_;
+ }
+
+ my @pkgs = map { scalar($_->fullname) } sort(grep { $_->flag_selected } @{$urpm->{depslist}});#{ $a->name cmp $b->name } @{$urpm->{depslist}}[keys %{$state->{selected}}];
+ @{$urpm->{ask_remove}} = sort urpm::select::removed_packages($urpm, $urpm->{state});
+ my @to_remove = grep { $_ } map { if_($pkgs->{$_}{selected}, $pkgs->{$_}{urpm_name}) } keys %$pkgs;
+
+ my $r = join "\n", urpm::select::translate_why_removed($urpm, $urpm->{state}, @to_remove);
+
+ my $install_count = int(@pkgs);
+ my $to_install = $install_count ?
+ #-PO: in singular form, we use %2\$
+ P("To satisfy dependencies, the following package is going to be installed:\n%2\$s\n", "To satisfy dependencies, the following %d packages are going to be installed:\n%s\n", $install_count, $install_count,
+ formatlistpkg(map { s!.*/!!; $_ } @pkgs)) : '';
+ my $remove_count = scalar(@to_remove);
+ interactive_msg(($to_install ? N("Confirmation") : N("Some packages need to be removed")),
+ ($r ?
+ (!$to_install ? join("\n\n", P("Remove one package?", "Remove %d packages?", $remove_count, $remove_count), $r) :
+ P("The following package has to be removed for others to be upgraded:", "The following packages have to be removed for others to be upgraded:", $remove_count) . join("\n\n", $r, if_($to_install, $to_install)) . N("Is it ok to continue?"))
+ : $to_install),
+ scroll => 1,
+ yesno => 1) or do {
+ $w->set_sensitive(1);
+ return 'canceled';
+ };
+
+ Rpmdrake::gurpm::init(1 ? N("Please wait") : N("Package installation..."), N("Initializing..."), transient => $::w->{real_window});
+ my $distant_progress;
+ my $canceled;
+ my %sources = $urpm->download_source_packages(
+ $local_sources,
+ $list,
+ force_local => 1, # removed in urpmi 4.8.7
+ ask_for_medium => sub {
+ interactive_msg(
+ N("Change medium"),
+ N("Please insert the medium named \"%s\" on device [%s]", $_[0], $_[1]),
+ yesno => 1, text => { no => N("Cancel"), yes => N("Ok") },
+ );
+ },
+ callback => sub {
+ my ($mode, $file, $percent) = @_;
+ if ($mode eq 'start') {
+ Rpmdrake::gurpm::label(N("Downloading package `%s' (%s/%s)...",
+ basename($file), ++$distant_progress, $distant_number));
+ Rpmdrake::gurpm::validate_cancel(but(N("Cancel")), sub { $canceled = 1 });
+ } elsif ($mode eq 'progress') {
+ Rpmdrake::gurpm::progress($percent/100);
+ } elsif ($mode eq 'end') {
+ Rpmdrake::gurpm::progress(1);
+ Rpmdrake::gurpm::invalidate_cancel();
+ }
+ $canceled and return 'canceled';
+ },
+ );
+ $canceled and goto return_with_error;
+ Rpmdrake::gurpm::invalidate_cancel_forever();
+
+ my %sources_install = %{$urpm->extract_packages_to_install(\%sources, $urpm->{rpmdrake_state}) || {}};
+ my @rpms_install = grep { !/\.src\.rpm$/ } values %sources_install;
+ my @rpms_upgrade = grep { !/\.src\.rpm$/ } values %sources;
+
+ if (!$::options{'no-verify-rpm'}) {
+ Rpmdrake::gurpm::label(N("Verifying package signatures..."));
+ my $total = @rpms_install + @rpms_upgrade;
+ my $progress;
+ my @invalid_sources = urpm::signature::check($urpm,
+ \%sources_install, \%sources,
+ translate => 1, basename => 1,
+ callback => sub {
+ Rpmdrake::gurpm::progress(++$progress/$total);
+ },
+ );
+ if (@invalid_sources) {
+ local $::main_window = $Rpmdrake::gurpm::mainw->{real_window};
+ interactive_msg(
+ N("Warning"),
+ N("The following packages have bad signatures:\n\n%s\n\nDo you want to continue installation?",
+ join("\n", sort @invalid_sources)), yesno => 1, if_(@invalid_sources > 10, scroll => 1),
+ ) or goto return_with_error;
+ }
+ }
+
+ my $_guard = before_leaving { urpm::removable::try_umounting_removables($urpm) };
+
+ my $something_installed;
+ if (@rpms_install || @rpms_upgrade || @to_remove) {
+ if (my @missing = grep { m|^/| && ! -e $_ } @rpms_install, @rpms_upgrade) {
+ interactive_msg(
+ N("Installation failed"),
+ N("Installation failed, some files are missing:\n%s\n\nYou may want to update your media database.",
+ join "\n", map { " $_" } @missing) .
+ (@error_msgs ? N("\n\nError(s) reported:\n%s", join("\n", @error_msgs)) : ''),
+ if_(@error_msgs > 1, scroll => 1),
+ );
+ goto return_with_error;
+ }
+ my $progress_nb;
+ my $total_nb = scalar grep { m|^/| } @rpms_install, @rpms_upgrade;
+ my $callback_inst = sub {
+ my ($urpm, $type, $id, $subtype, $amount, $total) = @_;
+ my $pkg = defined $id ? $urpm->{depslist}[$id] : undef;
+ if ($subtype eq 'start') {
+ if ($type eq 'trans') {
+ Rpmdrake::gurpm::label(@rpms_install ? N("Preparing packages installation...") : N("Preparing..."));
+ } elsif (defined $pkg) {
+ $something_installed = 1;
+ Rpmdrake::gurpm::label(N("Installing package `%s' (%s/%s)...", $pkg->name, ++$progress_nb, $total_nb));
+ }
+ } elsif ($subtype eq 'progress') {
+ Rpmdrake::gurpm::progress($total ? $amount/$total : 1);
+ }
+ };
+ my $fh;
+ my @errors = urpm::install::install($urpm,
+ \@to_remove,
+ \%sources_install,
+ \%sources,
+ post_clean_cache => $urpm->{options}{'post-clean'},
+ callback_open => sub {
+ my ($_data, $_type, $id) = @_;
+ my $f = $sources_install{$id} || $sources{$id};
+ open $fh, $f or $urpm->{error}(N("unable to access rpm file [%s]", $f));
+ return fileno $fh;
+ },
+ callback_inst => $callback_inst,
+ callback_trans => $callback_inst,
+ callback_close => sub {
+ my ($urpm, undef, $pkgid) = @_;
+ return unless defined $pkgid;
+ my $pkg = $urpm->{depslist}[$pkgid];
+ my $fullname = $pkg->fullname;
+ my $trtype = (any { /\Q$fullname/ } values %sources_install) ? 'install' : '(update|upgrade)';
+ foreach ($pkg->files) { /\bREADME(\.$trtype)?\.urpmi$/ and $Readmes{$_} = $fullname }
+ close $fh;
+ },
+ );
+ Rpmdrake::gurpm::end();
+
+ if (@errors || @error_msgs) {
+ interactive_msg(
+ N("Problem during installation"),
+ N("There was a problem during the installation:\n\n%s",
+ join("\n", @errors, @error_msgs)),
+ if_(@errors + @error_msgs > 1, scroll => 1),
+ );
+ $w->set_sensitive(1);
+ return !$something_installed;
+ }
+
+ my %pkg2rpmnew;
+ foreach my $u (@rpms_upgrade) {
+ $u =~ m|/([^/]+-[^-]+-[^-]+)\.[^\./]+\.rpm$|
+ and $pkg2rpmnew{$1} = [ grep { m|^/etc| && (-r "$_.rpmnew" || -r "$_.rpmsave") }
+ map { chomp_($_) } run_rpm("rpm -ql $1") ];
+ }
+ dialog_rpmnew(N("The installation is finished; everything was installed correctly.
+
+Some configuration files were created as `.rpmnew' or `.rpmsave',
+you may now inspect some in order to take actions:"),
+ %pkg2rpmnew)
+ and $statusbar_msg_id = statusbar_msg(N("All requested packages were installed successfully."));
+ if (keys %Readmes) { #- display the README*.urpmi files
+ interactive_packtable(
+ N("Upgrade information"),
+ $w->{real_window},
+ N("These packages come with upgrade information"),
+ [ map {
+ my $fullname = $_;
+ [ gtkpack__(
+ gtknew('HBox'),
+ gtkset_selectable(gtknew('Label', text => $Readmes{$fullname}),1),
+ ),
+ gtksignal_connect(
+ gtknew('Button', text => N("Upgrade information about this package")),
+ clicked => sub {
+ interactive_msg(
+ N("Upgrade information about package %s", $Readmes{$fullname}),
+ (join '' => formatAlaTeX(scalar cat_($fullname))),
+ scroll => 1,
+ );
+ },
+ ),
+ ] } keys %Readmes ],
+ [ gtknew('Button', text => N("Ok"), clicked => sub { Gtk2->main_quit }) ]
+ );
+ }
+ } else {
+ Rpmdrake::gurpm::end();
+ interactive_msg(N("Error"),
+ N("Unrecoverable error: no package found for installation, sorry."));
+ }
+
+ $w->set_sensitive(1);
+ statusbar_msg_remove($statusbar_msg_id); #- XXX maybe remove this
+ return !($something_installed || scalar(@to_remove));
+
+ fatal_error:
+ Rpmdrake::gurpm::end();
+ interactive_msg(N("Installation failed"),
+ N("There was a problem during the installation:\n\n%s", $fatal_msg));
+ return_with_error:
+ Rpmdrake::gurpm::end();
+ $w->set_sensitive(1);
+ return 1;
+}
+
+
+# -=-=-=---=-=-=---=-=-=-- remove packages -=-=-=---=-=-=---=-=-=-
+
+sub perform_removal {
+ my ($urpm, $pkgs) = @_;
+ my @toremove = map { if_($pkgs->{$_}{selected}, $pkgs->{$_}{urpm_name}) } keys %$pkgs;
+ my @results;
+ slow_func_statusbar(
+ N("Please wait, removing packages..."),
+ $::main_window->{real_window},
+ sub {
+ @results = $::options{parallel}
+ ? urpm::parallel::remove($urpm, \@toremove)
+ : urpm::install::install($urpm, \@toremove, {}, {});
+ open_db('force_sync');
+ },
+ );
+ if (@results) {
+ interactive_msg(
+ N("Problem during removal"),
+ N("There was a problem during the removal of packages:\n\n%s", join("\n", @results)),
+ if_(@results > 1, scroll => 1),
+ );
+ return 1;
+ } else {
+ return 0;
+ }
+}
+
+1;
diff --git a/rpmdrake b/rpmdrake
index 8b025977..8b515eae 100755
--- a/rpmdrake
+++ b/rpmdrake
@@ -63,13 +63,10 @@ BEGIN { #- for mcc
}
use rpmdrake;
-use urpm::lock;
-use urpm::install;
-use Rpmdrake::gurpm;
use Rpmdrake::rpmnew;
use Rpmdrake::formatting;
-use urpm::signature;
-use urpm::get_pkgs;
+use Rpmdrake::pkg;
+use urpm::media;
use urpm::select;
#- This is needed because text printed by Gtk2 will always be encoded
@@ -115,7 +112,6 @@ if ($MODE eq 'remove') {
use mygtk2 qw(gtknew); #- do not import anything else, especially gtkadd() which conflicts with ugtk2 one
use ugtk2 qw(:all);
-use Gtk2::Pango;
use Gtk2::Gdk::Keysyms;
$MODE eq 'update' || $options{root} and require_root_capability();
@@ -299,111 +295,6 @@ sub ctreefy {
join('|', map { translate($_) } split m|/|, $_[0]);
}
-sub parse_compssUsers_flat() {
- my (%compssUsers, $category);
- my $compss = '/var/lib/urpmi/compssUsers.flat';
- -r $compss or $compss = '/usr/share/rpmdrake/compssUsers.flat.default';
- -r $compss or do {
- print STDERR "No compssUsers.flat file found\n";
- return undef;
- };
- foreach (cat_($compss)) {
- s/#.*//;
- /^\s*$/ and next;
- if (/^\S/) {
- if (/^(.+?) \[icon=.+?\] \[path=(.+?)\]/) {
- $category = translate($2) . '|' . translate($1);
- } else {
- print STDERR "Malformed category in compssUsers.flat: <$_>\n";
- }
- } elsif (/^\t(\d) (\S+)\s*$/) {
- $category or print STDERR "Entry without category <$_>\n";
- push @{$compssUsers{$2}}, $category . ($1 <= 3 ? '|' . N("Other") : '');
- }
- }
- \%compssUsers;
-}
-
-sub run_rpm {
- foreach (qw(LANG LC_CTYPE LC_NUMERIC LC_TIME LC_COLLATE LC_MONETARY LC_MESSAGES LC_PAPER LC_NAME LC_ADDRESS LC_TELEPHONE LC_MEASUREMENT LC_IDENTIFICATION LC_ALL)) {
- local $ENV{$_} = $ENV{$_} . '.UTF-8' if !/UTF-8/;
- }
- my @l = map { to_utf8($_) } `@_`;
- wantarray() ? @l : join('', @l);
-}
-
-
-sub extract_header {
- my ($pkg, $urpm) = @_;
- my $chg_prepro = sub {
- #- preprocess changelog for faster TextView insert reaction
- [ map { [ "$_\n", if_(/^\*/, { 'weight' => Gtk2::Pango->PANGO_WEIGHT_BOLD }) ] } split("\n", $_[0]) ];
- };
- my $name = urpm_name($pkg->{pkg});
- if ($pkg->{pkg}->flag_installed && !$pkg->{pkg}->flag_upgrade) {
- add2hash($pkg, { files => [ split /\n/, chomp_(scalar(run_rpm("rpm -ql $name"))) || N("(none)") ],
- changelog => $chg_prepro->(scalar(run_rpm("rpm -q --changelog $name"))) });
- } else {
- my ($p, $medium) = ($pkg->{pkg}, pkg2medium($pkg->{pkg}, $urpm));
- my $hdlist = urpm::media::any_hdlist($urpm, $medium);
- $hdlist =~ s!^file:/+!!;
- if (-r $hdlist) {
- my $packer;
- require MDV::Packdrakeng;
- eval { $packer = MDV::Packdrakeng->open(archive => $hdlist, quiet => 1) } or do {
- warn "Warning, hdlist $hdlist seems corrupted ($@)\n";
- goto header_non_available;
- };
- my ($headersdir, $retries);
- while (!-d $headersdir && $retries < 5) {
- $headersdir = chomp_(`mktemp -d /tmp/rpmdrake.XXXXXXXX`);
- $retries++;
- -d $headersdir or warn qq(Could not create temporary directory "$headersdir");
- }
- -d $headersdir or do {
- warn "Warning, could not extract header!";
- goto header_non_available;
- };
- $packer->extract($headersdir, $p->header_filename);
- $p->update_header("$headersdir/" . $p->header_filename) or do {
- warn "Warning, could not extract header!";
- goto header_non_available;
- };
- rm_rf($headersdir);
- add2hash($pkg, { summary => rpm_summary($p->summary), description => rpm_description($p->description) });
- add2hash($pkg, {
- files => scalar($p->files) ? [ $p->files ] : [ N("(none)") ],
- changelog => $chg_prepro->(join("\n", mapn { "* " . localtime2changelog($_[2]) . " $_[0]\n\n$_[1]\n" }
- [ $p->changelog_name ], [ $p->changelog_text ], [ $p->changelog_time ])) });
- $p->pack_header;
- } else {
- header_non_available:
- add2hash($pkg, { summary => $p->summary || N("(Not available)"), description => undef });
- }
- }
-}
-
-sub open_db {
- my ($o_force) = @_;
- my $host;
- log::explanations("opening the RPM database");
- if ($options{parallel} && ((undef, $host) = @{$options{parallel}})) {
- my $done if 0;
- my $dblocation = "/var/cache/urpmi/distantdb/$host";
- if (!$done || $o_force) {
- print "syncing db from $host to $dblocation...";
- mkdir_p "$dblocation/var/lib/rpm";
- system "rsync -Sauz -e ssh $host:/var/lib/rpm/ $dblocation/var/lib/rpm";
- $? == 0 or die "Couldn't sync db from $host to $dblocation";
- $done = 1;
- print "done.\n";
- }
- URPM::DB::open($dblocation) or die "Couldn't open RPM DB";
- } else {
- URPM::DB::open or die "Couldn't open RPM DB";
- }
-}
-
my $db = open_db();
sub do_search($$$$$$$) {
@@ -507,25 +398,6 @@ sub do_search($$$$$$$) {
}
}
-sub find_installed_version {
- my ($p) = @_;
- my @version;
- $db->traverse_tag('name', [ $p->name ], sub { push @version, $_[0]->version . '-' . $_[0]->release });
- @version ? join(',', sort @version) : N("(none)");
-}
-
-sub formatlistpkg { join("\n", sort { uc($a) cmp uc($b) } @_) }
-
-sub format_header {
- my ($str) = @_;
- '<big>' . escape_text_for_TextView_markup_format($str) . '</big>';
-}
-
-sub format_field {
- my ($str) = @_;
- '<b>' . escape_text_for_TextView_markup_format($str) . '</b>';
-}
-
package Gtk2::Mdv::TextView;
sub new {
@@ -1369,532 +1241,6 @@ Do you really want to install all the selected packages?"), yesno => 1)
ask_browse_tree_info_given_widgets_for_rpmdrake($options);
}
-# -=-=-=---=-=-=---=-=-=-- install packages -=-=-=---=-=-=---=-=-=-
-
-
-sub get_pkgs {
- my ($urpm, $opts) = @_;
- my $update_name = 'update_source';
- my %update_descr;
- my @update_medias;
-
- my $error_happened;
- my $fatal_handler = sub {
- $error_happened = 1;
- interactive_msg(N("Fatal error"),
- N("A fatal error occurred: %s.", $_[1]));
- myexit(-1) if 0; #FIXME
- };
-
- Rpmdrake::gurpm::init(1 ? N("Please wait") : N("Package installation..."), N("Initializing..."), transient => $::w->{real_window});
- my $_guard = before_leaving { Rpmdrake::gurpm::end() };
-
- if (!$urpm) {
- $urpm ||= urpm->new;
- $urpm->{fatal} = $fatal_handler;
- my $media = ref $options{media} ? join(',', @{$options{media}}) : '';
- urpm::media::configure($urpm, media => $media);
- if ($error_happened) {
- touch('/etc/urpmi/urpmi.cfg');
- exec('edit-urpm-sources.pl');
- }
- }
- my $_lock = urpm::lock::urpmi_db($urpm);
- my $statedir = $urpm->{statedir};
- @update_medias = grep { !$_->{ignore} && $_->{update} } @{$urpm->{media}};
-
-
- $urpm->{fatal} = $fatal_handler;
- if (member($default_list_mode, qw(all_updates security bugfix normal))) {
- unless ($options{'no-media-update'}) {
- if (@update_medias > 0) {
- if (!$opts->{skip_updating_mu}) {
- $options{'no-confirmation'} or interactive_msg_with_banner(N("Confirmation"),
-N("I need to contact the mirror to get latest update packages.
-Please check that your network is currently running.
-
-Is it ok to continue?"), yesno => 1) or myexit(-1);
- urpm::media::select_media($urpm, map { $_->{name} } @update_medias);
- update_sources($urpm, noclean => 1, banner => $::isEmbedded);
- }
- } else {
- if (any { $_->{update} } @{$urpm->{media}}) {
- interactive_msg(N("Already existing update media"),
-N("You already have at least one update medium configured, but
-all of them are currently disabled. You should run the Software
-Media Manager to enable at least one (check it in the Enabled?
-column).
-
-Then, restart %s.", $rpmdrake::myname_update));
- myexit(-1);
- }
- mu_retry_another_mirror:
- my ($mirror) = choose_mirror(if_(exists $w->{real_window}, transient => $w->{real_window}));
- my $m = ref($mirror) ? $mirror->{url} : '';
- $m or interactive_msg(N("How to choose manually your mirror"),
-N("You may also choose your desired mirror manually: to do so,
-launch the Software Media Manager, and then add a `Security
-updates' medium.
-
-Then, restart %s.", $rpmdrake::myname_update)), myexit(-1);
- add_medium_and_check(
- $urpm, {},
- $update_name, make_url_mirror($m), 'media_info/synthesis.hdlist.cz', update => 1,
- );
- @update_medias = { name => $update_name }; #- hack to simulate a medium for parsing of descriptions
- }
- }
- }
-
- Rpmdrake::gurpm::label(N("Reading updates description"));
- Rpmdrake::gurpm::progress(0.05);
- my ($cur, $section);
- #- parse the description file
- foreach my $medium (@update_medias) {
- foreach (cat_("$statedir/descriptions.$medium->{name}")) {
- /^%package +(.+)/ and do {
- my @pkg_list = split /\s+/, $1;
- exists $cur->{importance} && $cur->{importance} !~ /^(?:security|bugfix)\z/
- and $cur->{importance} = 'normal';
- $update_descr{$_} = $cur foreach @{$cur->{pkgs} || []};
- $cur = { pkgs => \@pkg_list, medium => $medium->{name} };
- $section = 'pkg';
- next;
- };
- /^%(pre|description)/ and do { $section = $1; next };
- /^Updated?: +(.+)/ && $section eq 'pkg'
- and do { $cur->{update} = $1; next };
- /^Importance: +(.+)/ && $section eq 'pkg'
- and do { $cur->{importance} = $1; next };
- /^(ID|URL): +(.+)/ && $section eq 'pkg'
- and do { $cur->{$1} = $2; next };
- $section =~ /^(pre|description)\z/ and $cur->{$1} .= $_;
- }
- }
-
- my $_unused = N("Please wait, finding available packages...");
-
- # find out installed packages:
-
- #$urpm = urpm->new;
- #$urpm->read_config;
- my $level = 0.05;
- my $total = @{$urpm->{depslist}};
- Rpmdrake::gurpm::label(N("Please wait, listing base packages..."));
- Rpmdrake::gurpm::progress($level);
-
- my ($count, $prev_stage, $new_stage, $limit);
-
- my $reset_update = sub { undef $prev_stage; $count = 0; $limit = $_[0] };
- my $update = sub {
- $count++;
- $new_stage = $level+($limit-$level)*$count/$total;
- if ($prev_stage + 0.01 < $new_stage) {
- $prev_stage = $new_stage;
- Rpmdrake::gurpm::progress($new_stage);
- }
- };
-
- my @base = ("basesystem", split /,\s*/, $urpm->{global_config}{'prohibit-remove'});
- my (%base, %basepackages);
- my $db = $db;
- my $sig_handler = sub { undef $db; exit 3 };
- local $SIG{INT} = $sig_handler;
- local $SIG{QUIT} = $sig_handler;
- $reset_update->(0.33);
- while (defined(local $_ = shift @base)) {
- exists $basepackages{$_} and next;
- $db->traverse_tag(m|^/| ? 'path' : 'whatprovides', [ $_ ], sub {
- $update->();
- push @{$basepackages{$_}}, urpm_name($_[0]);
- push @base, $_[0]->requires_nosense;
- });
- }
- foreach (values %basepackages) {
- my $n = @$_; #- count number of times it's provided
- foreach (@$_) {
- $base{$_} = \$n;
- }
- }
- Rpmdrake::gurpm::label(N("Please wait, finding installed packages..."));
- Rpmdrake::gurpm::progress($level = 0.33);
- $reset_update->(0.66);
- my %installed_pkgs;
- $db->traverse(sub {
- my ($pkg) = @_;
- $update->();
- my $fullname = urpm_name($pkg);
- #- Extract summary and description since they'll be lost when the header is packed
- $installed_pkgs{$fullname} = {
- selected => 0, pkg => $pkg, urpm_name => urpm_name($pkg),
- summary => rpm_summary($pkg->summary),
- description => rpm_description($pkg->description),
- } if !($installed_pkgs{$fullname} && $installed_pkgs{$fullname}{description});
- if (my $name = $base{$fullname}) {
- $installed_pkgs{$fullname}{base} = \$name;
- $pkg->set_flag_base(1) if $$name == 1;
- }
- $pkg->pack_header;
- });
- my $group;
- if ($options{parallel} && (($group) = @{$options{parallel}})) {
- urpm::media::configure($urpm, parallel => $group);
- }
-
-
- # find out availlable packages:
-
- #$urpm = urpm->new;
- $urpm->{state} = {};
- my %installable_pkgs;
- my %updates;
-
- Rpmdrake::gurpm::label(N("Please wait, finding available packages..."));
- Rpmdrake::gurpm::progress($level = 0.66);
-
- @update_medias = grep { !$_->{ignore} && $_->{update} } @{$urpm->{media}};
- check_update_media_version($urpm, @update_medias);
-
- my $requested = {};
- my $state = {};
- $urpm->request_packages_to_upgrade(
- $db,
- $state,
- $requested,
- start => 0,
- end => $#{$urpm->{depslist}},
- );
- $urpm->compute_installed_flags($db); # TODO/FIXME: not for updates
- $urpm->{depslist}[$_]->set_flag_installed foreach keys %$requested; #- pretend it's installed
- $urpm->{rpmdrake_state} = $state; #- Don't forget it
- Rpmdrake::gurpm::progress($level = 0.7);
-
- my %pkg_sel = map { $_ => 1 } @{$options{'pkg-sel'} || []};
- my %pkg_nosel = map { $_ => 1 } @{$options{'pkg-nosel'} || []};
- my @updates_media_names = map { $_->{name} } @update_medias;
- $reset_update->(1);
- foreach my $pkg (@{$urpm->{depslist}}) {
- $update->();
- $pkg->flag_upgrade or next;
- my $selected = 0;
-
- if (member(pkg2medium($pkg, $urpm)->{name}, @updates_media_names) && $pkg->flag_installed) { # TODO/FIXME: for updates
- any { $pkg->id >= $_->{start} && $pkg->id <= $_->{end} } @update_medias or next;
- if ($options{'pkg-sel'} || $options{'pkg-nosel'}) {
- my $n = urpm_name($pkg);
- $pkg_sel{$n} || $pkg_nosel{$n} or next;
- $pkg_sel{$n} and $selected = 1;
- } else {
- # selecting updates by default:
- $selected = 1;
- }
- $updates{urpm_name($pkg)} = { selected => $selected, pkg => $pkg };
- } else {
- $installable_pkgs{urpm_name($pkg)} = { selected => $selected, pkg => $pkg };
- }
- }
- if ($options{'pkg-sel'} && $options{'pkg-nosel'}) {
- push @{$options{'pkg-nosel'}}, @{$options{'pkg-sel'}};
- delete $options{'pkg-sel'};
- }
-
- $_->{pkg}->set_flag_installed foreach values %installed_pkgs;
-
- +{ urpm => $urpm,
- installed => \%installed_pkgs,
- installable => \%installable_pkgs,
- updates => \%updates,
- update_descr => \%update_descr,
- };
-}
-
-sub perform_installation { #- (partially) duplicated from /usr/sbin/urpmi :-(
- my ($urpm, $pkgs) = @_;
-
- my $fatal_msg;
- my @error_msgs;
- my %Readmes;
- my $statusbar_msg_id;
- local $urpm->{fatal} = sub { printf STDERR "Fatal: %s\n", $_[1]; $fatal_msg = $_[1]; goto fatal_error };
- local $urpm->{error} = sub { printf STDERR "Error: %s\n", $_[0]; push @error_msgs, $_[0] };
-
- $w->{rwindow}->set_sensitive(0);
-
- my $group;
- if ($options{parallel} && (($group) = @{$options{parallel}})) {
- my $pkgs = join(' ', map { if_($_->flag_requested, urpm_name($_)) } @{$urpm->{depslist}});
- system("urpmi -v --X --parallel $group $pkgs");
- if ($? == 0) {
- $statusbar_msg_id = statusbar_msg(
- #N("Everything installed successfully"),
- N("All requested packages were installed successfully."),
- );
- } else {
- interactive_msg(
- N("Problem during installation"),
- N("There was a problem during the installation:\n\n%s", join("\n", @error_msgs)),
- scroll => 1,
- );
- }
- open_db('force_sync');
- $w->{rwindow}->set_sensitive(1);
- return 0;
- }
-
- my $_lock = urpm::lock::urpmi_db($urpm);
- my $_rpm_lock = urpm::lock::rpm_db($urpm, 'exclusive');
- my %pkgs = map { $_->id => undef } grep { $_->flag_selected } @{$urpm->{depslist}};
- my ($local_sources, $list, $local_to_removes) = urpm::get_pkgs::selected2list($urpm,
- \%pkgs,
- clean_all => 1,
- );
- my $distant_number = scalar keys %pkgs;
- if (!$local_sources && (!$list || !@$list)) {
- interactive_msg(
- N("Unable to get source packages."),
- N("Unable to get source packages, sorry. %s",
- @error_msgs ? N("\n\nError(s) reported:\n%s", join("\n", @error_msgs)) : ''),
- scroll => 1,
- );
- goto return_with_error;
- }
- foreach (@$local_to_removes) {
- unlink $_;
- }
-
- my @pkgs = map { scalar($_->fullname) } sort(grep { $_->flag_selected } @{$urpm->{depslist}});#{ $a->name cmp $b->name } @{$urpm->{depslist}}[keys %{$state->{selected}}];
- @{$urpm->{ask_remove}} = sort urpm::select::removed_packages($urpm, $urpm->{state});
- my @to_remove = grep { $_ } map { if_($pkgs->{$_}{selected}, $pkgs->{$_}{urpm_name}) } keys %$pkgs;
-
- my $r = join "\n", urpm::select::translate_why_removed($urpm, $urpm->{state}, @to_remove);
-
- my $install_count = int(@pkgs);
- my $to_install = $install_count ?
- #-PO: in singular form, we use %2\$
- P("To satisfy dependencies, the following package is going to be installed:\n%2\$s\n", "To satisfy dependencies, the following %d packages are going to be installed:\n%s\n", $install_count, $install_count,
- formatlistpkg(map { s!.*/!!; $_ } @pkgs)) : '';
- my $remove_count = scalar(@to_remove);
- interactive_msg(($to_install ? N("Confirmation") : N("Some packages need to be removed")),
- ($r ?
- (!$to_install ? join("\n\n", P("Remove one package?", "Remove %d packages?", $remove_count, $remove_count), $r) :
- P("The following package has to be removed for others to be upgraded:", "The following packages have to be removed for others to be upgraded:", $remove_count) . join("\n\n", $r, if_($to_install, $to_install)) . N("Is it ok to continue?"))
- : $to_install),
- scroll => 1,
- yesno => 1) or do {
- $w->{rwindow}->set_sensitive(1);
- return 'canceled';
- };
-
- Rpmdrake::gurpm::init(1 ? N("Please wait") : N("Package installation..."), N("Initializing..."), transient => $::w->{real_window});
- my $distant_progress;
- my $canceled;
- my %sources = $urpm->download_source_packages(
- $local_sources,
- $list,
- force_local => 1, # removed in urpmi 4.8.7
- ask_for_medium => sub {
- interactive_msg(
- N("Change medium"),
- N("Please insert the medium named \"%s\" on device [%s]", $_[0], $_[1]),
- yesno => 1, text => { no => N("Cancel"), yes => N("Ok") },
- );
- },
- callback => sub {
- my ($mode, $file, $percent) = @_;
- if ($mode eq 'start') {
- Rpmdrake::gurpm::label(N("Downloading package `%s' (%s/%s)...",
- basename($file), ++$distant_progress, $distant_number));
- Rpmdrake::gurpm::validate_cancel(but(N("Cancel")), sub { $canceled = 1 });
- } elsif ($mode eq 'progress') {
- Rpmdrake::gurpm::progress($percent/100);
- } elsif ($mode eq 'end') {
- Rpmdrake::gurpm::progress(1);
- Rpmdrake::gurpm::invalidate_cancel();
- }
- $canceled and return 'canceled';
- },
- );
- $canceled and goto return_with_error;
- Rpmdrake::gurpm::invalidate_cancel_forever();
-
- my %sources_install = %{$urpm->extract_packages_to_install(\%sources, $urpm->{rpmdrake_state}) || {}};
- my @rpms_install = grep { !/\.src\.rpm$/ } values %sources_install;
- my @rpms_upgrade = grep { !/\.src\.rpm$/ } values %sources;
-
- if (!$options{'no-verify-rpm'}) {
- Rpmdrake::gurpm::label(N("Verifying package signatures..."));
- my $total = @rpms_install + @rpms_upgrade;
- my $progress;
- my @invalid_sources = urpm::signature::check($urpm,
- \%sources_install, \%sources,
- translate => 1, basename => 1,
- callback => sub {
- Rpmdrake::gurpm::progress(++$progress/$total);
- },
- );
- if (@invalid_sources) {
- local $::main_window = $Rpmdrake::gurpm::mainw->{real_window};
- interactive_msg(
- N("Warning"),
- N("The following packages have bad signatures:\n\n%s\n\nDo you want to continue installation?",
- join("\n", sort @invalid_sources)), yesno => 1, if_(@invalid_sources > 10, scroll => 1),
- ) or goto return_with_error;
- }
- }
-
- my $_guard = before_leaving { urpm::removable::try_umounting_removables($urpm) };
-
- my $something_installed;
- if (@rpms_install || @rpms_upgrade || @to_remove) {
- if (my @missing = grep { m|^/| && ! -e $_ } @rpms_install, @rpms_upgrade) {
- interactive_msg(
- N("Installation failed"),
- N("Installation failed, some files are missing:\n%s\n\nYou may want to update your media database.",
- join "\n", map { " $_" } @missing) .
- (@error_msgs ? N("\n\nError(s) reported:\n%s", join("\n", @error_msgs)) : ''),
- if_(@error_msgs > 1, scroll => 1),
- );
- goto return_with_error;
- }
- my $progress_nb;
- my $total_nb = scalar grep { m|^/| } @rpms_install, @rpms_upgrade;
- my $callback_inst = sub {
- my ($urpm, $type, $id, $subtype, $amount, $total) = @_;
- my $pkg = defined $id ? $urpm->{depslist}[$id] : undef;
- if ($subtype eq 'start') {
- if ($type eq 'trans') {
- Rpmdrake::gurpm::label(@rpms_install ? N("Preparing packages installation...") : N("Preparing..."));
- } elsif (defined $pkg) {
- $something_installed = 1;
- Rpmdrake::gurpm::label(N("Installing package `%s' (%s/%s)...", $pkg->name, ++$progress_nb, $total_nb));
- }
- } elsif ($subtype eq 'progress') {
- Rpmdrake::gurpm::progress($total ? $amount/$total : 1);
- }
- };
- my $fh;
- my @errors = urpm::install::install($urpm,
- \@to_remove,
- \%sources_install,
- \%sources,
- post_clean_cache => $urpm->{options}{'post-clean'},
- callback_open => sub {
- my ($_data, $_type, $id) = @_;
- my $f = $sources_install{$id} || $sources{$id};
- open $fh, $f or $urpm->{error}(N("unable to access rpm file [%s]", $f));
- return fileno $fh;
- },
- callback_inst => $callback_inst,
- callback_trans => $callback_inst,
- callback_close => sub {
- my ($urpm, undef, $pkgid) = @_;
- return unless defined $pkgid;
- my $pkg = $urpm->{depslist}[$pkgid];
- my $fullname = $pkg->fullname;
- my $trtype = (any { /\Q$fullname/ } values %sources_install) ? 'install' : '(update|upgrade)';
- foreach ($pkg->files) { /\bREADME(\.$trtype)?\.urpmi$/ and $Readmes{$_} = $fullname }
- close $fh;
- },
- );
- Rpmdrake::gurpm::end();
-
- if (@errors || @error_msgs) {
- interactive_msg(
- N("Problem during installation"),
- N("There was a problem during the installation:\n\n%s",
- join("\n", @errors, @error_msgs)),
- if_(@errors + @error_msgs > 1, scroll => 1),
- );
- $w->{rwindow}->set_sensitive(1);
- return !$something_installed;
- }
-
- my %pkg2rpmnew;
- foreach my $u (@rpms_upgrade) {
- $u =~ m|/([^/]+-[^-]+-[^-]+)\.[^\./]+\.rpm$|
- and $pkg2rpmnew{$1} = [ grep { m|^/etc| && (-r "$_.rpmnew" || -r "$_.rpmsave") }
- map { chomp_($_) } run_rpm("rpm -ql $1") ];
- }
- dialog_rpmnew(N("The installation is finished; everything was installed correctly.
-
-Some configuration files were created as `.rpmnew' or `.rpmsave',
-you may now inspect some in order to take actions:"),
- %pkg2rpmnew)
- and $statusbar_msg_id = statusbar_msg(N("All requested packages were installed successfully."));
- if (keys %Readmes) { #- display the README*.urpmi files
- interactive_packtable(
- N("Upgrade information"),
- $w->{real_window},
- N("These packages come with upgrade information"),
- [ map {
- my $fullname = $_;
- [ gtkpack__(
- gtknew('HBox'),
- gtkset_selectable(gtknew('Label', text => $Readmes{$fullname}),1),
- ),
- gtksignal_connect(
- gtknew('Button', text => N("Upgrade information about this package")),
- clicked => sub {
- interactive_msg(
- N("Upgrade information about package %s", $Readmes{$fullname}),
- (join '' => formatAlaTeX(scalar cat_($fullname))),
- scroll => 1,
- );
- },
- ),
- ] } keys %Readmes ],
- [ gtknew('Button', text => N("Ok"), clicked => sub { Gtk2->main_quit }) ]
- );
- }
- } else {
- Rpmdrake::gurpm::end();
- interactive_msg(N("Error"),
- N("Unrecoverable error: no package found for installation, sorry."));
- }
-
- $w->{rwindow}->set_sensitive(1);
- statusbar_msg_remove($statusbar_msg_id); #- XXX maybe remove this
- return !($something_installed || scalar(@to_remove));
-
- fatal_error:
- Rpmdrake::gurpm::end();
- interactive_msg(N("Installation failed"),
- N("There was a problem during the installation:\n\n%s", $fatal_msg));
- return_with_error:
- Rpmdrake::gurpm::end();
- $w->{rwindow}->set_sensitive(1);
- return 1;
-}
-
-
-# -=-=-=---=-=-=---=-=-=-- remove packages -=-=-=---=-=-=---=-=-=-
-
-sub perform_removal {
- my ($urpm, $pkgs) = @_;
- my @toremove = map { if_($pkgs->{$_}{selected}, $pkgs->{$_}{urpm_name}) } keys %$pkgs;
- my @results;
- slow_func_statusbar(
- N("Please wait, removing packages..."),
- $w->{real_window},
- sub {
- @results = $options{parallel}
- ? urpm::parallel::remove($urpm, \@toremove)
- : urpm::install::install($urpm, \@toremove, {}, {});
- open_db('force_sync');
- },
- );
- if (@results) {
- interactive_msg(
- N("Problem during removal"),
- N("There was a problem during the removal of packages:\n\n%s", join("\n", @results)),
- if_(@results > 1, scroll => 1),
- );
- return 1;
- } else {
- return 0;
- }
-}
-
# -=-=-=---=-=-=---=-=-=-- main -=-=-=---=-=-=---=-=-=-
generated by cgit v1.2.1 (git 2.21.0) at 2025-03-14 23:59:16 +0000