?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
core cleanup: move out is_oof_note flag
[siplcs.git] / src / core / sipe-notify.c
blobf7834621177816fba94c3c4d9c5ecd1096a6acd8
1 /**
2 * @file sipe-notify.c
3 *
4 * pidgin-sipe
5 *
6 * Copyright (C) 2011 SIPE Project <http://sipe.sourceforge.net/>
7 *
8 *
9 * This program is free software; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License as published by
11 * the Free Software Foundation; either version 2 of the License, or
12 * (at your option) any later version.
13 *
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
18 *
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
22 *
23 *
24 * Process incoming SIP NOTIFY/BENOTIFY messages
25 *
26 */
27
28 #ifdef HAVE_CONFIG_H
29 #include "config.h"
30 #endif
31
32 #include <stdlib.h>
33 #include <string.h>
34
35 #include <glib.h>
36
37 #include "sipe-common.h"
38 #include "http-conn.h" /* sipe-cal.h requires this */
39 #include "sipmsg.h"
40 #include "sip-csta.h"
41 #include "sip-soap.h"
42 #include "sip-transport.h"
43 #include "sipe-backend.h"
44 #include "sipe-buddy.h"
45 #include "sipe-cal.h"
46 #include "sipe-conf.h"
47 #include "sipe-core.h"
48 #include "sipe-core-private.h"
49 #include "sipe-group.h"
50 #include "sipe-media.h"
51 #include "sipe-mime.h"
52 #include "sipe-nls.h"
53 #include "sipe-notify.h"
54 #include "sipe-ocs2005.h"
55 #include "sipe-ocs2007.h"
56 #include "sipe-schedule.h"
57 #include "sipe-status.h"
58 #include "sipe-subscriptions.h"
59 #include "sipe-utils.h"
60 #include "sipe-xml.h"
61 #include "sipe.h"
62
63 /* OCS2005 */
64 static void sipe_process_provisioning(struct sipe_core_private *sipe_private,
65 struct sipmsg *msg)
66 {
67 sipe_xml *xn_provision;
68 const sipe_xml *node;
69
70 xn_provision = sipe_xml_parse(msg->body, msg->bodylen);
71 if ((node = sipe_xml_child(xn_provision, "user"))) {
72 SIPE_DEBUG_INFO("sipe_process_provisioning: uri=%s", sipe_xml_attribute(node, "uri"));
73 if ((node = sipe_xml_child(node, "line"))) {
74 const gchar *line_uri = sipe_xml_attribute(node, "uri");
75 const gchar *server = sipe_xml_attribute(node, "server");
76 SIPE_DEBUG_INFO("sipe_process_provisioning: line_uri=%s server=%s", line_uri, server);
77 sip_csta_open(sipe_private, line_uri, server);
78 }
79 }
80 sipe_xml_free(xn_provision);
81 }
82
83 /* OCS2007+ */
84 static void sipe_process_provisioning_v2(struct sipe_core_private *sipe_private,
85 struct sipmsg *msg)
86 {
87 sipe_xml *xn_provision_group_list;
88 const sipe_xml *node;
89
90 xn_provision_group_list = sipe_xml_parse(msg->body, msg->bodylen);
91
92 /* provisionGroup */
93 for (node = sipe_xml_child(xn_provision_group_list, "provisionGroup"); node; node = sipe_xml_twin(node)) {
94 if (sipe_strequal("ServerConfiguration", sipe_xml_attribute(node, "name"))) {
95 g_free(sipe_private->focus_factory_uri);
96 sipe_private->focus_factory_uri = sipe_xml_data(sipe_xml_child(node, "focusFactoryUri"));
97 SIPE_DEBUG_INFO("sipe_process_provisioning_v2: sipe_private->focus_factory_uri=%s",
98 sipe_private->focus_factory_uri ? sipe_private->focus_factory_uri : "");
99
100 #ifdef HAVE_VV
101 g_free(sipe_private->mras_uri);
102 sipe_private->mras_uri = g_strstrip(sipe_xml_data(sipe_xml_child(node, "mrasUri")));
103 SIPE_DEBUG_INFO("sipe_process_provisioning_v2: sipe_private->mras_uri=%s",
104 sipe_private->mras_uri ? sipe_private->mras_uri : "");
105
106 if (sipe_private->mras_uri)
107 sipe_media_get_av_edge_credentials(sipe_private);
108 #endif
109 break;
110 }
111 }
112 sipe_xml_free(xn_provision_group_list);
113 }
114
115 static void process_incoming_notify_rlmi_resub(struct sipe_core_private *sipe_private,
116 const gchar *data, unsigned len)
117 {
118 sipe_xml *xn_list;
119 const sipe_xml *xn_resource;
120 GHashTable *servers = g_hash_table_new_full(g_str_hash, g_str_equal,
121 g_free, NULL);
122 GSList *server;
123 gchar *host;
124
125 xn_list = sipe_xml_parse(data, len);
126
127 for (xn_resource = sipe_xml_child(xn_list, "resource");
128 xn_resource;
129 xn_resource = sipe_xml_twin(xn_resource) )
130 {
131 const char *uri, *state;
132 const sipe_xml *xn_instance;
133
134 xn_instance = sipe_xml_child(xn_resource, "instance");
135 if (!xn_instance) continue;
136
137 uri = sipe_xml_attribute(xn_resource, "uri");
138 state = sipe_xml_attribute(xn_instance, "state");
139 SIPE_DEBUG_INFO("process_incoming_notify_rlmi_resub: uri(%s),state(%s)", uri, state);
140
141 if (strstr(state, "resubscribe")) {
142 const char *poolFqdn = sipe_xml_attribute(xn_instance, "poolFqdn");
143
144 if (poolFqdn) { //[MS-PRES] Section 3.4.5.1.3 Processing Details
145 gchar *user = g_strdup(uri);
146 host = g_strdup(poolFqdn);
147 server = g_hash_table_lookup(servers, host);
148 server = g_slist_append(server, user);
149 g_hash_table_insert(servers, host, server);
150 } else {
151 sipe_subscribe_presence_single(sipe_private,
152 (void *) uri);
153 }
154 }
155 }
156
157 /* Send out any deferred poolFqdn subscriptions */
158 g_hash_table_foreach(servers, (GHFunc) sipe_subscribe_poolfqdn_resource_uri, sipe_private);
159 g_hash_table_destroy(servers);
160
161 sipe_xml_free(xn_list);
162 }
163
164 /**
165 * Update user phone
166 * Suitable for both 2005 and 2007 systems.
167 *
168 * @param uri buddy SIP URI with 'sip:' prefix whose info we want to change.
169 * @param phone_type
170 * @param phone may be modified to strip white space
171 * @param phone_display_string may be modified to strip white space
172 */
173 static void
174 sipe_update_user_phone(struct sipe_core_private *sipe_private,
175 const gchar *uri,
176 const gchar *phone_type,
177 gchar *phone,
178 gchar *phone_display_string)
179 {
180 sipe_buddy_info_fields phone_node = SIPE_BUDDY_INFO_WORK_PHONE; /* work phone by default */
181 sipe_buddy_info_fields phone_display_node = SIPE_BUDDY_INFO_WORK_PHONE_DISPLAY; /* work phone by default */
182
183 if(!phone || strlen(phone) == 0) return;
184
185 if ((sipe_strequal(phone_type, "mobile") || sipe_strequal(phone_type, "cell"))) {
186 phone_node = SIPE_BUDDY_INFO_MOBILE_PHONE;
187 phone_display_node = SIPE_BUDDY_INFO_MOBILE_PHONE_DISPLAY;
188 } else if (sipe_strequal(phone_type, "home")) {
189 phone_node = SIPE_BUDDY_INFO_HOME_PHONE;
190 phone_display_node = SIPE_BUDDY_INFO_HOME_PHONE_DISPLAY;
191 } else if (sipe_strequal(phone_type, "other")) {
192 phone_node = SIPE_BUDDY_INFO_OTHER_PHONE;
193 phone_display_node = SIPE_BUDDY_INFO_OTHER_PHONE_DISPLAY;
194 } else if (sipe_strequal(phone_type, "custom1")) {
195 phone_node = SIPE_BUDDY_INFO_CUSTOM1_PHONE;
196 phone_display_node = SIPE_BUDDY_INFO_CUSTOM1_PHONE_DISPLAY;
197 }
198
199 sipe_buddy_update_property(sipe_private, uri, phone_node, phone);
200 if (phone_display_string) {
201 sipe_buddy_update_property(sipe_private, uri, phone_display_node, phone_display_string);
202 }
203 }
204
205 static void process_incoming_notify_msrtc(struct sipe_core_private *sipe_private,
206 const gchar *data,
207 unsigned len)
208 {
209 struct sipe_account_data *sip = SIPE_ACCOUNT_DATA_PRIVATE;
210 char *activity = NULL;
211 const char *epid;
212 const char *status_id = NULL;
213 const char *name;
214 char *uri;
215 char *self_uri = sip_uri_self(sipe_private);
216 int avl;
217 int act;
218 const char *device_name = NULL;
219 const char *cal_start_time = NULL;
220 const char *cal_granularity = NULL;
221 char *cal_free_busy_base64 = NULL;
222 struct sipe_buddy *sbuddy;
223 const sipe_xml *node;
224 sipe_xml *xn_presentity;
225 const sipe_xml *xn_availability;
226 const sipe_xml *xn_activity;
227 const sipe_xml *xn_display_name;
228 const sipe_xml *xn_email;
229 const sipe_xml *xn_phone_number;
230 const sipe_xml *xn_userinfo;
231 const sipe_xml *xn_note;
232 const sipe_xml *xn_oof;
233 const sipe_xml *xn_state;
234 const sipe_xml *xn_contact;
235 char *note;
236 int user_avail;
237 const char *user_avail_nil;
238 int res_avail;
239 time_t user_avail_since = 0;
240 time_t activity_since = 0;
241
242 /* fix for Reuters environment on Linux */
243 if (data && strstr(data, "encoding=\"utf-16\"")) {
244 char *tmp_data;
245 tmp_data = replace(data, "encoding=\"utf-16\"", "encoding=\"utf-8\"");
246 xn_presentity = sipe_xml_parse(tmp_data, strlen(tmp_data));
247 g_free(tmp_data);
248 } else {
249 xn_presentity = sipe_xml_parse(data, len);
250 }
251
252 xn_availability = sipe_xml_child(xn_presentity, "availability");
253 xn_activity = sipe_xml_child(xn_presentity, "activity");
254 xn_display_name = sipe_xml_child(xn_presentity, "displayName");
255 xn_email = sipe_xml_child(xn_presentity, "email");
256 xn_phone_number = sipe_xml_child(xn_presentity, "phoneNumber");
257 xn_userinfo = sipe_xml_child(xn_presentity, "userInfo");
258 xn_oof = xn_userinfo ? sipe_xml_child(xn_userinfo, "oof") : NULL;
259 xn_state = xn_userinfo ? sipe_xml_child(xn_userinfo, "states/state"): NULL;
260 user_avail = xn_state ? sipe_xml_int_attribute(xn_state, "avail", 0) : 0;
261 user_avail_since = xn_state ? sipe_utils_str_to_time(sipe_xml_attribute(xn_state, "since")) : 0;
262 user_avail_nil = xn_state ? sipe_xml_attribute(xn_state, "nil") : NULL;
263 xn_contact = xn_userinfo ? sipe_xml_child(xn_userinfo, "contact") : NULL;
264 xn_note = xn_userinfo ? sipe_xml_child(xn_userinfo, "note") : NULL;
265 note = xn_note ? sipe_xml_data(xn_note) : NULL;
266
267 if (sipe_strequal(user_avail_nil, "true")) { /* null-ed */
268 user_avail = 0;
269 user_avail_since = 0;
270 }
271
272 name = sipe_xml_attribute(xn_presentity, "uri"); /* without 'sip:' prefix */
273 uri = sip_uri_from_name(name);
274 avl = sipe_xml_int_attribute(xn_availability, "aggregate", 0);
275 epid = sipe_xml_attribute(xn_availability, "epid");
276 act = sipe_xml_int_attribute(xn_activity, "aggregate", 0);
277
278 status_id = sipe_ocs2005_status_from_activity_availability(act, avl);
279 activity = g_strdup(sipe_ocs2005_activity_description(act));
280 res_avail = sipe_ocs2007_availability_from_status(status_id, NULL);
281 if (user_avail > res_avail) {
282 res_avail = user_avail;
283 status_id = sipe_ocs2007_status_from_legacy_availability(user_avail);
284 }
285
286 if (xn_display_name) {
287 char *display_name = g_strdup(sipe_xml_attribute(xn_display_name, "displayName"));
288 char *email = xn_email ? g_strdup(sipe_xml_attribute(xn_email, "email")) : NULL;
289 char *phone_label = xn_phone_number ? g_strdup(sipe_xml_attribute(xn_phone_number, "label")) : NULL;
290 char *phone_number = xn_phone_number ? g_strdup(sipe_xml_attribute(xn_phone_number, "number")) : NULL;
291 char *tel_uri = sip_to_tel_uri(phone_number);
292
293 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_DISPLAY_NAME, display_name);
294 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_EMAIL, email);
295 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_WORK_PHONE, tel_uri);
296 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_WORK_PHONE_DISPLAY, !is_empty(phone_label) ? phone_label : phone_number);
297
298 g_free(tel_uri);
299 g_free(phone_label);
300 g_free(phone_number);
301 g_free(email);
302 g_free(display_name);
303 }
304
305 if (xn_contact) {
306 /* tel */
307 for (node = sipe_xml_child(xn_contact, "tel"); node; node = sipe_xml_twin(node))
308 {
309 /* Ex.: <tel type="work">tel:+3222220000</tel> */
310 const char *phone_type = sipe_xml_attribute(node, "type");
311 char* phone = sipe_xml_data(node);
312
313 sipe_update_user_phone(sipe_private, uri, phone_type, phone, NULL);
314
315 g_free(phone);
316 }
317 }
318
319 /* devicePresence */
320 for (node = sipe_xml_child(xn_presentity, "devices/devicePresence"); node; node = sipe_xml_twin(node)) {
321 const sipe_xml *xn_device_name;
322 const sipe_xml *xn_calendar_info;
323 const sipe_xml *xn_state;
324 char *state;
325
326 /* deviceName */
327 if (sipe_strequal(sipe_xml_attribute(node, "epid"), epid)) {
328 xn_device_name = sipe_xml_child(node, "deviceName");
329 device_name = xn_device_name ? sipe_xml_attribute(xn_device_name, "name") : NULL;
330 }
331
332 /* calendarInfo */
333 xn_calendar_info = sipe_xml_child(node, "calendarInfo");
334 if (xn_calendar_info) {
335 const char *cal_start_time_tmp = sipe_xml_attribute(xn_calendar_info, "startTime");
336
337 if (cal_start_time) {
338 time_t cal_start_time_t = sipe_utils_str_to_time(cal_start_time);
339 time_t cal_start_time_t_tmp = sipe_utils_str_to_time(cal_start_time_tmp);
340
341 if (cal_start_time_t_tmp > cal_start_time_t) {
342 cal_start_time = cal_start_time_tmp;
343 cal_granularity = sipe_xml_attribute(xn_calendar_info, "granularity");
344 g_free(cal_free_busy_base64);
345 cal_free_busy_base64 = sipe_xml_data(xn_calendar_info);
346
347 SIPE_DEBUG_INFO("process_incoming_notify_msrtc: startTime=%s granularity=%s cal_free_busy_base64=\n%s", cal_start_time, cal_granularity, cal_free_busy_base64);
348 }
349 } else {
350 cal_start_time = cal_start_time_tmp;
351 cal_granularity = sipe_xml_attribute(xn_calendar_info, "granularity");
352 g_free(cal_free_busy_base64);
353 cal_free_busy_base64 = sipe_xml_data(xn_calendar_info);
354
355 SIPE_DEBUG_INFO("process_incoming_notify_msrtc: startTime=%s granularity=%s cal_free_busy_base64=\n%s", cal_start_time, cal_granularity, cal_free_busy_base64);
356 }
357 }
358
359 /* state */
360 xn_state = sipe_xml_child(node, "states/state");
361 if (xn_state) {
362 int dev_avail = sipe_xml_int_attribute(xn_state, "avail", 0);
363 time_t dev_avail_since = sipe_utils_str_to_time(sipe_xml_attribute(xn_state, "since"));
364
365 state = sipe_xml_data(xn_state);
366 if (dev_avail_since > user_avail_since &&
367 dev_avail >= res_avail)
368 {
369 const gchar *new_desc;
370 res_avail = dev_avail;
371 if (!is_empty(state)) {
372 if (sipe_strequal(state, sipe_backend_activity_to_token(SIPE_ACTIVITY_ON_PHONE))) {
373 g_free(activity);
374 activity = g_strdup(sipe_core_activity_description(SIPE_ACTIVITY_ON_PHONE));
375 } else if (sipe_strequal(state, "presenting")) {
376 g_free(activity);
377 activity = g_strdup(sipe_core_activity_description(SIPE_ACTIVITY_IN_CONF));
378 } else {
379 activity = state;
380 state = NULL;
381 }
382 activity_since = dev_avail_since;
383 }
384 status_id = sipe_ocs2007_status_from_legacy_availability(res_avail);
385 new_desc = sipe_ocs2007_legacy_activity_description(res_avail);
386 if (new_desc) {
387 g_free(activity);
388 activity = g_strdup(new_desc);
389 }
390 }
391 g_free(state);
392 }
393 }
394
395 /* oof */
396 if (xn_oof && res_avail >= 15000) { /* 12000 in 2007 */
397 g_free(activity);
398 activity = g_strdup(sipe_core_activity_description(SIPE_ACTIVITY_OOF));
399 activity_since = 0;
400 }
401
402 sbuddy = g_hash_table_lookup(sipe_private->buddies, uri);
403 if (sbuddy)
404 {
405 g_free(sbuddy->activity);
406 sbuddy->activity = activity;
407 activity = NULL;
408
409 sbuddy->activity_since = activity_since;
410
411 sbuddy->user_avail = user_avail;
412 sbuddy->user_avail_since = user_avail_since;
413
414 g_free(sbuddy->note);
415 sbuddy->note = NULL;
416 if (!is_empty(note)) { sbuddy->note = g_markup_escape_text(note, -1); }
417
418 sbuddy->is_oof_note = (xn_oof != NULL);
419
420 g_free(sbuddy->device_name);
421 sbuddy->device_name = NULL;
422 if (!is_empty(device_name)) { sbuddy->device_name = g_strdup(device_name); }
423
424 if (!is_empty(cal_free_busy_base64)) {
425 g_free(sbuddy->cal_start_time);
426 sbuddy->cal_start_time = g_strdup(cal_start_time);
427
428 sbuddy->cal_granularity = sipe_strcase_equal(cal_granularity, "PT15M") ? 15 : 0;
429
430 g_free(sbuddy->cal_free_busy_base64);
431 sbuddy->cal_free_busy_base64 = cal_free_busy_base64;
432 cal_free_busy_base64 = NULL;
433
434 g_free(sbuddy->cal_free_busy);
435 sbuddy->cal_free_busy = NULL;
436 }
437
438 sbuddy->last_non_cal_status_id = status_id;
439 g_free(sbuddy->last_non_cal_activity);
440 sbuddy->last_non_cal_activity = g_strdup(sbuddy->activity);
441
442 if (sipe_strcase_equal(sbuddy->name, self_uri)) {
443 if (!sipe_strequal(sbuddy->note, sip->note)) /* not same */
444 {
445 if (sbuddy->is_oof_note)
446 SIPE_CORE_PRIVATE_FLAG_SET(OOF_NOTE);
447 else
448 SIPE_CORE_PRIVATE_FLAG_UNSET(OOF_NOTE);
449
450 g_free(sip->note);
451 sip->note = g_strdup(sbuddy->note);
452
453 sip->note_since = time(NULL);
454 }
455
456 sipe_status_set_token(sipe_private,
457 sbuddy->last_non_cal_status_id);
458 }
459 }
460 g_free(cal_free_busy_base64);
461 g_free(activity);
462
463 SIPE_DEBUG_INFO("process_incoming_notify_msrtc: status(%s)", status_id);
464 sipe_core_buddy_got_status(SIPE_CORE_PUBLIC, uri, status_id);
465
466 if (!SIPE_CORE_PRIVATE_FLAG_IS(OCS2007) && sipe_strcase_equal(self_uri, uri)) {
467 sipe_ocs2005_user_info_has_updated(sipe_private, xn_userinfo);
468 }
469
470 g_free(note);
471 sipe_xml_free(xn_presentity);
472 g_free(uri);
473 g_free(self_uri);
474 }
475
476 static void process_incoming_notify_rlmi(struct sipe_core_private *sipe_private,
477 const gchar *data,
478 unsigned len)
479 {
480 const char *uri;
481 sipe_xml *xn_categories;
482 const sipe_xml *xn_category;
483 const char *status = NULL;
484 gboolean do_update_status = FALSE;
485 gboolean has_note_cleaned = FALSE;
486 gboolean has_free_busy_cleaned = FALSE;
487
488 xn_categories = sipe_xml_parse(data, len);
489 uri = sipe_xml_attribute(xn_categories, "uri"); /* with 'sip:' prefix */
490
491 for (xn_category = sipe_xml_child(xn_categories, "category");
492 xn_category ;
493 xn_category = sipe_xml_twin(xn_category) )
494 {
495 const sipe_xml *xn_node;
496 const char *tmp;
497 const char *attrVar = sipe_xml_attribute(xn_category, "name");
498 time_t publish_time = (tmp = sipe_xml_attribute(xn_category, "publishTime")) ?
499 sipe_utils_str_to_time(tmp) : 0;
500
501 /* contactCard */
502 if (sipe_strequal(attrVar, "contactCard"))
503 {
504 const sipe_xml *card = sipe_xml_child(xn_category, "contactCard");
505
506 if (card) {
507 const sipe_xml *node;
508 /* identity - Display Name and email */
509 node = sipe_xml_child(card, "identity");
510 if (node) {
511 char* display_name = sipe_xml_data(
512 sipe_xml_child(node, "name/displayName"));
513 char* email = sipe_xml_data(
514 sipe_xml_child(node, "email"));
515
516 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_DISPLAY_NAME, display_name);
517 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_EMAIL, email);
518
519 g_free(display_name);
520 g_free(email);
521 }
522 /* company */
523 node = sipe_xml_child(card, "company");
524 if (node) {
525 char* company = sipe_xml_data(node);
526 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_COMPANY, company);
527 g_free(company);
528 }
529 /* department */
530 node = sipe_xml_child(card, "department");
531 if (node) {
532 char* department = sipe_xml_data(node);
533 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_DEPARTMENT, department);
534 g_free(department);
535 }
536 /* title */
537 node = sipe_xml_child(card, "title");
538 if (node) {
539 char* title = sipe_xml_data(node);
540 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_JOB_TITLE, title);
541 g_free(title);
542 }
543 /* office */
544 node = sipe_xml_child(card, "office");
545 if (node) {
546 char* office = sipe_xml_data(node);
547 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_OFFICE, office);
548 g_free(office);
549 }
550 /* site (url) */
551 node = sipe_xml_child(card, "url");
552 if (node) {
553 char* site = sipe_xml_data(node);
554 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_SITE, site);
555 g_free(site);
556 }
557 /* phone */
558 for (node = sipe_xml_child(card, "phone");
559 node;
560 node = sipe_xml_twin(node))
561 {
562 const char *phone_type = sipe_xml_attribute(node, "type");
563 char* phone = sipe_xml_data(sipe_xml_child(node, "uri"));
564 char* phone_display_string = sipe_xml_data(sipe_xml_child(node, "displayString"));
565
566 sipe_update_user_phone(sipe_private, uri, phone_type, phone, phone_display_string);
567
568 g_free(phone);
569 g_free(phone_display_string);
570 }
571 /* address */
572 for (node = sipe_xml_child(card, "address");
573 node;
574 node = sipe_xml_twin(node))
575 {
576 if (sipe_strequal(sipe_xml_attribute(node, "type"), "work")) {
577 char* street = sipe_xml_data(sipe_xml_child(node, "street"));
578 char* city = sipe_xml_data(sipe_xml_child(node, "city"));
579 char* state = sipe_xml_data(sipe_xml_child(node, "state"));
580 char* zipcode = sipe_xml_data(sipe_xml_child(node, "zipcode"));
581 char* country_code = sipe_xml_data(sipe_xml_child(node, "countryCode"));
582
583 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_STREET, street);
584 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_CITY, city);
585 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_STATE, state);
586 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_ZIPCODE, zipcode);
587 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_COUNTRY, country_code);
588
589 g_free(street);
590 g_free(city);
591 g_free(state);
592 g_free(zipcode);
593 g_free(country_code);
594
595 break;
596 }
597 }
598 }
599 }
600 /* note */
601 else if (sipe_strequal(attrVar, "note"))
602 {
603 if (uri) {
604 struct sipe_buddy *sbuddy = g_hash_table_lookup(sipe_private->buddies, uri);
605
606 if (!has_note_cleaned) {
607 has_note_cleaned = TRUE;
608
609 g_free(sbuddy->note);
610 sbuddy->note = NULL;
611 sbuddy->is_oof_note = FALSE;
612 sbuddy->note_since = publish_time;
613
614 do_update_status = TRUE;
615 }
616 if (sbuddy && (publish_time >= sbuddy->note_since)) {
617 /* clean up in case no 'note' element is supplied
618 * which indicate note removal in client
619 */
620 g_free(sbuddy->note);
621 sbuddy->note = NULL;
622 sbuddy->is_oof_note = FALSE;
623 sbuddy->note_since = publish_time;
624
625 xn_node = sipe_xml_child(xn_category, "note/body");
626 if (xn_node) {
627 char *tmp;
628 sbuddy->note = g_markup_escape_text((tmp = sipe_xml_data(xn_node)), -1);
629 g_free(tmp);
630 sbuddy->is_oof_note = sipe_strequal(sipe_xml_attribute(xn_node, "type"), "OOF");
631 sbuddy->note_since = publish_time;
632
633 SIPE_DEBUG_INFO("process_incoming_notify_rlmi: uri(%s), note(%s)",
634 uri, sbuddy->note ? sbuddy->note : "");
635 }
636 /* to trigger UI refresh in case no status info is supplied in this update */
637 do_update_status = TRUE;
638 }
639 }
640 }
641 /* state */
642 else if(sipe_strequal(attrVar, "state"))
643 {
644 char *tmp;
645 int availability;
646 const sipe_xml *xn_availability;
647 const sipe_xml *xn_activity;
648 const sipe_xml *xn_meeting_subject;
649 const sipe_xml *xn_meeting_location;
650 struct sipe_buddy *sbuddy = uri ? g_hash_table_lookup(sipe_private->buddies, uri) : NULL;
651
652 xn_node = sipe_xml_child(xn_category, "state");
653 if (!xn_node) continue;
654 xn_availability = sipe_xml_child(xn_node, "availability");
655 if (!xn_availability) continue;
656 xn_activity = sipe_xml_child(xn_node, "activity");
657 xn_meeting_subject = sipe_xml_child(xn_node, "meetingSubject");
658 xn_meeting_location = sipe_xml_child(xn_node, "meetingLocation");
659
660 tmp = sipe_xml_data(xn_availability);
661 availability = atoi(tmp);
662 g_free(tmp);
663
664 /* activity, meeting_subject, meeting_location */
665 if (sbuddy) {
666 const gchar *tmp;
667
668 /* activity */
669 g_free(sbuddy->activity);
670 sbuddy->activity = NULL;
671 if (xn_activity) {
672 const char *token = sipe_xml_attribute(xn_activity, "token");
673 const sipe_xml *xn_custom = sipe_xml_child(xn_activity, "custom");
674
675 /* from token */
676 if (!is_empty(token)) {
677 sbuddy->activity = g_strdup(sipe_core_activity_description(sipe_backend_token_to_activity(token)));
678 }
679 /* from custom element */
680 if (xn_custom) {
681 char *custom = sipe_xml_data(xn_custom);
682
683 if (!is_empty(custom)) {
684 g_free(sbuddy->activity);
685 sbuddy->activity = custom;
686 custom = NULL;
687 }
688 g_free(custom);
689 }
690 }
691 /* meeting_subject */
692 g_free(sbuddy->meeting_subject);
693 sbuddy->meeting_subject = NULL;
694 if (xn_meeting_subject) {
695 char *meeting_subject = sipe_xml_data(xn_meeting_subject);
696
697 if (!is_empty(meeting_subject)) {
698 sbuddy->meeting_subject = meeting_subject;
699 meeting_subject = NULL;
700 }
701 g_free(meeting_subject);
702 }
703 /* meeting_location */
704 g_free(sbuddy->meeting_location);
705 sbuddy->meeting_location = NULL;
706 if (xn_meeting_location) {
707 char *meeting_location = sipe_xml_data(xn_meeting_location);
708
709 if (!is_empty(meeting_location)) {
710 sbuddy->meeting_location = meeting_location;
711 meeting_location = NULL;
712 }
713 g_free(meeting_location);
714 }
715
716 status = sipe_ocs2007_status_from_legacy_availability(availability);
717 tmp = sipe_ocs2007_legacy_activity_description(availability);
718 if (sbuddy->activity && tmp) {
719 gchar *tmp2 = sbuddy->activity;
720
721 sbuddy->activity = g_strdup_printf("%s, %s", sbuddy->activity, tmp);
722 g_free(tmp2);
723 } else if (tmp) {
724 sbuddy->activity = g_strdup(tmp);
725 }
726 }
727
728 do_update_status = TRUE;
729 }
730 /* calendarData */
731 else if(sipe_strequal(attrVar, "calendarData"))
732 {
733 struct sipe_buddy *sbuddy = uri ? g_hash_table_lookup(sipe_private->buddies, uri) : NULL;
734 const sipe_xml *xn_free_busy = sipe_xml_child(xn_category, "calendarData/freeBusy");
735 const sipe_xml *xn_working_hours = sipe_xml_child(xn_category, "calendarData/WorkingHours");
736
737 if (sbuddy && xn_free_busy) {
738 if (!has_free_busy_cleaned) {
739 has_free_busy_cleaned = TRUE;
740
741 g_free(sbuddy->cal_start_time);
742 sbuddy->cal_start_time = NULL;
743
744 g_free(sbuddy->cal_free_busy_base64);
745 sbuddy->cal_free_busy_base64 = NULL;
746
747 g_free(sbuddy->cal_free_busy);
748 sbuddy->cal_free_busy = NULL;
749
750 sbuddy->cal_free_busy_published = publish_time;
751 }
752
753 if (publish_time >= sbuddy->cal_free_busy_published) {
754 g_free(sbuddy->cal_start_time);
755 sbuddy->cal_start_time = g_strdup(sipe_xml_attribute(xn_free_busy, "startTime"));
756
757 sbuddy->cal_granularity = sipe_strcase_equal(sipe_xml_attribute(xn_free_busy, "granularity"), "PT15M") ?
758 15 : 0;
759
760 g_free(sbuddy->cal_free_busy_base64);
761 sbuddy->cal_free_busy_base64 = sipe_xml_data(xn_free_busy);
762
763 g_free(sbuddy->cal_free_busy);
764 sbuddy->cal_free_busy = NULL;
765
766 sbuddy->cal_free_busy_published = publish_time;
767
768 SIPE_DEBUG_INFO("process_incoming_notify_rlmi: startTime=%s granularity=%d cal_free_busy_base64=\n%s", sbuddy->cal_start_time, sbuddy->cal_granularity, sbuddy->cal_free_busy_base64);
769 }
770 }
771
772 if (sbuddy && xn_working_hours) {
773 sipe_cal_parse_working_hours(xn_working_hours, sbuddy);
774 }
775 }
776 }
777
778 if (do_update_status) {
779 if (!status) {
780 /* no status category in this update,
781 using contact's current status */
782 status = sipe_backend_buddy_get_status(SIPE_CORE_PUBLIC,
783 uri);
784 }
785
786 SIPE_DEBUG_INFO("process_incoming_notify_rlmi: %s", status);
787 sipe_core_buddy_got_status(SIPE_CORE_PUBLIC, uri, status);
788 }
789
790 sipe_xml_free(xn_categories);
791 }
792
793 static void sipe_buddy_status_from_activity(struct sipe_core_private *sipe_private,
794 const gchar *uri,
795 const gchar *activity,
796 gboolean is_online)
797 {
798 if (is_online) {
799 const gchar *status_id = NULL;
800 if (activity) {
801 if (sipe_strequal(activity,
802 sipe_backend_activity_to_token(SIPE_ACTIVITY_BUSY))) {
803 status_id = sipe_backend_activity_to_token(SIPE_ACTIVITY_BUSY);
804 } else if (sipe_strequal(activity,
805 sipe_backend_activity_to_token(SIPE_ACTIVITY_AWAY))) {
806 status_id = sipe_backend_activity_to_token(SIPE_ACTIVITY_AWAY);
807 }
808 }
809
810 if (!status_id) {
811 status_id = sipe_backend_activity_to_token(SIPE_ACTIVITY_AVAILABLE);
812 }
813
814 SIPE_DEBUG_INFO("sipe_buddy_status_from_activity: status_id(%s)", status_id);
815 sipe_core_buddy_got_status(SIPE_CORE_PUBLIC, uri, status_id);
816 } else {
817 sipe_core_buddy_got_status(SIPE_CORE_PUBLIC, uri,
818 sipe_backend_activity_to_token(SIPE_ACTIVITY_OFFLINE));
819 }
820 }
821
822 static void process_incoming_notify_pidf(struct sipe_core_private *sipe_private,
823 const gchar *data,
824 unsigned len)
825 {
826 gchar *uri;
827 gchar *getbasic;
828 gchar *activity = NULL;
829 sipe_xml *pidf;
830 const sipe_xml *basicstatus = NULL, *tuple, *status;
831 gboolean isonline = FALSE;
832 const sipe_xml *display_name_node;
833
834 pidf = sipe_xml_parse(data, len);
835 if (!pidf) {
836 SIPE_DEBUG_INFO("process_incoming_notify_pidf: no parseable pidf:%s", data);
837 return;
838 }
839
840 if ((tuple = sipe_xml_child(pidf, "tuple")))
841 {
842 if ((status = sipe_xml_child(tuple, "status"))) {
843 basicstatus = sipe_xml_child(status, "basic");
844 }
845 }
846
847 if (!basicstatus) {
848 SIPE_DEBUG_INFO_NOFORMAT("process_incoming_notify_pidf: no basic found");
849 sipe_xml_free(pidf);
850 return;
851 }
852
853 getbasic = sipe_xml_data(basicstatus);
854 if (!getbasic) {
855 SIPE_DEBUG_INFO_NOFORMAT("process_incoming_notify_pidf: no basic data found");
856 sipe_xml_free(pidf);
857 return;
858 }
859
860 SIPE_DEBUG_INFO("process_incoming_notify_pidf: basic-status(%s)", getbasic);
861 if (strstr(getbasic, "open")) {
862 isonline = TRUE;
863 }
864 g_free(getbasic);
865
866 uri = sip_uri(sipe_xml_attribute(pidf, "entity")); /* with 'sip:' prefix */ /* AOL comes without the prefix */
867
868 display_name_node = sipe_xml_child(pidf, "display-name");
869 if (display_name_node) {
870 char * display_name = sipe_xml_data(display_name_node);
871
872 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_DISPLAY_NAME, display_name);
873 g_free(display_name);
874 }
875
876 if ((tuple = sipe_xml_child(pidf, "tuple"))) {
877 if ((status = sipe_xml_child(tuple, "status"))) {
878 if ((basicstatus = sipe_xml_child(status, "activities"))) {
879 if ((basicstatus = sipe_xml_child(basicstatus, "activity"))) {
880 activity = sipe_xml_data(basicstatus);
881 SIPE_DEBUG_INFO("process_incoming_notify_pidf: activity(%s)", activity);
882 }
883 }
884 }
885 }
886
887 sipe_buddy_status_from_activity(sipe_private,
888 uri,
889 activity,
890 isonline);
891
892 g_free(activity);
893 g_free(uri);
894 sipe_xml_free(pidf);
895 }
896
897 static void sipe_presence_mime_cb(gpointer user_data, /* sipe_core_private */
898 const GSList *fields,
899 const gchar *body,
900 gsize length)
901 {
902 const gchar *type = sipe_utils_nameval_find(fields, "Content-Type");
903
904 if (strstr(type,"application/rlmi+xml")) {
905 process_incoming_notify_rlmi_resub(user_data, body, length);
906 } else if (strstr(type, "text/xml+msrtc.pidf")) {
907 process_incoming_notify_msrtc(user_data, body, length);
908 } else {
909 process_incoming_notify_rlmi(user_data, body, length);
910 }
911 }
912
913 static void sipe_process_presence(struct sipe_core_private *sipe_private,
914 struct sipmsg *msg)
915 {
916 const char *ctype = sipmsg_find_header(msg, "Content-Type");
917
918 SIPE_DEBUG_INFO("sipe_process_presence: Content-Type: %s", ctype ? ctype : "");
919
920 if (ctype &&
921 (strstr(ctype, "application/rlmi+xml") ||
922 strstr(ctype, "application/msrtc-event-categories+xml")))
923 {
924 if (strstr(ctype, "multipart"))
925 {
926 sipe_mime_parts_foreach(ctype, msg->body, sipe_presence_mime_cb, sipe_private);
927 }
928 else if(strstr(ctype, "application/msrtc-event-categories+xml") )
929 {
930 process_incoming_notify_rlmi(sipe_private, msg->body, msg->bodylen);
931 }
932 else if(strstr(ctype, "application/rlmi+xml"))
933 {
934 process_incoming_notify_rlmi_resub(sipe_private, msg->body, msg->bodylen);
935 }
936 }
937 else if(ctype && strstr(ctype, "text/xml+msrtc.pidf"))
938 {
939 process_incoming_notify_msrtc(sipe_private, msg->body, msg->bodylen);
940 }
941 else
942 {
943 process_incoming_notify_pidf(sipe_private, msg->body, msg->bodylen);
944 }
945 }
946
947 /**
948 * Fires on deregistration event initiated by server.
949 * [MS-SIPREGE] SIP extension.
950 *
951 * OCS2007 Example
952 *
953 * Content-Type: text/registration-event
954 * subscription-state: terminated;expires=0
955 * ms-diagnostics-public: 4141;reason="User disabled"
956 *
957 * deregistered;event=rejected
958 */
959 static void sipe_process_registration_notify(struct sipe_core_private *sipe_private,
960 struct sipmsg *msg)
961 {
962 const gchar *contenttype = sipmsg_find_header(msg, "Content-Type");
963 gchar *event = NULL;
964 gchar *reason = NULL;
965 gchar *warning;
966
967 SIPE_DEBUG_INFO_NOFORMAT("sipe_process_registration_notify: deregistration received.");
968
969 if (!g_ascii_strncasecmp(contenttype, "text/registration-event", 23)) {
970 event = sipmsg_find_part_of_header(msg->body, "event=", NULL, NULL);
971 //@TODO have proper parameter extraction _by_name_ func, case insesitive.
972 event = event ? event : sipmsg_find_part_of_header(msg->body, "event=", ";", NULL);
973 } else {
974 SIPE_DEBUG_INFO_NOFORMAT("sipe_process_registration_notify: unknown content type, exiting.");
975 return;
976 }
977
978 reason = sipmsg_get_ms_diagnostics_reason(msg);
979 reason = reason ? reason : sipmsg_get_ms_diagnostics_public_reason(msg);
980 if (!reason) { // for LCS2005
981 if (event && sipe_strcase_equal(event, "unregistered")) {
982 //reason = g_strdup(_("User logged out")); // [MS-OCER]
983 reason = g_strdup(_("you are already signed in at another location"));
984 } else if (event && sipe_strcase_equal(event, "rejected")) {
985 reason = g_strdup(_("user disabled")); // [MS-OCER]
986 } else if (event && sipe_strcase_equal(event, "deactivated")) {
987 reason = g_strdup(_("user moved")); // [MS-OCER]
988 }
989 }
990 g_free(event);
991 warning = g_strdup_printf(_("You have been rejected by the server: %s"), reason ? reason : _("no reason given"));
992 g_free(reason);
993
994 sipe_backend_connection_error(SIPE_CORE_PUBLIC,
995 SIPE_CONNECTION_ERROR_INVALID_USERNAME,
996 warning);
997 g_free(warning);
998
999 }
1000
1001 /**
1002 * Removes entries from local buddy list
1003 * that does not correspond ones in the roaming contact list.
1004 */
1005 static void sipe_cleanup_local_blist(struct sipe_core_private *sipe_private)
1006 {
1007 GSList *buddies = sipe_backend_buddy_find_all(SIPE_CORE_PUBLIC,
1008 NULL, NULL);
1009 GSList *entry = buddies;
1010 struct sipe_buddy *buddy;
1011 sipe_backend_buddy b;
1012 gchar *bname;
1013 gchar *gname;
1014
1015 SIPE_DEBUG_INFO("sipe_cleanup_local_blist: overall %d backend buddies (including clones)", g_slist_length(buddies));
1016 SIPE_DEBUG_INFO("sipe_cleanup_local_blist: %d sipe buddies (unique)", g_hash_table_size(sipe_private->buddies));
1017 while (entry) {
1018 b = entry->data;
1019 gname = sipe_backend_buddy_get_group_name(SIPE_CORE_PUBLIC, b);
1020 bname = sipe_backend_buddy_get_name(SIPE_CORE_PUBLIC, b);
1021 buddy = g_hash_table_lookup(sipe_private->buddies, bname);
1022 if(buddy) {
1023 gboolean in_sipe_groups = FALSE;
1024 GSList *entry2 = buddy->groups;
1025 while (entry2) {
1026 struct sipe_group *group = entry2->data;
1027 if (sipe_strequal(group->name, gname)) {
1028 in_sipe_groups = TRUE;
1029 break;
1030 }
1031 entry2 = entry2->next;
1032 }
1033 if(!in_sipe_groups) {
1034 SIPE_DEBUG_INFO("*** REMOVING %s from blist group: %s as not having this group in roaming list", bname, gname);
1035 sipe_backend_buddy_remove(SIPE_CORE_PUBLIC, b);
1036 }
1037 } else {
1038 SIPE_DEBUG_INFO("*** REMOVING %s from blist group: %s as this buddy not in roaming list", bname, gname);
1039 sipe_backend_buddy_remove(SIPE_CORE_PUBLIC, b);
1040 }
1041 g_free(bname);
1042 g_free(gname);
1043 entry = entry->next;
1044 }
1045 g_slist_free(buddies);
1046 }
1047
1048 /**
1049 * A callback for g_hash_table_foreach
1050 */
1051 static void sipe_buddy_subscribe_cb(char *buddy_name,
1052 SIPE_UNUSED_PARAMETER struct sipe_buddy *buddy,
1053 struct sipe_core_private *sipe_private)
1054 {
1055 gchar *action_name = sipe_utils_presence_key(buddy_name);
1056 /* g_hash_table_size() can never return 0, otherwise this function wouldn't be called :-) */
1057 guint time_range = (g_hash_table_size(sipe_private->buddies) * 1000) / 25; /* time interval for 25 requests per sec. In msec. */
1058 guint timeout = ((guint) rand()) / (RAND_MAX / time_range) + 1; /* random period within the range but never 0! */
1059
1060 sipe_schedule_mseconds(sipe_private,
1061 action_name,
1062 g_strdup(buddy_name),
1063 timeout,
1064 sipe_subscribe_presence_single,
1065 g_free);
1066 g_free(action_name);
1067 }
1068
1069 static gboolean sipe_process_roaming_contacts(struct sipe_core_private *sipe_private,
1070 struct sipmsg *msg)
1071 {
1072 struct sipe_account_data *sip = SIPE_ACCOUNT_DATA_PRIVATE;
1073 int len = msg->bodylen;
1074
1075 const gchar *tmp = sipmsg_find_header(msg, "Event");
1076 const sipe_xml *item;
1077 sipe_xml *isc;
1078 guint delta;
1079 const sipe_xml *group_node;
1080 if (!g_str_has_prefix(tmp, "vnd-microsoft-roaming-contacts")) {
1081 return FALSE;
1082 }
1083
1084 /* Convert the contact from XML to backend Buddies */
1085 isc = sipe_xml_parse(msg->body, len);
1086 if (!isc) {
1087 return FALSE;
1088 }
1089
1090 /* [MS-SIP]: deltaNum MUST be non-zero */
1091 delta = sipe_xml_int_attribute(isc, "deltaNum", 0);
1092 if (delta) {
1093 sipe_private->deltanum_contacts = delta;
1094 }
1095
1096 if (sipe_strequal(sipe_xml_name(isc), "contactList")) {
1097
1098 /* Parse groups */
1099 for (group_node = sipe_xml_child(isc, "group"); group_node; group_node = sipe_xml_twin(group_node)) {
1100 struct sipe_group * group = g_new0(struct sipe_group, 1);
1101 const char *name = sipe_xml_attribute(group_node, "name");
1102
1103 if (g_str_has_prefix(name, "~")) {
1104 name = _("Other Contacts");
1105 }
1106 group->name = g_strdup(name);
1107 group->id = (int)g_ascii_strtod(sipe_xml_attribute(group_node, "id"), NULL);
1108
1109 sipe_group_add(sipe_private, group);
1110 }
1111
1112 // Make sure we have at least one group
1113 if (g_slist_length(sipe_private->groups) == 0) {
1114 sipe_group_create(sipe_private, _("Other Contacts"), NULL);
1115 }
1116
1117 /* Parse contacts */
1118 for (item = sipe_xml_child(isc, "contact"); item; item = sipe_xml_twin(item)) {
1119 const gchar *uri = sipe_xml_attribute(item, "uri");
1120 const gchar *name = sipe_xml_attribute(item, "name");
1121 gchar *buddy_name;
1122 struct sipe_buddy *buddy = NULL;
1123 gchar *tmp;
1124 gchar **item_groups;
1125 int i = 0;
1126
1127 /* Buddy name must be lower case as we use purple_normalize_nocase() to compare */
1128 tmp = sip_uri_from_name(uri);
1129 buddy_name = g_ascii_strdown(tmp, -1);
1130 g_free(tmp);
1131
1132 /* assign to group Other Contacts if nothing else received */
1133 tmp = g_strdup(sipe_xml_attribute(item, "groups"));
1134 if(is_empty(tmp)) {
1135 struct sipe_group *group = sipe_group_find_by_name(sipe_private, _("Other Contacts"));
1136 g_free(tmp);
1137 tmp = group ? g_strdup_printf("%d", group->id) : g_strdup("1");
1138 }
1139 item_groups = g_strsplit(tmp, " ", 0);
1140 g_free(tmp);
1141
1142 while (item_groups[i]) {
1143 struct sipe_group *group = sipe_group_find_by_id(sipe_private, g_ascii_strtod(item_groups[i], NULL));
1144
1145 // If couldn't find the right group for this contact, just put them in the first group we have
1146 if (group == NULL && g_slist_length(sipe_private->groups) > 0) {
1147 group = sipe_private->groups->data;
1148 }
1149
1150 if (group != NULL) {
1151 gchar *b_alias;
1152 sipe_backend_buddy b = sipe_backend_buddy_find(SIPE_CORE_PUBLIC, buddy_name, group->name);
1153 if (!b){
1154 b = sipe_backend_buddy_add(SIPE_CORE_PUBLIC, buddy_name, uri, group->name);
1155 SIPE_DEBUG_INFO("Created new buddy %s with alias %s", buddy_name, uri);
1156 }
1157
1158 b_alias = sipe_backend_buddy_get_alias(SIPE_CORE_PUBLIC, b);
1159 if (sipe_strcase_equal(uri, b_alias)) {
1160 if (name != NULL && strlen(name) != 0) {
1161 sipe_backend_buddy_set_alias(SIPE_CORE_PUBLIC, b, name);
1162
1163 SIPE_DEBUG_INFO("Replaced buddy %s alias with %s", buddy_name, name);
1164 }
1165 }
1166 g_free(b_alias);
1167
1168 if (!buddy) {
1169 buddy = g_new0(struct sipe_buddy, 1);
1170 buddy->name = sipe_backend_buddy_get_name(SIPE_CORE_PUBLIC, b);
1171 g_hash_table_insert(sipe_private->buddies, buddy->name, buddy);
1172
1173 SIPE_DEBUG_INFO("Added SIPE buddy %s", buddy->name);
1174 }
1175
1176 buddy->groups = slist_insert_unique_sorted(buddy->groups, group, (GCompareFunc)sipe_group_compare);
1177
1178 SIPE_DEBUG_INFO("Added buddy %s to group %s", buddy->name, group->name);
1179 } else {
1180 SIPE_DEBUG_INFO("No group found for contact %s! Unable to add to buddy list",
1181 name);
1182 }
1183
1184 i++;
1185 } // while, contact groups
1186 g_strfreev(item_groups);
1187 g_free(buddy_name);
1188
1189 } // for, contacts
1190
1191 sipe_cleanup_local_blist(sipe_private);
1192
1193 /* Add self-contact if not there yet. 2005 systems. */
1194 /* This will resemble subscription to roaming_self in 2007 systems */
1195 if (!SIPE_CORE_PRIVATE_FLAG_IS(OCS2007)) {
1196 gchar *self_uri = sip_uri_self(sipe_private);
1197 struct sipe_buddy *buddy = g_hash_table_lookup(sipe_private->buddies, self_uri);
1198
1199 if (!buddy) {
1200 buddy = g_new0(struct sipe_buddy, 1);
1201 buddy->name = g_strdup(self_uri);
1202 g_hash_table_insert(sipe_private->buddies, buddy->name, buddy);
1203 }
1204 g_free(self_uri);
1205 }
1206 }
1207 sipe_xml_free(isc);
1208
1209 /* subscribe to buddies */
1210 if (!sip->subscribed_buddies) { //do it once, then count Expire field to schedule resubscribe.
1211 if (SIPE_CORE_PRIVATE_FLAG_IS(BATCHED_SUPPORT)) {
1212 sipe_subscribe_presence_batched(sipe_private);
1213 } else {
1214 g_hash_table_foreach(sipe_private->buddies,
1215 (GHFunc)sipe_buddy_subscribe_cb,
1216 sipe_private);
1217 }
1218 sip->subscribed_buddies = TRUE;
1219 }
1220 /* for 2005 systems schedule contacts' status update
1221 * based on their calendar information
1222 */
1223 if (!SIPE_CORE_PRIVATE_FLAG_IS(OCS2007)) {
1224 sipe_ocs2005_schedule_status_update(sipe_private, time(NULL));
1225 }
1226
1227 return 0;
1228 }
1229
1230 static void sipe_process_roaming_acl(struct sipe_core_private *sipe_private,
1231 struct sipmsg *msg)
1232 {
1233 guint delta;
1234 sipe_xml *xml;
1235
1236 xml = sipe_xml_parse(msg->body, msg->bodylen);
1237 if (!xml)
1238 return;
1239
1240 /* [MS-SIP]: deltaNum MUST be non-zero */
1241 delta = sipe_xml_int_attribute(xml, "deltaNum", 0);
1242 if (delta) {
1243 sipe_private->deltanum_acl = delta;
1244 }
1245
1246 sipe_xml_free(xml);
1247 }
1248
1249 struct sipe_auth_job {
1250 gchar *who;
1251 struct sipe_core_private *sipe_private;
1252 };
1253
1254 void sipe_core_contact_allow_deny(struct sipe_core_public *sipe_public,
1255 const gchar* who,
1256 gboolean allow)
1257 {
1258 struct sipe_core_private *sipe_private = SIPE_CORE_PRIVATE;
1259
1260 if (allow) {
1261 SIPE_DEBUG_INFO("sipe_core_contact_allow_deny: authorizing contact %s", who);
1262 } else {
1263 SIPE_DEBUG_INFO("sipe_core_contact_allow_deny: blocking contact %s", who);
1264 }
1265
1266 if (SIPE_CORE_PRIVATE_FLAG_IS(OCS2007)) {
1267 sipe_ocs2007_change_access_level(sipe_private,
1268 (allow ? -1 : 32000),
1269 "user",
1270 sipe_get_no_sip_uri(who));
1271 } else {
1272 sip_soap_ocs2005_setacl(sipe_private, who, allow);
1273 }
1274 }
1275
1276
1277 static void sipe_auth_user_cb(gpointer data)
1278 {
1279 struct sipe_auth_job *job = (struct sipe_auth_job *) data;
1280 if (!job) return;
1281
1282 sipe_core_contact_allow_deny((struct sipe_core_public *)job->sipe_private,
1283 job->who,
1284 TRUE);
1285 g_free(job);
1286 }
1287
1288 static void sipe_deny_user_cb(gpointer data)
1289 {
1290 struct sipe_auth_job *job = (struct sipe_auth_job *) data;
1291 if (!job) return;
1292
1293 sipe_core_contact_allow_deny((struct sipe_core_public *)job->sipe_private,
1294 job->who,
1295 FALSE);
1296 g_free(job);
1297 }
1298
1299 /* OCS2005- */
1300 static void sipe_process_presence_wpending (struct sipe_core_private *sipe_private,
1301 struct sipmsg * msg)
1302 {
1303 sipe_xml *watchers;
1304 const sipe_xml *watcher;
1305 // Ensure it's either not a response (eg it's a BENOTIFY) or that it's a 200 OK response
1306 if (msg->response != 0 && msg->response != 200) return;
1307
1308 if (msg->bodylen == 0 || msg->body == NULL || sipe_strequal(sipmsg_find_header(msg, "Event"), "msrtc.wpending")) return;
1309
1310 watchers = sipe_xml_parse(msg->body, msg->bodylen);
1311 if (!watchers) return;
1312
1313 for (watcher = sipe_xml_child(watchers, "watcher"); watcher; watcher = sipe_xml_twin(watcher)) {
1314 gchar * remote_user = g_strdup(sipe_xml_attribute(watcher, "uri"));
1315 gchar * alias = g_strdup(sipe_xml_attribute(watcher, "displayName"));
1316 gboolean on_list = g_hash_table_lookup(sipe_private->buddies, remote_user) != NULL;
1317
1318 // TODO pull out optional displayName to pass as alias
1319 if (remote_user) {
1320 struct sipe_auth_job * job = g_new0(struct sipe_auth_job, 1);
1321 job->who = remote_user;
1322 job->sipe_private = sipe_private;
1323 sipe_backend_buddy_request_authorization(SIPE_CORE_PUBLIC,
1324 remote_user,
1325 alias,
1326 on_list,
1327 sipe_auth_user_cb,
1328 sipe_deny_user_cb,
1329 (gpointer)job);
1330 }
1331 }
1332
1333
1334 sipe_xml_free(watchers);
1335 return;
1336 }
1337
1338 static void sipe_presence_timeout_mime_cb(gpointer user_data,
1339 SIPE_UNUSED_PARAMETER const GSList *fields,
1340 const gchar *body,
1341 gsize length)
1342 {
1343 GSList **buddies = user_data;
1344 sipe_xml *xml = sipe_xml_parse(body, length);
1345
1346 if (xml && !sipe_strequal(sipe_xml_name(xml), "list")) {
1347 const gchar *uri = sipe_xml_attribute(xml, "uri");
1348 const sipe_xml *xn_category;
1349
1350 /**
1351 * automaton: presence is never expected to change
1352 *
1353 * see: http://msdn.microsoft.com/en-us/library/ee354295(office.13).aspx
1354 */
1355 for (xn_category = sipe_xml_child(xml, "category");
1356 xn_category;
1357 xn_category = sipe_xml_twin(xn_category)) {
1358 if (sipe_strequal(sipe_xml_attribute(xn_category, "name"),
1359 "contactCard")) {
1360 const sipe_xml *node = sipe_xml_child(xn_category, "contactCard/automaton");
1361 if (node) {
1362 char *boolean = sipe_xml_data(node);
1363 if (sipe_strequal(boolean, "true")) {
1364 SIPE_DEBUG_INFO("sipe_process_presence_timeout: %s is an automaton: - not subscribing to presence updates",
1365 uri);
1366 uri = NULL;
1367 }
1368 g_free(boolean);
1369 }
1370 break;
1371 }
1372 }
1373
1374 if (uri) {
1375 *buddies = g_slist_append(*buddies, sip_uri(uri));
1376 }
1377 }
1378
1379 sipe_xml_free(xml);
1380 }
1381
1382 static void sipe_process_presence_timeout(struct sipe_core_private *sipe_private,
1383 struct sipmsg *msg,
1384 const gchar *who,
1385 int timeout)
1386 {
1387 const char *ctype = sipmsg_find_header(msg, "Content-Type");
1388 gchar *action_name = sipe_utils_presence_key(who);
1389
1390 SIPE_DEBUG_INFO("sipe_process_presence_timeout: Content-Type: %s", ctype ? ctype : "");
1391
1392 if (ctype &&
1393 strstr(ctype, "multipart") &&
1394 (strstr(ctype, "application/rlmi+xml") ||
1395 strstr(ctype, "application/msrtc-event-categories+xml"))) {
1396 GSList *buddies = NULL;
1397
1398 sipe_mime_parts_foreach(ctype, msg->body, sipe_presence_timeout_mime_cb, &buddies);
1399
1400 if (buddies)
1401 sipe_subscribe_presence_batched_schedule(sipe_private,
1402 action_name,
1403 who,
1404 buddies,
1405 timeout);
1406
1407 } else {
1408 sipe_schedule_seconds(sipe_private,
1409 action_name,
1410 g_strdup(who),
1411 timeout,
1412 sipe_subscribe_presence_single,
1413 g_free);
1414 SIPE_DEBUG_INFO("Resubscription single contact with batched support(%s) in %d", who, timeout);
1415 }
1416 g_free(action_name);
1417 }
1418
1419 /**
1420 * Dispatcher for all incoming subscription information
1421 * whether it comes from NOTIFY, BENOTIFY requests or
1422 * piggy-backed to subscription's OK responce.
1423 *
1424 * @param request whether initiated from BE/NOTIFY request or OK-response message.
1425 * @param benotify whether initiated from NOTIFY or BENOTIFY request.
1426 */
1427 void process_incoming_notify(struct sipe_core_private *sipe_private,
1428 struct sipmsg *msg,
1429 gboolean request, gboolean benotify)
1430 {
1431 struct sipe_account_data *sip = SIPE_ACCOUNT_DATA_PRIVATE;
1432 const gchar *content_type = sipmsg_find_header(msg, "Content-Type");
1433 const gchar *event = sipmsg_find_header(msg, "Event");
1434 const gchar *subscription_state = sipmsg_find_header(msg, "subscription-state");
1435
1436 SIPE_DEBUG_INFO("process_incoming_notify: subscription_state: %s", subscription_state ? subscription_state : "");
1437
1438 /* implicit subscriptions */
1439 if (content_type && g_str_has_prefix(content_type, "application/ms-imdn+xml")) {
1440 sipe_process_imdn(sipe_private, msg);
1441 }
1442
1443 if (event) {
1444 /* for one off subscriptions (send with Expire: 0) */
1445 if (sipe_strcase_equal(event, "vnd-microsoft-provisioning-v2"))
1446 {
1447 sipe_process_provisioning_v2(sipe_private, msg);
1448 }
1449 else if (sipe_strcase_equal(event, "vnd-microsoft-provisioning"))
1450 {
1451 sipe_process_provisioning(sipe_private, msg);
1452 }
1453 else if (sipe_strcase_equal(event, "presence"))
1454 {
1455 sipe_process_presence(sipe_private, msg);
1456 }
1457 else if (sipe_strcase_equal(event, "registration-notify"))
1458 {
1459 sipe_process_registration_notify(sipe_private, msg);
1460 }
1461
1462 if (!subscription_state || strstr(subscription_state, "active"))
1463 {
1464 if (sipe_strcase_equal(event, "vnd-microsoft-roaming-contacts"))
1465 {
1466 sipe_process_roaming_contacts(sipe_private, msg);
1467 }
1468 else if (sipe_strcase_equal(event, "vnd-microsoft-roaming-self"))
1469 {
1470 sipe_ocs2007_process_roaming_self(sipe_private, msg);
1471 }
1472 else if (sipe_strcase_equal(event, "vnd-microsoft-roaming-ACL"))
1473 {
1474 sipe_process_roaming_acl(sipe_private, msg);
1475 }
1476 else if (sipe_strcase_equal(event, "presence.wpending"))
1477 {
1478 sipe_process_presence_wpending(sipe_private, msg);
1479 }
1480 else if (sipe_strcase_equal(event, "conference"))
1481 {
1482 sipe_process_conference(sipe_private, msg);
1483 }
1484 }
1485 }
1486
1487 /* The server sends status 'terminated' */
1488 if (subscription_state && strstr(subscription_state, "terminated") ) {
1489 gchar *who = parse_from(sipmsg_find_header(msg, request ? "From" : "To"));
1490 gchar *key = sipe_utils_subscription_key(event, who);
1491
1492 SIPE_DEBUG_INFO("process_incoming_notify: server says that subscription to %s was terminated.", who);
1493 g_free(who);
1494
1495 sipe_subscriptions_remove(sipe_private, key);
1496 g_free(key);
1497 }
1498
1499 if (!request && event) {
1500 const gchar *expires_header = sipmsg_find_header(msg, "Expires");
1501 int timeout = expires_header ? strtol(expires_header, NULL, 10) : 0;
1502 SIPE_DEBUG_INFO("process_incoming_notify: subscription expires:%d", timeout);
1503
1504 if (timeout) {
1505 /* 2 min ahead of expiration */
1506 timeout = (timeout - 120) > 120 ? (timeout - 120) : timeout;
1507
1508 if (sipe_strcase_equal(event, "presence.wpending") &&
1509 g_slist_find_custom(sip->allow_events, "presence.wpending", (GCompareFunc)g_ascii_strcasecmp))
1510 {
1511 gchar *action_name = g_strdup_printf("<%s>", "presence.wpending");
1512 sipe_schedule_seconds(sipe_private,
1513 action_name,
1514 NULL,
1515 timeout,
1516 sipe_subscribe_presence_wpending,
1517 NULL);
1518 g_free(action_name);
1519 }
1520 else if (sipe_strcase_equal(event, "presence") &&
1521 g_slist_find_custom(sip->allow_events, "presence", (GCompareFunc)g_ascii_strcasecmp))
1522 {
1523 gchar *who = parse_from(sipmsg_find_header(msg, "To"));
1524 gchar *action_name = sipe_utils_presence_key(who);
1525
1526 if (SIPE_CORE_PRIVATE_FLAG_IS(BATCHED_SUPPORT)) {
1527 sipe_process_presence_timeout(sipe_private, msg, who, timeout);
1528 }
1529 else {
1530 sipe_schedule_seconds(sipe_private,
1531 action_name,
1532 g_strdup(who),
1533 timeout,
1534 sipe_subscribe_presence_single,
1535 g_free);
1536 SIPE_DEBUG_INFO("Resubscription single contact (%s) in %d", who, timeout);
1537 }
1538 g_free(action_name);
1539 g_free(who);
1540 }
1541 }
1542 }
1543
1544 /* The client responses on received a NOTIFY message */
1545 if (request && !benotify)
1546 {
1547 sip_transport_response(sipe_private, msg, 200, "OK", NULL);
1548 }
1549 }
1550
1551 /*
1552 Local Variables:
1553 mode: c
1554 c-file-style: "bsd"
1555 indent-tabs-mode: t
1556 tab-width: 8
1557 End:
1558 */
A third-party Pidgin plugin for Microsoft LCS/OCS