Updater: Enable qubesadmin caching

This avoids O(N^2) Admin API calls.

Signed-off-by: Demi Marie Obenour <demiobenour@gmail.com>

Author: DemiMarie

qui/updater/updater.py

@@ -2,6 +2,7 @@
 # -*- coding: utf-8 -*-
 # pylint: disable=wrong-import-position,import-error
 import argparse
+import asyncio
 import logging
 import sys
 import time
@@ -22,8 +23,13 @@
 import qui.updater.utils
 
 gi.require_version("Gtk", "3.0")  # isort:skip
+from gi.events import GLibEventLoopPolicy
 from gi.repository import Gtk, Gdk, Gio  # isort:skip
+
+asyncio.set_event_loop_policy(GLibEventLoopPolicy)
+
 from qubesadmin import Qubes
+import qubesadmin.events
 import qubesadmin.exc
 
 # using locale.gettext is necessary for Gtk.Builder translation support to work
@@ -45,7 +51,7 @@ class QubesUpdater(Gtk.Application):
     LOGPATH = "/var/log/qubes/qui.updater.log"
     LOG_FORMAT = "%(asctime)s %(message)s"
 
-    def __init__(self, qapp, cliargs):
+    def __init__(self, qapp, cliargs, future):
         super().__init__(
             application_id="org.gnome.example",
             flags=Gio.ApplicationFlags.FLAGS_NONE,
@@ -64,6 +70,7 @@ def __init__(self, qapp, cliargs):
         self.log = logging.getLogger("vm-update.agent.PackageManager")
         self.log.addHandler(log_handler)
         self.log.setLevel(self.cliargs.log)
+        asyncio.ensure_future(future)
 
     def do_activate(self, *_args, **_kwargs):
         if not self.primary:
@@ -513,8 +520,9 @@ def skip_intro_if_args(args):
 
 def main(args=None):
     qapp = Qubes()
+    dispatcher = qubesadmin.events.EventDispatcher(qapp)
     cliargs = parse_args(args, qapp)
-    app = QubesUpdater(qapp, cliargs)
+    app = QubesUpdater(qapp, cliargs, dispatcher)
     app.run()
     if app.retcode == 100 and not app.cliargs.signal_no_updates:
         app.retcode = 0