?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
ucs: extract Exchange Key from persona
[siplcs.git] / src / core / sipe-buddy.c
blob1a621c324b56e145f8a14b87f1e898cea919e863
1 /**
2 * @file sipe-buddy.c
3 *
4 * pidgin-sipe
5 *
6 * Copyright (C) 2010-2013 SIPE Project <http://sipe.sourceforge.net/>
7 *
8 * This program is free software; you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License as published by
10 * the Free Software Foundation; either version 2 of the License, or
11 * (at your option) any later version.
12 *
13 * This program is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 * GNU General Public License for more details.
17 *
18 * You should have received a copy of the GNU General Public License
19 * along with this program; if not, write to the Free Software
20 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
21 */
22
23 #ifdef HAVE_CONFIG_H
24 #include "config.h"
25 #endif
26
27 #include <stdlib.h>
28 #include <string.h>
29 #include <time.h>
30
31 #include <glib.h>
32
33 #include "sipe-common.h"
34 #include "sipmsg.h"
35 #include "sip-csta.h"
36 #include "sip-soap.h"
37 #include "sip-transport.h"
38 #include "sipe-backend.h"
39 #include "sipe-buddy.h"
40 #include "sipe-cal.h"
41 #include "sipe-chat.h"
42 #include "sipe-conf.h"
43 #include "sipe-core.h"
44 #include "sipe-core-private.h"
45 #include "sipe-group.h"
46 #include "sipe-http.h"
47 #include "sipe-im.h"
48 #include "sipe-nls.h"
49 #include "sipe-ocs2005.h"
50 #include "sipe-ocs2007.h"
51 #include "sipe-schedule.h"
52 #include "sipe-session.h"
53 #include "sipe-status.h"
54 #include "sipe-subscriptions.h"
55 #include "sipe-svc.h"
56 #include "sipe-ucs.h"
57 #include "sipe-utils.h"
58 #include "sipe-webticket.h"
59 #include "sipe-xml.h"
60
61 struct photo_response_data {
62 gchar *who;
63 gchar *photo_hash;
64 struct sipe_http_request *request;
65 };
66
67 static void buddy_fetch_photo(struct sipe_core_private *sipe_private,
68 const gchar *uri);
69 static void photo_response_data_free(struct photo_response_data *data);
70
71 struct sipe_buddy *sipe_buddy_add(struct sipe_core_private *sipe_private,
72 const gchar *uri,
73 const gchar *exchange_key)
74 {
75 struct sipe_buddy *buddy = g_hash_table_lookup(sipe_private->buddies, uri);
76 if (!buddy) {
77 buddy = g_new0(struct sipe_buddy, 1);
78 buddy->name = g_strdup(uri);
79 buddy->exchange_key = g_strdup(exchange_key);
80 g_hash_table_insert(sipe_private->buddies, buddy->name, buddy);
81
82 SIPE_DEBUG_INFO("sipe_buddy_add: Added buddy %s", uri);
83
84 buddy_fetch_photo(sipe_private, uri);
85 } else {
86 SIPE_DEBUG_INFO("sipe_buddy_add: Buddy %s already exists", uri);
87 }
88
89 return buddy;
90 }
91
92 static void buddy_free(struct sipe_buddy *buddy)
93 {
94 #ifndef _WIN32
95 /*
96 * We are calling g_hash_table_foreach_steal(). That means that no
97 * key/value deallocation functions are called. Therefore the glib
98 * hash code does not touch the key (buddy->name) or value (buddy)
99 * of the to-be-deleted hash node at all. It follows that we
100 *
101 * - MUST free the memory for the key ourselves and
102 * - ARE allowed to do it in this function
103 *
104 * Conclusion: glib must be broken on the Windows platform if sipe
105 * crashes with SIGTRAP when closing. You'll have to live
106 * with the memory leak until this is fixed.
107 */
108 g_free(buddy->name);
109 #endif
110 g_free(buddy->exchange_key);
111 g_free(buddy->activity);
112 g_free(buddy->meeting_subject);
113 g_free(buddy->meeting_location);
114 g_free(buddy->note);
115
116 g_free(buddy->cal_start_time);
117 g_free(buddy->cal_free_busy_base64);
118 g_free(buddy->cal_free_busy);
119 g_free(buddy->last_non_cal_activity);
120
121 sipe_cal_free_working_hours(buddy->cal_working_hours);
122
123 g_free(buddy->device_name);
124 g_slist_free(buddy->groups);
125 g_free(buddy);
126 }
127
128 static gboolean buddy_free_cb(SIPE_UNUSED_PARAMETER gpointer key,
129 gpointer buddy,
130 SIPE_UNUSED_PARAMETER gpointer user_data)
131 {
132 buddy_free(buddy);
133 /* We must return TRUE as the key/value have already been deleted */
134 return(TRUE);
135 }
136
137 void sipe_buddy_free_all(struct sipe_core_private *sipe_private)
138 {
139 g_hash_table_foreach_steal(sipe_private->buddies,
140 buddy_free_cb,
141 NULL);
142
143 /* core is being deallocated, remove all its pending photo requests */
144 while (sipe_private->pending_photo_requests) {
145 struct photo_response_data *data =
146 sipe_private->pending_photo_requests->data;
147 sipe_private->pending_photo_requests =
148 g_slist_remove(sipe_private->pending_photo_requests, data);
149 photo_response_data_free(data);
150 }
151 }
152
153 gchar *sipe_core_buddy_status(struct sipe_core_public *sipe_public,
154 const gchar *uri,
155 guint activity,
156 const gchar *status_text)
157 {
158 struct sipe_buddy *sbuddy;
159 const char *activity_str;
160
161 if (!sipe_public) return NULL; /* happens on pidgin exit */
162
163 sbuddy = g_hash_table_lookup(SIPE_CORE_PRIVATE->buddies, uri);
164 if (!sbuddy) return NULL;
165
166 activity_str = sbuddy->activity ? sbuddy->activity :
167 (activity == SIPE_ACTIVITY_BUSY) || (activity == SIPE_ACTIVITY_BRB) ?
168 status_text : NULL;
169
170 if (activity_str && sbuddy->note) {
171 return g_strdup_printf("%s - <i>%s</i>", activity_str, sbuddy->note);
172 } else if (activity_str) {
173 return g_strdup(activity_str);
174 } else if (sbuddy->note) {
175 return g_strdup_printf("<i>%s</i>", sbuddy->note);
176 } else {
177 return NULL;
178 }
179 }
180
181 gchar *sipe_buddy_get_alias(struct sipe_core_private *sipe_private,
182 const gchar *with)
183 {
184 sipe_backend_buddy pbuddy;
185 gchar *alias = NULL;
186 if ((pbuddy = sipe_backend_buddy_find(SIPE_CORE_PUBLIC, with, NULL))) {
187 alias = sipe_backend_buddy_get_alias(SIPE_CORE_PUBLIC, pbuddy);
188 }
189 return alias;
190 }
191
192 void sipe_core_buddy_group(struct sipe_core_public *sipe_public,
193 const gchar *who,
194 const gchar *old_group_name,
195 const gchar *new_group_name)
196 {
197 struct sipe_buddy * buddy = g_hash_table_lookup(SIPE_CORE_PRIVATE->buddies, who);
198 struct sipe_group * old_group = NULL;
199 struct sipe_group * new_group;
200
201 SIPE_DEBUG_INFO("sipe_core_buddy_group: who:%s old_group_name:%s new_group_name:%s",
202 who ? who : "", old_group_name ? old_group_name : "", new_group_name ? new_group_name : "");
203
204 if(!buddy) { // buddy not in roaming list
205 return;
206 }
207
208 if (old_group_name) {
209 old_group = sipe_group_find_by_name(SIPE_CORE_PRIVATE, old_group_name);
210 }
211 new_group = sipe_group_find_by_name(SIPE_CORE_PRIVATE, new_group_name);
212
213 if (old_group) {
214 buddy->groups = g_slist_remove(buddy->groups, old_group);
215 SIPE_DEBUG_INFO("sipe_core_buddy_group: buddy %s removed from old group %s", who, old_group_name);
216 }
217
218 if (!new_group) {
219 sipe_group_create(SIPE_CORE_PRIVATE, new_group_name, who);
220 } else {
221 buddy->groups = sipe_utils_slist_insert_unique_sorted(buddy->groups,
222 new_group,
223 (GCompareFunc)sipe_group_compare,
224 NULL);
225 sipe_group_update_buddy(SIPE_CORE_PRIVATE, buddy);
226 }
227 }
228
229 void sipe_core_buddy_add(struct sipe_core_public *sipe_public,
230 const gchar *uri,
231 const gchar *group_name)
232 {
233 struct sipe_core_private *sipe_private = SIPE_CORE_PRIVATE;
234
235 if (!g_hash_table_lookup(sipe_private->buddies, uri)) {
236 struct sipe_buddy *b = sipe_buddy_add(sipe_private, uri, NULL);
237 b->just_added = TRUE;
238
239 sipe_subscribe_presence_single_cb(sipe_private, b->name);
240
241 } else {
242 SIPE_DEBUG_INFO("sipe_core_buddy_add: buddy %s already in internal list",
243 uri);
244 }
245
246 sipe_core_buddy_group(sipe_public,
247 uri,
248 NULL,
249 group_name);
250 }
251
252 void sipe_buddy_remove(struct sipe_core_private *sipe_private,
253 struct sipe_buddy *buddy)
254 {
255 gchar *action_name = sipe_utils_presence_key(buddy->name);
256 sipe_schedule_cancel(sipe_private, action_name);
257 g_free(action_name);
258
259 g_hash_table_remove(sipe_private->buddies, buddy->name);
260
261 buddy_free(buddy);
262 }
263
264 /**
265 * Unassociates buddy from group first.
266 * Then see if no groups left, removes buddy completely.
267 * Otherwise updates buddy groups on server.
268 */
269 void sipe_core_buddy_remove(struct sipe_core_public *sipe_public,
270 const gchar *uri,
271 const gchar *group_name)
272 {
273 struct sipe_core_private *sipe_private = SIPE_CORE_PRIVATE;
274 struct sipe_buddy *b = g_hash_table_lookup(sipe_private->buddies,
275 uri);
276
277 if (!b) return;
278
279 if (group_name) {
280 struct sipe_group *g = sipe_group_find_by_name(sipe_private,
281 group_name);
282 if (g) {
283 b->groups = g_slist_remove(b->groups, g);
284 SIPE_DEBUG_INFO("sipe_core_buddy_remove: buddy %s removed from group %s",
285 uri, g->name);
286 }
287 }
288
289 if (g_slist_length(b->groups) < 1) {
290 gchar *request = g_strdup_printf("<m:URI>%s</m:URI>",
291 b->name);
292 sip_soap_request(sipe_private,
293 "deleteContact",
294 request);
295 g_free(request);
296 sipe_buddy_remove(sipe_private, b);
297 } else {
298 /* updates groups on server */
299 sipe_group_update_buddy(sipe_private, b);
300 }
301
302 }
303
304 void sipe_core_buddy_got_status(struct sipe_core_public *sipe_public,
305 const gchar *uri,
306 guint activity)
307 {
308 struct sipe_core_private *sipe_private = SIPE_CORE_PRIVATE;
309 struct sipe_buddy *sbuddy = g_hash_table_lookup(sipe_private->buddies,
310 uri);
311
312 if (!sbuddy) return;
313
314 /* Check if on 2005 system contact's calendar,
315 * then set/preserve it.
316 */
317 if (SIPE_CORE_PRIVATE_FLAG_IS(OCS2007)) {
318 sipe_backend_buddy_set_status(sipe_public, uri, activity);
319 } else {
320 sipe_ocs2005_apply_calendar_status(sipe_private,
321 sbuddy,
322 sipe_status_activity_to_token(activity));
323 }
324 }
325
326 void sipe_core_buddy_tooltip_info(struct sipe_core_public *sipe_public,
327 const gchar *uri,
328 const gchar *status_name,
329 gboolean is_online,
330 struct sipe_backend_buddy_tooltip *tooltip)
331 {
332 struct sipe_core_private *sipe_private = SIPE_CORE_PRIVATE;
333 gchar *note = NULL;
334 gboolean is_oof_note = FALSE;
335 const gchar *activity = NULL;
336 gchar *calendar = NULL;
337 const gchar *meeting_subject = NULL;
338 const gchar *meeting_location = NULL;
339 gchar *access_text = NULL;
340
341 #define SIPE_ADD_BUDDY_INFO(l, t) \
342 { \
343 gchar *tmp = g_markup_escape_text((t), -1); \
344 sipe_backend_buddy_tooltip_add(sipe_public, tooltip, (l), tmp); \
345 g_free(tmp); \
346 }
347 #define SIPE_ADD_BUDDY_INFO_NOESCAPE(l, t) \
348 sipe_backend_buddy_tooltip_add(sipe_public, tooltip, (l), (t))
349
350 if (sipe_public) { /* happens on pidgin exit */
351 struct sipe_buddy *sbuddy = g_hash_table_lookup(sipe_private->buddies, uri);
352 if (sbuddy) {
353 note = sbuddy->note;
354 is_oof_note = sbuddy->is_oof_note;
355 activity = sbuddy->activity;
356 calendar = sipe_cal_get_description(sbuddy);
357 meeting_subject = sbuddy->meeting_subject;
358 meeting_location = sbuddy->meeting_location;
359 }
360 if (SIPE_CORE_PRIVATE_FLAG_IS(OCS2007)) {
361 gboolean is_group_access = FALSE;
362 const int container_id = sipe_ocs2007_find_access_level(sipe_private,
363 "user",
364 sipe_get_no_sip_uri(uri),
365 &is_group_access);
366 const char *access_level = sipe_ocs2007_access_level_name(container_id);
367 access_text = is_group_access ?
368 g_strdup(access_level) :
369 g_strdup_printf(SIPE_OCS2007_INDENT_MARKED_FMT,
370 access_level);
371 }
372 }
373
374 if (is_online) {
375 const gchar *status_str = activity ? activity : status_name;
376
377 SIPE_ADD_BUDDY_INFO(_("Status"), status_str);
378 }
379 if (is_online && !is_empty(calendar)) {
380 SIPE_ADD_BUDDY_INFO(_("Calendar"), calendar);
381 }
382 g_free(calendar);
383 if (!is_empty(meeting_location)) {
384 SIPE_DEBUG_INFO("sipe_tooltip_text: %s meeting location: '%s'", uri, meeting_location);
385 SIPE_ADD_BUDDY_INFO(_("Meeting in"), meeting_location);
386 }
387 if (!is_empty(meeting_subject)) {
388 SIPE_DEBUG_INFO("sipe_tooltip_text: %s meeting subject: '%s'", uri, meeting_subject);
389 SIPE_ADD_BUDDY_INFO(_("Meeting about"), meeting_subject);
390 }
391 if (note) {
392 gchar *note_italics = g_strdup_printf("<i>%s</i>", note);
393 SIPE_DEBUG_INFO("sipe_tooltip_text: %s note: '%s'", uri, note);
394 SIPE_ADD_BUDDY_INFO_NOESCAPE(is_oof_note ? _("Out of office note") : _("Note"),
395 note_italics);
396 g_free(note_italics);
397 }
398 if (access_text) {
399 SIPE_ADD_BUDDY_INFO(_("Access level"), access_text);
400 g_free(access_text);
401 }
402 }
403
404 void sipe_buddy_update_property(struct sipe_core_private *sipe_private,
405 const char *uri,
406 sipe_buddy_info_fields propkey,
407 char *property_value)
408 {
409 GSList *buddies, *entry;
410
411 if (property_value)
412 property_value = g_strstrip(property_value);
413
414 entry = buddies = sipe_backend_buddy_find_all(SIPE_CORE_PUBLIC, uri, NULL); /* all buddies in different groups */
415 while (entry) {
416 gchar *prop_str;
417 sipe_backend_buddy p_buddy = entry->data;
418
419 /* for Display Name */
420 if (propkey == SIPE_BUDDY_INFO_DISPLAY_NAME) {
421 gchar *alias;
422 alias = sipe_backend_buddy_get_alias(SIPE_CORE_PUBLIC, p_buddy);
423 if (property_value && sipe_is_bad_alias(uri, alias)) {
424 SIPE_DEBUG_INFO("Replacing alias for %s with %s", uri, property_value);
425 sipe_backend_buddy_set_alias(SIPE_CORE_PUBLIC, p_buddy, property_value);
426 }
427 g_free(alias);
428
429 alias = sipe_backend_buddy_get_server_alias(SIPE_CORE_PUBLIC, p_buddy);
430 if (!is_empty(property_value) &&
431 (!sipe_strequal(property_value, alias) || is_empty(alias)) )
432 {
433 SIPE_DEBUG_INFO("Replacing service alias for %s with %s", uri, property_value);
434 sipe_backend_buddy_set_server_alias(SIPE_CORE_PUBLIC, p_buddy, property_value);
435 }
436 g_free(alias);
437 }
438 /* for other properties */
439 else {
440 if (!is_empty(property_value)) {
441 prop_str = sipe_backend_buddy_get_string(SIPE_CORE_PUBLIC, p_buddy, propkey);
442 if (!prop_str || !sipe_strcase_equal(prop_str, property_value)) {
443 sipe_backend_buddy_set_string(SIPE_CORE_PUBLIC, p_buddy, propkey, property_value);
444 }
445 g_free(prop_str);
446 }
447 }
448
449 entry = entry->next;
450 }
451 g_slist_free(buddies);
452 }
453
454
455 struct ms_dlx_data;
456 struct ms_dlx_data {
457 GSList *search_rows;
458 gchar *other;
459 guint max_returns;
460 sipe_svc_callback *callback;
461 struct sipe_svc_session *session;
462 gchar *wsse_security;
463 struct sipe_backend_search_token *token;
464 /* must call ms_dlx_free() */
465 void (*failed_callback)(struct sipe_core_private *sipe_private,
466 struct ms_dlx_data *mdd);
467 };
468
469 static void ms_dlx_free(struct ms_dlx_data *mdd)
470 {
471 sipe_utils_slist_free_full(mdd->search_rows, g_free);
472 sipe_svc_session_close(mdd->session);
473 g_free(mdd->other);
474 g_free(mdd->wsse_security);
475 g_free(mdd);
476 }
477
478 #define SIPE_SOAP_SEARCH_ROW "<m:row m:attrib=\"%s\" m:value=\"%s\"/>"
479 #define DLX_SEARCH_ITEM \
480 "<AbEntryRequest.ChangeSearchQuery>" \
481 " <SearchOn>%s</SearchOn>" \
482 " <Value>%s</Value>" \
483 "</AbEntryRequest.ChangeSearchQuery>"
484
485 static gchar * prepare_buddy_search_query(GSList *query_rows, gboolean use_dlx) {
486 gchar **attrs = g_new(gchar *, (g_slist_length(query_rows) / 2) + 1);
487 guint i = 0;
488 gchar *query = NULL;
489
490 while (query_rows) {
491 gchar *attr;
492 gchar *value;
493
494 attr = query_rows->data;
495 query_rows = g_slist_next(query_rows);
496 value = query_rows->data;
497 query_rows = g_slist_next(query_rows);
498
499 if (!attr || !value)
500 break;
501
502 attrs[i++] = g_markup_printf_escaped(use_dlx ? DLX_SEARCH_ITEM : SIPE_SOAP_SEARCH_ROW,
503 attr, value);
504 }
505 attrs[i] = NULL;
506
507 if (i) {
508 query = g_strjoinv(NULL, attrs);
509 SIPE_DEBUG_INFO("prepare_buddy_search_query: rows:\n%s",
510 query ? query : "");
511 }
512
513 g_strfreev(attrs);
514
515 return query;
516 }
517
518 static void ms_dlx_webticket(struct sipe_core_private *sipe_private,
519 const gchar *base_uri,
520 const gchar *auth_uri,
521 const gchar *wsse_security,
522 SIPE_UNUSED_PARAMETER const gchar *failure_msg,
523 gpointer callback_data)
524 {
525 struct ms_dlx_data *mdd = callback_data;
526
527 if (wsse_security) {
528 gchar *query = prepare_buddy_search_query(mdd->search_rows, TRUE);
529
530 SIPE_DEBUG_INFO("ms_dlx_webticket: got ticket for %s",
531 base_uri);
532
533 if (sipe_svc_ab_entry_request(sipe_private,
534 mdd->session,
535 auth_uri,
536 wsse_security,
537 query,
538 g_slist_length(mdd->search_rows) / 2,
539 mdd->max_returns,
540 mdd->callback,
541 mdd)) {
542
543 /* keep webticket security token for potential further use */
544 mdd->wsse_security = g_strdup(wsse_security);
545
546 /* callback data passed down the line */
547 mdd = NULL;
548 }
549 g_free(query);
550
551 } else {
552 /* no ticket: this will show the minmum information */
553 SIPE_DEBUG_ERROR("ms_dlx_webticket: no web ticket for %s",
554 base_uri);
555 }
556
557 if (mdd)
558 mdd->failed_callback(sipe_private, mdd);
559 }
560
561 static void ms_dlx_webticket_request(struct sipe_core_private *sipe_private,
562 struct ms_dlx_data *mdd)
563 {
564 if (!sipe_webticket_request(sipe_private,
565 mdd->session,
566 sipe_private->dlx_uri,
567 "AddressBookWebTicketBearer",
568 ms_dlx_webticket,
569 mdd)) {
570 SIPE_DEBUG_ERROR("ms_dlx_webticket_request: couldn't request webticket for %s",
571 sipe_private->dlx_uri);
572 mdd->failed_callback(sipe_private, mdd);
573 }
574 }
575
576 static void search_contacts_finalize(struct sipe_core_private *sipe_private,
577 struct sipe_backend_search_results *results,
578 guint match_count,
579 gboolean more)
580 {
581 gchar *secondary = g_strdup_printf(
582 dngettext(PACKAGE_NAME,
583 "Found %d contact%s:",
584 "Found %d contacts%s:", match_count),
585 match_count, more ? _(" (more matched your query)") : "");
586
587 sipe_backend_search_results_finalize(SIPE_CORE_PUBLIC,
588 results,
589 secondary,
590 more);
591 g_free(secondary);
592 }
593
594 static void search_ab_entry_response(struct sipe_core_private *sipe_private,
595 const gchar *uri,
596 SIPE_UNUSED_PARAMETER const gchar *raw,
597 sipe_xml *soap_body,
598 gpointer callback_data)
599 {
600 struct ms_dlx_data *mdd = callback_data;
601
602 if (soap_body) {
603 const sipe_xml *node;
604 struct sipe_backend_search_results *results;
605 GHashTable *found;
606
607 SIPE_DEBUG_INFO("search_ab_entry_response: received valid SOAP message from service %s",
608 uri);
609
610 /* any matches? */
611 node = sipe_xml_child(soap_body, "Body/SearchAbEntryResponse/SearchAbEntryResult/Items/AbEntry");
612 if (!node) {
613 SIPE_DEBUG_ERROR_NOFORMAT("search_ab_entry_response: no matches");
614 sipe_backend_search_failed(SIPE_CORE_PUBLIC,
615 mdd->token,
616 _("No contacts found"));
617 ms_dlx_free(mdd);
618 return;
619 }
620
621 /* OK, we found something - show the results to the user */
622 results = sipe_backend_search_results_start(SIPE_CORE_PUBLIC,
623 mdd->token);
624 if (!results) {
625 SIPE_DEBUG_ERROR_NOFORMAT("search_ab_entry_response: Unable to display the search results.");
626 sipe_backend_search_failed(SIPE_CORE_PUBLIC,
627 mdd->token,
628 _("Unable to display the search results"));
629 ms_dlx_free(mdd);
630 return;
631 }
632
633 /* SearchAbEntryResult can contain duplicates */
634 found = g_hash_table_new_full(g_str_hash, g_str_equal,
635 g_free, NULL);
636
637 for (/* initialized above */ ; node; node = sipe_xml_twin(node)) {
638 const sipe_xml *attrs;
639 gchar *sip_uri = NULL;
640 gchar *displayname = NULL;
641 gchar *company = NULL;
642 gchar *country = NULL;
643 gchar *email = NULL;
644
645 for (attrs = sipe_xml_child(node, "Attributes/Attribute");
646 attrs;
647 attrs = sipe_xml_twin(attrs)) {
648 gchar *name = sipe_xml_data(sipe_xml_child(attrs,
649 "Name"));
650 gchar *value = sipe_xml_data(sipe_xml_child(attrs,
651 "Value"));
652
653 if (!is_empty(value)) {
654 if (sipe_strcase_equal(name, "msrtcsip-primaryuseraddress")) {
655 g_free(sip_uri);
656 sip_uri = value;
657 value = NULL;
658 } else if (sipe_strcase_equal(name, "displayname")) {
659 g_free(displayname);
660 displayname = value;
661 value = NULL;
662 } else if (sipe_strcase_equal(name, "mail")) {
663 g_free(email);
664 email = value;
665 value = NULL;
666 } else if (sipe_strcase_equal(name, "company")) {
667 g_free(company);
668 company = value;
669 value = NULL;
670 } else if (sipe_strcase_equal(name, "country")) {
671 g_free(country);
672 country = value;
673 value = NULL;
674 }
675 }
676
677 g_free(value);
678 g_free(name);
679 }
680
681 if (sip_uri && !g_hash_table_lookup(found, sip_uri)) {
682 gchar **uri_parts = g_strsplit(sip_uri, ":", 2);
683 sipe_backend_search_results_add(SIPE_CORE_PUBLIC,
684 results,
685 uri_parts[1],
686 displayname,
687 company,
688 country,
689 email);
690 g_strfreev(uri_parts);
691
692 g_hash_table_insert(found, sip_uri, (gpointer) TRUE);
693 sip_uri = NULL;
694 }
695
696 g_free(email);
697 g_free(country);
698 g_free(company);
699 g_free(displayname);
700 g_free(sip_uri);
701 }
702
703 search_contacts_finalize(sipe_private, results,
704 g_hash_table_size(found),
705 FALSE);
706 g_hash_table_destroy(found);
707 ms_dlx_free(mdd);
708
709 } else {
710 mdd->failed_callback(sipe_private, mdd);
711 }
712 }
713
714 static gboolean process_search_contact_response(struct sipe_core_private *sipe_private,
715 struct sipmsg *msg,
716 struct transaction *trans)
717 {
718 struct sipe_backend_search_token *token = trans->payload->data;
719 struct sipe_backend_search_results *results;
720 sipe_xml *searchResults;
721 const sipe_xml *mrow;
722 guint match_count = 0;
723 gboolean more = FALSE;
724
725 /* valid response? */
726 if (msg->response != 200) {
727 SIPE_DEBUG_ERROR("process_search_contact_response: request failed (%d)",
728 msg->response);
729 sipe_backend_search_failed(SIPE_CORE_PUBLIC,
730 token,
731 _("Contact search failed"));
732 return(FALSE);
733 }
734
735 SIPE_DEBUG_INFO("process_search_contact_response: body:\n%s", msg->body ? msg->body : "");
736
737 /* valid XML? */
738 searchResults = sipe_xml_parse(msg->body, msg->bodylen);
739 if (!searchResults) {
740 SIPE_DEBUG_INFO_NOFORMAT("process_search_contact_response: no parseable searchResults");
741 sipe_backend_search_failed(SIPE_CORE_PUBLIC,
742 token,
743 _("Contact search failed"));
744 return(FALSE);
745 }
746
747 /* any matches? */
748 mrow = sipe_xml_child(searchResults, "Body/Array/row");
749 if (!mrow) {
750 SIPE_DEBUG_ERROR_NOFORMAT("process_search_contact_response: no matches");
751 sipe_backend_search_failed(SIPE_CORE_PUBLIC,
752 token,
753 _("No contacts found"));
754
755 sipe_xml_free(searchResults);
756 return(FALSE);
757 }
758
759 /* OK, we found something - show the results to the user */
760 results = sipe_backend_search_results_start(SIPE_CORE_PUBLIC,
761 trans->payload->data);
762 if (!results) {
763 SIPE_DEBUG_ERROR_NOFORMAT("process_search_contact_response: Unable to display the search results.");
764 sipe_backend_search_failed(SIPE_CORE_PUBLIC,
765 token,
766 _("Unable to display the search results"));
767
768 sipe_xml_free(searchResults);
769 return FALSE;
770 }
771
772 for (/* initialized above */ ; mrow; mrow = sipe_xml_twin(mrow)) {
773 gchar **uri_parts = g_strsplit(sipe_xml_attribute(mrow, "uri"), ":", 2);
774 sipe_backend_search_results_add(SIPE_CORE_PUBLIC,
775 results,
776 uri_parts[1],
777 sipe_xml_attribute(mrow, "displayName"),
778 sipe_xml_attribute(mrow, "company"),
779 sipe_xml_attribute(mrow, "country"),
780 sipe_xml_attribute(mrow, "email"));
781 g_strfreev(uri_parts);
782 match_count++;
783 }
784
785 if ((mrow = sipe_xml_child(searchResults, "Body/directorySearch/moreAvailable")) != NULL) {
786 char *data = sipe_xml_data(mrow);
787 more = (g_ascii_strcasecmp(data, "true") == 0);
788 g_free(data);
789 }
790
791 search_contacts_finalize(sipe_private, results, match_count, more);
792 sipe_xml_free(searchResults);
793
794 return(TRUE);
795 }
796
797 static void search_soap_request(struct sipe_core_private *sipe_private,
798 struct sipe_backend_search_token *token,
799 GSList *search_rows)
800 {
801 gchar *query = prepare_buddy_search_query(search_rows, FALSE);
802 struct transaction_payload *payload = g_new0(struct transaction_payload, 1);
803
804 payload->data = token;
805
806 sip_soap_directory_search(sipe_private,
807 100,
808 query,
809 process_search_contact_response,
810 payload);
811 g_free(query);
812 }
813
814 static void search_ab_entry_failed(struct sipe_core_private *sipe_private,
815 struct ms_dlx_data *mdd)
816 {
817 /* error using [MS-DLX] server, retry using Active Directory */
818 search_soap_request(sipe_private, mdd->token, mdd->search_rows);
819 ms_dlx_free(mdd);
820 }
821
822 void sipe_core_buddy_search(struct sipe_core_public *sipe_public,
823 struct sipe_backend_search_token *token,
824 const gchar *given_name,
825 const gchar *surname,
826 const gchar *email,
827 const gchar *company,
828 const gchar *country)
829 {
830 GSList *query_rows = NULL;
831
832 #define ADD_QUERY_ROW(attr, val) \
833 if (val) { \
834 query_rows = g_slist_append(query_rows, g_strdup(attr)); \
835 query_rows = g_slist_append(query_rows, g_strdup(val)); \
836 }
837
838 ADD_QUERY_ROW("givenName", given_name);
839 ADD_QUERY_ROW("sn", surname);
840 ADD_QUERY_ROW("mail", email);
841 ADD_QUERY_ROW("company", company);
842 ADD_QUERY_ROW("c", country);
843
844 if (query_rows) {
845 if (SIPE_CORE_PRIVATE->dlx_uri != NULL) {
846 struct ms_dlx_data *mdd = g_new0(struct ms_dlx_data, 1);
847
848 mdd->search_rows = query_rows;
849 mdd->max_returns = 100;
850 mdd->callback = search_ab_entry_response;
851 mdd->failed_callback = search_ab_entry_failed;
852 mdd->session = sipe_svc_session_start();
853 mdd->token = token;
854
855 ms_dlx_webticket_request(SIPE_CORE_PRIVATE, mdd);
856
857 } else {
858 /* no [MS-DLX] server, use Active Directory search instead */
859 search_soap_request(SIPE_CORE_PRIVATE, token, query_rows);
860 sipe_utils_slist_free_full(query_rows, g_free);
861 }
862 } else
863 sipe_backend_search_failed(sipe_public,
864 token,
865 _("Invalid contact search query"));
866 }
867
868 static void get_info_finalize(struct sipe_core_private *sipe_private,
869 struct sipe_backend_buddy_info *info,
870 const gchar *uri,
871 const gchar *server_alias,
872 const gchar *email)
873 {
874 sipe_backend_buddy bbuddy;
875 struct sipe_buddy *sbuddy;
876 gchar *alias;
877 gchar *value;
878
879 if (!info) {
880 info = sipe_backend_buddy_info_start(SIPE_CORE_PUBLIC);
881 } else {
882 sipe_backend_buddy_info_break(SIPE_CORE_PUBLIC, info);
883 }
884 if (!info)
885 return;
886
887 bbuddy = sipe_backend_buddy_find(SIPE_CORE_PUBLIC, uri, NULL);
888
889 if (is_empty(server_alias)) {
890 value = sipe_backend_buddy_get_server_alias(SIPE_CORE_PUBLIC,
891 bbuddy);
892 if (value) {
893 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
894 info,
895 SIPE_BUDDY_INFO_DISPLAY_NAME,
896 value);
897 }
898 } else {
899 value = g_strdup(server_alias);
900 }
901
902 /* present alias if it differs from server alias */
903 alias = sipe_backend_buddy_get_local_alias(SIPE_CORE_PUBLIC, bbuddy);
904 if (alias && !sipe_strequal(alias, value))
905 {
906 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
907 info,
908 SIPE_BUDDY_INFO_ALIAS,
909 alias);
910 }
911 g_free(alias);
912 g_free(value);
913
914 if (is_empty(email)) {
915 value = sipe_backend_buddy_get_string(SIPE_CORE_PUBLIC,
916 bbuddy,
917 SIPE_BUDDY_INFO_EMAIL);
918 if (value) {
919 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
920 info,
921 SIPE_BUDDY_INFO_EMAIL,
922 value);
923 g_free(value);
924 }
925 }
926
927 value = sipe_backend_buddy_get_string(SIPE_CORE_PUBLIC,
928 bbuddy,
929 SIPE_BUDDY_INFO_SITE);
930 if (value) {
931 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
932 info,
933 SIPE_BUDDY_INFO_SITE,
934 value);
935 g_free(value);
936 }
937
938 sbuddy = g_hash_table_lookup(sipe_private->buddies, uri);
939 if (sbuddy && sbuddy->device_name) {
940 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
941 info,
942 SIPE_BUDDY_INFO_DEVICE,
943 sbuddy->device_name);
944 }
945
946 sipe_backend_buddy_info_finalize(SIPE_CORE_PUBLIC, info, uri);
947 }
948
949
950 static void get_info_ab_entry_response(struct sipe_core_private *sipe_private,
951 const gchar *uri,
952 SIPE_UNUSED_PARAMETER const gchar *raw,
953 sipe_xml *soap_body,
954 gpointer callback_data)
955 {
956 struct ms_dlx_data *mdd = callback_data;
957 struct sipe_backend_buddy_info *info = NULL;
958 gchar *server_alias = NULL;
959 gchar *email = NULL;
960
961 if (soap_body) {
962 const sipe_xml *node;
963
964 SIPE_DEBUG_INFO("get_info_ab_entry_response: received valid SOAP message from service %s",
965 uri);
966
967 info = sipe_backend_buddy_info_start(SIPE_CORE_PUBLIC);
968
969 for (node = sipe_xml_child(soap_body, "Body/SearchAbEntryResponse/SearchAbEntryResult/Items/AbEntry/Attributes/Attribute");
970 node;
971 node = sipe_xml_twin(node)) {
972 gchar *name = sipe_xml_data(sipe_xml_child(node,
973 "Name"));
974 gchar *value = sipe_xml_data(sipe_xml_child(node,
975 "Value"));
976 const sipe_xml *values = sipe_xml_child(node,
977 "Values");
978
979 /* Single value entries */
980 if (!is_empty(value)) {
981
982 if (sipe_strcase_equal(name, "displayname")) {
983 g_free(server_alias);
984 server_alias = value;
985 value = NULL;
986 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
987 info,
988 SIPE_BUDDY_INFO_DISPLAY_NAME,
989 server_alias);
990 } else if (sipe_strcase_equal(name, "mail")) {
991 g_free(email);
992 email = value;
993 value = NULL;
994 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
995 info,
996 SIPE_BUDDY_INFO_EMAIL,
997 email);
998 } else if (sipe_strcase_equal(name, "title")) {
999 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
1000 info,
1001 SIPE_BUDDY_INFO_JOB_TITLE,
1002 value);
1003 } else if (sipe_strcase_equal(name, "company")) {
1004 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
1005 info,
1006 SIPE_BUDDY_INFO_COMPANY,
1007 value);
1008 } else if (sipe_strcase_equal(name, "country")) {
1009 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
1010 info,
1011 SIPE_BUDDY_INFO_COUNTRY,
1012 value);
1013 }
1014
1015 } else if (values) {
1016 gchar *first = sipe_xml_data(sipe_xml_child(values,
1017 "string"));
1018
1019 if (sipe_strcase_equal(name, "telephonenumber")) {
1020 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
1021 info,
1022 SIPE_BUDDY_INFO_WORK_PHONE,
1023 first);
1024 }
1025
1026 g_free(first);
1027 }
1028
1029 g_free(value);
1030 g_free(name);
1031 }
1032 }
1033
1034 /* this will show the minmum information */
1035 get_info_finalize(sipe_private,
1036 info,
1037 mdd->other,
1038 server_alias,
1039 email);
1040
1041 g_free(email);
1042 g_free(server_alias);
1043 ms_dlx_free(mdd);
1044 }
1045
1046 static gboolean process_get_info_response(struct sipe_core_private *sipe_private,
1047 struct sipmsg *msg,
1048 struct transaction *trans)
1049 {
1050 const gchar *uri = trans->payload->data;
1051 struct sipe_backend_buddy_info *info = NULL;
1052 gchar *server_alias = NULL;
1053 gchar *email = NULL;
1054
1055 SIPE_DEBUG_INFO("Fetching %s's user info for %s",
1056 uri, sipe_private->username);
1057
1058 if (msg->response != 200) {
1059 SIPE_DEBUG_INFO("process_get_info_response: SERVICE response is %d", msg->response);
1060 } else {
1061 sipe_xml *searchResults;
1062 const sipe_xml *mrow;
1063
1064 SIPE_DEBUG_INFO("process_get_info_response: body:\n%s",
1065 msg->body ? msg->body : "");
1066
1067 searchResults = sipe_xml_parse(msg->body, msg->bodylen);
1068 if (!searchResults) {
1069
1070 SIPE_DEBUG_INFO_NOFORMAT("process_get_info_response: no parseable searchResults");
1071
1072 } else if ((mrow = sipe_xml_child(searchResults, "Body/Array/row"))) {
1073 const gchar *value;
1074 gchar *phone_number;
1075
1076 info = sipe_backend_buddy_info_start(SIPE_CORE_PUBLIC);
1077
1078 server_alias = g_strdup(sipe_xml_attribute(mrow, "displayName"));
1079 email = g_strdup(sipe_xml_attribute(mrow, "email"));
1080 phone_number = g_strdup(sipe_xml_attribute(mrow, "phone"));
1081
1082 /*
1083 * For 2007 system we will take this from ContactCard -
1084 * it has cleaner tel: URIs at least
1085 */
1086 if (!SIPE_CORE_PRIVATE_FLAG_IS(OCS2007)) {
1087 char *tel_uri = sip_to_tel_uri(phone_number);
1088 /* trims its parameters, so call first */
1089 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_DISPLAY_NAME, server_alias);
1090 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_EMAIL, email);
1091 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_WORK_PHONE, tel_uri);
1092 sipe_buddy_update_property(sipe_private, uri, SIPE_BUDDY_INFO_WORK_PHONE_DISPLAY, phone_number);
1093 g_free(tel_uri);
1094
1095 sipe_backend_buddy_refresh_properties(SIPE_CORE_PUBLIC,
1096 uri);
1097 }
1098
1099 if (!is_empty(server_alias)) {
1100 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
1101 info,
1102 SIPE_BUDDY_INFO_DISPLAY_NAME,
1103 server_alias);
1104 }
1105 if ((value = sipe_xml_attribute(mrow, "title")) && strlen(value) > 0) {
1106 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
1107 info,
1108 SIPE_BUDDY_INFO_JOB_TITLE,
1109 value);
1110 }
1111 if ((value = sipe_xml_attribute(mrow, "office")) && strlen(value) > 0) {
1112 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
1113 info,
1114 SIPE_BUDDY_INFO_OFFICE,
1115 value);
1116 }
1117 if (!is_empty(phone_number)) {
1118 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
1119 info,
1120 SIPE_BUDDY_INFO_WORK_PHONE,
1121 phone_number);
1122 }
1123 g_free(phone_number);
1124 if ((value = sipe_xml_attribute(mrow, "company")) && strlen(value) > 0) {
1125 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
1126 info,
1127 SIPE_BUDDY_INFO_COMPANY,
1128 value);
1129 }
1130 if ((value = sipe_xml_attribute(mrow, "city")) && strlen(value) > 0) {
1131 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
1132 info,
1133 SIPE_BUDDY_INFO_CITY,
1134 value);
1135 }
1136 if ((value = sipe_xml_attribute(mrow, "state")) && strlen(value) > 0) {
1137 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
1138 info,
1139 SIPE_BUDDY_INFO_STATE,
1140 value);
1141 }
1142 if ((value = sipe_xml_attribute(mrow, "country")) && strlen(value) > 0) {
1143 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
1144 info,
1145 SIPE_BUDDY_INFO_COUNTRY,
1146 value);
1147 }
1148 if (!is_empty(email)) {
1149 sipe_backend_buddy_info_add(SIPE_CORE_PUBLIC,
1150 info,
1151 SIPE_BUDDY_INFO_EMAIL,
1152 email);
1153 }
1154 }
1155 sipe_xml_free(searchResults);
1156 }
1157
1158 /* this will show the minmum information */
1159 get_info_finalize(sipe_private,
1160 info,
1161 uri,
1162 server_alias,
1163 email);
1164
1165 g_free(server_alias);
1166 g_free(email);
1167
1168 return TRUE;
1169 }
1170
1171 static void get_info_ab_entry_failed(struct sipe_core_private *sipe_private,
1172 struct ms_dlx_data *mdd)
1173 {
1174 /* error using [MS-DLX] server, retry using Active Directory */
1175 gchar *query = prepare_buddy_search_query(mdd->search_rows, FALSE);
1176 struct transaction_payload *payload = g_new0(struct transaction_payload, 1);
1177
1178 payload->destroy = g_free;
1179 payload->data = mdd->other;
1180 mdd->other = NULL;
1181
1182 sip_soap_directory_search(sipe_private,
1183 1,
1184 query,
1185 process_get_info_response,
1186 payload);
1187
1188 ms_dlx_free(mdd);
1189 g_free(query);
1190 }
1191
1192 void sipe_core_buddy_get_info(struct sipe_core_public *sipe_public,
1193 const gchar *who)
1194 {
1195 struct sipe_core_private *sipe_private = SIPE_CORE_PRIVATE;
1196
1197 if (sipe_private->dlx_uri) {
1198 struct ms_dlx_data *mdd = g_new0(struct ms_dlx_data, 1);
1199
1200 mdd->search_rows = g_slist_append(mdd->search_rows, g_strdup("msRTCSIP-PrimaryUserAddress"));
1201 mdd->search_rows = g_slist_append(mdd->search_rows, g_strdup(who));
1202
1203 mdd->other = g_strdup(who);
1204 mdd->max_returns = 1;
1205 mdd->callback = get_info_ab_entry_response;
1206 mdd->failed_callback = get_info_ab_entry_failed;
1207 mdd->session = sipe_svc_session_start();
1208
1209 ms_dlx_webticket_request(sipe_private, mdd);
1210
1211 } else {
1212 /* no [MS-DLX] server, use Active Directory search instead */
1213 gchar *row = g_markup_printf_escaped(SIPE_SOAP_SEARCH_ROW,
1214 "msRTCSIP-PrimaryUserAddress",
1215 who);
1216 struct transaction_payload *payload = g_new0(struct transaction_payload, 1);
1217
1218 SIPE_DEBUG_INFO("sipe_core_buddy_get_info: row: %s",
1219 row ? row : "");
1220
1221 payload->destroy = g_free;
1222 payload->data = g_strdup(who);
1223
1224 sip_soap_directory_search(sipe_private,
1225 1,
1226 row,
1227 process_get_info_response,
1228 payload);
1229 g_free(row);
1230 }
1231 }
1232
1233 static void photo_response_data_free(struct photo_response_data *data)
1234 {
1235 g_free(data->who);
1236 g_free(data->photo_hash);
1237 if (data->request) {
1238 sipe_http_request_cancel(data->request);
1239 }
1240 g_free(data);
1241 }
1242
1243 static void process_buddy_photo_response(struct sipe_core_private *sipe_private,
1244 guint status,
1245 GSList *headers,
1246 const char *body,
1247 gpointer data)
1248 {
1249 struct photo_response_data *rdata = (struct photo_response_data *) data;
1250
1251 rdata->request = NULL;
1252
1253 if (status == SIPE_HTTP_STATUS_OK) {
1254 const gchar *len_str = sipe_utils_nameval_find(headers,
1255 "Content-Length");
1256 if (len_str) {
1257 gsize photo_size = atoi(len_str);
1258 gpointer photo = g_new(char, photo_size);
1259
1260 if (photo) {
1261 memcpy(photo, body, photo_size);
1262
1263 sipe_backend_buddy_set_photo(SIPE_CORE_PUBLIC,
1264 rdata->who,
1265 photo,
1266 photo_size,
1267 rdata->photo_hash);
1268 }
1269 }
1270 }
1271
1272 sipe_private->pending_photo_requests =
1273 g_slist_remove(sipe_private->pending_photo_requests, rdata);
1274
1275 photo_response_data_free(rdata);
1276 }
1277
1278 static gchar *create_x_ms_webticket_header(const gchar *wsse_security)
1279 {
1280 gchar *assertion = sipe_xml_extract_raw(wsse_security, "saml:Assertion", TRUE);
1281 gchar *wsse_security_base64;
1282 gchar *x_ms_webticket_header;
1283
1284 if (!assertion) {
1285 return NULL;
1286 }
1287
1288 wsse_security_base64 = g_base64_encode((const guchar *)assertion,
1289 strlen(assertion));
1290 x_ms_webticket_header = g_strdup_printf("X-MS-WebTicket: opaque=%s\r\n",
1291 wsse_security_base64);
1292
1293 g_free(assertion);
1294 g_free(wsse_security_base64);
1295
1296 return x_ms_webticket_header;
1297 }
1298
1299 static void get_photo_ab_entry_response(struct sipe_core_private *sipe_private,
1300 const gchar *uri,
1301 SIPE_UNUSED_PARAMETER const gchar *raw,
1302 sipe_xml *soap_body,
1303 gpointer callback_data)
1304 {
1305 struct ms_dlx_data *mdd = callback_data;
1306 gchar *photo_rel_path = NULL;
1307 gchar *photo_hash = NULL;
1308 const gchar *photo_hash_old =
1309 sipe_backend_buddy_get_photo_hash(SIPE_CORE_PUBLIC, mdd->other);
1310
1311 if (soap_body) {
1312 const sipe_xml *node;
1313
1314 SIPE_DEBUG_INFO("get_photo_ab_entry_response: received valid SOAP message from service %s",
1315 uri);
1316
1317 for (node = sipe_xml_child(soap_body, "Body/SearchAbEntryResponse/SearchAbEntryResult/Items/AbEntry/Attributes/Attribute");
1318 node;
1319 node = sipe_xml_twin(node)) {
1320 gchar *name = sipe_xml_data(sipe_xml_child(node, "Name"));
1321 gchar *value = sipe_xml_data(sipe_xml_child(node, "Value"));
1322
1323 if (!is_empty(value)) {
1324 if (sipe_strcase_equal(name, "PhotoRelPath")) {
1325 g_free(photo_rel_path);
1326 photo_rel_path = value;
1327 value = NULL;
1328 } else if (sipe_strcase_equal(name, "PhotoHash")) {
1329 g_free(photo_hash);
1330 photo_hash = value;
1331 value = NULL;
1332 }
1333 }
1334
1335 g_free(value);
1336 g_free(name);
1337 }
1338 }
1339
1340 if (sipe_private->addressbook_uri && photo_rel_path &&
1341 photo_hash && !sipe_strequal(photo_hash, photo_hash_old)) {
1342 gchar *photo_url = g_strdup_printf("%s/%s",
1343 sipe_private->addressbook_uri, photo_rel_path);
1344 gchar *x_ms_webticket_header = create_x_ms_webticket_header(mdd->wsse_security);
1345
1346 struct photo_response_data *data = g_new(struct photo_response_data, 1);
1347 data->who = g_strdup(mdd->other);
1348 data->photo_hash = photo_hash;
1349 photo_hash = NULL;
1350
1351 data->request = sipe_http_request_get(sipe_private,
1352 photo_url,
1353 x_ms_webticket_header,
1354 process_buddy_photo_response,
1355 data);
1356
1357 if (data->request) {
1358 sipe_private->pending_photo_requests =
1359 g_slist_append(sipe_private->pending_photo_requests, data);
1360 sipe_http_request_ready(data->request);
1361 } else {
1362 photo_response_data_free(data);
1363 }
1364
1365 g_free(x_ms_webticket_header);
1366 g_free(photo_url);
1367 }
1368
1369 g_free(photo_rel_path);
1370 g_free(photo_hash);
1371 ms_dlx_free(mdd);
1372 }
1373
1374 static void get_photo_ab_entry_failed(SIPE_UNUSED_PARAMETER struct sipe_core_private *sipe_private,
1375 struct ms_dlx_data *mdd)
1376 {
1377 ms_dlx_free(mdd);
1378 }
1379
1380 static void buddy_fetch_photo(struct sipe_core_private *sipe_private,
1381 const gchar *uri)
1382 {
1383 if (sipe_backend_uses_photo()) {
1384
1385 /* Lync 2013 or newer: use UCS */
1386 if (SIPE_CORE_PRIVATE_FLAG_IS(LYNC2013)) {
1387
1388 sipe_ucs_get_photo(sipe_private, uri);
1389
1390 /* Lync 2010: use [MS-DLX] */
1391 } else if (sipe_private->dlx_uri &&
1392 sipe_private->addressbook_uri) {
1393 struct ms_dlx_data *mdd = g_new0(struct ms_dlx_data, 1);
1394
1395 mdd->search_rows = g_slist_append(mdd->search_rows, g_strdup("msRTCSIP-PrimaryUserAddress"));
1396 mdd->search_rows = g_slist_append(mdd->search_rows, g_strdup(uri));
1397
1398 mdd->other = g_strdup(uri);
1399 mdd->max_returns = 1;
1400 mdd->callback = get_photo_ab_entry_response;
1401 mdd->failed_callback = get_photo_ab_entry_failed;
1402 mdd->session = sipe_svc_session_start();
1403
1404 ms_dlx_webticket_request(sipe_private, mdd);
1405 }
1406 }
1407 }
1408
1409 static void buddy_refresh_photos_cb(gpointer uri,
1410 SIPE_UNUSED_PARAMETER gpointer value,
1411 gpointer sipe_private)
1412 {
1413 buddy_fetch_photo(sipe_private, uri);
1414 }
1415
1416 void sipe_buddy_refresh_photos(struct sipe_core_private *sipe_private)
1417 {
1418 g_hash_table_foreach(sipe_private->buddies,
1419 buddy_refresh_photos_cb,
1420 sipe_private);
1421 }
1422
1423 /* Buddy menu callbacks*/
1424
1425 void sipe_core_buddy_new_chat(struct sipe_core_public *sipe_public,
1426 const gchar *who)
1427 {
1428 struct sipe_core_private *sipe_private = SIPE_CORE_PRIVATE;
1429
1430 /* 2007+ conference */
1431 if (SIPE_CORE_PRIVATE_FLAG_IS(OCS2007)) {
1432 sipe_conf_add(sipe_private, who);
1433
1434 /* 2005- multiparty chat */
1435 } else {
1436 gchar *self = sip_uri_self(sipe_private);
1437 struct sip_session *session;
1438
1439 session = sipe_session_add_chat(sipe_private,
1440 NULL,
1441 TRUE,
1442 self);
1443 session->chat_session->backend = sipe_backend_chat_create(SIPE_CORE_PUBLIC,
1444 session->chat_session,
1445 session->chat_session->title,
1446 self);
1447 g_free(self);
1448
1449 sipe_im_invite(sipe_private, session, who,
1450 NULL, NULL, NULL, FALSE);
1451 }
1452 }
1453
1454 void sipe_core_buddy_send_email(struct sipe_core_public *sipe_public,
1455 const gchar *who)
1456 {
1457 sipe_backend_buddy buddy = sipe_backend_buddy_find(sipe_public,
1458 who,
1459 NULL);
1460 gchar *email = sipe_backend_buddy_get_string(sipe_public,
1461 buddy,
1462 SIPE_BUDDY_INFO_EMAIL);
1463
1464 if (email) {
1465 gchar *command_line = g_strdup_printf(
1466 #ifdef _WIN32
1467 "cmd /c start"
1468 #else
1469 "xdg-email"
1470 #endif
1471 " mailto:%s", email);
1472 g_free(email);
1473
1474 SIPE_DEBUG_INFO("sipe_core_buddy_send_email: going to call email client: %s",
1475 command_line);
1476 g_spawn_command_line_async(command_line, NULL);
1477 g_free(command_line);
1478
1479 } else {
1480 SIPE_DEBUG_INFO("sipe_core_buddy_send_email: no email address stored for buddy=%s",
1481 who);
1482 }
1483 }
1484
1485 /* Buddy menu */
1486
1487 static struct sipe_backend_buddy_menu *buddy_menu_phone(struct sipe_core_public *sipe_public,
1488 struct sipe_backend_buddy_menu *menu,
1489 sipe_backend_buddy buddy,
1490 sipe_buddy_info_fields id_phone,
1491 sipe_buddy_info_fields id_display,
1492 const gchar *type)
1493 {
1494 gchar *phone = sipe_backend_buddy_get_string(sipe_public,
1495 buddy,
1496 id_phone);
1497 if (phone) {
1498 gchar *display = sipe_backend_buddy_get_string(sipe_public,
1499 buddy,
1500 id_display);
1501 gchar *tmp = NULL;
1502 gchar *label = g_strdup_printf("%s %s",
1503 type,
1504 display ? display :
1505 (tmp = sip_tel_uri_denormalize(phone)));
1506 menu = sipe_backend_buddy_menu_add(sipe_public,
1507 menu,
1508 label,
1509 SIPE_BUDDY_MENU_MAKE_CALL,
1510 phone);
1511 g_free(tmp);
1512 g_free(label);
1513 g_free(display);
1514 g_free(phone);
1515 }
1516
1517 return(menu);
1518 }
1519
1520 struct sipe_backend_buddy_menu *sipe_core_buddy_create_menu(struct sipe_core_public *sipe_public,
1521 const gchar *buddy_name,
1522 struct sipe_backend_buddy_menu *menu)
1523 {
1524 struct sipe_core_private *sipe_private = SIPE_CORE_PRIVATE;
1525 sipe_backend_buddy buddy = sipe_backend_buddy_find(sipe_public,
1526 buddy_name,
1527 NULL);
1528 gchar *self = sip_uri_self(sipe_private);
1529
1530 SIPE_SESSION_FOREACH {
1531 if (!sipe_strcase_equal(self, buddy_name) && session->chat_session)
1532 {
1533 struct sipe_chat_session *chat_session = session->chat_session;
1534 gboolean is_conf = (chat_session->type == SIPE_CHAT_TYPE_CONFERENCE);
1535
1536 if (sipe_backend_chat_find(chat_session->backend, buddy_name))
1537 {
1538 gboolean conf_op = sipe_backend_chat_is_operator(chat_session->backend, self);
1539
1540 if (is_conf &&
1541 /* Not conf OP */
1542 !sipe_backend_chat_is_operator(chat_session->backend, buddy_name) &&
1543 /* We are a conf OP */
1544 conf_op) {
1545 gchar *label = g_strdup_printf(_("Make leader of '%s'"),
1546 chat_session->title);
1547 menu = sipe_backend_buddy_menu_add(sipe_public,
1548 menu,
1549 label,
1550 SIPE_BUDDY_MENU_MAKE_CHAT_LEADER,
1551 chat_session);
1552 g_free(label);
1553 }
1554
1555 if (is_conf &&
1556 /* We are a conf OP */
1557 conf_op) {
1558 gchar *label = g_strdup_printf(_("Remove from '%s'"),
1559 chat_session->title);
1560 menu = sipe_backend_buddy_menu_add(sipe_public,
1561 menu,
1562 label,
1563 SIPE_BUDDY_MENU_REMOVE_FROM_CHAT,
1564 chat_session);
1565 g_free(label);
1566 }
1567 }
1568 else
1569 {
1570 if (!is_conf ||
1571 (is_conf && !session->locked)) {
1572 gchar *label = g_strdup_printf(_("Invite to '%s'"),
1573 chat_session->title);
1574 menu = sipe_backend_buddy_menu_add(sipe_public,
1575 menu,
1576 label,
1577 SIPE_BUDDY_MENU_INVITE_TO_CHAT,
1578 chat_session);
1579 g_free(label);
1580 }
1581 }
1582 }
1583 } SIPE_SESSION_FOREACH_END;
1584 g_free(self);
1585
1586 menu = sipe_backend_buddy_menu_add(sipe_public,
1587 menu,
1588 _("New chat"),
1589 SIPE_BUDDY_MENU_NEW_CHAT,
1590 NULL);
1591
1592 /* add buddy's phone numbers if we have call control */
1593 if (sip_csta_is_idle(sipe_private)) {
1594
1595 /* work phone */
1596 menu = buddy_menu_phone(sipe_public,
1597 menu,
1598 buddy,
1599 SIPE_BUDDY_INFO_WORK_PHONE,
1600 SIPE_BUDDY_INFO_WORK_PHONE_DISPLAY,
1601 _("Work"));
1602 /* mobile phone */
1603 menu = buddy_menu_phone(sipe_public,
1604 menu,
1605 buddy,
1606 SIPE_BUDDY_INFO_MOBILE_PHONE,
1607 SIPE_BUDDY_INFO_MOBILE_PHONE_DISPLAY,
1608 _("Mobile"));
1609
1610 /* home phone */
1611 menu = buddy_menu_phone(sipe_public,
1612 menu,
1613 buddy,
1614 SIPE_BUDDY_INFO_HOME_PHONE,
1615 SIPE_BUDDY_INFO_HOME_PHONE_DISPLAY,
1616 _("Home"));
1617
1618 /* other phone */
1619 menu = buddy_menu_phone(sipe_public,
1620 menu,
1621 buddy,
1622 SIPE_BUDDY_INFO_OTHER_PHONE,
1623 SIPE_BUDDY_INFO_OTHER_PHONE_DISPLAY,
1624 _("Other"));
1625
1626 /* custom1 phone */
1627 menu = buddy_menu_phone(sipe_public,
1628 menu,
1629 buddy,
1630 SIPE_BUDDY_INFO_CUSTOM1_PHONE,
1631 SIPE_BUDDY_INFO_CUSTOM1_PHONE_DISPLAY,
1632 _("Custom1"));
1633 }
1634
1635 {
1636 gchar *email = sipe_backend_buddy_get_string(sipe_public,
1637 buddy,
1638 SIPE_BUDDY_INFO_EMAIL);
1639 if (email) {
1640 menu = sipe_backend_buddy_menu_add(sipe_public,
1641 menu,
1642 _("Send email..."),
1643 SIPE_BUDDY_MENU_SEND_EMAIL,
1644 NULL);
1645 g_free(email);
1646 }
1647 }
1648
1649 /* access level control */
1650 if (SIPE_CORE_PRIVATE_FLAG_IS(OCS2007))
1651 menu = sipe_backend_buddy_sub_menu_add(sipe_public,
1652 menu,
1653 _("Access level"),
1654 sipe_ocs2007_access_control_menu(sipe_private,
1655 buddy_name));
1656
1657 return(menu);
1658 }
1659
1660 /*
1661 Local Variables:
1662 mode: c
1663 c-file-style: "bsd"
1664 indent-tabs-mode: t
1665 tab-width: 8
1666 End:
1667 */
A third-party Pidgin plugin for Microsoft LCS/OCS