From 8ddd8c978e44610965aa0e1ea52f8082fb0fe282 Mon Sep 17 00:00:00 2001
From: Pascal Rigaux <pixel@mandriva.com>
Date: Thu, 9 Aug 2007 20:53:41 +0000
Subject: - urpmi   o move some code to new module urpm::main_loop to share it
 with rpmdrake

---
 urpmi | 249 +++++-------------------------------------------------------------
 1 file changed, 19 insertions(+), 230 deletions(-)

(limited to 'urpmi')

diff --git a/urpmi b/urpmi
index 22d6d920..12abbaf2 100755
--- a/urpmi
+++ b/urpmi
@@ -23,12 +23,10 @@ use strict;
 use urpm;
 use urpm::args;
 use urpm::msg;
-use urpm::install;
 use urpm::media;
 use urpm::select;
-use urpm::get_pkgs;
-use urpm::signature;
 use urpm::util qw(untaint difference2 member partition);
+use urpm::main_loop;
 
 #- contains informations to parse installed system.
 my $urpm = new urpm;
@@ -606,21 +604,10 @@ if (@root_only) {
     message_input("$msg\n$p\n$msg2" . N(" (Y/n) "), $force && $yesexpr, boolean => 1) =~ /[$noexpr]/ and exit 0;
 }
 
-my ($local_sources, $list) = urpm::get_pkgs::selected2list($urpm,
-    $state->{selected},
-    clean_all => $clean,
-    clean_other => !$noclean && $urpm->{options}{'pre-clean'},
-);
-unless ($local_sources || $list) {
-    $urpm->{fatal}(3, N("unable to get source packages, aborting"));
-}
-
-my %sources = %$local_sources;
-my %error_sources;
-
-urpm::removable::copy_packages_of_removable_media($urpm,
-    $list, \%sources,
-    (!$urpm->{options}{auto} || $allow_medium_change) && sub {
+my $exit_code = urpm::main_loop::run($urpm, $state, 
+				     @names || @src_names || @files || @src_files, 
+				     \@ask_unselect, \%requested, {
+    (!$urpm->{options}{auto} || $allow_medium_change ? (copy_removable =>  sub {
 	my $msg = N("Please insert the medium named \"%s\" on device [%s]", $_[0], $_[1]);
 	my $msg2 = N("Press Enter when ready...");
 	if ($ENV{DISPLAY} && $::gui) {
@@ -631,226 +618,28 @@ urpm::removable::copy_packages_of_removable_media($urpm,
 	    }
 	}
 	return defined message_input("$msg\n$msg2 ");
-    });
-
-#- now create transaction just before installation, this will save user impression of slowness.
-#- split of transaction should be disabled if --test is used.
-urpm::install::create_transaction($urpm, $state,
-			  nodeps => $urpm->{options}{'allow-nodeps'} || $urpm->{options}{'allow-force'},
-			  split_level => $urpm->{options}{'split-level'},
-			  split_length => !$test && $urpm->{options}{'split-length'});
-
-my ($ok, $nok) = (0, 0);
-my @errors;
-
-foreach my $set (@{$state->{transaction} || []}) {
-    my (@transaction_list, %transaction_sources);
-
-    #- put a blank line to separate with previous transaction or user question.
-    print "\n" if $options{verbose} >= 0;
-
-    #- prepare transaction...
-    urpm::install::prepare_transaction($urpm, $set, $list, \%sources, \@transaction_list, \%transaction_sources);
-
-    #- first, filter out what is really needed to download for this small transaction.
-    urpm::get_pkgs::download_packages_of_distant_media($urpm,
-	\@transaction_list,
-	\%transaction_sources,
-	\%error_sources,
-	quiet => $options{verbose} < 0,
-	callback => sub {
+    }) : ()),
+    trans_log => sub {
 #	    my ($mode, $file, $percent, $total, $eta, $speed) = @_;
 	    goto &urpm::download::sync_logger;
-	},
-    );
-    my %transaction_sources_install = %{$urpm->extract_packages_to_install(\%transaction_sources, $state) || {}};
-
-    if (!$force && ($urpm->{options}{'verify-rpm'} || grep { $_->{'verify-rpm'} } @{$urpm->{media}})) {
-	my @bad_signatures = urpm::signature::check($urpm, \%transaction_sources_install, \%transaction_sources);
-
-	if (@bad_signatures) {
-	    my $msg = @bad_signatures == 1 ?
-	    	N("The following package has bad signature")
-		: N("The following packages have bad signatures");
-	    my $msg2 = N("Do you want to continue installation ?");
-	    my $p = join "\n", @bad_signatures;
+    },
+    bad_signature => sub {
+	    my ($msg, $msg2) = @_;
 	    #- rurpmi always abort here
 	    if ($urpm->{options}{auto} || $restricted) {
-		print "$msg:\n$p\n\n";
+		print "$msg\n";
 		exit 1;
 	    } else {
 		my $yesexpr = N("Yy");
-		message_input("$msg:\n$p\n$msg2" . N(" (y/N) "), $force && $yesexpr, boolean => 1) =~ /[$yesexpr]/ or exit 1;
-	    }
-	}
-    }
-
-    #- install source package only (whatever the user is root or not, but use rpm for that).
-    if ($install_src) {
-	if (my @l = grep { /\.src\.rpm$/ } values %transaction_sources_install, values %transaction_sources) {
-	    my $rpm_opt = $options{verbose} >= 0 ? 'vh' : '';
-	    system("rpm", "-i$rpm_opt", @l, ($urpm->{root} ? ("--root", $urpm->{root}) : @{[]}));
-	    #- Warning : the following message is parsed in urpm::parallel_*
-	    if ($?) {
-		print N("Installation failed"), "\n";
-		++$nok;
-	    }
-	}
-	next;
-    }
-
-    next if $no_install;
-
-    #- clean to remove any src package now.
-    foreach (\%transaction_sources_install, \%transaction_sources) {
-	foreach my $id (keys %$_) {
-	    my $pkg = $urpm->{depslist}[$id] or next;
-	    $pkg->arch eq 'src' and delete $_->{$id};
-	}
-    }
-
-    if (keys(%transaction_sources_install) || keys(%transaction_sources)) {
-	if ($parallel) {
-	    print N("distributing %s", join(' ', values %transaction_sources_install, values %transaction_sources)), "\n";
-	    #- no remove are handle here, automatically done by each distant node.
-	    $urpm->{log}("starting distributed install");
-	    $urpm->{parallel_handler}->parallel_install(
-		$urpm,
-		[ keys %{$state->{rejected} || {}} ], \%transaction_sources_install, \%transaction_sources,
-		test => $test,
-		excludepath => $urpm->{options}{excludepath}, excludedocs => $urpm->{options}{excludedocs},
-	    );
-	} else {
-	    if ($options{verbose} >= 0) {
-		my @packnames = (values %transaction_sources_install, values %transaction_sources);
-		(my $common_prefix) = $packnames[0] =~ m!^(.*)/!;
-		if (length($common_prefix) && @packnames == grep { m!^\Q$common_prefix/! } @packnames) {
-		    #- there's a common prefix, simplify message
-		    print N("installing %s from %s", join(' ', map { s!.*/!!; $_ } @packnames), $common_prefix), "\n";
-		} else {
-		    print N("installing %s", join "\n", @packnames), "\n";
-		}
-	    }
-	    my $to_remove = $urpm->{options}{'allow-force'} ? [] : $set->{remove} || [];
-	    bug_log(scalar localtime(), " ", join(' ', values %transaction_sources_install, values %transaction_sources), "\n");
-	    $urpm->{log}("starting installing packages");
-	    my %install_options_common = (
-		test => $test,
-		excludepath => $urpm->{options}{excludepath},
-		excludedocs => $urpm->{options}{excludedocs},
-		repackage   => $urpm->{options}{repackage},
-		post_clean_cache => $urpm->{options}{'post-clean'},
-		oldpackage => $state->{oldpackage},
-		nosize => $urpm->{options}{ignoresize},
-		ignorearch => $urpm->{options}{ignorearch},
-		noscripts => $urpm->{options}{noscripts},
-	    );
-	    my @l = urpm::install::install($urpm,
-		$to_remove,
-		\%transaction_sources_install, \%transaction_sources,
-		%install_options_common,
-	    );
-	    if (@l) {
-		#- Warning : the following message is parsed in urpm::parallel_*
-		print N("Installation failed:") . "\n" . join("\n",  map { "\t$_" } @l), "\n";
-		if ($urpm->{options}{auto} || !$urpm->{options}{'allow-nodeps'} && !$urpm->{options}{'allow-force'}) {
-		    ++$nok;
-		    ++$urpm->{logger_id};
-		    push @errors, @l;
-		} else {
-		    my $yesexpr = N("Yy");
-		    message_input(N("Try installation without checking dependencies? (y/N) "),
-				  $force && $yesexpr, boolean => 1) =~ /[$yesexpr]/ or ++$nok, next;
-		    $urpm->{log}("starting installing packages without deps");
-		    @l = urpm::install::install($urpm,
-			$to_remove,
-			\%transaction_sources_install, \%transaction_sources,
-			nodeps => 1,
-			%install_options_common,
-		    );
-		    if (@l) {
-			#- Warning : the following message is parsed in urpm::parallel_*
-			print N("Installation failed:") . "\n" . join("\n", map { "\t$_" } @l), "\n";
-			if (!$urpm->{options}{'allow-force'}) {
-			    ++$nok;
-			    ++$urpm->{logger_id};
-			    push @errors, @l;
-			} else {
-			    message_input(N("Try harder to install (--force)? (y/N) "),
-					  $force && $yesexpr, boolean => 1) =~ /[$yesexpr]/ or ++$nok, next;
-			    $urpm->{log}("starting force installing packages without deps");
-			    @l = urpm::install::install($urpm,
-				$to_remove,
-				\%transaction_sources_install, \%transaction_sources,
-				nodeps => 1, force => 1,
-				%install_options_common,
-			    );
-			    if (@l) {
-				#- Warning : the following message is parsed in urpm::parallel_*
-				print N("Installation failed:") . "\n" . join("\n", map { "\t$_" } @l), "\n";
-				++$nok;
-				++$urpm->{logger_id};
-				push @errors, @l;
-			    } else {
-				++$ok;
-			    }
-			}
-		    } else {
-			++$ok;
-		    }
-		}
-	    } else {
-		++$ok;
-	    }
-	}
-    }
-}
-
-#- keep a track of error code.
-my $exit_code = 0;
-if (values %error_sources) {
-    #- Warning : the following message is parsed in urpm::parallel_*
-    print N("Installation failed, some files are missing:\n%s\nYou may want to update your urpmi database",
-	join "\n", map { s|([^:]*://[^/:\@]*:)[^/:\@]*(\@.*)|$1xxxx$2|; "    $_" } values %error_sources), "\n";
-    $exit_code = 10;
-}
-if ($nok) {
-    $nok > 1 and print P("%d installation transaction failed",
-	    "%d installation transactions failed", $nok, $nok) . (@errors && ":\n" . join("\n", map { "\t$_" } @errors)), "\n";
-    if ($exit_code) {
-	$exit_code = $ok ? 13 : 14;
-    } else {
-	$exit_code = $ok ? 11 : 12;
-    }
-} else {
-    if ($test) {
-	#- Warning : the following message is parsed in urpm::parallel_*
-	print N("Installation is possible"), "\n";
-    } elsif (@names || @src_names || @files || @src_files || $auto_select) {
-	if (@{$state->{transaction} || []} == 0 && @ask_unselect == 0) {
-	    if ($options{verbose} >= 0) {
-		if ($auto_select) {
-		    print N("Packages are up to date"), "\n";
-		} else {
-		    my @pkgs = map { $urpm->{depslist}[$_] } map { split /\|/ } keys %requested;
-		    my ($installed, $error) = partition { $_->flag_installed } @pkgs;
-		    my @installed = map { scalar $_->fullname } @$installed;
-		    my @error = map { scalar $_->fullname } @$error;
-		    my @msg1 = @installed == 0 ? () :
-		    	@installed == 1 ?
-			  N("Package %s is already installed", join(', ', @installed)) :
-			  N("Packages %s are already installed", join(', ', @installed));
-		    my @msg2 = @error == 0 ? () :
-		    	@error == 1 ?
-			  N("Package %s can not be installed", join(', ', @error)) :
-			  N("Packages %s can not be installed", join(', ', @error));
-		    print join("\n", @msg1, @msg2, '');
-		}
+		message_input("$msg$msg2" . N(" (y/N) "), $force && $yesexpr, boolean => 1) =~ /[$yesexpr]/ or exit 1;
 	    }
-	    $exit_code = 15 if our $expect_install;
-	}
-    }
-}
+    },                           
+    ask_yes_or_no => sub {
+	my ($_title, $msg) = @_; # graphical title
+	my $yesexpr = N("Yy");
+	message_input($msg, $force && $yesexpr, boolean => 1) =~ /[$yesexpr]/;
+    },
+});
 
 unless ($env || $options{nolock}) {
     $urpmi_lock->unlock;
-- 
cgit v1.2.1