?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
conf: allow to reject incoming AV conference call
[siplcs.git] / src / core / sipe-conf.c
blob0be771b60559daf1212ccadd64ffbdc20012b167
1 /**
2 * @file sipe-conf.c
3 *
4 * pidgin-sipe
5 *
6 * Copyright (C) 2010-11 SIPE Project <http://sipe.sourceforge.net/>
7 * Copyright (C) 2009 pier11 <pier11@operamail.com>
8 *
9 *
10 * This program is free software; you can redistribute it and/or modify
11 * it under the terms of the GNU General Public License as published by
12 * the Free Software Foundation; either version 2 of the License, or
13 * (at your option) any later version.
14 *
15 * This program is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 * GNU General Public License for more details.
19 *
20 * You should have received a copy of the GNU General Public License
21 * along with this program; if not, write to the Free Software
22 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
23 */
24
25 #ifdef HAVE_CONFIG_H
26 #include "config.h"
27 #endif
28
29 #include <stdlib.h>
30 #include <string.h>
31 #include <time.h>
32
33 #include <glib.h>
34
35 #include "sipe-common.h"
36 #include "sipmsg.h"
37 #include "sip-transport.h"
38 #include "sipe-backend.h"
39 #include "sipe-chat.h"
40 #include "sipe-conf.h"
41 #include "sipe-core.h"
42 #include "sipe-core-private.h"
43 #include "sipe-dialog.h"
44 #include "sipe-im.h"
45 #ifdef HAVE_VV
46 #include "sipe-media.h"
47 #endif
48 #include "sipe-nls.h"
49 #include "sipe-session.h"
50 #include "sipe-subscriptions.h"
51 #include "sipe-user.h"
52 #include "sipe-utils.h"
53 #include "sipe-xml.h"
54 #include "sipe.h"
55
56 #ifdef HAVE_VV
57 #define ENTITY_VIEW_AUDIO_VIDEO "<msci:entity-view entity=\"audio-video\"/>"
58 #else
59 #define ENTITY_VIEW_AUDIO_VIDEO
60 #endif
61
62 /**
63 * Add Conference request to FocusFactory.
64 * @param focus_factory_uri (%s) Ex.: sip:bob7@boston.local;gruu;opaque=app:conf:focusfactory
65 * @param from (%s) Ex.: sip:bob7@boston.local
66 * @param request_id (%d) Ex.: 1094520
67 * @param conference_id (%s) Ex.: 8386E6AEAAA41E4AA6627BA76D43B6D1
68 * @param expiry_time (%s) Ex.: 2009-07-13T17:57:09Z , Default duration: 7 hours
69 */
70 #define SIPE_SEND_CONF_ADD \
71 "<?xml version=\"1.0\"?>"\
72 "<request xmlns=\"urn:ietf:params:xml:ns:cccp\" "\
73 "xmlns:mscp=\"http://schemas.microsoft.com/rtc/2005/08/cccpextensions\" "\
74 "C3PVersion=\"1\" "\
75 "to=\"%s\" "\
76 "from=\"%s\" "\
77 "requestId=\"%d\">"\
78 "<addConference>"\
79 "<ci:conference-info xmlns:ci=\"urn:ietf:params:xml:ns:conference-info\" entity=\"\" xmlns:msci=\"http://schemas.microsoft.com/rtc/2005/08/confinfoextensions\">"\
80 "<ci:conference-description>"\
81 "<ci:subject/>"\
82 "<msci:conference-id>%s</msci:conference-id>"\
83 "<msci:expiry-time>%s</msci:expiry-time>"\
84 "<msci:admission-policy>openAuthenticated</msci:admission-policy>"\
85 "</ci:conference-description>"\
86 "<msci:conference-view>"\
87 "<msci:entity-view entity=\"chat\"/>"\
88 ENTITY_VIEW_AUDIO_VIDEO \
89 "</msci:conference-view>"\
90 "</ci:conference-info>"\
91 "</addConference>"\
92 "</request>"
93
94 /**
95 * AddUser request to Focus.
96 * Params:
97 * focus_URI, from, request_id, focus_URI, from, endpoint_GUID
98 */
99 #define SIPE_SEND_CONF_ADD_USER \
100 "<?xml version=\"1.0\"?>"\
101 "<request xmlns=\"urn:ietf:params:xml:ns:cccp\" xmlns:mscp=\"http://schemas.microsoft.com/rtc/2005/08/cccpextensions\" "\
102 "C3PVersion=\"1\" "\
103 "to=\"%s\" "\
104 "from=\"%s\" "\
105 "requestId=\"%d\">"\
106 "<addUser>"\
107 "<conferenceKeys confEntity=\"%s\"/>"\
108 "<ci:user xmlns:ci=\"urn:ietf:params:xml:ns:conference-info\" entity=\"%s\">"\
109 "<ci:roles>"\
110 "<ci:entry>attendee</ci:entry>"\
111 "</ci:roles>"\
112 "<ci:endpoint entity=\"{%s}\" xmlns:msci=\"http://schemas.microsoft.com/rtc/2005/08/confinfoextensions\"/>"\
113 "</ci:user>"\
114 "</addUser>"\
115 "</request>"
116
117 /**
118 * ModifyUserRoles request to Focus. Makes user a leader.
119 * @param focus_uri (%s)
120 * @param from (%s)
121 * @param request_id (%d)
122 * @param focus_uri (%s)
123 * @param who (%s)
124 */
125 #define SIPE_SEND_CONF_MODIFY_USER_ROLES \
126 "<?xml version=\"1.0\"?>"\
127 "<request xmlns=\"urn:ietf:params:xml:ns:cccp\" xmlns:mscp=\"http://schemas.microsoft.com/rtc/2005/08/cccpextensions\" "\
128 "C3PVersion=\"1\" "\
129 "to=\"%s\" "\
130 "from=\"%s\" "\
131 "requestId=\"%d\">"\
132 "<modifyUserRoles>"\
133 "<userKeys confEntity=\"%s\" userEntity=\"%s\"/>"\
134 "<user-roles xmlns=\"urn:ietf:params:xml:ns:conference-info\">"\
135 "<entry>presenter</entry>"\
136 "</user-roles>"\
137 "</modifyUserRoles>"\
138 "</request>"
139
140 /**
141 * ModifyConferenceLock request to Focus. Locks/unlocks conference.
142 * @param focus_uri (%s)
143 * @param from (%s)
144 * @param request_id (%d)
145 * @param focus_uri (%s)
146 * @param locked (%s) "true" or "false" values applicable
147 */
148 #define SIPE_SEND_CONF_MODIFY_CONF_LOCK \
149 "<?xml version=\"1.0\"?>"\
150 "<request xmlns=\"urn:ietf:params:xml:ns:cccp\" xmlns:mscp=\"http://schemas.microsoft.com/rtc/2005/08/cccpextensions\" "\
151 "C3PVersion=\"1\" "\
152 "to=\"%s\" "\
153 "from=\"%s\" "\
154 "requestId=\"%d\">"\
155 "<modifyConferenceLock>"\
156 "<conferenceKeys confEntity=\"%s\"/>"\
157 "<locked>%s</locked>"\
158 "</modifyConferenceLock>"\
159 "</request>"
160
161 /**
162 * ModifyConferenceLock request to Focus. Locks/unlocks conference.
163 * @param focus_uri (%s)
164 * @param from (%s)
165 * @param request_id (%d)
166 * @param focus_uri (%s)
167 * @param who (%s)
168 */
169 #define SIPE_SEND_CONF_DELETE_USER \
170 "<?xml version=\"1.0\"?>"\
171 "<request xmlns=\"urn:ietf:params:xml:ns:cccp\" xmlns:mscp=\"http://schemas.microsoft.com/rtc/2005/08/cccpextensions\" "\
172 "C3PVersion=\"1\" "\
173 "to=\"%s\" "\
174 "from=\"%s\" "\
175 "requestId=\"%d\">"\
176 "<deleteUser>"\
177 "<userKeys confEntity=\"%s\" userEntity=\"%s\"/>"\
178 "</deleteUser>"\
179 "</request>"
180
181 /**
182 * Invite counterparty to join conference.
183 * @param focus_uri (%s)
184 * @param subject (%s) of conference
185 */
186 #define SIPE_SEND_CONF_INVITE \
187 "<Conferencing version=\"2.0\">"\
188 "<focus-uri>%s</focus-uri>"\
189 "<subject>%s</subject>"\
190 "<im available=\"true\">"\
191 "<first-im/>"\
192 "</im>"\
193 "</Conferencing>"
194
195 /**
196 * Generates random GUID.
197 * This method is borrowed from pidgin's msnutils.c
198 */
199 static char *
200 rand_guid()
201 {
202 return g_strdup_printf("%4X%4X-%4X-%4X-%4X-%4X%4X%4X",
203 rand() % 0xAAFF + 0x1111,
204 rand() % 0xAAFF + 0x1111,
205 rand() % 0xAAFF + 0x1111,
206 rand() % 0xAAFF + 0x1111,
207 rand() % 0xAAFF + 0x1111,
208 rand() % 0xAAFF + 0x1111,
209 rand() % 0xAAFF + 0x1111,
210 rand() % 0xAAFF + 0x1111);
211 }
212
213 /**
214 * @param expires not respected if set to negative value (E.g. -1)
215 */
216 static void
217 sipe_subscribe_conference(struct sipe_core_private *sipe_private,
218 struct sip_session *session,
219 gboolean expires)
220 {
221 sipe_subscribe(sipe_private,
222 session->chat_session->id,
223 "conference",
224 "application/conference-info+xml",
225 expires ? "Expires: 0\r\n" : NULL,
226 NULL,
227 NULL);
228 }
229
230 /** Invite us to the focus callback */
231 static gboolean
232 process_invite_conf_focus_response(struct sipe_core_private *sipe_private,
233 struct sipmsg *msg,
234 SIPE_UNUSED_PARAMETER struct transaction *trans)
235 {
236 struct sip_session *session = NULL;
237 char *focus_uri = parse_from(sipmsg_find_header(msg, "To"));
238
239 session = sipe_session_find_conference(sipe_private, focus_uri);
240
241 if (!session) {
242 SIPE_DEBUG_INFO("process_invite_conf_focus_response: unable to find conf session with focus=%s", focus_uri);
243 g_free(focus_uri);
244 return FALSE;
245 }
246
247 if (!session->focus_dialog) {
248 SIPE_DEBUG_INFO_NOFORMAT("process_invite_conf_focus_response: session's focus_dialog is NULL");
249 g_free(focus_uri);
250 return FALSE;
251 }
252
253 sipe_dialog_parse(session->focus_dialog, msg, TRUE);
254
255 if (msg->response >= 200) {
256 /* send ACK to focus */
257 session->focus_dialog->cseq = 0;
258 sip_transport_ack(sipe_private, session->focus_dialog);
259 session->focus_dialog->outgoing_invite = NULL;
260 session->focus_dialog->is_established = TRUE;
261 }
262
263 if (msg->response >= 400) {
264 gchar *reason = sipmsg_get_ms_diagnostics_reason(msg);
265
266 SIPE_DEBUG_INFO_NOFORMAT("process_invite_conf_focus_response: INVITE response is not 200. Failed to join focus.");
267 sipe_backend_notify_error(_("Failed to join the conference"),
268 reason ? reason : _("no reason given"));
269 g_free(reason);
270
271 sipe_session_remove(sipe_private, session);
272 g_free(focus_uri);
273 return FALSE;
274 } else if (msg->response == 200) {
275 sipe_xml *xn_response = sipe_xml_parse(msg->body, msg->bodylen);
276 const gchar *code = sipe_xml_attribute(xn_response, "code");
277 if (sipe_strequal(code, "success")) {
278 /* subscribe to focus */
279 sipe_subscribe_conference(sipe_private, session, FALSE);
280 #ifdef HAVE_VV
281 if (session->is_call)
282 sipe_core_media_connect_conference(SIPE_CORE_PUBLIC,
283 session->chat_session,
284 FALSE);
285 #endif
286 }
287 sipe_xml_free(xn_response);
288 }
289
290 g_free(focus_uri);
291 return TRUE;
292 }
293
294 struct sip_session *
295 sipe_core_conf_create(struct sipe_core_public *sipe_public,
296 const gchar *focus_uri)
297 {
298 gchar *buf;
299 const gchar *focus_uri_ue;
300 struct sip_session *session = NULL;
301
302 focus_uri_ue = buf = sipe_utils_uri_unescape(focus_uri);
303
304 // URI can have this prefix if it was typed in by the user
305 if (g_str_has_prefix(focus_uri_ue, "meet:"))
306 focus_uri_ue += 5;
307
308 if (!focus_uri_ue || !g_str_has_prefix(focus_uri_ue, "sip:") ||
309 strlen(focus_uri_ue) == 4 || g_strstr_len(focus_uri_ue, -1, "%")) {
310 gchar *error = g_strdup_printf(_("\"%s\" is not a valid focus URI"),
311 focus_uri ? focus_uri : "");
312 sipe_backend_notify_error(_("Failed to join the conference"),
313 error);
314 g_free(error);
315 } else {
316 gchar *querystr = g_strstr_len(focus_uri_ue, -1, "?");
317 if (querystr) {
318 /* TODO: Investigate how conf-key field should be used,
319 * ignoring for now */
320 *querystr = '\0';
321 }
322
323 session = sipe_conf_create(SIPE_CORE_PRIVATE, NULL, focus_uri_ue);
324 }
325
326 g_free(buf);
327
328 return session;
329 }
330
331 /** Create new session with Focus URI */
332 struct sip_session *
333 sipe_conf_create(struct sipe_core_private *sipe_private,
334 struct sipe_chat_session *chat_session,
335 const gchar *focus_uri)
336 {
337 gchar *hdr;
338 gchar *contact;
339 gchar *body;
340 gchar *self;
341 struct sip_session *session = sipe_session_add_chat(sipe_private,
342 chat_session,
343 FALSE,
344 focus_uri);
345
346 session->focus_dialog = g_new0(struct sip_dialog, 1);
347 session->focus_dialog->callid = gencallid();
348 session->focus_dialog->with = g_strdup(session->chat_session->id);
349 session->focus_dialog->endpoint_GUID = rand_guid();
350 session->focus_dialog->ourtag = gentag();
351
352 contact = get_contact(sipe_private);
353 hdr = g_strdup_printf(
354 "Supported: ms-sender\r\n"
355 "Contact: %s\r\n"
356 "Content-Type: application/cccp+xml\r\n",
357 contact);
358 g_free(contact);
359
360 /* @TODO put request_id to queue to further compare with incoming one */
361 /* focus_URI, from, request_id, focus_URI, from, endpoint_GUID */
362 self = sip_uri_self(sipe_private);
363 body = g_strdup_printf(
364 SIPE_SEND_CONF_ADD_USER,
365 session->focus_dialog->with,
366 self,
367 session->request_id++,
368 session->focus_dialog->with,
369 self,
370 session->focus_dialog->endpoint_GUID);
371
372 session->focus_dialog->outgoing_invite =
373 sip_transport_invite(sipe_private,
374 hdr,
375 body,
376 session->focus_dialog,
377 process_invite_conf_focus_response);
378 g_free(body);
379 g_free(hdr);
380
381 /* Rejoin existing session? */
382 if (chat_session) {
383 SIPE_DEBUG_INFO("sipe_conf_create: rejoin '%s' (%s)",
384 chat_session->title,
385 chat_session->id);
386 sipe_backend_chat_rejoin(SIPE_CORE_PUBLIC,
387 chat_session->backend,
388 self,
389 chat_session->title);
390 }
391 g_free(self);
392
393 return(session);
394 }
395
396 /** Modify User Role */
397 void
398 sipe_conf_modify_user_role(struct sipe_core_private *sipe_private,
399 struct sip_session *session,
400 const gchar* who)
401 {
402 gchar *hdr;
403 gchar *body;
404 gchar *self;
405
406 if (!session->focus_dialog || !session->focus_dialog->is_established) {
407 SIPE_DEBUG_INFO_NOFORMAT("sipe_conf_modify_user_role: no dialog with focus, exiting.");
408 return;
409 }
410
411 hdr = g_strdup(
412 "Content-Type: application/cccp+xml\r\n");
413
414 /* @TODO put request_id to queue to further compare with incoming one */
415 self = sip_uri_self(sipe_private);
416 body = g_strdup_printf(
417 SIPE_SEND_CONF_MODIFY_USER_ROLES,
418 session->focus_dialog->with,
419 self,
420 session->request_id++,
421 session->focus_dialog->with,
422 who);
423 g_free(self);
424
425 sip_transport_info(sipe_private,
426 hdr,
427 body,
428 session->focus_dialog,
429 NULL);
430 g_free(body);
431 g_free(hdr);
432 }
433
434 /**
435 * Check conference lock status
436 */
437 sipe_chat_lock_status sipe_core_chat_lock_status(struct sipe_core_public *sipe_public,
438 struct sipe_chat_session *chat_session)
439 {
440 struct sipe_core_private *sipe_private = SIPE_CORE_PRIVATE;
441 sipe_chat_lock_status status = SIPE_CHAT_LOCK_STATUS_NOT_ALLOWED;
442
443 if (chat_session &&
444 (chat_session->type == SIPE_CHAT_TYPE_CONFERENCE)) {
445 struct sip_session *session = sipe_session_find_chat(sipe_private,
446 chat_session);
447 if (session) {
448 gchar *self = sip_uri_self(sipe_private);
449
450 /* Only operators are allowed to change the lock status */
451 if (sipe_backend_chat_is_operator(chat_session->backend, self)) {
452 status = session->locked ?
453 SIPE_CHAT_LOCK_STATUS_LOCKED :
454 SIPE_CHAT_LOCK_STATUS_UNLOCKED;
455 }
456
457 g_free(self);
458 }
459 }
460
461 return(status);
462 }
463
464 /**
465 * Modify Conference Lock
466 * Sends request to Focus.
467 * INFO method is a carrier of application/cccp+xml
468 */
469 void
470 sipe_core_chat_modify_lock(struct sipe_core_public *sipe_public,
471 struct sipe_chat_session *chat_session,
472 const gboolean locked)
473 {
474 struct sipe_core_private *sipe_private = SIPE_CORE_PRIVATE;
475 gchar *hdr;
476 gchar *body;
477 gchar *self;
478
479 struct sip_session *session = sipe_session_find_chat(sipe_private,
480 chat_session);
481
482 if (!session) return;
483 if (!session->focus_dialog || !session->focus_dialog->is_established) {
484 SIPE_DEBUG_INFO_NOFORMAT("sipe_conf_modify_conference_lock: no dialog with focus, exiting.");
485 return;
486 }
487
488 hdr = g_strdup(
489 "Content-Type: application/cccp+xml\r\n");
490
491 /* @TODO put request_id to queue to further compare with incoming one */
492 self = sip_uri_self(sipe_private);
493 body = g_strdup_printf(
494 SIPE_SEND_CONF_MODIFY_CONF_LOCK,
495 session->focus_dialog->with,
496 self,
497 session->request_id++,
498 session->focus_dialog->with,
499 locked ? "true" : "false");
500 g_free(self);
501
502 sip_transport_info(sipe_private,
503 hdr,
504 body,
505 session->focus_dialog,
506 NULL);
507 g_free(body);
508 g_free(hdr);
509 }
510
511 /** Modify Delete User */
512 void
513 sipe_conf_delete_user(struct sipe_core_private *sipe_private,
514 struct sip_session *session,
515 const gchar* who)
516 {
517 gchar *hdr;
518 gchar *body;
519 gchar *self;
520
521 if (!session->focus_dialog || !session->focus_dialog->is_established) {
522 SIPE_DEBUG_INFO_NOFORMAT("sipe_conf_delete_user: no dialog with focus, exiting.");
523 return;
524 }
525
526 hdr = g_strdup(
527 "Content-Type: application/cccp+xml\r\n");
528
529 /* @TODO put request_id to queue to further compare with incoming one */
530 self = sip_uri_self(sipe_private);
531 body = g_strdup_printf(
532 SIPE_SEND_CONF_DELETE_USER,
533 session->focus_dialog->with,
534 self,
535 session->request_id++,
536 session->focus_dialog->with,
537 who);
538 g_free(self);
539
540 sip_transport_info(sipe_private,
541 hdr,
542 body,
543 session->focus_dialog,
544 NULL);
545 g_free(body);
546 g_free(hdr);
547 }
548
549 /** Invite counterparty to join conference callback */
550 static gboolean
551 process_invite_conf_response(struct sipe_core_private *sipe_private,
552 struct sipmsg *msg,
553 SIPE_UNUSED_PARAMETER struct transaction *trans)
554 {
555 struct sip_dialog *dialog = g_new0(struct sip_dialog, 1);
556
557 dialog->callid = g_strdup(sipmsg_find_header(msg, "Call-ID"));
558 dialog->cseq = sipmsg_parse_cseq(msg);
559 dialog->with = parse_from(sipmsg_find_header(msg, "To"));
560 sipe_dialog_parse(dialog, msg, TRUE);
561
562 if (msg->response >= 200) {
563 /* send ACK to counterparty */
564 dialog->cseq--;
565 sip_transport_ack(sipe_private, dialog);
566 dialog->outgoing_invite = NULL;
567 dialog->is_established = TRUE;
568 }
569
570 if (msg->response >= 400) {
571 SIPE_DEBUG_INFO("process_invite_conf_response: INVITE response is not 200. Failed to invite %s.", dialog->with);
572 /* @TODO notify user of failure to invite counterparty */
573 sipe_dialog_free(dialog);
574 return FALSE;
575 }
576
577 if (msg->response >= 200) {
578 struct sip_session *session = sipe_session_find_im(sipe_private, dialog->with);
579 struct sip_dialog *im_dialog = sipe_dialog_find(session, dialog->with);
580
581 /* close IM session to counterparty */
582 if (im_dialog) {
583 sip_transport_bye(sipe_private, im_dialog);
584 sipe_dialog_remove(session, dialog->with);
585 }
586 }
587
588 sipe_dialog_free(dialog);
589 return TRUE;
590 }
591
592 /**
593 * Invites counterparty to join conference.
594 */
595 void
596 sipe_invite_conf(struct sipe_core_private *sipe_private,
597 struct sip_session *session,
598 const gchar* who)
599 {
600 gchar *hdr;
601 gchar *contact;
602 gchar *body;
603 struct sip_dialog *dialog = NULL;
604
605 /* It will be short lived special dialog.
606 * Will not be stored in session.
607 */
608 dialog = g_new0(struct sip_dialog, 1);
609 dialog->callid = gencallid();
610 dialog->with = g_strdup(who);
611 dialog->ourtag = gentag();
612
613 contact = get_contact(sipe_private);
614 hdr = g_strdup_printf(
615 "Supported: ms-sender\r\n"
616 "Contact: %s\r\n"
617 "Content-Type: application/ms-conf-invite+xml\r\n",
618 contact);
619 g_free(contact);
620
621 body = g_strdup_printf(
622 SIPE_SEND_CONF_INVITE,
623 session->chat_session->id,
624 session->subject ? session->subject : ""
625 );
626
627 sip_transport_invite(sipe_private,
628 hdr,
629 body,
630 dialog,
631 process_invite_conf_response);
632
633 sipe_dialog_free(dialog);
634 g_free(body);
635 g_free(hdr);
636 }
637
638 /** Create conference callback */
639 static gboolean
640 process_conf_add_response(struct sipe_core_private *sipe_private,
641 struct sipmsg *msg,
642 struct transaction *trans)
643 {
644 if (msg->response >= 400) {
645 SIPE_DEBUG_INFO_NOFORMAT("process_conf_add_response: SERVICE response is not 200. Failed to create conference.");
646 /* @TODO notify user of failure to create conference */
647 return FALSE;
648 }
649 if (msg->response == 200) {
650 sipe_xml *xn_response = sipe_xml_parse(msg->body, msg->bodylen);
651 if (sipe_strequal("success", sipe_xml_attribute(xn_response, "code")))
652 {
653 gchar *who = trans->payload->data;
654 const sipe_xml *xn_conference_info = sipe_xml_child(xn_response, "addConference/conference-info");
655 struct sip_session *session = sipe_conf_create(sipe_private,
656 NULL,
657 sipe_xml_attribute(xn_conference_info,
658 "entity"));
659
660 SIPE_DEBUG_INFO("process_conf_add_response: session->focus_uri=%s",
661 session->chat_session->id);
662
663 session->pending_invite_queue = slist_insert_unique_sorted(
664 session->pending_invite_queue, g_strdup(who), (GCompareFunc)strcmp);
665 }
666 sipe_xml_free(xn_response);
667 }
668
669 return TRUE;
670 }
671
672 /**
673 * Creates conference.
674 */
675 void
676 sipe_conf_add(struct sipe_core_private *sipe_private,
677 const gchar* who)
678 {
679 gchar *hdr;
680 gchar *conference_id;
681 gchar *contact;
682 gchar *body;
683 gchar *self;
684 struct transaction *trans;
685 struct sip_dialog *dialog = NULL;
686 time_t expiry = time(NULL) + 7*60*60; /* 7 hours */
687 char *expiry_time;
688 struct transaction_payload *payload;
689
690 contact = get_contact(sipe_private);
691 hdr = g_strdup_printf(
692 "Supported: ms-sender\r\n"
693 "Contact: %s\r\n"
694 "Content-Type: application/cccp+xml\r\n",
695 contact);
696 g_free(contact);
697
698 expiry_time = sipe_utils_time_to_str(expiry);
699 self = sip_uri_self(sipe_private);
700 conference_id = genconfid();
701 body = g_strdup_printf(
702 SIPE_SEND_CONF_ADD,
703 sipe_private->focus_factory_uri,
704 self,
705 rand(),
706 conference_id,
707 expiry_time);
708 g_free(self);
709 g_free(conference_id);
710 g_free(expiry_time);
711
712 trans = sip_transport_service(sipe_private,
713 sipe_private->focus_factory_uri,
714 hdr,
715 body,
716 process_conf_add_response);
717
718 payload = g_new0(struct transaction_payload, 1);
719 payload->destroy = g_free;
720 payload->data = g_strdup(who);
721 trans->payload = payload;
722
723 sipe_dialog_free(dialog);
724 g_free(body);
725 g_free(hdr);
726 }
727
728 void
729 process_incoming_invite_conf(struct sipe_core_private *sipe_private,
730 struct sipmsg *msg)
731 {
732 sipe_xml *xn_conferencing = sipe_xml_parse(msg->body, msg->bodylen);
733 const sipe_xml *xn_focus_uri = sipe_xml_child(xn_conferencing, "focus-uri");
734 const sipe_xml *xn_audio = sipe_xml_child(xn_conferencing, "audio");
735 gchar *focus_uri = sipe_xml_data(xn_focus_uri);
736 gboolean audio = sipe_strequal(sipe_xml_attribute(xn_audio, "available"), "true");
737 gchar *newTag = gentag();
738 const gchar *oldHeader = sipmsg_find_header(msg, "To");
739 gchar *newHeader;
740 struct sip_session *session;
741
742 sipe_xml_free(xn_conferencing);
743
744 /* send OK */
745 SIPE_DEBUG_INFO("We have received invitation to Conference. Focus URI=%s", focus_uri);
746
747 newHeader = g_strdup_printf("%s;tag=%s", oldHeader, newTag);
748 g_free(newTag);
749 sipmsg_remove_header_now(msg, "To");
750 sipmsg_add_header_now(msg, "To", newHeader);
751 g_free(newHeader);
752
753 /* acknowledge invite */
754 sip_transport_response(sipe_private, msg, 200, "OK", NULL);
755
756 /* add self to conf */
757 session = sipe_conf_create(sipe_private, NULL, focus_uri);
758 session->is_call = audio;
759 g_free(focus_uri);
760 }
761
762 void
763 sipe_process_conference(struct sipe_core_private *sipe_private,
764 struct sipmsg *msg)
765 {
766 sipe_xml *xn_conference_info;
767 const sipe_xml *node;
768 const sipe_xml *xn_subject;
769 const gchar *focus_uri;
770 struct sip_session *session;
771 gboolean just_joined = FALSE;
772 #ifdef HAVE_VV
773 gboolean audio_was_added = FALSE;
774 #endif
775
776 if (msg->response != 0 && msg->response != 200) return;
777
778 if (msg->bodylen == 0 || msg->body == NULL || !sipe_strequal(sipmsg_find_header(msg, "Event"), "conference")) return;
779
780 xn_conference_info = sipe_xml_parse(msg->body, msg->bodylen);
781 if (!xn_conference_info) return;
782
783 focus_uri = sipe_xml_attribute(xn_conference_info, "entity");
784 session = sipe_session_find_conference(sipe_private, focus_uri);
785
786 if (!session) {
787 SIPE_DEBUG_INFO("sipe_process_conference: unable to find conf session with focus=%s", focus_uri);
788 return;
789 }
790
791 if (!session->chat_session->backend) {
792 gchar *self = sip_uri_self(sipe_private);
793
794 /* create chat */
795 session->chat_session->backend = sipe_backend_chat_create(SIPE_CORE_PUBLIC,
796 session->chat_session,
797 session->chat_session->title,
798 self);
799 just_joined = TRUE;
800 /* @TODO ask for full state (re-subscribe) if it was a partial one -
801 * this is to obtain full list of conference participants.
802 */
803 g_free(self);
804 }
805
806 /* subject */
807 if ((xn_subject = sipe_xml_child(xn_conference_info, "conference-description/subject"))) {
808 g_free(session->subject);
809 session->subject = sipe_xml_data(xn_subject);
810 sipe_backend_chat_topic(session->chat_session->backend, session->subject);
811 SIPE_DEBUG_INFO("sipe_process_conference: subject=%s", session->subject ? session->subject : "");
812 }
813
814 /* IM MCU URI */
815 if (!session->im_mcu_uri) {
816 for (node = sipe_xml_child(xn_conference_info, "conference-description/conf-uris/entry");
817 node;
818 node = sipe_xml_twin(node))
819 {
820 gchar *purpose = sipe_xml_data(sipe_xml_child(node, "purpose"));
821
822 if (sipe_strequal("chat", purpose)) {
823 g_free(purpose);
824 session->im_mcu_uri = sipe_xml_data(sipe_xml_child(node, "uri"));
825 SIPE_DEBUG_INFO("sipe_process_conference: im_mcu_uri=%s", session->im_mcu_uri);
826 break;
827 }
828 g_free(purpose);
829 }
830 }
831
832 /* users */
833 for (node = sipe_xml_child(xn_conference_info, "users/user"); node; node = sipe_xml_twin(node)) {
834 const gchar *user_uri = sipe_xml_attribute(node, "entity");
835 const gchar *state = sipe_xml_attribute(node, "state");
836 gchar *role = sipe_xml_data(sipe_xml_child(node, "roles/entry"));
837 gboolean is_operator = sipe_strequal(role, "presenter");
838 gboolean is_in_im_mcu = FALSE;
839 gchar *self = sip_uri_self(sipe_private);
840
841 if (sipe_strequal("deleted", state)) {
842 if (sipe_backend_chat_find(session->chat_session->backend, user_uri)) {
843 sipe_backend_chat_remove(session->chat_session->backend,
844 user_uri);
845 }
846 } else {
847 /* endpoints */
848 const sipe_xml *endpoint;
849 for (endpoint = sipe_xml_child(node, "endpoint"); endpoint; endpoint = sipe_xml_twin(endpoint)) {
850 const gchar *session_type;
851 gchar *status = sipe_xml_data(sipe_xml_child(endpoint, "status"));
852 gboolean connected = sipe_strequal("connected", status);
853 g_free(status);
854
855 if (!connected)
856 continue;
857
858 session_type = sipe_xml_attribute(endpoint, "session-type");
859
860 if (sipe_strequal("chat", session_type)) {
861 is_in_im_mcu = TRUE;
862 if (!sipe_backend_chat_find(session->chat_session->backend, user_uri)) {
863 sipe_backend_chat_add(session->chat_session->backend,
864 user_uri,
865 !just_joined && g_strcasecmp(user_uri, self));
866 }
867 if (is_operator) {
868 sipe_backend_chat_operator(session->chat_session->backend,
869 user_uri);
870 }
871 } else if (sipe_strequal("audio-video", session_type)) {
872 #ifdef HAVE_VV
873 if (!session->is_call)
874 audio_was_added = TRUE;
875 #endif
876 }
877 }
878 if (!is_in_im_mcu) {
879 if (sipe_backend_chat_find(session->chat_session->backend, user_uri)) {
880 sipe_backend_chat_remove(session->chat_session->backend,
881 user_uri);
882 }
883 }
884 }
885 g_free(role);
886 g_free(self);
887 }
888
889 #ifdef HAVE_VV
890 if (audio_was_added) {
891 session->is_call = TRUE;
892 sipe_core_media_connect_conference(SIPE_CORE_PUBLIC,
893 session->chat_session, FALSE);
894 }
895 #endif
896
897 /* entity-view, locked */
898 for (node = sipe_xml_child(xn_conference_info, "conference-view/entity-view");
899 node;
900 node = sipe_xml_twin(node)) {
901
902 const sipe_xml *xn_type = sipe_xml_child(node, "entity-state/media/entry/type");
903 gchar *tmp = NULL;
904 if (xn_type && sipe_strequal("chat", (tmp = sipe_xml_data(xn_type)))) {
905 const sipe_xml *xn_locked = sipe_xml_child(node, "entity-state/locked");
906 if (xn_locked) {
907 gchar *locked = sipe_xml_data(xn_locked);
908 gboolean prev_locked = session->locked;
909 session->locked = sipe_strequal(locked, "true");
910 if (prev_locked && !session->locked) {
911 sipe_user_present_info(sipe_private, session,
912 _("This conference is no longer locked. Additional participants can now join."));
913 }
914 if (!prev_locked && session->locked) {
915 sipe_user_present_info(sipe_private, session,
916 _("This conference is locked. Nobody else can join the conference while it is locked."));
917 }
918
919 SIPE_DEBUG_INFO("sipe_process_conference: session->locked=%s",
920 session->locked ? "TRUE" : "FALSE");
921 g_free(locked);
922 }
923 }
924 g_free(tmp);
925 }
926 sipe_xml_free(xn_conference_info);
927
928 if (session->im_mcu_uri) {
929 struct sip_dialog *dialog = sipe_dialog_find(session, session->im_mcu_uri);
930 if (!dialog) {
931 dialog = sipe_dialog_add(session);
932
933 dialog->callid = g_strdup(session->callid);
934 dialog->with = g_strdup(session->im_mcu_uri);
935
936 /* send INVITE to IM MCU */
937 sipe_im_invite(sipe_private, session, dialog->with, NULL, NULL, NULL, FALSE);
938 }
939 }
940
941 sipe_process_pending_invite_queue(sipe_private, session);
942 }
943
944 void
945 sipe_conf_immcu_closed(struct sipe_core_private *sipe_private,
946 struct sip_session *session)
947 {
948 sipe_user_present_info(sipe_private, session,
949 _("You have been disconnected from this conference."));
950 sipe_backend_chat_close(session->chat_session->backend);
951 }
952
953 void
954 conf_session_close(struct sipe_core_private *sipe_private,
955 struct sip_session *session)
956 {
957 if (session) {
958 /* unsubscribe from focus */
959 sipe_subscribe_conference(sipe_private, session, TRUE);
960
961 if (session->focus_dialog) {
962 /* send BYE to focus */
963 sip_transport_bye(sipe_private, session->focus_dialog);
964 }
965 }
966 }
967
968 void
969 sipe_process_imdn(struct sipe_core_private *sipe_private,
970 struct sipmsg *msg)
971 {
972 gchar *with = parse_from(sipmsg_find_header(msg, "From"));
973 const gchar *callid = sipmsg_find_header(msg, "Call-ID");
974 static struct sip_session *session;
975 sipe_xml *xn_imdn;
976 const sipe_xml *node;
977 gchar *message_id;
978 gchar *message;
979
980 session = sipe_session_find_chat_or_im(sipe_private, callid, with);
981 if (!session) {
982 SIPE_DEBUG_INFO("sipe_process_imdn: unable to find conf session with callid=%s", callid);
983 g_free(with);
984 return;
985 }
986
987 xn_imdn = sipe_xml_parse(msg->body, msg->bodylen);
988 message_id = sipe_xml_data(sipe_xml_child(xn_imdn, "message-id"));
989
990 message = g_hash_table_lookup(session->conf_unconfirmed_messages, message_id);
991
992 /* recipient */
993 for (node = sipe_xml_child(xn_imdn, "recipient"); node; node = sipe_xml_twin(node)) {
994 gchar *tmp = parse_from(sipe_xml_attribute(node, "uri"));
995 gchar *uri = parse_from(tmp);
996 sipe_user_present_message_undelivered(sipe_private, session, -1, -1, uri, message);
997 g_free(tmp);
998 g_free(uri);
999 }
1000
1001 sipe_xml_free(xn_imdn);
1002
1003 g_hash_table_remove(session->conf_unconfirmed_messages, message_id);
1004 SIPE_DEBUG_INFO("sipe_process_imdn: removed message %s from conf_unconfirmed_messages(count=%d)",
1005 message_id, g_hash_table_size(session->conf_unconfirmed_messages));
1006 g_free(message_id);
1007 g_free(with);
1008 }
1009
1010
1011 /*
1012 Local Variables:
1013 mode: c
1014 c-file-style: "bsd"
1015 indent-tabs-mode: t
1016 tab-width: 8
1017 End:
1018 */
A third-party Pidgin plugin for Microsoft LCS/OCS