aboutsummaryrefslogtreecommitdiff
path: root/src/apt-watcher.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/apt-watcher.c')
-rw-r--r--src/apt-watcher.c31
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);
}