1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*-
* vi:set noexpandtab tabstop=8 shiftwidth=8:
*
* Copyright (C) 2016-2018 Richard Hughes <richard@hughsie.com>
* Copyright (C) 2019 Kalev Lember <klember@redhat.com>
*
* SPDX-License-Identifier: GPL-2.0+
*/
#include "config.h"
#include <glib.h>
#include "gs-packagekit-helper.h"
#include "packagekit-common.h"
struct _GsPackagekitHelper {
GObject parent_instance;
GHashTable *apps;
GsApp *progress_app;
GsPlugin *plugin;
};
G_DEFINE_TYPE (GsPackagekitHelper, gs_packagekit_helper, G_TYPE_OBJECT)
void
gs_packagekit_helper_cb (PkProgress *progress, PkProgressType type, gpointer user_data)
{
GsPackagekitHelper *self = (GsPackagekitHelper *) user_data;
GsPlugin *plugin = gs_packagekit_helper_get_plugin (self);
const gchar *package_id = pk_progress_get_package_id (progress);
GsApp *app = NULL;
/* optional */
if (self->progress_app != NULL)
app = self->progress_app;
else if (package_id != NULL)
app = gs_packagekit_helper_get_app_by_id (self, package_id);
if (type == PK_PROGRESS_TYPE_STATUS) {
PkStatusEnum status = pk_progress_get_status (progress);
GsPluginStatus plugin_status = packagekit_status_enum_to_plugin_status (status);
if (plugin_status != GS_PLUGIN_STATUS_UNKNOWN)
gs_plugin_status_update (plugin, app, plugin_status);
} else if (type == PK_PROGRESS_TYPE_PERCENTAGE) {
gint percentage = pk_progress_get_percentage (progress);
if (app != NULL && percentage >= 0 && percentage <= 100)
gs_app_set_progress (app, (guint) percentage);
}
/* Only go from TRUE to FALSE - it doesn't make sense for a package
* install to become uncancellable later on */
if (app != NULL && gs_app_get_allow_cancel (app))
gs_app_set_allow_cancel (app, pk_progress_get_allow_cancel (progress));
}
void
gs_packagekit_helper_add_app (GsPackagekitHelper *self, GsApp *app)
{
GPtrArray *source_ids = gs_app_get_source_ids (app);
g_return_if_fail (GS_IS_PACKAGEKIT_HELPER (self));
g_return_if_fail (GS_IS_APP (app));
for (guint i = 0; i < source_ids->len; i++) {
const gchar *source_id = g_ptr_array_index (source_ids, i);
g_hash_table_insert (self->apps,
g_strdup (source_id),
g_object_ref (app));
}
}
void
gs_packagekit_helper_set_progress_app (GsPackagekitHelper *self, GsApp *progress_app)
{
g_set_object (&self->progress_app, progress_app);
}
GsPlugin *
gs_packagekit_helper_get_plugin (GsPackagekitHelper *self)
{
g_return_val_if_fail (GS_IS_PACKAGEKIT_HELPER (self), NULL);
return self->plugin;
}
GsApp *
gs_packagekit_helper_get_app_by_id (GsPackagekitHelper *self, const gchar *package_id)
{
g_return_val_if_fail (GS_IS_PACKAGEKIT_HELPER (self), NULL);
g_return_val_if_fail (package_id != NULL, NULL);
return g_hash_table_lookup (self->apps, package_id);
}
static void
gs_packagekit_helper_finalize (GObject *object)
{
GsPackagekitHelper *self;
g_return_if_fail (GS_IS_PACKAGEKIT_HELPER (object));
self = GS_PACKAGEKIT_HELPER (object);
g_object_unref (self->plugin);
g_clear_object (&self->progress_app);
g_hash_table_unref (self->apps);
G_OBJECT_CLASS (gs_packagekit_helper_parent_class)->finalize (object);
}
static void
gs_packagekit_helper_class_init (GsPackagekitHelperClass *klass)
{
GObjectClass *object_class = G_OBJECT_CLASS (klass);
object_class->finalize = gs_packagekit_helper_finalize;
}
static void
gs_packagekit_helper_init (GsPackagekitHelper *self)
{
self->apps = g_hash_table_new_full (g_str_hash, g_str_equal,
g_free, (GDestroyNotify) g_object_unref);
}
GsPackagekitHelper *
gs_packagekit_helper_new (GsPlugin *plugin)
{
GsPackagekitHelper *self;
self = g_object_new (GS_TYPE_PACKAGEKIT_HELPER, NULL);
self->plugin = g_object_ref (plugin);
return GS_PACKAGEKIT_HELPER (self);
}
|
