1 /* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */
2 /*
3 * This program is free software: you can redistribute it and/or modify it
4 * under the terms of the GNU Lesser General Public License as published by
5 * the Free Software Foundation.
6 *
7 * This program is distributed in the hope that it will be useful, but
8 * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
9 * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License
10 * for more details.
11 *
12 * You should have received a copy of the GNU Lesser General Public License
13 * along with this program. If not, see <http://www.gnu.org/licenses/>.
14 *
15 */
16
17 #include <stdlib.h>
18 #include <libecal/libecal.h>
19
20 #include "e-test-server-utils.h"
21
22 static ETestServerClosure cal_closure_sync =
23 { E_TEST_SERVER_CALENDAR, NULL, E_CAL_CLIENT_SOURCE_TYPE_EVENTS, FALSE, NULL, FALSE };
24 static ETestServerClosure cal_closure_async =
25 { E_TEST_SERVER_CALENDAR, NULL, E_CAL_CLIENT_SOURCE_TYPE_EVENTS, FALSE, NULL, TRUE };
26
27 typedef enum {
28 SUBTEST_OBJECTS_ADDED,
29 SUBTEST_OBJECTS_MODIFIED,
30 SUBTEST_OBJECTS_REMOVED,
31 SUBTEST_VIEW_DONE,
32 NUM_SUBTESTS,
33 SUBTEST_RESET
34 } SubTestId;
35
36 static void
subtest_passed(SubTestId id,GMainLoop * loop)37 subtest_passed (SubTestId id,
38 GMainLoop *loop)
39 {
40 static guint subtests_complete = 0;
41
42 if (id == SUBTEST_RESET) {
43 subtests_complete = 0;
44 return;
45 }
46
47 subtests_complete |= (1 << id);
48
49 if (subtests_complete == ((1 << NUM_SUBTESTS) - 1))
50 g_main_loop_quit (loop);
51 }
52
53 static ICalTime *
get_last_modified(ICalComponent * component)54 get_last_modified (ICalComponent *component)
55 {
56 ICalComponent *inner = i_cal_component_get_inner (component);
57 ICalProperty *prop;
58 ICalTime *res;
59
60 if (!inner)
61 return i_cal_time_new_null_time ();
62
63 prop = i_cal_component_get_first_property (inner, I_CAL_LASTMODIFIED_PROPERTY);
64
65 if (prop) {
66 res = i_cal_property_get_lastmodified (prop);
67 g_object_unref (prop);
68 } else {
69 res = i_cal_time_new_null_time ();
70 }
71
72 g_clear_object (&inner);
73
74 return res;
75 }
76
77 static void
objects_added_cb(GObject * object,const GSList * objects,gpointer data)78 objects_added_cb (GObject *object,
79 const GSList *objects,
80 gpointer data)
81 {
82 const GSList *l;
83 GMainLoop *loop = (GMainLoop *) data;
84
85 for (l = objects; l; l = l->next) {
86 ICalComponent *component = l->data;
87 ICalTime *recurrence = i_cal_component_get_recurrenceid (component);
88 ICalTime *last_modified = get_last_modified (component);
89 gchar *str_recurrence, *str_last_modified;
90
91 str_recurrence = i_cal_time_as_ical_string (recurrence);
92 str_last_modified = i_cal_time_as_ical_string (last_modified);
93
94 g_print (
95 "Object added %s (recurrence id:%s, last-modified:%s)\n",
96 i_cal_component_get_uid (component),
97 str_recurrence,
98 str_last_modified);
99
100 g_clear_object (&recurrence);
101 g_clear_object (&last_modified);
102 g_free (str_recurrence);
103 g_free (str_last_modified);
104
105 g_assert (i_cal_component_get_summary (component) == NULL);
106 }
107
108 subtest_passed (SUBTEST_OBJECTS_ADDED, loop);
109 }
110
111 static void
objects_modified_cb(GObject * object,const GSList * objects,gpointer data)112 objects_modified_cb (GObject *object,
113 const GSList *objects,
114 gpointer data)
115 {
116 const GSList *l;
117 GMainLoop *loop = (GMainLoop *) data;
118
119 for (l = objects; l; l = l->next) {
120 ICalComponent *component = l->data;
121 ICalTime *recurrence = i_cal_component_get_recurrenceid (component);
122 ICalTime *last_modified = get_last_modified (component);
123 gchar *str_recurrence, *str_last_modified;
124
125 str_recurrence = i_cal_time_as_ical_string (recurrence);
126 str_last_modified = i_cal_time_as_ical_string (last_modified);
127
128 g_print (
129 "Object modified %s (recurrence id:%s, last-modified:%s)\n",
130 i_cal_component_get_uid (component),
131 str_recurrence,
132 str_last_modified);
133
134 g_clear_object (&recurrence);
135 g_clear_object (&last_modified);
136 g_free (str_recurrence);
137 g_free (str_last_modified);
138
139 g_assert (i_cal_component_get_summary (component) == NULL);
140 }
141
142 subtest_passed (SUBTEST_OBJECTS_MODIFIED, loop);
143 }
144
145 static void
objects_removed_cb(GObject * object,const GSList * objects,gpointer data)146 objects_removed_cb (GObject *object,
147 const GSList *objects,
148 gpointer data)
149 {
150 GMainLoop *loop = (GMainLoop *) data;
151 const GSList *l;
152
153 for (l = objects; l; l = l->next) {
154 ECalComponentId *id = l->data;
155
156 g_print ("Object removed: uid: %s, rid: %s\n", e_cal_component_id_get_uid (id), e_cal_component_id_get_rid (id));
157 }
158
159 subtest_passed (SUBTEST_OBJECTS_REMOVED, loop);
160 }
161
162 static void
complete_cb(GObject * object,const GError * error,gpointer data)163 complete_cb (GObject *object,
164 const GError *error,
165 gpointer data)
166 {
167 GMainLoop *loop = (GMainLoop *) data;
168
169 g_print ("View complete (status: %d, error_msg:%s)\n", error ? error->code : 0, error ? error->message : "NULL");
170
171 subtest_passed (SUBTEST_VIEW_DONE, loop);
172 }
173
174 static gpointer
alter_cal_client(gpointer user_data)175 alter_cal_client (gpointer user_data)
176 {
177 ECalClient *cal_client = user_data;
178 GError *error = NULL;
179 ICalComponent *icomp;
180 ICalTime *now, *itt;
181 gchar *uid = NULL;
182
183 g_return_val_if_fail (cal_client != NULL, NULL);
184
185 now = i_cal_time_new_current_with_zone (i_cal_timezone_get_utc_timezone ());
186 itt = i_cal_time_new_from_timet_with_zone (i_cal_time_as_timet (now) + 60 * 60 * 60, 0, NULL);
187
188 icomp = i_cal_component_new (I_CAL_VEVENT_COMPONENT);
189 i_cal_component_set_summary (icomp, "Initial event summary");
190 i_cal_component_set_dtstart (icomp, now);
191 i_cal_component_set_dtend (icomp, itt);
192
193 if (!e_cal_client_create_object_sync (cal_client, icomp, E_CAL_OPERATION_FLAG_NONE, &uid, NULL, &error))
194 g_error ("create object sync: %s", error->message);
195
196 i_cal_component_set_uid (icomp, uid);
197 i_cal_component_set_summary (icomp, "Modified event summary");
198
199 if (!e_cal_client_modify_object_sync (cal_client, icomp, E_CAL_OBJ_MOD_ALL, E_CAL_OPERATION_FLAG_NONE, NULL, &error))
200 g_error ("modify object sync: %s", error->message);
201
202 if (!e_cal_client_remove_object_sync (cal_client, uid, NULL, E_CAL_OBJ_MOD_ALL, E_CAL_OPERATION_FLAG_NONE, NULL, &error))
203 g_error ("remove object sync: %s", error->message);
204
205 g_object_unref (icomp);
206 g_object_unref (now);
207 g_object_unref (itt);
208 g_free (uid);
209
210 return FALSE;
211 }
212
213 static void
async_get_view_ready(GObject * source_object,GAsyncResult * result,gpointer user_data)214 async_get_view_ready (GObject *source_object,
215 GAsyncResult *result,
216 gpointer user_data)
217 {
218 ECalClient *cal_client = E_CAL_CLIENT (source_object);
219 ECalClientView *view = NULL;
220 GError *error = NULL;
221 GMainLoop *loop = (GMainLoop *) user_data;
222 GSList *field_list = NULL;
223
224 g_return_if_fail (cal_client != NULL);
225
226 if (!e_cal_client_get_view_finish (cal_client, result, &view, &error))
227 g_error ("get view finish: %s", error->message);
228
229 g_object_set_data_full (G_OBJECT (cal_client), "cal-view", view, g_object_unref);
230
231 subtest_passed (SUBTEST_RESET, loop);
232 g_signal_connect (view, "objects_added", G_CALLBACK (objects_added_cb), loop);
233 g_signal_connect (view, "objects_modified", G_CALLBACK (objects_modified_cb), loop);
234 g_signal_connect (view, "objects_removed", G_CALLBACK (objects_removed_cb), loop);
235 g_signal_connect (view, "complete", G_CALLBACK (complete_cb), loop);
236
237 field_list = g_slist_prepend (NULL, (gpointer) "UID");
238 field_list = g_slist_prepend (field_list, (gpointer) "RECURRENCE-ID");
239 field_list = g_slist_prepend (field_list, (gpointer) "LAST-MODIFIED");
240
241 e_cal_client_view_set_fields_of_interest (view, field_list, &error);
242 if (error)
243 g_error ("set fields of interest: %s", error->message);
244 g_slist_free (field_list);
245
246 e_cal_client_view_start (view, NULL);
247 alter_cal_client (cal_client);
248 }
249
250 static void
test_get_revision_view_async(ETestServerFixture * fixture,gconstpointer user_data)251 test_get_revision_view_async (ETestServerFixture *fixture,
252 gconstpointer user_data)
253 {
254 ECalClient *cal_client;
255
256 cal_client = E_TEST_SERVER_UTILS_SERVICE (fixture, ECalClient);
257
258 e_cal_client_get_view (cal_client, "(contains? \"any\" \"event\")", NULL, async_get_view_ready, fixture->loop);
259 g_main_loop_run (fixture->loop);
260
261 /* Will unref the view */
262 g_object_set_data (G_OBJECT (cal_client), "cal-view", NULL);
263 }
264
265 static void
test_get_revision_view_sync(ETestServerFixture * fixture,gconstpointer user_data)266 test_get_revision_view_sync (ETestServerFixture *fixture,
267 gconstpointer user_data)
268 {
269 ECalClient *cal_client;
270 GError *error = NULL;
271 ECalClientView *view = NULL;
272 GSList *field_list = NULL;
273
274 cal_client = E_TEST_SERVER_UTILS_SERVICE (fixture, ECalClient);
275
276 if (!e_cal_client_get_view_sync (cal_client, "(contains? \"any\" \"event\")", &view, NULL, &error))
277 g_error ("get view sync: %s", error->message);
278
279 subtest_passed (SUBTEST_RESET, fixture->loop);
280 g_signal_connect (view, "objects_added", G_CALLBACK (objects_added_cb), fixture->loop);
281 g_signal_connect (view, "objects_modified", G_CALLBACK (objects_modified_cb), fixture->loop);
282 g_signal_connect (view, "objects_removed", G_CALLBACK (objects_removed_cb), fixture->loop);
283 g_signal_connect (view, "complete", G_CALLBACK (complete_cb), fixture->loop);
284
285 field_list = g_slist_prepend (NULL, (gpointer) "UID");
286 field_list = g_slist_prepend (field_list, (gpointer) "RECURRENCE-ID");
287 field_list = g_slist_prepend (field_list, (gpointer) "LAST-MODIFIED");
288
289 e_cal_client_view_set_fields_of_interest (view, field_list, &error);
290 if (error)
291 g_error ("set fields of interest: %s", error->message);
292 g_slist_free (field_list);
293
294 e_cal_client_view_start (view, NULL);
295
296 g_idle_add ((GSourceFunc) alter_cal_client, cal_client);
297 g_main_loop_run (fixture->loop);
298
299 g_object_unref (view);
300 }
301
302 gint
main(gint argc,gchar ** argv)303 main (gint argc,
304 gchar **argv)
305 {
306 g_test_init (&argc, &argv, NULL);
307 g_test_bug_base ("http://bugzilla.gnome.org/");
308
309 g_test_add (
310 "/ECalClient/GetRevisionView/Sync",
311 ETestServerFixture,
312 &cal_closure_sync,
313 e_test_server_utils_setup,
314 test_get_revision_view_sync,
315 e_test_server_utils_teardown);
316 g_test_add (
317 "/ECalClient/GetRevisionView/Async",
318 ETestServerFixture,
319 &cal_closure_async,
320 e_test_server_utils_setup,
321 test_get_revision_view_async,
322 e_test_server_utils_teardown);
323
324 return e_test_server_utils_run (argc, argv);
325 }
326