?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
conf: revert most of 0db497786f492e352a935e4986b2686daad954a9
[siplcs.git] / src / core / sipe-conf.c
blobae21e046b0a74c5c7e23d24e447d1b7effb0a207
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 #endif
285 }
286 sipe_xml_free(xn_response);
287 }
288
289 g_free(focus_uri);
290 return TRUE;
291 }
292
293 struct sip_session *
294 sipe_core_conf_create(struct sipe_core_public *sipe_public,
295 const gchar *focus_uri)
296 {
297 gchar *buf;
298 const gchar *focus_uri_ue;
299 struct sip_session *session = NULL;
300
301 focus_uri_ue = buf = sipe_utils_uri_unescape(focus_uri);
302
303 // URI can have this prefix if it was typed in by the user
304 if (g_str_has_prefix(focus_uri_ue, "meet:"))
305 focus_uri_ue += 5;
306
307 if (!focus_uri_ue || !g_str_has_prefix(focus_uri_ue, "sip:") ||
308 strlen(focus_uri_ue) == 4 || g_strstr_len(focus_uri_ue, -1, "%")) {
309 gchar *error = g_strdup_printf(_("\"%s\" is not a valid focus URI"),
310 focus_uri ? focus_uri : "");
311 sipe_backend_notify_error(_("Failed to join the conference"),
312 error);
313 g_free(error);
314 } else {
315 gchar *querystr = g_strstr_len(focus_uri_ue, -1, "?");
316 if (querystr) {
317 /* TODO: Investigate how conf-key field should be used,
318 * ignoring for now */
319 *querystr = '\0';
320 }
321
322 session = sipe_conf_create(SIPE_CORE_PRIVATE, NULL, focus_uri_ue);
323 }
324
325 g_free(buf);
326
327 return session;
328 }
329
330 /** Create new session with Focus URI */
331 struct sip_session *
332 sipe_conf_create(struct sipe_core_private *sipe_private,
333 struct sipe_chat_session *chat_session,
334 const gchar *focus_uri)
335 {
336 gchar *hdr;
337 gchar *contact;
338 gchar *body;
339 gchar *self;
340 struct sip_session *session = sipe_session_add_chat(sipe_private,
341 chat_session,
342 FALSE,
343 focus_uri);
344
345 session->focus_dialog = g_new0(struct sip_dialog, 1);
346 session->focus_dialog->callid = gencallid();
347 session->focus_dialog->with = g_strdup(session->chat_session->id);
348 session->focus_dialog->endpoint_GUID = rand_guid();
349 session->focus_dialog->ourtag = gentag();
350
351 contact = get_contact(sipe_private);
352 hdr = g_strdup_printf(
353 "Supported: ms-sender\r\n"
354 "Contact: %s\r\n"
355 "Content-Type: application/cccp+xml\r\n",
356 contact);
357 g_free(contact);
358
359 /* @TODO put request_id to queue to further compare with incoming one */
360 /* focus_URI, from, request_id, focus_URI, from, endpoint_GUID */
361 self = sip_uri_self(sipe_private);
362 body = g_strdup_printf(
363 SIPE_SEND_CONF_ADD_USER,
364 session->focus_dialog->with,
365 self,
366 session->request_id++,
367 session->focus_dialog->with,
368 self,
369 session->focus_dialog->endpoint_GUID);
370
371 session->focus_dialog->outgoing_invite =
372 sip_transport_invite(sipe_private,
373 hdr,
374 body,
375 session->focus_dialog,
376 process_invite_conf_focus_response);
377 g_free(body);
378 g_free(hdr);
379
380 /* Rejoin existing session? */
381 if (chat_session) {
382 SIPE_DEBUG_INFO("sipe_conf_create: rejoin '%s' (%s)",
383 chat_session->title,
384 chat_session->id);
385 sipe_backend_chat_rejoin(SIPE_CORE_PUBLIC,
386 chat_session->backend,
387 self,
388 chat_session->title);
389 }
390 g_free(self);
391
392 return(session);
393 }
394
395 /** Modify User Role */
396 void
397 sipe_conf_modify_user_role(struct sipe_core_private *sipe_private,
398 struct sip_session *session,
399 const gchar* who)
400 {
401 gchar *hdr;
402 gchar *body;
403 gchar *self;
404
405 if (!session->focus_dialog || !session->focus_dialog->is_established) {
406 SIPE_DEBUG_INFO_NOFORMAT("sipe_conf_modify_user_role: no dialog with focus, exiting.");
407 return;
408 }
409
410 hdr = g_strdup(
411 "Content-Type: application/cccp+xml\r\n");
412
413 /* @TODO put request_id to queue to further compare with incoming one */
414 self = sip_uri_self(sipe_private);
415 body = g_strdup_printf(
416 SIPE_SEND_CONF_MODIFY_USER_ROLES,
417 session->focus_dialog->with,
418 self,
419 session->request_id++,
420 session->focus_dialog->with,
421 who);
422 g_free(self);
423
424 sip_transport_info(sipe_private,
425 hdr,
426 body,
427 session->focus_dialog,
428 NULL);
429 g_free(body);
430 g_free(hdr);
431 }
432
433 /**
434 * Check conference lock status
435 */
436 sipe_chat_lock_status sipe_core_chat_lock_status(struct sipe_core_public *sipe_public,
437 struct sipe_chat_session *chat_session)
438 {
439 struct sipe_core_private *sipe_private = SIPE_CORE_PRIVATE;
440 sipe_chat_lock_status status = SIPE_CHAT_LOCK_STATUS_NOT_ALLOWED;
441
442 if (chat_session &&
443 (chat_session->type == SIPE_CHAT_TYPE_CONFERENCE)) {
444 struct sip_session *session = sipe_session_find_chat(sipe_private,
445 chat_session);
446 if (session) {
447 gchar *self = sip_uri_self(sipe_private);
448
449 /* Only operators are allowed to change the lock status */
450 if (sipe_backend_chat_is_operator(chat_session->backend, self)) {
451 status = session->locked ?
452 SIPE_CHAT_LOCK_STATUS_LOCKED :
453 SIPE_CHAT_LOCK_STATUS_UNLOCKED;
454 }
455
456 g_free(self);
457 }
458 }
459
460 return(status);
461 }
462
463 /**
464 * Modify Conference Lock
465 * Sends request to Focus.
466 * INFO method is a carrier of application/cccp+xml
467 */
468 void
469 sipe_core_chat_modify_lock(struct sipe_core_public *sipe_public,
470 struct sipe_chat_session *chat_session,
471 const gboolean locked)
472 {
473 struct sipe_core_private *sipe_private = SIPE_CORE_PRIVATE;
474 gchar *hdr;
475 gchar *body;
476 gchar *self;
477
478 struct sip_session *session = sipe_session_find_chat(sipe_private,
479 chat_session);
480
481 if (!session) return;
482 if (!session->focus_dialog || !session->focus_dialog->is_established) {
483 SIPE_DEBUG_INFO_NOFORMAT("sipe_conf_modify_conference_lock: no dialog with focus, exiting.");
484 return;
485 }
486
487 hdr = g_strdup(
488 "Content-Type: application/cccp+xml\r\n");
489
490 /* @TODO put request_id to queue to further compare with incoming one */
491 self = sip_uri_self(sipe_private);
492 body = g_strdup_printf(
493 SIPE_SEND_CONF_MODIFY_CONF_LOCK,
494 session->focus_dialog->with,
495 self,
496 session->request_id++,
497 session->focus_dialog->with,
498 locked ? "true" : "false");
499 g_free(self);
500
501 sip_transport_info(sipe_private,
502 hdr,
503 body,
504 session->focus_dialog,
505 NULL);
506 g_free(body);
507 g_free(hdr);
508 }
509
510 /** Modify Delete User */
511 void
512 sipe_conf_delete_user(struct sipe_core_private *sipe_private,
513 struct sip_session *session,
514 const gchar* who)
515 {
516 gchar *hdr;
517 gchar *body;
518 gchar *self;
519
520 if (!session->focus_dialog || !session->focus_dialog->is_established) {
521 SIPE_DEBUG_INFO_NOFORMAT("sipe_conf_delete_user: no dialog with focus, exiting.");
522 return;
523 }
524
525 hdr = g_strdup(
526 "Content-Type: application/cccp+xml\r\n");
527
528 /* @TODO put request_id to queue to further compare with incoming one */
529 self = sip_uri_self(sipe_private);
530 body = g_strdup_printf(
531 SIPE_SEND_CONF_DELETE_USER,
532 session->focus_dialog->with,
533 self,
534 session->request_id++,
535 session->focus_dialog->with,
536 who);
537 g_free(self);
538
539 sip_transport_info(sipe_private,
540 hdr,
541 body,
542 session->focus_dialog,
543 NULL);
544 g_free(body);
545 g_free(hdr);
546 }
547
548 /** Invite counterparty to join conference callback */
549 static gboolean
550 process_invite_conf_response(struct sipe_core_private *sipe_private,
551 struct sipmsg *msg,
552 SIPE_UNUSED_PARAMETER struct transaction *trans)
553 {
554 struct sip_dialog *dialog = g_new0(struct sip_dialog, 1);
555
556 dialog->callid = g_strdup(sipmsg_find_header(msg, "Call-ID"));
557 dialog->cseq = sipmsg_parse_cseq(msg);
558 dialog->with = parse_from(sipmsg_find_header(msg, "To"));
559 sipe_dialog_parse(dialog, msg, TRUE);
560
561 if (msg->response >= 200) {
562 /* send ACK to counterparty */
563 dialog->cseq--;
564 sip_transport_ack(sipe_private, dialog);
565 dialog->outgoing_invite = NULL;
566 dialog->is_established = TRUE;
567 }
568
569 if (msg->response >= 400) {
570 SIPE_DEBUG_INFO("process_invite_conf_response: INVITE response is not 200. Failed to invite %s.", dialog->with);
571 /* @TODO notify user of failure to invite counterparty */
572 sipe_dialog_free(dialog);
573 return FALSE;
574 }
575
576 if (msg->response >= 200) {
577 struct sip_session *session = sipe_session_find_im(sipe_private, dialog->with);
578 struct sip_dialog *im_dialog = sipe_dialog_find(session, dialog->with);
579
580 /* close IM session to counterparty */
581 if (im_dialog) {
582 sip_transport_bye(sipe_private, im_dialog);
583 sipe_dialog_remove(session, dialog->with);
584 }
585 }
586
587 sipe_dialog_free(dialog);
588 return TRUE;
589 }
590
591 /**
592 * Invites counterparty to join conference.
593 */
594 void
595 sipe_invite_conf(struct sipe_core_private *sipe_private,
596 struct sip_session *session,
597 const gchar* who)
598 {
599 gchar *hdr;
600 gchar *contact;
601 gchar *body;
602 struct sip_dialog *dialog = NULL;
603
604 /* It will be short lived special dialog.
605 * Will not be stored in session.
606 */
607 dialog = g_new0(struct sip_dialog, 1);
608 dialog->callid = gencallid();
609 dialog->with = g_strdup(who);
610 dialog->ourtag = gentag();
611
612 contact = get_contact(sipe_private);
613 hdr = g_strdup_printf(
614 "Supported: ms-sender\r\n"
615 "Contact: %s\r\n"
616 "Content-Type: application/ms-conf-invite+xml\r\n",
617 contact);
618 g_free(contact);
619
620 body = g_strdup_printf(
621 SIPE_SEND_CONF_INVITE,
622 session->chat_session->id,
623 session->subject ? session->subject : ""
624 );
625
626 sip_transport_invite(sipe_private,
627 hdr,
628 body,
629 dialog,
630 process_invite_conf_response);
631
632 sipe_dialog_free(dialog);
633 g_free(body);
634 g_free(hdr);
635 }
636
637 /** Create conference callback */
638 static gboolean
639 process_conf_add_response(struct sipe_core_private *sipe_private,
640 struct sipmsg *msg,
641 struct transaction *trans)
642 {
643 if (msg->response >= 400) {
644 SIPE_DEBUG_INFO_NOFORMAT("process_conf_add_response: SERVICE response is not 200. Failed to create conference.");
645 /* @TODO notify user of failure to create conference */
646 return FALSE;
647 }
648 if (msg->response == 200) {
649 sipe_xml *xn_response = sipe_xml_parse(msg->body, msg->bodylen);
650 if (sipe_strequal("success", sipe_xml_attribute(xn_response, "code")))
651 {
652 gchar *who = trans->payload->data;
653 const sipe_xml *xn_conference_info = sipe_xml_child(xn_response, "addConference/conference-info");
654 struct sip_session *session = sipe_conf_create(sipe_private,
655 NULL,
656 sipe_xml_attribute(xn_conference_info,
657 "entity"));
658
659 SIPE_DEBUG_INFO("process_conf_add_response: session->focus_uri=%s",
660 session->chat_session->id);
661
662 session->pending_invite_queue = slist_insert_unique_sorted(
663 session->pending_invite_queue, g_strdup(who), (GCompareFunc)strcmp);
664 }
665 sipe_xml_free(xn_response);
666 }
667
668 return TRUE;
669 }
670
671 /**
672 * Creates conference.
673 */
674 void
675 sipe_conf_add(struct sipe_core_private *sipe_private,
676 const gchar* who)
677 {
678 gchar *hdr;
679 gchar *conference_id;
680 gchar *contact;
681 gchar *body;
682 gchar *self;
683 struct transaction *trans;
684 struct sip_dialog *dialog = NULL;
685 time_t expiry = time(NULL) + 7*60*60; /* 7 hours */
686 char *expiry_time;
687 struct transaction_payload *payload;
688
689 contact = get_contact(sipe_private);
690 hdr = g_strdup_printf(
691 "Supported: ms-sender\r\n"
692 "Contact: %s\r\n"
693 "Content-Type: application/cccp+xml\r\n",
694 contact);
695 g_free(contact);
696
697 expiry_time = sipe_utils_time_to_str(expiry);
698 self = sip_uri_self(sipe_private);
699 conference_id = genconfid();
700 body = g_strdup_printf(
701 SIPE_SEND_CONF_ADD,
702 sipe_private->focus_factory_uri,
703 self,
704 rand(),
705 conference_id,
706 expiry_time);
707 g_free(self);
708 g_free(conference_id);
709 g_free(expiry_time);
710
711 trans = sip_transport_service(sipe_private,
712 sipe_private->focus_factory_uri,
713 hdr,
714 body,
715 process_conf_add_response);
716
717 payload = g_new0(struct transaction_payload, 1);
718 payload->destroy = g_free;
719 payload->data = g_strdup(who);
720 trans->payload = payload;
721
722 sipe_dialog_free(dialog);
723 g_free(body);
724 g_free(hdr);
725 }
726
727 void
728 process_incoming_invite_conf(struct sipe_core_private *sipe_private,
729 struct sipmsg *msg)
730 {
731 sipe_xml *xn_conferencing = sipe_xml_parse(msg->body, msg->bodylen);
732 const sipe_xml *xn_focus_uri = sipe_xml_child(xn_conferencing, "focus-uri");
733 const sipe_xml *xn_audio = sipe_xml_child(xn_conferencing, "audio");
734 gchar *focus_uri = sipe_xml_data(xn_focus_uri);
735 gboolean audio = sipe_strequal(sipe_xml_attribute(xn_audio, "available"), "true");
736 gchar *newTag = gentag();
737 const gchar *oldHeader = sipmsg_find_header(msg, "To");
738 gchar *newHeader;
739 struct sip_session *session;
740
741 sipe_xml_free(xn_conferencing);
742
743 /* send OK */
744 SIPE_DEBUG_INFO("We have received invitation to Conference. Focus URI=%s", focus_uri);
745
746 newHeader = g_strdup_printf("%s;tag=%s", oldHeader, newTag);
747 g_free(newTag);
748 sipmsg_remove_header_now(msg, "To");
749 sipmsg_add_header_now(msg, "To", newHeader);
750 g_free(newHeader);
751
752 /* acknowledge invite */
753 sip_transport_response(sipe_private, msg, 200, "OK", NULL);
754
755 /* add self to conf */
756 session = sipe_conf_create(sipe_private, NULL, focus_uri);
757 session->is_call = audio;
758 g_free(focus_uri);
759 }
760
761 void
762 sipe_process_conference(struct sipe_core_private *sipe_private,
763 struct sipmsg *msg)
764 {
765 sipe_xml *xn_conference_info;
766 const sipe_xml *node;
767 const sipe_xml *xn_subject;
768 const gchar *focus_uri;
769 struct sip_session *session;
770 gboolean just_joined = FALSE;
771 #ifdef HAVE_VV
772 gboolean audio_was_added = FALSE;
773 #endif
774
775 if (msg->response != 0 && msg->response != 200) return;
776
777 if (msg->bodylen == 0 || msg->body == NULL || !sipe_strequal(sipmsg_find_header(msg, "Event"), "conference")) return;
778
779 xn_conference_info = sipe_xml_parse(msg->body, msg->bodylen);
780 if (!xn_conference_info) return;
781
782 focus_uri = sipe_xml_attribute(xn_conference_info, "entity");
783 session = sipe_session_find_conference(sipe_private, focus_uri);
784
785 if (!session) {
786 SIPE_DEBUG_INFO("sipe_process_conference: unable to find conf session with focus=%s", focus_uri);
787 return;
788 }
789
790 if (!session->chat_session->backend) {
791 gchar *self = sip_uri_self(sipe_private);
792
793 /* create chat */
794 session->chat_session->backend = sipe_backend_chat_create(SIPE_CORE_PUBLIC,
795 session->chat_session,
796 session->chat_session->title,
797 self);
798 just_joined = TRUE;
799 /* @TODO ask for full state (re-subscribe) if it was a partial one -
800 * this is to obtain full list of conference participants.
801 */
802 g_free(self);
803 }
804
805 /* subject */
806 if ((xn_subject = sipe_xml_child(xn_conference_info, "conference-description/subject"))) {
807 g_free(session->subject);
808 session->subject = sipe_xml_data(xn_subject);
809 sipe_backend_chat_topic(session->chat_session->backend, session->subject);
810 SIPE_DEBUG_INFO("sipe_process_conference: subject=%s", session->subject ? session->subject : "");
811 }
812
813 /* IM MCU URI */
814 if (!session->im_mcu_uri) {
815 for (node = sipe_xml_child(xn_conference_info, "conference-description/conf-uris/entry");
816 node;
817 node = sipe_xml_twin(node))
818 {
819 gchar *purpose = sipe_xml_data(sipe_xml_child(node, "purpose"));
820
821 if (sipe_strequal("chat", purpose)) {
822 g_free(purpose);
823 session->im_mcu_uri = sipe_xml_data(sipe_xml_child(node, "uri"));
824 SIPE_DEBUG_INFO("sipe_process_conference: im_mcu_uri=%s", session->im_mcu_uri);
825 break;
826 }
827 g_free(purpose);
828 }
829 }
830
831 /* users */
832 for (node = sipe_xml_child(xn_conference_info, "users/user"); node; node = sipe_xml_twin(node)) {
833 const gchar *user_uri = sipe_xml_attribute(node, "entity");
834 const gchar *state = sipe_xml_attribute(node, "state");
835 gchar *role = sipe_xml_data(sipe_xml_child(node, "roles/entry"));
836 gboolean is_operator = sipe_strequal(role, "presenter");
837 gboolean is_in_im_mcu = FALSE;
838 gchar *self = sip_uri_self(sipe_private);
839
840 if (sipe_strequal("deleted", state)) {
841 if (sipe_backend_chat_find(session->chat_session->backend, user_uri)) {
842 sipe_backend_chat_remove(session->chat_session->backend,
843 user_uri);
844 }
845 } else {
846 /* endpoints */
847 const sipe_xml *endpoint;
848 for (endpoint = sipe_xml_child(node, "endpoint"); endpoint; endpoint = sipe_xml_twin(endpoint)) {
849 const gchar *session_type;
850 gchar *status = sipe_xml_data(sipe_xml_child(endpoint, "status"));
851 gboolean connected = sipe_strequal("connected", status);
852 g_free(status);
853
854 if (!connected)
855 continue;
856
857 session_type = sipe_xml_attribute(endpoint, "session-type");
858
859 if (sipe_strequal("chat", session_type)) {
860 is_in_im_mcu = TRUE;
861 if (!sipe_backend_chat_find(session->chat_session->backend, user_uri)) {
862 sipe_backend_chat_add(session->chat_session->backend,
863 user_uri,
864 !just_joined && g_strcasecmp(user_uri, self));
865 }
866 if (is_operator) {
867 sipe_backend_chat_operator(session->chat_session->backend,
868 user_uri);
869 }
870 } else if (sipe_strequal("audio-video", session_type)) {
871 #ifdef HAVE_VV
872 if (!session->is_call)
873 audio_was_added = TRUE;
874 #endif
875 }
876 }
877 if (!is_in_im_mcu) {
878 if (sipe_backend_chat_find(session->chat_session->backend, user_uri)) {
879 sipe_backend_chat_remove(session->chat_session->backend,
880 user_uri);
881 }
882 }
883 }
884 g_free(role);
885 g_free(self);
886 }
887
888 #ifdef HAVE_VV
889 if (audio_was_added) {
890 session->is_call = TRUE;
891 sipe_core_media_connect_conference(SIPE_CORE_PUBLIC,
892 session->chat_session);
893 }
894 #endif
895
896 /* entity-view, locked */
897 for (node = sipe_xml_child(xn_conference_info, "conference-view/entity-view");
898 node;
899 node = sipe_xml_twin(node)) {
900
901 const sipe_xml *xn_type = sipe_xml_child(node, "entity-state/media/entry/type");
902 gchar *tmp = NULL;
903 if (xn_type && sipe_strequal("chat", (tmp = sipe_xml_data(xn_type)))) {
904 const sipe_xml *xn_locked = sipe_xml_child(node, "entity-state/locked");
905 if (xn_locked) {
906 gchar *locked = sipe_xml_data(xn_locked);
907 gboolean prev_locked = session->locked;
908 session->locked = sipe_strequal(locked, "true");
909 if (prev_locked && !session->locked) {
910 sipe_user_present_info(sipe_private, session,
911 _("This conference is no longer locked. Additional participants can now join."));
912 }
913 if (!prev_locked && session->locked) {
914 sipe_user_present_info(sipe_private, session,
915 _("This conference is locked. Nobody else can join the conference while it is locked."));
916 }
917
918 SIPE_DEBUG_INFO("sipe_process_conference: session->locked=%s",
919 session->locked ? "TRUE" : "FALSE");
920 g_free(locked);
921 }
922 }
923 g_free(tmp);
924 }
925 sipe_xml_free(xn_conference_info);
926
927 if (session->im_mcu_uri) {
928 struct sip_dialog *dialog = sipe_dialog_find(session, session->im_mcu_uri);
929 if (!dialog) {
930 dialog = sipe_dialog_add(session);
931
932 dialog->callid = g_strdup(session->callid);
933 dialog->with = g_strdup(session->im_mcu_uri);
934
935 /* send INVITE to IM MCU */
936 sipe_im_invite(sipe_private, session, dialog->with, NULL, NULL, NULL, FALSE);
937 }
938 }
939
940 sipe_process_pending_invite_queue(sipe_private, session);
941 }
942
943 void
944 sipe_conf_immcu_closed(struct sipe_core_private *sipe_private,
945 struct sip_session *session)
946 {
947 sipe_user_present_info(sipe_private, session,
948 _("You have been disconnected from this conference."));
949 sipe_backend_chat_close(session->chat_session->backend);
950 }
951
952 void
953 conf_session_close(struct sipe_core_private *sipe_private,
954 struct sip_session *session)
955 {
956 if (session) {
957 /* unsubscribe from focus */
958 sipe_subscribe_conference(sipe_private, session, TRUE);
959
960 if (session->focus_dialog) {
961 /* send BYE to focus */
962 sip_transport_bye(sipe_private, session->focus_dialog);
963 }
964 }
965 }
966
967 void
968 sipe_process_imdn(struct sipe_core_private *sipe_private,
969 struct sipmsg *msg)
970 {
971 gchar *with = parse_from(sipmsg_find_header(msg, "From"));
972 const gchar *callid = sipmsg_find_header(msg, "Call-ID");
973 static struct sip_session *session;
974 sipe_xml *xn_imdn;
975 const sipe_xml *node;
976 gchar *message_id;
977 gchar *message;
978
979 session = sipe_session_find_chat_or_im(sipe_private, callid, with);
980 if (!session) {
981 SIPE_DEBUG_INFO("sipe_process_imdn: unable to find conf session with callid=%s", callid);
982 g_free(with);
983 return;
984 }
985
986 xn_imdn = sipe_xml_parse(msg->body, msg->bodylen);
987 message_id = sipe_xml_data(sipe_xml_child(xn_imdn, "message-id"));
988
989 message = g_hash_table_lookup(session->conf_unconfirmed_messages, message_id);
990
991 /* recipient */
992 for (node = sipe_xml_child(xn_imdn, "recipient"); node; node = sipe_xml_twin(node)) {
993 gchar *tmp = parse_from(sipe_xml_attribute(node, "uri"));
994 gchar *uri = parse_from(tmp);
995 sipe_user_present_message_undelivered(sipe_private, session, -1, -1, uri, message);
996 g_free(tmp);
997 g_free(uri);
998 }
999
1000 sipe_xml_free(xn_imdn);
1001
1002 g_hash_table_remove(session->conf_unconfirmed_messages, message_id);
1003 SIPE_DEBUG_INFO("sipe_process_imdn: removed message %s from conf_unconfirmed_messages(count=%d)",
1004 message_id, g_hash_table_size(session->conf_unconfirmed_messages));
1005 g_free(message_id);
1006 g_free(with);
1007 }
1008
1009
1010 /*
1011 Local Variables:
1012 mode: c
1013 c-file-style: "bsd"
1014 indent-tabs-mode: t
1015 tab-width: 8
1016 End:
1017 */
A third-party Pidgin plugin for Microsoft LCS/OCS