FM / DistUpgrade

/usr/lib/python3/dist-packages/DistUpgrade/

/usr/lib/python3/dist-packages/DistUpgrade

Name	Size	Mode	Actions
__pycache__/	-	0755	rm
apt_btrfs_snapshot.py	9915	0644	edit dl rm
apt_clone.py	33530	0644	edit dl rm
dist-upgrade.py	129	0644	edit dl rm
distro.py	23763	0644	edit dl rm
DistUpgradeApport.py	5058	0644	edit dl rm
DistUpgradeCache.py	54225	0644	edit dl rm
DistUpgradeConfigParser.py	3837	0644	edit dl rm
DistUpgradeController.py	101282	0644	edit dl rm
DistUpgradeFetcher.py	6009	0644	edit dl rm
DistUpgradeFetcherCore.py	12745	0644	edit dl rm
DistUpgradeFetcherKDE.py	9950	0644	edit dl rm
DistUpgradeFetcherSelf.py	1955	0644	edit dl rm
DistUpgradeGettext.py	3043	0644	edit dl rm
DistUpgradeMain.py	9359	0644	edit dl rm
DistUpgradePatcher.py	4018	0644	edit dl rm
DistUpgradeQuirks.py	70360	0644	edit dl rm
DistUpgradeVersion.py	21	0644	edit dl rm
DistUpgradeView.py	17344	0644	edit dl rm
DistUpgradeViewGtk3.py	34670	0644	edit dl rm
DistUpgradeViewKDE.py	41846	0644	edit dl rm
DistUpgradeViewNonInteractive.py	13862	0644	edit dl rm
DistUpgradeViewText.py	12829	0644	edit dl rm
GtkProgress.py	4020	0644	edit dl rm
MetaRelease.py	17543	0644	edit dl rm
QUrlOpener.py	3321	0644	edit dl rm
ReleaseNotesViewer.py	7658	0644	edit dl rm
ReleaseNotesViewerWebkit.py	2983	0644	edit dl rm
SimpleGtk3builderApp.py	2056	0644	edit dl rm
SimpleGtkbuilderApp.py	2037	0644	edit dl rm
telemetry.py	3478	0644	edit dl rm
utils.py	18541	0644	edit dl rm
xorg_fix_proprietary.py	4083	0644	edit dl rm
__init__.py	0	0644	edit dl rm

Edit: /usr/lib/python3/dist-packages/DistUpgrade/DistUpgradeViewGtk3.py (34670B)

# DistUpgradeViewGtk3.py
#
# Copyright (c) 2011 Canonical
#
# Author: Michael Vogt <michael.vogt@ubuntu.com>
#
# This program is free software; you can redistribute it and/or
# modify it under the terms of the GNU General Public License as
# published by the Free Software Foundation; either version 2 of the
# License, or (at your option) any later version.
#
# 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

import gi

vte291 = False
try:
    gi.require_version("Vte", "2.91")
    from gi.repository import Vte
    vte291 = True
except Exception:
    gi.require_version("Vte", "2.90")
    # COMPAT: Dear upstream, this compat code below will be duplicated in
    #         all python-vte using applications. Love, Michael
    from gi.repository import Vte
    Vte.Pty.new_sync = Vte.Pty.new

from gi.repository import Gtk
from gi.repository import Gdk
from gi.repository import GLib
from gi.repository import GObject
from gi.repository import Pango

import sys
import locale
import logging
import time
import subprocess

import apt
import apt_pkg
import os

from .DistUpgradeApport import run_apport, apport_crash

from .DistUpgradeView import DistUpgradeView, FuzzyTimeToStr, InstallProgress, AcquireProgress
from .telemetry import get as get_telemetry
from .SimpleGtk3builderApp import SimpleGtkbuilderApp

import gettext
from .DistUpgradeGettext import gettext as _

class GtkCdromProgressAdapter(apt.progress.base.CdromProgress):
    """ Report the cdrom add progress
        Subclass this class to implement cdrom add progress reporting
    """
    def __init__(self, parent):
        self.status = parent.label_status
        self.progress = parent.progressbar_cache
        self.parent = parent
    def update(self, text, step):
        """ update is called regularly so that the gui can be redrawn """
        if text:
            self.status.set_text(text)
        self.progress.set_fraction(step.value/float(self.totalSteps))
        while Gtk.events_pending():
            Gtk.main_iteration()
    def ask_cdrom_name(self):
        return (False, "")
    def change_cdrom(self):
        return False

class GtkOpProgress(apt.progress.base.OpProgress):
    def __init__(self, progressbar):
        self.progressbar = progressbar
        #self.progressbar.set_pulse_step(0.01)
        #self.progressbar.pulse()
        self.fraction = 0.0

def update(self, percent=None):
        super(GtkOpProgress, self).update(percent)
        #if self.percent > 99:
        #    self.progressbar.set_fraction(1)
        #else:
        #    self.progressbar.pulse()
        new_fraction = self.percent/100.0
        if abs(self.fraction-new_fraction) > 0.1:
            self.fraction = new_fraction
            self.progressbar.set_fraction(self.fraction)
        while Gtk.events_pending():
            Gtk.main_iteration()

def done(self):
        self.progressbar.set_text(" ")

class GtkAcquireProgressAdapter(AcquireProgress):
    # FIXME: we really should have some sort of "we are at step"
    # xy in the gui
    # FIXME2: we need to thing about mediaCheck here too
    def __init__(self, parent):
        super(GtkAcquireProgressAdapter, self).__init__()
        # if this is set to false the download will cancel
        self.status = parent.label_status
        self.progress = parent.progressbar_cache
        self.parent = parent
        self.canceled = False
        self.button_cancel = parent.button_fetch_cancel
        self.button_cancel.connect('clicked', self.cancelClicked)
    def cancelClicked(self, widget):
        logging.debug("cancelClicked")
        self.canceled = True
    def media_change(self, medium, drive):
        #print("mediaChange %s %s" % (medium, drive))
        msg = _("Please insert '%s' into the drive '%s'") % (medium,drive)
        dialog = Gtk.MessageDialog(parent=self.parent.window_main,
                                   flags=Gtk.DialogFlags.MODAL,
                                   type=Gtk.MessageType.QUESTION,
                                   buttons=Gtk.ButtonsType.OK_CANCEL)
        dialog.set_markup(msg)
        res = dialog.run()
        dialog.set_title("")
        dialog.destroy()
        if res == Gtk.ResponseType.OK:
            return True
        return False
    def start(self):
        #logging.debug("start")
        super(GtkAcquireProgressAdapter, self).start()
        self.progress.set_fraction(0)
        self.status.show()
        self.button_cancel.show()
    def stop(self):
        #logging.debug("stop")
        self.progress.set_text(" ")
        self.status.set_text(_("Fetching is complete"))
        self.button_cancel.hide()
    def pulse(self, owner):
        super(GtkAcquireProgressAdapter, self).pulse(owner)
        # only update if there is a noticable change
        if abs(self.percent-self.progress.get_fraction()*100.0) > 0.1:
            self.progress.set_fraction(self.percent/100.0)
            currentItem = self.current_items + 1
            if currentItem > self.total_items:
                currentItem = self.total_items
            if self.current_cps > 0:
                current_cps = apt_pkg.size_to_str(self.current_cps)
                if isinstance(current_cps, bytes):
                    current_cps = current_cps.decode(
                        locale.getpreferredencoding())
                self.status.set_text(_("Fetching file %li of %li at %sB/s") % (
                    currentItem, self.total_items, current_cps))
                self.progress.set_text(_("About %s remaining") % FuzzyTimeToStr(
                    self.eta))
            else:
                self.status.set_text(_("Fetching file %li of %li") % (
                    currentItem, self.total_items))
                self.progress.set_text("  ")
        while Gtk.events_pending():
            Gtk.main_iteration()
        return (not self.canceled)

class GtkInstallProgressAdapter(InstallProgress):
    # timeout with no status change when the terminal is expanded
    # automatically
    TIMEOUT_TERMINAL_ACTIVITY = 300

def __init__(self,parent):
        InstallProgress.__init__(self)
        self._cache = None
        self.label_status = parent.label_status
        self.progress = parent.progressbar_cache
        self.expander = parent.expander_terminal
        self.term = parent._term
        self.term.connect("child-exited", self.child_exited)
        self.parent = parent
        # setup the child waiting
        # some options for dpkg to make it die less easily
        apt_pkg.config.set("DPkg::StopOnError","False")

def start_update(self):
        InstallProgress.start_update(self)
        self.finished = False
        # FIXME: add support for the timeout
        # of the terminal (to display something useful then)
        # -> longer term, move this code into python-apt
        self.label_status.set_text(_("Applying changes"))
        self.progress.set_fraction(0.0)
        self.progress.set_text(" ")
        self.expander.set_sensitive(True)
        self.term.show()
        self.term.connect("contents-changed", self._on_term_content_changed)
        # if no libgtk3-perl is installed show the terminal
        frontend= os.environ.get("DEBIAN_FRONTEND") or "gnome"
        if frontend == "gnome" and self._cache:
            if (not "libgtk3-perl" in self._cache or
                not self._cache["libgtk3-perl"].is_installed):
                frontend = "dialog"
                self.expander.set_expanded(True)
        self.env = ["VTE_PTY_KEEP_FD=%s"% self.writefd,
                    "APT_LISTCHANGES_FRONTEND=none"]
        if "DEBIAN_FRONTEND" not in os.environ:
            self.env.append("DEBIAN_FRONTEND=%s" % frontend)
        # do a bit of time-keeping
        self.start_time = 0.0
        self.time_ui = 0.0
        self.last_activity = 0.0

def error(self, pkg, errormsg):
        InstallProgress.error(self, pkg, errormsg)
        logging.error("got an error from dpkg for pkg: '%s': '%s'" % (pkg, errormsg))
        # we do not report followup errors from earlier failures
        if gettext.dgettext('dpkg', "dependency problems - leaving unconfigured") in errormsg:
            return False

#self.expander_terminal.set_expanded(True)
 self.parent.dialog_error.set_transient_for(self.parent.window_main)
 summary = _("Could not install '%s'") % pkg
 msg = _("The upgrade will continue but the '%s' package may not "
 "be in a working state. Please consider submitting a "
 "bug report about it.") % pkg
 markup="<big>%s</big>\n\n%s" % (summary, msg)
 self.parent.dialog_error.realize()
 self.parent.dialog_error.set_title("")
 self.parent.dialog_error.get_window().set_functions(Gdk.WMFunction.MOVE)
 self.parent.label_error.set_markup(markup)
 self.parent.textview_error.get_buffer().set_text(errormsg)
 self.parent.scroll_error.show()
 self.parent.dialog_error.run()
 self.parent.dialog_error.hide()

def conffile(self, current, new):
 logging.debug("got a conffile-prompt from dpkg for file: '%s'" % current)
 start = time.time()
 #self.expander.set_expanded(True)
 prim = _("Replace the customized configuration file\n'%s'?") % current
 sec = _("You will lose any changes you have made to this "
 "configuration file if you choose to replace it with "
 "a newer version.")
 markup = "%s \n\n%s" % (prim, sec)
 self.parent.label_conffile.set_markup(markup)
 self.parent.dialog_conffile.set_title("")
 self.parent.dialog_conffile.set_transient_for(self.parent.window_main)

# workaround silly dpkg
        if not os.path.exists(current):
            current = current+".dpkg-dist"

# now get the diff
        if os.path.exists("/usr/bin/diff"):
            cmd = ["/usr/bin/diff", "-u", current, new]
            diff = subprocess.Popen(
                cmd, stdout=subprocess.PIPE).communicate()[0]
            diff = diff.decode("UTF-8", "replace")
            self.parent.textview_conffile.get_buffer().set_text(diff)
        else:
            self.parent.textview_conffile.get_buffer().set_text(_("The 'diff' command was not found"))
        res = self.parent.dialog_conffile.run()
        self.parent.dialog_conffile.hide()
        self.time_ui += time.time() - start
        # if replace, send this to the terminal
        if res == Gtk.ResponseType.YES:
            response = "y\n"
        else:
            response = "n\n"
        try:
            self.term.feed_child(response.encode("utf-8"))
        except:
            self.term.feed_child(response, -1)

def fork(self):
        pty = Vte.Pty.new_sync(Vte.PtyFlags.DEFAULT)
        pid = os.fork()
        if pid == 0:
            # WORKAROUND for broken feisty vte where envv does not work)
            for env in self.env:
                (key, value) = env.split("=")
                os.environ[key] = value
            # MUST be called
            pty.child_setup()
            # force dpkg terminal messages untranslated for better bug
            # duplication detection
            os.environ["DPKG_UNTRANSLATED_MESSAGES"] = "1"
        else:
            self.term.set_pty(pty)
            self.term.watch_child(pid)
        return pid

def _on_term_content_changed(self, term):
        """ helper function that is called when the terminal changed
            to ensure that we have a accurate idea when something hangs
        """
        self.last_activity = time.time()
        self.activity_timeout_reported = False

def status_change(self, pkg, percent, status):
 # start the timer when the first package changes its status
 if self.start_time == 0.0:
 #print("setting start time to %s" % self.start_time)
 self.start_time = time.time()
 # only update if there is a noticable change
 if abs(percent-self.progress.get_fraction()*100.0) > 0.1:
 self.progress.set_fraction(float(percent)/100.0)
 self.label_status.set_text(status.strip())
 # start showing when we gathered some data
 if percent > 1.0:
 delta = self.last_activity - self.start_time
 # time wasted in conffile questions (or other ui activity)
 delta -= self.time_ui
 time_per_percent = (float(delta)/percent)
 eta = (100.0 - percent) * time_per_percent
 # only show if we have some sensible data (60sec < eta < 2days)
 if eta > 61.0 and eta < (60*60*24*2):
 self.progress.set_text(_("About %s remaining") % FuzzyTimeToStr(eta))
 else:
 self.progress.set_text(" ")
 # 2 == WEBKIT_LOAD_FINISHED - the enums is not exposed via python
 if (self.parent._webkit_view and
 self.parent._webkit_view.get_property("load-status") == 2):
 self.parent._webkit_view.execute_script('progress("%s")' % percent)

def child_exited(self, term, status=None):
        # we need to capture the full status here (not only the WEXITSTATUS)
        if status is None:
            # COMPAT we must keep until 16.04
            self.apt_status = term.get_child_exit_status()
        else:
            self.apt_status =  status
        self.finished = True

def wait_child(self):
        while not self.finished:
            self.update_interface()
        return self.apt_status

def finish_update(self):
        self.label_status.set_text("")

def update_interface(self):
 InstallProgress.update_interface(self)
 # check if we haven't started yet with packages, pulse then
 if self.start_time == 0.0:
 self.progress.pulse()
 time.sleep(0.2)
 # check about terminal activity
 if self.last_activity > 0 and \
 (self.last_activity + self.TIMEOUT_TERMINAL_ACTIVITY) < time.time():
 if not self.activity_timeout_reported:
 logging.warning("no activity on terminal for %s seconds (%s)" % (self.TIMEOUT_TERMINAL_ACTIVITY, self.label_status.get_text()))
 self.activity_timeout_reported = True
 self.parent.expander_terminal.set_expanded(True)
 # process events
 while Gtk.events_pending():
 Gtk.main_iteration()
 time.sleep(0.01)

class DistUpgradeVteTerminal(object):
 def __init__(self, parent, term):
 self.term = term
 self.parent = parent
 def call(self, cmd, hidden=False):
 if vte291:
 def wait_for_child(terminal, status):
 #print("wait for child finished")
 self.finished=True
 else:
 def wait_for_child(widget):
 #print("wait for child finished")
 self.finished=True
 self.term.show()
 self.term.connect("child-exited", wait_for_child)
 self.parent.expander_terminal.set_sensitive(True)
 if hidden==False:
 self.parent.expander_terminal.set_expanded(True)
 self.finished = False
 if vte291:
 (success, pid) = self.term.spawn_sync(
 Vte.PtyFlags.DEFAULT,
 "/",
 cmd,
 None,
 0, # GLib.SpawnFlags
 None, # child_setup
 None, # child_setup_data
 None, # GCancellable
 )
 else:
 (success, pid) = self.term.fork_command_full(
 Vte.PtyFlags.DEFAULT,
 "/",
 cmd,
 None,
 0, # GLib.SpawnFlags
 None, # child_setup
 None, # child_setup_data
 )
 if not success or pid < 0:
 # error
 return
 while not self.finished:
 while Gtk.events_pending():
 Gtk.main_iteration()
 time.sleep(0.1)
 del self.finished

class HtmlView(object):
    def __init__(self, webkit_view):
        self._webkit_view = webkit_view
    def open(self, url):
        if not self._webkit_view:
            return
        try:
            from gi.repository import WebKit2
            assert WebKit2 # silence pep8
            self._webkit_view.load_uri(url)
            self._webkit_view.connect("load-changed", self._on_load_changed)
        except ImportError:
            self._webkit_view.open(url)
            self._webkit_view.connect("load-finished", self._on_load_finished)
    def show(self):
        self._webkit_view.show()
    def hide(self):
        self._webkit_view.hide()
    def _on_load_finished(self, view, frame):
        view.show()
    def _on_load_changed(self, view, event, data):
        from gi.repository import WebKit2
        if event == WebKit2.LoadEvent.LOAD_FINISHED:
            view.show()

class DistUpgradeViewGtk3(DistUpgradeView,SimpleGtkbuilderApp):
    " gtk frontend of the distUpgrade tool "
    def __init__(self, datadir=None, logdir=None):
        DistUpgradeView.__init__(self)
        self.logdir = logdir
        if not datadir or datadir == '.':
            localedir=os.path.join(os.getcwd(),"mo")
            gladedir=os.getcwd()
        else:
            localedir="/usr/share/locale/"
            gladedir=os.path.join(datadir, "gtkbuilder")

# check if we have a display etc
        Gtk.init_check(sys.argv)

get_telemetry().set_updater_type('GTK')

try:
            locale.bindtextdomain("ubuntu-release-upgrader",localedir)
            gettext.textdomain("ubuntu-release-upgrader")
        except Exception as e:
            logging.warning("Error setting locales (%s)" % e)

SimpleGtkbuilderApp.__init__(self,
                                     gladedir+"/DistUpgrade.ui",
                                     "ubuntu-release-upgrader")

icons = Gtk.IconTheme.get_default()
        try:
            self.window_main.set_default_icon(icons.load_icon("system-software-update", 32, 0))
        except GObject.GError as e:
            logging.debug("error setting default icon, ignoring (%s)" % e)
            pass

title_string = self.label_title.get_label()
        title_string = title_string.replace("%s", "22.04")
        self.label_title.set_label(title_string)

# terminal stuff
        self.create_terminal()

self.prev_step = None # keep a record of the latest step
        # we don't use this currently
        #self.window_main.set_keep_above(True)
        self.icontheme = Gtk.IconTheme.get_default()
        self._webkit_view = None
        self.window_main.realize()
        self.window_main.get_window().set_functions(Gdk.WMFunction.MOVE)
        self._opCacheProgress = GtkOpProgress(self.progressbar_cache)
        self._acquireProgress = GtkAcquireProgressAdapter(self)
        self._cdromProgress = GtkCdromProgressAdapter(self)
        self._installProgress = GtkInstallProgressAdapter(self)
        # details dialog
        self.details_list = Gtk.TreeStore(GObject.TYPE_STRING)
        column = Gtk.TreeViewColumn("")
        render = Gtk.CellRendererText()
        column.pack_start(render, True)
        column.add_attribute(render, "markup", 0)
        self.treeview_details.append_column(column)
        self.details_list.set_sort_column_id(0, Gtk.SortType.ASCENDING)
        self.treeview_details.set_model(self.details_list)
        # lp: #1072460
        self.dialog_changes.set_resizable(False)
        def _activated(w):
            # the *current* expanded state which will change after the signal
            expanded = self.expander_details.get_expanded()
            self.dialog_changes.set_resizable(not expanded)
        self.expander_details.connect("activate", _activated)
        # FIXME: portme
        # Use italic style in the status labels
        #attrlist=Pango.AttrList()
        #attr = Pango.AttrStyle(Pango.Style.ITALIC, 0, -1)
        #attr = Pango.AttrScale(Pango.SCALE_SMALL, 0, -1)
        #attrlist.insert(attr)
        #self.label_status.set_property("attributes", attrlist)
        # reasonable fault handler
        sys.excepthook = self._handleException

def _handleException(self, type, value, tb):
        # we handle the exception here, hand it to apport and run the
        # apport gui manually after it because we kill u-n during the upgrade
        # to prevent it from poping up for reboot notifications or FF restart
        # notifications or somesuch
        import traceback
        lines = traceback.format_exception(type, value, tb)
        logging.error("not handled exception:\n%s" % "\n".join(lines))
        # we can't be sure that apport will run in the middle of a upgrade
        # so we still show a error message here
        apport_crash(type, value, tb)
        if not run_apport():
            self.error(_("A fatal error occurred"),
                       _("Please report this as a bug (if you haven't already) and include the "
                         "files /var/log/dist-upgrade/main.log and "
                         "/var/log/dist-upgrade/apt.log "
                         "in your report. The upgrade has aborted.\n"
                         "Your original sources.list was saved in "
                         "/etc/apt/sources.list.distUpgrade."),
                       "\n".join(lines))
        sys.exit(1)

def getTerminal(self):
        return DistUpgradeVteTerminal(self, self._term)
    def getHtmlView(self):
        if self._webkit_view is None:
            try:
                try:
                    from gi.repository import WebKit2 as WebKit
                except ImportError:
                    from gi.repository import WebKit
                self._webkit_view = WebKit.WebView()
                settings = self._webkit_view.get_settings()
                settings.set_property("enable-plugins", False)
                self.vbox_main.pack_end(self._webkit_view, True, True, 0)
            except:
                logging.exception("html widget")
                return DistUpgradeView.SampleHtmlView()
        return HtmlView(self._webkit_view)

def _key_press_handler(self, widget, keyev):
        # user pressed ctrl-c
        if len(keyev.string) == 1 and ord(keyev.string) == 3:
            summary = _("Ctrl-c pressed")
            msg = _("This will abort the operation and may leave the system "
                    "in a broken state. Are you sure you want to do that?")
            res = self.askYesNoQuestion(summary, msg)
            logging.warning("ctrl-c press detected, user decided to pass it "
                            "on: %s", res)
            return not res
        return False

def create_terminal(self):
        " helper to create a vte terminal "
        self._term = Vte.Terminal.new()
        # COMPAT that must be kept until 16.04
        if not hasattr(self._term, "set_pty"):
            self._term.set_pty = self._term.set_pty_object

self._term.connect("key-press-event", self._key_press_handler)
        fontdesc = Pango.font_description_from_string("monospace 10")
        self._term.set_font(fontdesc)
        self._terminal_lines = []
        self.hbox_custom.pack_start(self._term, True, True, 0)
        self._term.realize()
        self.vscrollbar_terminal = Gtk.VScrollbar()
        self.vscrollbar_terminal.show()
        self.hbox_custom.pack_start(self.vscrollbar_terminal, True, True, 0)
        self.vscrollbar_terminal.set_adjustment(self._term.get_vadjustment())

try:
            self._terminal_log = open(os.path.join(self.logdir,"term.log"),"w")
        except Exception:
            # if something goes wrong (permission denied etc), use stdout
            self._terminal_log = sys.stdout
        return self._term

def getAcquireProgress(self):
        return self._acquireProgress
    def getInstallProgress(self, cache):
        self._installProgress._cache = cache
        return self._installProgress
    def getOpCacheProgress(self):
        return self._opCacheProgress
    def getCdromProgress(self):
        return self._cdromProgress
    def updateStatus(self, msg):
        self.label_status.set_text("%s" % msg)
    def hideStep(self, step):
        image = getattr(self,"image_step%i" % step.value)
        label = getattr(self,"label_step%i" % step.value)
        #arrow = getattr(self,"arrow_step%i" % step.value)
        image.hide()
        label.hide()
    def showStep(self, step):
        image = getattr(self,"image_step%i" % step.value)
        label = getattr(self,"label_step%i" % step.value)
        image.show()
        label.show()
    def abort(self):
        size = Gtk.IconSize.MENU
        step = self.prev_step
        if step:
            image = getattr(self,"image_step%i" % step.value)
            arrow = getattr(self,"arrow_step%i" % step.value)
            image.set_from_stock(Gtk.STOCK_CANCEL, size)
            image.show()
            arrow.hide()
    def setStep(self, step):
        super(DistUpgradeViewGtk3, self).setStep(step)
        if self.icontheme.rescan_if_needed():
            logging.debug("icon theme changed, re-reading")
        # first update the "previous" step as completed
        size = Gtk.IconSize.MENU
        attrlist=Pango.AttrList()
        if self.prev_step:
            image = getattr(self,"image_step%i" % self.prev_step.value)
            label = getattr(self,"label_step%i" % self.prev_step.value)
            arrow = getattr(self,"arrow_step%i" % self.prev_step.value)
            label.set_property("attributes",attrlist)
            image.set_from_stock(Gtk.STOCK_APPLY, size)
            image.show()
            arrow.hide()
        self.prev_step = step
        # show the an arrow for the current step and make the label bold
        image = getattr(self,"image_step%i" % step.value)
        label = getattr(self,"label_step%i" % step.value)
        arrow = getattr(self,"arrow_step%i" % step.value)
        # check if that step was not hidden with hideStep()
        if not label.get_property("visible"):
            return
        arrow.show()
        image.hide()
        # FIXME: portme
        #attr = Pango.AttrWeight(Pango.Weight.BOLD, 0, -1)
        #attrlist.insert(attr)
        #label.set_property("attributes",attrlist)

def information(self, summary, msg, extended_msg=None):
 self.dialog_information.set_title("")
 self.dialog_information.set_transient_for(self.window_main)
 msg = "<big>%s</big>\n\n%s" % (summary,msg)
 self.label_information.set_markup(msg)
 if extended_msg != None:
 buffer = self.textview_information.get_buffer()
 buffer.set_text(extended_msg)
 self.scroll_information.show()
 else:
 self.scroll_information.hide()
 self.dialog_information.realize()
 self.dialog_information.get_window().set_functions(Gdk.WMFunction.MOVE)
 self.dialog_information.run()
 self.dialog_information.hide()
 while Gtk.events_pending():
 Gtk.main_iteration()

def error(self, summary, msg, extended_msg=None):
 self.dialog_error.set_title("")
 self.dialog_error.set_transient_for(self.window_main)
 #self.expander_terminal.set_expanded(True)
 msg="<big>%s</big>\n\n%s" % (summary, msg)
 self.label_error.set_markup(msg)
 if extended_msg != None:
 buffer = self.textview_error.get_buffer()
 buffer.set_text(extended_msg)
 self.scroll_error.show()
 else:
 self.scroll_error.hide()
 self.dialog_error.realize()
 self.dialog_error.get_window().set_functions(Gdk.WMFunction.MOVE)
 self.dialog_error.run()
 self.dialog_error.hide()
 return False

def confirmChanges(self, summary, changes, demotions, downloadSize,
 actions=None, removal_bold=True):
 # FIXME: add an allow list here for packages that we expect to be
 # removed (how to calc this automatically?)
 if not DistUpgradeView.confirmChanges(self, summary, changes,
 demotions, downloadSize):
 return False
 # append warning
 self.confirmChangesMessage += "\n\n%s" % \
 _("To prevent data loss close all open "
 "applications and documents.")

if actions != None:
            self.button_cancel_changes.set_use_stock(False)
            self.button_cancel_changes.set_use_underline(True)
            self.button_cancel_changes.set_label(actions[0])
            self.button_confirm_changes.set_label(actions[1])

self.label_summary.set_markup("<big>%s</big>" % summary)
 self.label_changes.set_markup(self.confirmChangesMessage)
 # fill in the details
 self.details_list.clear()
 for (parent_text, details_list) in (
 ( _("No longer supported by Canonical (%s)"), self.demotions),
 ( _("Downgrade (%s)"), self.toDowngrade),
 ( _("Remove (%s)"), self.toRemove),
 ( _("No longer needed (%s)"), self.toRemoveAuto),
 ( _("Install (%s)"), self.toInstall),
 ( _("Upgrade (%s)"), self.toUpgrade),
 ):
 if details_list:
 node = self.details_list.append(None,
 [parent_text % len(details_list)])
 for pkg in details_list:
 self.details_list.append(node, ["%s - %s" % (
 pkg.name, GLib.markup_escape_text(getattr(pkg.candidate, "summary", None)))])
 # prepare dialog
 self.dialog_changes.realize()
 self.dialog_changes.set_transient_for(self.window_main)
 self.dialog_changes.set_title("")
 self.dialog_changes.get_window().set_functions(Gdk.WMFunction.MOVE|
 Gdk.WMFunction.RESIZE)
 res = self.dialog_changes.run()
 self.dialog_changes.hide()
 if res == Gtk.ResponseType.YES:
 return True
 return False

def askYesNoQuestion(self, summary, msg, default='No'):
 msg = "<big>%s</big>\n\n%s" % (summary,msg)
 dialog = Gtk.MessageDialog(parent=self.window_main,
 flags=Gtk.DialogFlags.MODAL,
 type=Gtk.MessageType.QUESTION,
 buttons=Gtk.ButtonsType.YES_NO)
 dialog.set_title("")
 if default == 'No':
 dialog.set_default_response(Gtk.ResponseType.NO)
 else:
 dialog.set_default_response(Gtk.ResponseType.YES)
 dialog.set_markup(msg)
 res = dialog.run()
 dialog.destroy()
 if res == Gtk.ResponseType.YES:
 return True
 return False

def askCancelContinueQuestion(self, summary, msg, default='Cancel'):
 if summary:
 msg = "<big>%s</big>\n\n%s" % (summary,msg)

dialog = Gtk.MessageDialog(parent=self.window_main,
                                   flags=Gtk.DialogFlags.MODAL,
                                   type=Gtk.MessageType.WARNING,
                                   buttons=Gtk.ButtonsType.NONE)
        dialog.set_title("")
        dialog.set_markup(msg)
        dialog.add_buttons(_('Cancel'), Gtk.ResponseType.CANCEL,
                           _('Continue'), Gtk.ResponseType.ACCEPT)

if default == 'Cancel':
            dialog.set_default_response(Gtk.ResponseType.CANCEL)
        else:
            dialog.set_default_response(Gtk.ResponseType.ACCEPT)

res = dialog.run()
        dialog.destroy()
        if res == Gtk.ResponseType.ACCEPT:
            return True
        return False

def confirmRestart(self):
        self.dialog_restart.set_transient_for(self.window_main)
        self.dialog_restart.set_title("")
        self.dialog_restart.realize()
        self.dialog_restart.get_window().set_functions(Gdk.WMFunction.MOVE)
        res = self.dialog_restart.run()
        self.dialog_restart.hide()
        if res == Gtk.ResponseType.YES:
            return True
        return False

def processEvents(self):
        while Gtk.events_pending():
            Gtk.main_iteration()

def pulseProgress(self, finished=False):
        self.progressbar_cache.pulse()
        if finished:
            self.progressbar_cache.set_fraction(1.0)

def on_window_main_delete_event(self, widget, event):
        self.dialog_cancel.set_transient_for(self.window_main)
        self.dialog_cancel.set_title("")
        self.dialog_cancel.realize()
        self.dialog_cancel.get_window().set_functions(Gdk.WMFunction.MOVE)
        res = self.dialog_cancel.run()
        self.dialog_cancel.hide()
        if res == Gtk.ResponseType.CANCEL:
            sys.exit(1)
        return True

if __name__ == "__main__":

view = DistUpgradeViewGtk3()
    fp = GtkAcquireProgressAdapter(view)
    ip = GtkInstallProgressAdapter(view)

view.getTerminal().call(["/usr/bin/dpkg","--configure","-a"])
    Gtk.main()
    sys.exit(0)

cache = apt.Cache()
    for pkg in sys.argv[1:]:
        if cache[pkg].is_installed:
            cache[pkg].mark_delete()
        else:
            cache[pkg].mark_install()
    cache.commit(fp,ip)
    Gtk.main()

#sys.exit(0)
    ip.conffile("TODO","TODO~")
    view.getTerminal().call(["/usr/bin/dpkg","--configure","-a"])
    #view.getTerminal().call(["ls","-R","/usr"])
    view.error("short","long",
               "asfds afsdj af asdf asdf asf dsa fadsf asdf as fasf sextended\n"
               "asfds afsdj af asdf asdf asf dsa fadsf asdf as fasf sextended\n"
               "asfds afsdj af asdf asdf asf dsa fadsf asdf as fasf sextended\n"
               "asfds afsdj af asdf asdf asf dsa fadsf asdf as fasf sextended\n"
               "asfds afsdj af asdf asdf asf dsa fadsf asdf as fasf sextended\n"
               "asfds afsdj af asdf asdf asf dsa fadsf asdf as fasf sextended\n"
               "asfds afsdj af asdf asdf asf dsa fadsf asdf as fasf sextended\n"
               )
    view.confirmChanges("xx",[], 100)

cmd: