diff options
| -rw-r--r-- | src/apt-watcher.c | 31 |
1 files changed, 27 insertions, 4 deletions
diff --git a/src/apt-watcher.c b/src/apt-watcher.c index 0165bf0..41ed8fc 100644 --- a/src/apt-watcher.c +++ b/src/apt-watcher.c @@ -30,6 +30,10 @@ with this program. If not, see <http://www.gnu.org/licenses/>. static guint watcher_id; +// TODO +// Get it working and then remove the pkclient pointer in the priv +// it's not needed. + struct _AptWatcher { GObject parent_instance; @@ -38,7 +42,7 @@ struct _AptWatcher AptState current_state; PkClient* pkclient; GCancellable * proxy_cancel; - GDBusProxy * proxy; + GDBusProxy * proxy; }; G_DEFINE_TYPE (AptWatcher, apt_watcher, G_TYPE_OBJECT); @@ -48,7 +52,23 @@ get_updates_complete (GObject *source_object, GAsyncResult *res, gpointer user_data) { + g_return_if_fail (APT_IS_WATCHER (user_data)); + //AptWatcher* self = APT_WATCHER (user_data); + + g_print ("Get updates complete"); + PkResults * results; + + results = pk_client_generic_finish (PK_CLIENT(source_object), res, NULL); + if (results == NULL){ + g_warning ("Unable to query for updates - results were NULL ?"); + return; + } + + GPtrArray *packages; + packages = pk_results_get_package_array (results); + g_ptr_array_unref (packages); + g_object_unref (results); } static void apt_watcher_signal_cb ( GDBusProxy* proxy, @@ -65,11 +85,12 @@ static void apt_watcher_signal_cb ( GDBusProxy* proxy, if (g_strcmp0(signal_name, "UpdatesChanged") == 0){ g_debug ("UpdatesChanged signal received"); - self->pkclient = pk_client_new (); + if (self->pkclient == NULL) + self->pkclient = pk_client_new (); pk_client_get_updates_async (self->pkclient, PK_FILTER_ENUM_NONE, NULL, NULL, NULL, - get_updates_complete, + (GAsyncReadyCallback)get_updates_complete, self); } else if (g_strcmp0(signal_name, "RestartScheduled") == 0) { @@ -198,7 +219,7 @@ static void apt_watcher_init (AptWatcher *self) { self->current_state = UP_TO_DATE; - g_timeout_add_seconds (60, + g_timeout_add_seconds (1, apt_watcher_start_apt_interaction, self); } @@ -211,6 +232,8 @@ apt_watcher_finalize (GObject *object) if (self->proxy != NULL) g_object_unref (self->proxy); + if (self->pkclient != NULL) + g_object_unref (self->pkclient); G_OBJECT_CLASS (apt_watcher_parent_class)->finalize (object); } |