← Back to branch summary

~ubuntu-branches/ubuntu/oneiric/ubuntuone-client/oneiric

« back to all changes in this revision

Viewing changes to libsyncdaemon/syncdaemon-folders-interface.c

  • Committer: Bazaar Package Importer
  • Author(s): Rodney Dawes
  • Date: 2010-06-08 17:31:18 UTC
  • mto: This revision was merged to the branch mainline in revision 31.
  • Revision ID: james.westby@ubuntu.com-20100608173118-o8s897ll11rtne99
Tags: upstream-1.3.0
Import upstream version 1.3.0

Show diffs side-by-side

added added

removed removed

Lines of Context:
libsyncdaemon/syncdaemon-folders-interface.c
 
1
/*
 
2
 * Syncdaemon API
 
3
 *
 
4
 * Authors: Rodrigo Moya <rodrigo.moya@canonical.com>
 
5
 *
 
6
 * Copyright 2010 Canonical Ltd.
 
7
 *
 
8
 * This program is free software: you can redistribute it and/or modify it
 
9
 * under the terms of the GNU General Public License version 3, as published
 
10
 * by the Free Software Foundation.
 
11
 *
 
12
 * This program is distributed in the hope that it will be useful, but
 
13
 * WITHOUT ANY WARRANTY; without even the implied warranties of
 
14
 * MERCHANTABILITY, SATISFACTORY QUALITY, or FITNESS FOR A PARTICULAR
 
15
 * PURPOSE.  See the GNU General Public License for more details.
 
16
 *
 
17
 * You should have received a copy of the GNU General Public License along
 
18
 * with this program.  If not, see <http://www.gnu.org/licenses/>.
 
19
 *
 
20
 */
 
21
 
 
22
#include "config.h"
 
23
#include "syncdaemon-folders-interface.h"
 
24
#include "utils.h"
 
25
 
 
26
G_DEFINE_TYPE(SyncdaemonFoldersInterface, syncdaemon_folders_interface, SYNCDAEMON_TYPE_INTERFACE)
 
27
 
 
28
struct _SyncdaemonFoldersInterfacePrivate {
 
29
        GObject *proxy;
 
30
};
 
31
 
 
32
static void
 
33
syncdaemon_folders_interface_finalize (GObject *object)
 
34
{
 
35
        SyncdaemonFoldersInterface *interface = SYNCDAEMON_FOLDERS_INTERFACE (object);
 
36
 
 
37
        if (interface->priv != NULL) {
 
38
                g_free (interface->priv);
 
39
        }
 
40
 
 
41
        G_OBJECT_CLASS (syncdaemon_folders_interface_parent_class)->finalize (object);
 
42
}
 
43
 
 
44
static void
 
45
syncdaemon_folders_interface_class_init (SyncdaemonFoldersInterfaceClass *klass)
 
46
{
 
47
        GObjectClass *object_class = G_OBJECT_CLASS (klass);
 
48
 
 
49
        object_class->finalize = syncdaemon_folders_interface_finalize;
 
50
}
 
51
 
 
52
static void
 
53
folder_created_cb (DBusGProxy *proxy, GHashTable *folder_info, gpointer user_data)
 
54
{
 
55
        SyncdaemonDaemon *daemon = NULL;
 
56
        SyncdaemonFoldersInterface *interface = SYNCDAEMON_FOLDERS_INTERFACE (user_data);
 
57
 
 
58
        g_object_get (G_OBJECT (interface), "daemon", &daemon, NULL);
 
59
        if (daemon != NULL)
 
60
                g_signal_emit_by_name (daemon, "folder_created", folder_info);
 
61
}
 
62
 
 
63
static void
 
64
folder_deleted_cb (DBusGProxy *proxy, GHashTable *folder_info, gpointer user_data)
 
65
{
 
66
        SyncdaemonDaemon *daemon = NULL;
 
67
        SyncdaemonFoldersInterface *interface = SYNCDAEMON_FOLDERS_INTERFACE (user_data);
 
68
 
 
69
        g_object_get (G_OBJECT (interface), "daemon", &daemon, NULL);
 
70
        if (daemon != NULL)
 
71
                g_signal_emit_by_name (daemon, "folder_deleted", folder_info);
 
72
}
 
73
 
 
74
static void
 
75
folder_subscribed_cb (DBusGProxy *proxy, GHashTable *folder_info, gpointer user_data)
 
76
{
 
77
        SyncdaemonDaemon *daemon = NULL;
 
78
        SyncdaemonFoldersInterface *interface = SYNCDAEMON_FOLDERS_INTERFACE (user_data);
 
79
 
 
80
        g_object_get (G_OBJECT (interface), "daemon", &daemon, NULL);
 
81
        if (daemon != NULL)
 
82
                g_signal_emit_by_name (daemon, "folder_subscribed", folder_info);
 
83
}
 
84
 
 
85
static void
 
86
folder_unsubscribed_cb (DBusGProxy *proxy, GHashTable *folder_info, gpointer user_data)
 
87
{
 
88
        SyncdaemonDaemon *daemon = NULL;
 
89
        SyncdaemonFoldersInterface *interface = SYNCDAEMON_FOLDERS_INTERFACE (user_data);
 
90
 
 
91
        g_object_get (G_OBJECT (interface), "daemon", &daemon, NULL);
 
92
        if (daemon != NULL)
 
93
                g_signal_emit_by_name (daemon, "folder_unsubscribed", folder_info);
 
94
}
 
95
 
 
96
static void
 
97
udf_error_cb (DBusGProxy *proxy, GHashTable *folder_info, gchar *error, gpointer user_data)
 
98
{
 
99
        SyncdaemonDaemon *daemon = NULL;
 
100
        SyncdaemonFoldersInterface *interface = SYNCDAEMON_FOLDERS_INTERFACE (user_data);
 
101
 
 
102
        g_object_get (G_OBJECT (interface), "daemon", &daemon, NULL);
 
103
        if (daemon != NULL)
 
104
                g_signal_emit_by_name (daemon, "error", error, folder_info);
 
105
}
 
106
 
 
107
static void
 
108
syncdaemon_folders_interface_init (SyncdaemonFoldersInterface *interface)
 
109
{
 
110
        interface->priv = g_new0 (SyncdaemonFoldersInterfacePrivate, 1);
 
111
 
 
112
        /* Setup DBus proxy */
 
113
        interface->priv->proxy = syncdaemon_interface_setup_proxy (SYNCDAEMON_INTERFACE (interface),
 
114
                                                                   "com.ubuntuone.Syncdaemon",
 
115
                                                                   "/folders", "com.ubuntuone.Syncdaemon.Folders");
 
116
        if (interface->priv->proxy != NULL) {
 
117
                /* Connect to DBus proxy signals */
 
118
                dbus_g_proxy_add_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderCreated",
 
119
                                         dbus_g_type_get_map ("GHashTable",
 
120
                                                              G_TYPE_STRING,
 
121
                                                              G_TYPE_STRING),
 
122
                                         G_TYPE_INVALID);
 
123
                dbus_g_proxy_connect_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderCreated",
 
124
                                             G_CALLBACK (folder_created_cb), interface, NULL);
 
125
 
 
126
                dbus_g_proxy_add_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderDeleted",
 
127
                                         dbus_g_type_get_map ("GHashTable",
 
128
                                                              G_TYPE_STRING,
 
129
                                                              G_TYPE_STRING),
 
130
                                         G_TYPE_INVALID);
 
131
                dbus_g_proxy_connect_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderDeleted",
 
132
                                             G_CALLBACK (folder_deleted_cb), interface, NULL);
 
133
 
 
134
                dbus_g_proxy_add_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderSubscribed",
 
135
                                         dbus_g_type_get_map ("GHashTable",
 
136
                                                              G_TYPE_STRING,
 
137
                                                              G_TYPE_STRING),
 
138
                                         G_TYPE_INVALID);
 
139
                dbus_g_proxy_connect_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderSubscribed",
 
140
                                             G_CALLBACK (folder_subscribed_cb), interface, NULL);
 
141
 
 
142
                dbus_g_proxy_add_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderUnSubscribed",
 
143
                                         dbus_g_type_get_map ("GHashTable",
 
144
                                                              G_TYPE_STRING,
 
145
                                                              G_TYPE_STRING),
 
146
                                         G_TYPE_INVALID);
 
147
                dbus_g_proxy_connect_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderUnSubscribed",
 
148
                                             G_CALLBACK (folder_unsubscribed_cb), interface, NULL);
 
149
 
 
150
                /* Error signals */
 
151
                dbus_g_proxy_add_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderCreateError",
 
152
                                         dbus_g_type_get_map ("GHashTable",
 
153
                                                              G_TYPE_STRING,
 
154
                                                              G_TYPE_STRING),
 
155
                                         G_TYPE_STRING,
 
156
                                         G_TYPE_INVALID);
 
157
                dbus_g_proxy_connect_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderCreateError",
 
158
                                             G_CALLBACK (udf_error_cb), interface, NULL);
 
159
 
 
160
                dbus_g_proxy_add_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderDeleteError",
 
161
                                         dbus_g_type_get_map ("GHashTable",
 
162
                                                              G_TYPE_STRING,
 
163
                                                              G_TYPE_STRING),
 
164
                                         G_TYPE_STRING,
 
165
                                         G_TYPE_INVALID);
 
166
                dbus_g_proxy_connect_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderDeleteError",
 
167
                                             G_CALLBACK (udf_error_cb), interface, NULL);
 
168
 
 
169
                dbus_g_proxy_add_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderSubscribeError",
 
170
                                         dbus_g_type_get_map ("GHashTable",
 
171
                                                              G_TYPE_STRING,
 
172
                                                              G_TYPE_STRING),
 
173
                                         G_TYPE_STRING,
 
174
                                         G_TYPE_INVALID);
 
175
                dbus_g_proxy_connect_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderSubscribeError",
 
176
                                             G_CALLBACK (udf_error_cb), interface, NULL);
 
177
 
 
178
                dbus_g_proxy_add_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderUnSubscribeError",
 
179
                                         dbus_g_type_get_map ("GHashTable",
 
180
                                                              G_TYPE_STRING,
 
181
                                                              G_TYPE_STRING),
 
182
                                         G_TYPE_STRING,
 
183
                                         G_TYPE_INVALID);
 
184
                dbus_g_proxy_connect_signal (DBUS_G_PROXY (interface->priv->proxy), "FolderUnSubscribedError",
 
185
                                             G_CALLBACK (udf_error_cb), interface, NULL);
 
186
        }
 
187
}
 
188
 
 
189
/**
 
190
 * syncdaemon_folders_interface_new:
 
191
 */
 
192
SyncdaemonFoldersInterface *
 
193
syncdaemon_folders_interface_new (SyncdaemonDaemon *daemon)
 
194
{
 
195
        g_return_val_if_fail (SYNCDAEMON_IS_DAEMON (daemon), NULL);
 
196
 
 
197
        return g_object_new (SYNCDAEMON_TYPE_FOLDERS_INTERFACE, "daemon", daemon, NULL);
 
198
}
 
199
 
 
200
/**
 
201
 * syncdaemon_folders_interface_create:
 
202
 */
 
203
void
 
204
syncdaemon_folders_interface_create (SyncdaemonFoldersInterface *interface, const gchar *path)
 
205
{
 
206
        g_return_if_fail (SYNCDAEMON_IS_FOLDERS_INTERFACE (interface));
 
207
        g_return_if_fail (path != NULL);
 
208
 
 
209
        dbus_g_proxy_begin_call (DBUS_G_PROXY (interface->priv->proxy), "create",
 
210
                                 no_output_dbus_call_ended_cb, interface, NULL,
 
211
                                 G_TYPE_STRING, path,
 
212
                                 G_TYPE_INVALID);
 
213
}
 
214
 
 
215
/**
 
216
 * syncdaemon_folders_interface_delete:
 
217
 */
 
218
void
 
219
syncdaemon_folders_interface_delete (SyncdaemonFoldersInterface *interface, const gchar *folder_id)
 
220
{
 
221
        g_return_if_fail (SYNCDAEMON_IS_FOLDERS_INTERFACE (interface));
 
222
        g_return_if_fail (folder_id != NULL);
 
223
 
 
224
        dbus_g_proxy_begin_call (DBUS_G_PROXY (interface->priv->proxy), "delete",
 
225
                                 no_output_dbus_call_ended_cb, interface, NULL,
 
226
                                 G_TYPE_STRING, folder_id,
 
227
                                 G_TYPE_INVALID);
 
228
}
 
229
 
 
230
/**
 
231
 * syncdaemon_folders_interface_get_folders:
 
232
 */
 
233
GSList *
 
234
syncdaemon_folders_interface_get_folders (SyncdaemonFoldersInterface *interface)
 
235
{
 
236
        GSList *folders = NULL;
 
237
        GError *error = NULL;
 
238
 
 
239
        g_return_val_if_fail (SYNCDAEMON_IS_FOLDERS_INTERFACE (interface), NULL);
 
240
 
 
241
        if (!dbus_g_proxy_call (DBUS_G_PROXY (interface->priv->proxy), "get_folders", &error,
 
242
                                G_TYPE_INVALID,
 
243
                                dbus_g_type_get_collection ("GSList",
 
244
                                                            dbus_g_type_get_map
 
245
                                                            ("GHashTable",
 
246
                                                             G_TYPE_STRING,
 
247
                                                             G_TYPE_STRING)), &folders,
 
248
                                G_TYPE_INVALID)) {
 
249
                g_warning ("Error calling get_folders: %s", error->message);
 
250
                g_error_free (error);
 
251
        }
 
252
 
 
253
        return folders;
 
254
}
 
255
 
 
256
/**
 
257
 * syncdaemon_folders_interface_get_info:
 
258
 */
 
259
GHashTable *
 
260
syncdaemon_folders_interface_get_info (SyncdaemonFoldersInterface *interface, const gchar *path)
 
261
{
 
262
        GHashTable *info = NULL;
 
263
        GError *error = NULL;
 
264
 
 
265
        g_return_val_if_fail (SYNCDAEMON_IS_FOLDERS_INTERFACE (interface), NULL);
 
266
        g_return_val_if_fail (path != NULL, NULL);
 
267
 
 
268
        if (!dbus_g_proxy_call (DBUS_G_PROXY (interface->priv->proxy), "get_info", &error,
 
269
                                G_TYPE_STRING, path,
 
270
                                G_TYPE_INVALID,
 
271
                                dbus_g_type_get_map ("GHashTable",
 
272
                                                        G_TYPE_STRING,
 
273
                                                        G_TYPE_STRING), &info,
 
274
                                G_TYPE_INVALID)) {
 
275
                g_warning ("Error calling get_info: %s", error->message);
 
276
                g_error_free (error);
 
277
        }
 
278
 
 
279
        return info;
 
280
}
 
281
 
 
282
/**
 
283
 * syncdaemon_folders_interface_refresh_volumes:
 
284
 */
 
285
void
 
286
syncdaemon_folders_interface_refresh_volumes (SyncdaemonFoldersInterface *interface)
 
287
{
 
288
        g_return_if_fail (SYNCDAEMON_IS_FOLDERS_INTERFACE (interface));
 
289
 
 
290
        dbus_g_proxy_begin_call (DBUS_G_PROXY (interface->priv->proxy), "refresh_volumes",
 
291
                                 no_output_dbus_call_ended_cb, interface, NULL,
 
292
                                 G_TYPE_INVALID);
 
293
}
 
294
 
 
295
/**
 
296
 * syncdaemon_folders_interface_subscribe:
 
297
 */
 
298
void
 
299
syncdaemon_folders_interface_subscribe (SyncdaemonFoldersInterface *interface, const gchar *folder_id)
 
300
{
 
301
        g_return_if_fail (SYNCDAEMON_IS_FOLDERS_INTERFACE (interface));
 
302
        g_return_if_fail (folder_id != NULL);
 
303
 
 
304
        dbus_g_proxy_begin_call (DBUS_G_PROXY (interface->priv->proxy), "subscribe",
 
305
                                 no_output_dbus_call_ended_cb, interface, NULL,
 
306
                                 G_TYPE_STRING, folder_id,
 
307
                                 G_TYPE_INVALID);
 
308
}
 
309
 
 
310
/**
 
311
 * syncdaemon_folders_interface_unsubscribe:
 
312
 */
 
313
void
 
314
syncdaemon_folders_interface_unsubscribe (SyncdaemonFoldersInterface *interface, const gchar *folder_id)
 
315
{
 
316
        g_return_if_fail (SYNCDAEMON_IS_FOLDERS_INTERFACE (interface));
 
317
        g_return_if_fail (folder_id != NULL);
 
318
 
 
319
        dbus_g_proxy_begin_call (DBUS_G_PROXY (interface->priv->proxy), "unsubscribe",
 
320
                                 no_output_dbus_call_ended_cb, interface, NULL,
 
321
                                 G_TYPE_STRING, folder_id,
 
322
                                 G_TYPE_INVALID);
 
323
}