[yast-commit] r60484 - in /trunk/wagon: package/ src/clients/ src/config/ src/include/ src/modules/

22 Jan 2010

Author: locilka
Date: Fri Jan 22 12:08:50 2010
New Revision: 60484

URL: http://svn.opensuse.org/viewcvs/yast?rev=60484&view=rev
Log:
- Wagon extended to read and use migration products from the
  <upgrade> section from product control files (BNC #559554).


Added:
    trunk/wagon/src/clients/wagon_migration_products.ycp
    trunk/wagon/src/clients/wagon_point_of_no_return.ycp
    trunk/wagon/src/include/
    trunk/wagon/src/include/Makefile.am
    trunk/wagon/src/include/common_func.ycp
Modified:
    trunk/wagon/package/yast2-wagon.changes
    trunk/wagon/src/clients/wagon.ycp
    trunk/wagon/src/clients/wagon_selfupdate.ycp
    trunk/wagon/src/config/online_migration.xml
    trunk/wagon/src/modules/Wagon.ycp

Modified: trunk/wagon/package/yast2-wagon.changes
URL: http://svn.opensuse.org/viewcvs/yast/trunk/wagon/package/yast2-wagon.changes?rev=60484&r1=60483&r2=60484&view=diff
==============================================================================

--- trunk/wagon/package/yast2-wagon.changes (original)
+++ trunk/wagon/package/yast2-wagon.changes Fri Jan 22 12:08:50 2010
@@ -1,3 +1,9 @@
+-------------------------------------------------------------------
+Fri Jan 22 11:57:00 CET 2010 - locilka@suse.cz
+
+- Wagon extended to read and use migration products from the
+  <upgrade> section from product control files (BNC #559554).
+
 ------------------------------------------------------------------
 Wed Jan 13 18:56:03 CET 2010 - kmachalkova@suse.cz
 

Modified: trunk/wagon/src/clients/wagon.ycp
URL: http://svn.opensuse.org/viewcvs/yast/trunk/wagon/src/clients/wagon.ycp?rev=60484&r1=60483&r2=60484&view=diff
==============================================================================
--- trunk/wagon/src/clients/wagon.ycp (original)
+++ trunk/wagon/src/clients/wagon.ycp Fri Jan 22 12:08:50 2010
@@ -26,6 +26,10 @@
     import "CommandLine";
     import "PackageLock";
     import "PackageCallbacks";
+    import "Report";
+    import "FileUtils";
+
+    include "wagon/common_func.ycp";
 
     textdomain "wagon";
 
@@ -137,6 +141,134 @@
 	}
     }
 
+    boolean RevertToOldProducts () {
+	if (Wagon::abort_can_revert_products != true) {
+	    y2warning ("Cannot revert the previous state of products, sorry. Installed products were: %1, Migration products were: %2",
+		Wagon::products_before_migration, Wagon::migration_products);
+
+	    Report::Warning (_("Cannot revert the previous state of installed products.
+You will have to revert them manually."));
+
+	    return false;
+	}
+
+	Wizard::SetContents (
+	    _("Reverting Migration"),
+	    `Label(_("Migration tool has to remove the temporary migration products,
+install the previously installed ones and contact Novell Customer Center
+to get update repositories.")),
+	    _("<p>Several tasks can be done by the migration tool. If you skip this step,
+you will have to do them manually.</p>"),
+	    false, true
+	);
+	Wizard::EnableAbortButton ();
+
+	boolean cont = true;
+	while (true) {
+	    any ret = UI::UserInput();
+	    if (ret == `next) {
+		cont = true;
+		break;
+	    } else if (ret == `abort || ret == `cancel) {
+		if (Popup::AnyQuestion (
+		    // popup dialog caption
+		    _("Migration Has to Be Reverted"),
+		    // popup dialog qustion
+		    _("Are you sure you want to skip reverting the migration?"),
+		    // button
+		    _("&Yes, Skip It"),
+		    // button
+		    _("&No"),
+		    `focus_no
+		)) {
+		    cont = false;
+		    break;
+		}
+	    }
+	}
+
+	if (cont != true) {
+	    y2warning ("User decided not to rollback");
+	    return false;
+	}
+
+	ResetPackager();
+
+	// Full paths to product files
+	list <string> removed_product_files = [];
+	// Product packages
+	list <string> removed_packages = [];
+
+	Wizard::SetContents (
+	    _("Reverting Migration"),
+	    `Label(_("Removing temporary migration products...")),
+	    "",
+	    false, true
+	);
+
+	// Remove all the migration products using packages approach manually
+	// Removing via ResolvableRemove + PkgSolve usually produces errors,
+	// dependency loops etc.
+	//
+	y2milestone ("Removing newly installed products: %1", Wagon::migration_products);
+	foreach (string migration_product, Wagon::migration_products, {
+	    foreach (map  remove_product, Pkg::ResolvableProperties (migration_product, `product, ""), {
+		remove_product = Wagon::MinimizeProductMap (remove_product);
+
+		string product_file = remove_product["product_file"]:"";
+		if (product_file == nil || product_file == "") {
+		    y2error ("Cannot remove product: %1, no product file defined", remove_product);
+		    Report::Error (sformat(_("Cannot remove product %1"), remove_product["name"]:_("Unknown product")));
+		    return;
+		}
+
+		if (! regexpmatch (product_file, "^/etc/products\\.d/.+"))
+		    product_file = sformat ("/etc/products.d/%1", product_file);
+
+		if (contains (removed_product_files, product_file)) {
+		    y2milestone ("Product file %1 has been already removed", product_file);
+		    return;
+		}
+
+		string package_name = Wagon::GetFileOwner (product_file);
+
+		if (package_name == nil || package_name == "") {
+		    y2error ("Cannot find out file owner %1", product_file);
+		    Report::Error (sformat(_("Cannot remove product %1"), remove_product["name"]:_("Unknown product")));
+		    return;
+		}
+
+		if (Pkg::TargetRemove (package_name) != true) {
+		    y2error ("Cannot remove package %1", package_name);
+		    Report::Error (sformat(_("Cannot remove product %1.
+Remove package %2 manually"), remove_product["name"]:_("Unknown product"), package_name));
+		    return;
+		}
+
+		y2milestone ("Product %1/%2 has been successfully removed", remove_product, package_name);
+		removed_product_files = add (removed_product_files, product_file);
+		removed_packages = add (removed_packages, package_name);
+	    });
+	});
+
+	if (size (removed_packages) > 0) {
+	    y2milestone ("%1 products were removed, reseting packager", size (removed_packages));
+	    ResetPackager();
+
+	    foreach (string one_package, removed_packages, {
+		y2milestone ("Removed product package check: %1", Pkg::ResolvableProperties (one_package, `package, ""));
+	    });
+	}
+
+	y2milestone ("Running registration");
+	if (WFM::call ("inst_suse_register") == `abort) {
+	    y2error ("Unable to register");
+	    return false;
+	}
+
+	return true;
+    }
+
     // main()
     HandleInit();
 
@@ -152,6 +284,12 @@
 	ret = ProductControl::RunFrom (current_step, false);
     }
 
+    // Wagon has been aborted, revert to the previous products
+    // if possible
+    if (ret == `abort || ret == `cancel) {
+	RevertToOldProducts();
+    }
+
     Wizard::CloseDialog();
 
     HandleRet (ret);

Added: trunk/wagon/src/clients/wagon_migration_products.ycp
URL: http://svn.opensuse.org/viewcvs/yast/trunk/wagon/src/clients/wagon_migration_products.ycp?rev=60484&view=auto
==============================================================================
--- trunk/wagon/src/clients/wagon_migration_products.ycp (added)
+++ trunk/wagon/src/clients/wagon_migration_products.ycp Fri Jan 22 12:08:50 2010
@@ -0,0 +1,127 @@
+/**
+ * File:
+ *	clients/wagon_migration_products.ycp
+ *
+ * Module:
+ *	Wagon
+ *
+ * Authors:
+ *	Lukas Ocilka 
+ *
+ * Summary:
+ *	Online Migration Tool
+ *
+ * $Id$
+ *
+ */
+
+{
+    /**
+     * Selects and installs all migration products.
+     */
+
+    textdomain "wagon";
+
+    import "Wagon";
+    import "PackagesUI";
+    import "GetInstArgs";
+    import "Report";
+    import "Popup";
+    import "Label";
+
+    include "wagon/common_func.ycp";
+
+    if (GetInstArgs::going_back()) {
+	y2milestone ("Going back...");
+	return `back;
+    }
+
+    boolean FindAndSelectMigrationProducts () {
+	if (Wagon::InitPkg() != true) {
+	    Report::Error (_("Unable to initialize the package manager."));
+	    return false;
+	}
+
+	list  > products = Pkg::ResolvableProperties ("", `product, "");
+
+	foreach (map p, products, {
+	    if (p["status"]:`unknown != `installed) {
+		y2milestone ("Product %1 (%2) is not installed, skipping...",
+		    p["name"]:"not-defined", p["short_name"]:p["display_name"]:"not-defined");
+		return;
+	    }
+
+	    if (! haskey (p, "upgrades") || p["upgrades"]:[] == []) {
+		y2warning ("Product %1 (%2) does not contain 'upgrades' section...",
+		    p["name"]:"not-defined", p["short_name"]:p["display_name"]:"not-defined");
+		return;
+	    }
+
+	    y2milestone ("Going to upgrade product %1 (%2)",
+		p["name"]:"not-defined", p["short_name"]:p["display_name"]:"not-defined");
+
+	    if (p["name"]:"" == nil || p["name"]:"" == "") {
+		y2error ("Product %1 doesn't have a name, reverting will be impossible", p);
+		Report::Error (sformat(_("Product %1 does not have a machine-readable 'name'.
+Automatic reverting of the product state will be impossible."),  p["short_name"]:p["display_name"]:"not-defined"));
+	    }
+
+	    foreach (map  supported_upgrade, (list  >) p["upgrades"]:[], {
+		if (! haskey (supported_upgrade, "product") || supported_upgrade["product"]:"" == "") {
+		    y2error ("Erroneous product upgrades: %1 (%2)", p, supported_upgrade);
+		    Report::Error (sformat (_("Cannot upgrade product %1 (%2).
+Migration path is erroneous."),  p["display_name"]:p["short_name"]:_("Unknown"), p["name"]:_("not-defined")));
+		    return;
+		}
+
+		string old_product = p["name"]:"";
+		string migration_product = supported_upgrade["product"]:"";
+
+		// Install the migration product
+		if ((size (Pkg::ResolvableProperties (migration_product, `product, "")) == 0) || (Pkg::ResolvableInstall (migration_product, `product) != true)) {
+		    y2error ("Cannot select migration product for installation: %1", Pkg::ResolvableProperties (migration_product, `product, ""));
+		    Report::Error (sformat (_("Cannot select product
+%1 (%2) for installation."), supported_upgrade["name"]:"", migration_product));
+		    return;
+		} else {
+		    Wagon::migration_products = add (Wagon::migration_products, migration_product);
+		}
+
+// Old products are removed automatically during the upgrade
+//		// Remove the old product
+//		if ((Pkg::ResolvableInstalled (old_product, `product) != true) || (Pkg::ResolvableRemove (migration_product, `product) == true)) {
+//		    Report::Error (sformat (_("Cannot select product %1 for deinstallation."), migration_product));
+//		    return;
+//		}
+	    });
+	});
+
+	return true;
+    }
+
+    if (FindAndSelectMigrationProducts() != true) {
+	return `auto;
+    }
+
+    symbol ret = SolveDependencies();
+
+    if (ret != `abort) {
+	// Solver ends with some resolvables changed
+	if (Pkg::IsAnyResolvable (`any, `to_install) == true || Pkg::IsAnyResolvable (`any, `to_remove) == true) {
+	    y2milestone ("Installing packages...");
+	    // Everybody hold your breath 'cause we're gonna be sinkin' soon
+	    any inst_ret = WFM::call ("inst_rpmcopy");
+	    y2milestone ("Package installation returned: %1", inst_ret);
+	    ret = `auto;
+	} else {
+	    y2milestone ("Nothing to install/remove");
+	    ret = `auto;
+	}
+    }
+
+    ResetPackager();
+
+    y2milestone ("Returning: %1", ret);
+
+    return ret;
+}

Added: trunk/wagon/src/clients/wagon_point_of_no_return.ycp
URL: http://svn.opensuse.org/viewcvs/yast/trunk/wagon/src/clients/wagon_point_of_no_return.ycp?rev=60484&view=auto
==============================================================================
--- trunk/wagon/src/clients/wagon_point_of_no_return.ycp (added)
+++ trunk/wagon/src/clients/wagon_point_of_no_return.ycp Fri Jan 22 12:08:50 2010
@@ -0,0 +1,39 @@
+/**
+ * File:
+ *	clients/wagon_custom_url.ycp
+ *
+ * Module:
+ *	Wagon
+ *
+ * Authors:
+ *	Lukas Ocilka 
+ *
+ * Summary:
+ *	Online Migration Tool
+ *
+ * $Id$
+ *
+ */
+
+{
+    textdomain "wagon";
+
+    import "GetInstArgs";
+    import "Wagon";
+
+    if (GetInstArgs::going_back()) {
+	y2milestone ("Going back...");
+	return `back;
+    }
+
+    /**
+     * Point of no return. After this call, YaST will start removing
+     * and installing packages. In other words, the real migration
+     * will start.
+     */
+
+    y2warning ("From this point, wagon cannot revert products anymore!");
+    Wagon::abort_can_revert_products = false;
+
+    return `auto;
+}

Modified: trunk/wagon/src/clients/wagon_selfupdate.ycp
URL: http://svn.opensuse.org/viewcvs/yast/trunk/wagon/src/clients/wagon_selfupdate.ycp?rev=60484&r1=60483&r2=60484&view=diff
==============================================================================
--- trunk/wagon/src/clients/wagon_selfupdate.ycp (original)
+++ trunk/wagon/src/clients/wagon_selfupdate.ycp Fri Jan 22 12:08:50 2010
@@ -28,20 +28,15 @@
     import "Popup";
     import "Label";
     import "PackagesUI";
+    import "Report";
+
+    include "wagon/common_func.ycp";
 
     if (GetInstArgs::going_back()) {
 	y2milestone ("Going back...");
 	return `back;
     }
 
-    boolean SolverRunWithFeedback () {
-	UI::OpenDialog (`Label (_("Solving the package dependencies...")));
-	boolean ret = Pkg::PkgSolve (false);
-	UI::CloseDialog();
-
-	return ret;
-    }
-
     /**
      * Tries to upgrade packages got as parameter.
      *
@@ -140,11 +135,50 @@
 	return pkgs_affected;
     }
 
+    integer UpdateInstalledProducts () {
+	integer affected_products = 0;
+
+	list  > products = Pkg::ResolvableProperties ("", `product, "");
+
+	foreach (map p, products, {
+	    // Product is not installed
+	    if (p["status"]:`unknown != `installed) return;
+
+	    // Make the logs readable
+	    p["license"] = "...";
+	    p["description"] = "...";
+
+	    string product_name = p["name"]:"";
+	    string product_version = p["version"]:"";
+
+	    if (product_name == nil || product_name == "") {
+		y2error ("Cannot distinguish product name: %1", product_name);
+		return;
+	    }
+
+	    // Product version is the same but release can be different
+	    // product map doesn't contain the release string. To be sure, product will be reinstalled
+	    y2milestone ("Upgrading product %1 version %2", product_name, product_version);
+	    // The version is the same, release can be different
+	    if (Pkg::ResolvableInstall (product_name, `product) != true) {
+		Report::Error (sformat(_("Cannot update installed product %1."), product_name));
+		return;
+	    }
+
+	    affected_products = affected_products + 1;
+	});
+
+	return affected_products;
+    }
+
     Wagon::InitPkg();
 
     list  > products = Pkg::ResolvableProperties ("", `product, "");
     y2milestone ("All known products: %1", products);
 
+    Wagon::ReadProductsBeforeMigration();
+    Wagon::StoreProductsBeforeMigration();
+
     symbol ret = `auto;
 
     // Patches need solver run
@@ -168,71 +202,21 @@
 	}
     }
 
+    integer products_selected_for_update = UpdateInstalledProducts();
+    if (products_selected_for_update > 0) {
+	y2milestone ("%1 products were selected for update", products_selected_for_update);
+	selected = products_selected_for_update;
+    }
+
     y2milestone ("Selected resolvables: %1", selected);
     if (selected < 1) {
 	y2milestone ("Neither patches nor packages for self-update have been selected");
 	return ret;
     }
 
-    boolean solved = nil;
-
-    while (solved != true) {
-	// Trying to solve automatically
-	solved = SolverRunWithFeedback();
-	symbol ret_sel = nil;
-
-	// PkgSolve didn't report any problem
-	if (solved) {
-	    y2milestone ("Solved automatically");
-	    // FIXME: inform user?
-	    ret = `restart_same_step;
-	// There are some issues in selecting the patches
-	} else {
-	    y2milestone ("Cannot be solved automatically");
-	    while (true) {
-		// Try to solve them manually
-		ret_sel = PackagesUI::RunPackageSelector ($["mode":`summaryMode]);
-
-		// Cannot or don't want to accept the proposal
-		if (ret_sel == `cancel) {
-		    // Confirmed
-		    if (Popup::AnyQuestion (
-			// TRANSLATORS: headline
-			_("Aborting the Upgrade"),
-			// TRANSLATORS: pop-up question
-			_("Cannot continue without installing the required patches.
-Are sure you want to abort the upgrade process?"),
-			_("Abort Upgrade"),
-			Label::NoButton(),
-			`yes_button
-		    )) {
-			ret = `abort;
-			break;
-		    // Try again
-		    } else {
-			continue;
-		    }
-		// Solved manually
-		} else if (ret_sel == `accept) {
-		    solved = true;
-		    break;
-		}
-	    }
-	}
-
-	if (ret == `abort) {
-	    solved = nil;
-	    y2warning ("Aborting...");
-	    break;
-	}
-
-	if (! Wagon::AcceptLicenses()) {
-	    y2warning ("Some license(s) have been rejected, running solver again");
-	    solved = nil;
-	}
-    }
+    ret = SolveDependencies();
 
-    if (solved == true) {
+    if (ret != `abort) {
 	// Solver ends with some resolvables changed
 	if (Pkg::IsAnyResolvable (`any, `to_install) == true || Pkg::IsAnyResolvable (`any, `to_remove) == true) {
 	    y2milestone ("Calling update...");

Modified: trunk/wagon/src/config/online_migration.xml
URL: http://svn.opensuse.org/viewcvs/yast/trunk/wagon/src/config/online_migration.xml?rev=60484&r1=60483&r2=60484&view=diff
==============================================================================
--- trunk/wagon/src/config/online_migration.xml (original)
+++ trunk/wagon/src/config/online_migration.xml Fri Jan 22 12:08:50 2010
@@ -29,8 +29,10 @@
 		<modules config:type="list">
 		    <module>welcome</module>
 		    <module>update_online_mechanism</module>
+		    <module>install_migration_products</module>
 		    <module>suse_register_workflow</module>
 		    <module>prepare_progress</module>
+		    <module>point_of_no_return</module>
 		    <module>wagon_kickoff</module>
 		    <module>wagon_rpmcopy</module>
 		    <module>suseconfig_after_update</module>
@@ -52,12 +54,14 @@
 		<modules config:type="list">
 		    <module>welcome</module>
 		    <module>update_online_mechanism</module>
+		    <module>install_migration_products</module>
 		    <!-- Workflow is switched after this module -->
 		    <module>update_url_dialog</module>
 		    <module>suse_register_workflow</module>
 		    <module>wagon_custom_url</module>
 		    <module>wagon_selfupdate_from_url</module>
 		    <module>prepare_progress</module>
+		    <module>point_of_no_return</module>
 		    <module>wagon_kickoff</module>
 		    <module>wagon_rpmcopy</module>
 		    <module>suseconfig_after_update</module>
@@ -77,10 +81,12 @@
 		<modules config:type="list">
 		    <module>welcome</module>
 		    <module>update_online_mechanism</module>
+		    <module>install_migration_products</module>
 		    <!-- Workflow is switched after this module -->
 		    <module>update_url_dialog</module>
 		    <module>suse_register_workflow</module>
 		    <module>prepare_progress</module>
+		    <module>point_of_no_return</module>
 		    <module>wagon_kickoff</module>
 		    <module>wagon_rpmcopy</module>
 		    <module>suseconfig_after_update</module>
@@ -100,11 +106,13 @@
 		<modules config:type="list">
 		    <module>welcome</module>
 		    <module>update_online_mechanism</module>
+		    <module>install_migration_products</module>
 		    <!-- Workflow is switched after this module -->
 		    <module>update_url_dialog</module>
 		    <module>wagon_custom_url</module>
 		    <module>wagon_selfupdate_from_url</module>
 		    <module>prepare_progress</module>
+		    <module>point_of_no_return</module>
 		    <module>wagon_kickoff</module>
 		    <module>wagon_rpmcopy</module>
 		    <module>suseconfig_after_update</module>
@@ -126,6 +134,7 @@
 		    <module>wagon_custom_url</module>
 		    <module>wagon_selfupdate_from_url</module>
 		    <module>prepare_progress</module>
+		    <module>point_of_no_return</module>
 		    <module>wagon_kickoff</module>
 		    <module>wagon_rpmcopy</module>
 		    <module>suseconfig_after_update</module>
@@ -199,16 +208,22 @@
 		    no
 		</module>
 
-		<!-- Update itself, Add new 'migration-product' -->
+		<!-- Update itself -->
 		<module>
 		    <label>Renew Update Stack</label>
 		    <name>update_online_mechanism</name>
 		    <execute>wagon_selfupdate</execute>
 		</module>
 
+		<!-- Add new 'migration-products' -->
+		<module>
+		    <label>Migration Configuration</label>
+		    <name>install_migration_products</name>
+		    <execute>wagon_migration_products</execute>
+		</module>
+
 		<!-- Offer several possibilities how to set update repository URL -->
 		<module>
-		    <label>Renew Update Stack</label>
 		    <name>update_url_dialog</name>
 		    <execute>wagon_update_url</execute>
 		</module>
@@ -219,7 +234,6 @@
 		    (*) Offered in wagon_update_url if not running via applet
 		-->
 		<module>
-		    <label>Renew Update Stack</label>
 		    <name>suse_register_workflow</name>
 		    <execute>inst_suse_register</execute>
 		</module>
@@ -229,7 +243,6 @@
 		    (*) Offered in wagon_update_url if not running via applet
 		-->
 		<module>
-		    <label>Renew Update Stack</label>
 		    <name>wagon_custom_url</name>
 		    <execute>wagon_custom_url</execute>
 		</module>
@@ -239,7 +252,6 @@
 		    Follows the wagon_ownurl
 		-->
 		<module>
-		    <label>Renew Update Stack</label>
 		    <name>wagon_selfupdate_from_url</name>
 		    <execute>wagon_selfupdate</execute>
 		</module>
@@ -266,6 +278,12 @@
 		    <execute>inst_prepareprogress</execute>
 		</module>
 
+		<!-- From this point, some possibilities are simply 'impossible' ;) -->
+		<module>
+		    <name>point_of_no_return</name>
+		    <execute>wagon_point_of_no_return</execute>
+		</module>
+
 		<module>
 		    <name>wagon_kickoff</name>
 		    <execute>inst_kickoff</execute>

Added: trunk/wagon/src/include/Makefile.am
URL: http://svn.opensuse.org/viewcvs/yast/trunk/wagon/src/include/Makefile.am?rev=60484&view=auto
==============================================================================
--- trunk/wagon/src/include/Makefile.am (added)
+++ trunk/wagon/src/include/Makefile.am Fri Jan 22 12:08:50 2010
@@ -0,0 +1,13 @@
+#
+# Makefile.am for wagon/src/include
+#
+
+yncludedir = @yncludedir@/wagon
+
+ynclude_DATA = $(wildcard *.ycp)
+
+YCPCFLAGS = -M ../modules
+
+EXTRA_DIST = $(ynclude_DATA)
+
+include $(top_srcdir)/Makefile.am.common

Added: trunk/wagon/src/include/common_func.ycp
URL: http://svn.opensuse.org/viewcvs/yast/trunk/wagon/src/include/common_func.ycp?rev=60484&view=auto
==============================================================================
--- trunk/wagon/src/include/common_func.ycp (added)
+++ trunk/wagon/src/include/common_func.ycp Fri Jan 22 12:08:50 2010
@@ -0,0 +1,128 @@
+/**
+ * File:
+ *	include/wagon/common_func.ycp
+ *
+ * Module:
+ *	Wagon
+ *
+ * Authors:
+ *	Lukas Ocilka 
+ *
+ * Summary:
+ *	Online Migration Tool
+ *
+ * $Id$
+ *
+ */
+
+{
+    textdomain "wagon";
+
+    import "Label";
+    import "Popup";
+    import "PackagesUI";
+    import "Wagon";
+    import "Wizard";
+
+    boolean SolverRunWithFeedback () {
+	UI::OpenDialog (`Label (_("Solving the package dependencies...")));
+	boolean ret = Pkg::PkgSolve (true);
+	UI::CloseDialog();
+
+	return ret;
+    }
+
+    symbol SolveDependencies () {
+	symbol ret = `auto;
+
+	boolean solved = nil;
+
+	while (solved != true) {
+	    // Trying to solve automatically
+	    solved = SolverRunWithFeedback();
+	    symbol ret_sel = nil;
+
+	    // PkgSolve didn't report any problem
+	    if (solved == true) {
+		y2milestone ("Solved automatically");
+		ret = `auto;
+	    // There are some issues in selecting the patches
+	    } else {
+		y2milestone ("Cannot be solved automatically");
+		while (true) {
+		    // Try to solve them manually
+		    ret_sel = PackagesUI::RunPackageSelector ($["mode":`summaryMode]);
+
+		    // Cannot or don't want to accept the proposal
+		    if (ret_sel == `cancel) {
+			// Confirmed
+			if (Popup::AnyQuestion (
+			    // TRANSLATORS: headline
+			    _("Aborting the Upgrade"),
+			    // TRANSLATORS: pop-up question
+			    _("Cannot continue without installing the required patches.
+Are sure you want to abort the upgrade process?"),
+			    _("Abort Upgrade"),
+			    Label::NoButton(),
+			    `yes_button
+			)) {
+			    ret = `abort;
+			    break;
+			// Try again
+			} else {
+			    continue;
+			}
+		    // Solved manually
+		    } else if (ret_sel == `accept) {
+			ret = `auto;
+			solved = true;
+			break;
+		    }
+		}
+	    }
+
+	    if (ret == `abort) {
+		solved = nil;
+		y2warning ("Aborting...");
+		break;
+	    }
+
+	    if (! Wagon::AcceptLicenses()) {
+		y2warning ("Some license(s) have been rejected, running solver again");
+		solved = nil;
+	    }
+	}
+
+	return ret;
+    }
+
+    void ResetPackager () {
+	Wizard::SetContents (
+	    _("Reseting Package Manager"),
+	    `Label(_("Reseting package manager...")),
+	    "",
+	    false, true
+	);
+
+	y2milestone ("Reseting Pkg");
+	Pkg::PkgApplReset();
+	Pkg::PkgReset();
+
+	symbol status = nil;
+	string name = nil;
+
+	y2milestone ("Neutralizing all resolvables");
+	foreach (symbol resolvable, [`pattern, `patch, `package, `product, `scrpackage], {
+	    Pkg::ResolvableNeutral ("" /* all */, resolvable, true /* force */);
+	});
+
+	y2milestone ("Running solver");
+	Pkg::PkgSolve (true);
+
+	Pkg::TargetFinish();
+	Pkg::SourceFinishAll();
+
+	Wagon::InitPkg();
+	Pkg::PkgSolve (true);
+    }
+}

Modified: trunk/wagon/src/modules/Wagon.ycp
URL: http://svn.opensuse.org/viewcvs/yast/trunk/wagon/src/modules/Wagon.ycp?rev=60484&r1=60483&r2=60484&view=diff
==============================================================================
--- trunk/wagon/src/modules/Wagon.ycp (original)
+++ trunk/wagon/src/modules/Wagon.ycp Fri Jan 22 12:08:50 2010
@@ -29,11 +29,23 @@
     import "Report";
     import "ProductFeatures";
     import "Update";
+    import "FileUtils";
+    import "String";
 
     boolean running_by_applet = false;
 
     string update_workflow_type = "manual";
 
+    // Products installed for the time of the migration
+    global list <string> migration_products = [];
+
+    // Products installed before the migration
+    global list  > products_before_migration = [];
+
+    // When aborting before the real migration starts, we can still
+    // revert to the old products
+    global boolean abort_can_revert_products = true;
+
     global void SetUpdateWorkflow (string new_update_workflow_type) {
 	// FIXME: check
 
@@ -275,17 +287,192 @@
 	return true;
     }
 
+    global map  MinimizeProductMap (map  product) {
+	if (haskey (product, "license")) product["license"] = "...";
+	if (haskey (product, "description")) product["description"] = "...";
+
+	return product;
+    }
+
+    string GetDisplayName (string display_name, string name) {
+	if (display_name == name)
+	    return display_name;
+
+	// 'Product Long Name (product-libzypp-name)'
+	return sformat (_("%1 (%2)"), display_name, name);
+    }
+
+    string GetDistributionUpgradeSummary () {
+	string ret = "";
+
+	list  > products = sort (
+	    map  x, map  y, Pkg::ResolvableProperties ("", `product, ""),
+	    ``(x["display_name"]:x["short_name"]:x["name"]:"a" < y["display_name"]:x["short_name"]:x["name"]:"b")
+	);
+
+	// migration_products contains list of temporary products for migration process
+
+	y2milestone ("All known migration products: %1", migration_products);
+
+	string display_name = nil;
+	string name = nil;
+
+	// list of all products that will be installed (are selected)
+	list <string> products_to_be_installed = [];
+	foreach (map  product, products, {
+	    if (product["status"]:`unknown != `selected) return;
+	    name = product["name"]:_("No short name defined");
+	    products_to_be_installed = add (products_to_be_installed, name);
+	});
+
+	// list of all products that will be upgraded
+	list <string> products_to_be_upgraded = [];
+
+	// Products that are going to be removed
+	foreach (map  product, products, {
+	    if (product["status"]:`unknown != `removed) return;
+
+	    product = MinimizeProductMap (product);
+	    display_name = product["display_name"]:product["short_name"]:product["name"]:_("No name defined");
+	    name = product["name"]:_("No short name defined");
+
+	    // Removing product and installing the same one (name) means -> upgrade
+	    if (contains (products_to_be_installed, name)) {
+		products_to_be_upgraded = add (products_to_be_upgraded, name);
+		y2milestone ("Product to be upgraded: %1 (this is the removed one)", product);
+		// Do not list this product as 'to removed', list it as 'to upgrade'
+		return;
+	    }
+
+	    // Removing a migration product is fine
+	    if (contains (migration_products, product["name"]:"")) {
+		y2milestone ("Migration product will be removed: %1", product);
+		ret = ret + "<li>" + sformat (
+		    _("Temporary migration product <b>%1</b> will be removed"),
+		    GetDisplayName (display_name, name)
+		) + "</li>\n";
+	    // Removing another product might be an issue
+	    } else {
+		y2warning ("Product will be removed: %1", product);
+		ret = ret + "<li>" + sformat (
+		    _("<font color='red'>Warning: Product <b>%1</b> will be removed</font>"),
+		    GetDisplayName (display_name, name)
+		) + "</li>\n";
+	    }
+	});
+
+	// Products that are going to be installed (new ones) or upgraded
+	foreach (map  product, products, {
+	    if (product["status"]:`unknown != `selected) return;
+
+	    product = MinimizeProductMap (product);
+	    display_name = product["display_name"]:product["short_name"]:product["name"]:_("No name defined");
+	    name = product["name"]:_("No short name defined");
+
+	    // Product is going to be upgraded (removed + installed new version)
+	    if (contains (products_to_be_upgraded, name)) {
+		y2milestone ("Product will be upgraded to: %1 (this is the installed one)", product);
+		ret = ret + "<li>" + sformat (
+		    _("Product <b>%1</b> will be upgraded"),
+		    GetDisplayName (display_name, name)
+		) + "</li>\n";
+	    // Newly installed product
+	    } else {
+		y2milestone ("Product will be upgraded: %1", product);
+		ret = ret + "<li>" + sformat (
+		    _("New product <b>%1</b> will be installed"),
+		    GetDisplayName (display_name, name)
+		) + "</li>\n";
+	    }
+	});
+
+	// Products that will keep installed (unchanged)
+	foreach (map  product, products, {
+	    if (product["status"]:`unknown != `installed) return;
+
+	    product = MinimizeProductMap (product);
+	    display_name = product["display_name"]:product["short_name"]:product["name"]:_("No name defined");
+	    name = product["name"]:_("No short name defined");
+
+	    y2milestone ("Product will keep: %1", product);
+	    ret = ret + "<li>" + sformat (
+		_("Product <b>%1</b> will keep installed"),
+		GetDisplayName (display_name, name)
+	    ) + "</li>\n";
+	});
+
+	return "<ul>\n" + ret + "</ul>\n";
+    }
+
     global map  ProposalSummary () {
 	map  ret = $[];
 
-	// FIXME: create a useful summary
 	ret = $[
-	    "preformatted_proposal" : "<ul><li>" + _("Distribution Upgrade") + "</li></ul>",
-	    "help" : _("<p>FIXME</p>"),
+	    "preformatted_proposal" : GetDistributionUpgradeSummary(),
+	    // help text
+	    "help" : _("<p>To change update settings go to <p>Software Proposal</p> section.</p>"),
 	];
 
 	return ret;
     }
 
+    global list  > ReadProductsBeforeMigration () {
+	list  > products = Pkg::ResolvableProperties ("", `product, "");
+	y2milestone ("All known products: %1", products);
+
+	foreach (map p, products, {
+	    if (p["status"]:`unknown != `installed)
+		return;
+
+	    // Remember the 'old' product just for the case of reverting
+	    products_before_migration = add (
+		products_before_migration,
+		    $["name" : p["name"]:"", "version" : p["version"]:""]
+	    );
+	});
+
+	return products_before_migration;
+    }
+
+    // YaST can be restarted but some data have to be kept
+    string migration_products_store_file = sformat ("%1/wagon_products_before_migration", Directory::vardir);
+
+    global boolean StoreProductsBeforeMigration () {
+	return (boolean) SCR::Write (.target.ycp, migration_products_store_file, products_before_migration);
+    }
+
+    global boolean RestoreProductsBeforeMigration () {
+	products_before_migration = (list  >) SCR::Read (.target.ycp, migration_products_store_file);
+
+	if (products_before_migration == nil) {
+	    products_before_migration = [];
+	    Report::Error (_("Error restoring the list of previously installed products."));
+	    return false;
+	}
+
+	return true;
+    }
+
+    global string GetFileOwner (string file) {
+	if (file == nil || file == "") {
+	    y2error ("File not provided");
+	    return nil;
+	}
+
+	if (! FileUtils::Exists (file)) {
+	    y2error ("File %1 doesn't exist", file);
+	    return nil;
+	}
+
+	string command = sformat ("rpm -qf '%1'", String::Quote (file)) + " --queryformat \"%{NAME}\"";
+	map  cmd = (map ) SCR::Execute (.target.bash_output, command);
+	if (cmd["exit"]:-1 != 0) {
+	    y2error ("Cannot get file owner %1: %2", command, cmd);
+	    return nil;
+	}
+
+	return (string) splitstring (cmd["stdout"]:"", "\n")[0]:nil;
+    }
+
 /* EOF */
 }

-- 
To unsubscribe, e-mail: yast-commit+unsubscribe@opensuse.org
For additional commands, e-mail: yast-commit+help@opensuse.org

    

[yast-commit] r60484 - in /trunk/wagon: package/ src/clients/ src/config/ src/include/ src/modules/

locilka＠svn.opensuse.org