src/core/sipe-dialog.c

   1 /**
   2  * @file sipe-dialog.c
   3  *
   4  * pidgin-sipe
   5  *
   6  * Copyright (C) 2009 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 #include <stdlib.h>
  24 #include <string.h>
  25 #include <time.h>
  26
  27 #include <glib.h>
  28
  29 #include "sipe-common.h"
  30 #include "sipmsg.h"
  31 #include "sipe-backend.h"
  32 #include "sipe-dialog.h"
  33 #include "sipe-session.h"
  34 #include "sipe-utils.h"
  35 #include "sipe-ft.h"
  36
  37 void sipe_dialog_free(struct sip_dialog *dialog)
  38 {
  39         GSList *entry;
  40         void *data;
  41
  42         if (!dialog) return;
  43
  44         g_free(dialog->with);
  45         g_free(dialog->endpoint_GUID);
  46         entry = dialog->routes;
  47         while (entry) {
  48                 data = entry->data;
  49                 entry = g_slist_remove(entry, data);
  50                 g_free(data);
  51         }
  52         entry = dialog->supported;
  53         while (entry) {
  54                 data = entry->data;
  55                 entry = g_slist_remove(entry, data);
  56                 g_free(data);
  57         }
  58
  59         while (dialog->filetransfers) {
  60                 struct sipe_file_transfer *ft = dialog->filetransfers->data;
  61                 sipe_core_ft_deallocate(ft);
  62         }
  63
  64         g_free(dialog->callid);
  65         g_free(dialog->ourtag);
  66         g_free(dialog->theirtag);
  67         g_free(dialog->theirepid);
  68         g_free(dialog->request);
  69
  70         g_free(dialog);
  71 }
  72
  73 void sipe_subscription_free(struct sip_subscription *subscription)
  74 {
  75         if (!subscription) return;
  76
  77         g_free(subscription->event);
  78         /* NOTE: use cast to prevent BAD_FREE warning from Coverity */
  79         sipe_dialog_free((struct sip_dialog *) subscription);
  80 }
  81
  82 struct sip_dialog *sipe_dialog_add(struct sip_session *session)
  83 {
  84         struct sip_dialog *dialog = g_new0(struct sip_dialog, 1);
  85         session->dialogs = g_slist_append(session->dialogs, dialog);
  86         return(dialog);
  87 }
  88
  89 static struct sip_dialog *
  90 sipe_dialog_find_3(struct sip_session *session,
  91                    struct sip_dialog *dialog_in)
  92 {
  93         if (session && dialog_in) {
  94                 SIPE_DIALOG_FOREACH {
  95                         if (    dialog_in->callid &&
  96                                 dialog_in->ourtag &&
  97                                 dialog_in->theirtag &&
  98
  99                                 dialog->callid &&
 100                                 dialog->ourtag &&
 101                                 dialog->theirtag &&
 102
 103                                 sipe_strcase_equal(dialog_in->callid, dialog->callid) &&
 104                                 sipe_strcase_equal(dialog_in->ourtag, dialog->ourtag) &&
 105                                 sipe_strcase_equal(dialog_in->theirtag, dialog->theirtag))
 106                         {
 107                                 SIPE_DEBUG_INFO("sipe_dialog_find_3 who='%s'",
 108                                                 dialog->with ? dialog->with : "");
 109                                 return dialog;
 110                         }
 111                 } SIPE_DIALOG_FOREACH_END;
 112         }
 113         return NULL;
 114 }
 115
 116 struct sip_dialog *sipe_dialog_find(struct sip_session *session,
 117                                     const gchar *who)
 118 {
 119         if (session && who) {
 120                 SIPE_DIALOG_FOREACH {
 121                         if (dialog->with && sipe_strcase_equal(who, dialog->with)) {
 122                                 SIPE_DEBUG_INFO("sipe_dialog_find who='%s'", who);
 123                                 return dialog;
 124                         }
 125                 } SIPE_DIALOG_FOREACH_END;
 126         }
 127         return NULL;
 128 }
 129
 130 void sipe_dialog_remove(struct sip_session *session, const gchar *who)
 131 {
 132         struct sip_dialog *dialog = sipe_dialog_find(session, who);
 133         if (dialog) {
 134                 SIPE_DEBUG_INFO("sipe_dialog_remove who='%s' with='%s'", who, dialog->with ? dialog->with : "");
 135                 session->dialogs = g_slist_remove(session->dialogs, dialog);
 136                 sipe_dialog_free(dialog);
 137         }
 138 }
 139
 140 void
 141 sipe_dialog_remove_3(struct sip_session *session,
 142                      struct sip_dialog *dialog_in)
 143 {
 144         struct sip_dialog *dialog = sipe_dialog_find_3(session, dialog_in);
 145         if (dialog) {
 146                 SIPE_DEBUG_INFO("sipe_dialog_remove_3 with='%s'",
 147                                 dialog->with ? dialog->with : "");
 148                 session->dialogs = g_slist_remove(session->dialogs, dialog);
 149                 sipe_dialog_free(dialog);
 150         }
 151 }
 152
 153 void sipe_dialog_remove_all(struct sip_session *session)
 154 {
 155         GSList *entry = session->dialogs;
 156         while (entry) {
 157                 struct sip_dialog *dialog = entry->data;
 158                 entry = g_slist_remove(entry, dialog);
 159                 sipe_dialog_free(dialog);
 160         }
 161 }
 162
 163 void sipe_dialog_parse_routes(struct sip_dialog *dialog,
 164                               const struct sipmsg *msg,
 165                               gboolean outgoing)
 166 {
 167         GSList *hdr = msg->headers;
 168         gchar *contact = sipmsg_find_part_of_header(sipmsg_find_header(msg, "Contact"), "<", ">", NULL);
 169
 170         /* Remove old routes */
 171         while (dialog->routes) {
 172                 void *data = dialog->routes->data;
 173                 dialog->routes = g_slist_remove(dialog->routes, data);
 174                 g_free(data);
 175         }
 176         g_free(dialog->request);
 177         dialog->request = NULL;
 178
 179         while (hdr) {
 180                 struct sipnameval *elem = hdr->data;
 181                 if (sipe_strcase_equal(elem->name, "Record-Route")) {
 182                         gchar **parts = g_strsplit(elem->value, ",", 0);
 183                         gchar **part = parts;
 184
 185                         while (*part) {
 186                                 gchar *route = sipmsg_find_part_of_header(*part, "<", ">", NULL);
 187                                 SIPE_DEBUG_INFO("sipe_dialog_parse_routes: route %s", route);
 188                                 dialog->routes = g_slist_append(dialog->routes, route);
 189                                 part++;
 190                         }
 191
 192                         g_strfreev(parts);
 193                 }
 194                 hdr = g_slist_next(hdr);
 195         }
 196         if (outgoing) {
 197                 dialog->routes = g_slist_reverse(dialog->routes);
 198         }
 199
 200         if (contact) {
 201                 dialog->request = contact;
 202         }
 203
 204         /* logic for strict router only - RFC3261 - 12.2.1.1 */
 205         /* @TODO: proper check for presence of 'lr' PARAMETER in URI */
 206         if (dialog->routes && !strstr(dialog->routes->data, ";lr")) {
 207                 dialog->request = dialog->routes->data;
 208                 dialog->routes = g_slist_remove(dialog->routes, dialog->routes->data);
 209                 if (contact) {
 210                         dialog->routes = g_slist_append(dialog->routes, contact);
 211                 }
 212         }
 213 }
 214
 215 static void
 216 sipe_get_supported_header(const struct sipmsg *msg,
 217                           struct sip_dialog *dialog,
 218                           SIPE_UNUSED_PARAMETER gboolean outgoing)
 219 {
 220         GSList *hdr = msg->headers;
 221         struct sipnameval *elem;
 222         while(hdr)
 223         {
 224                 elem = hdr->data;
 225                 if (sipe_strcase_equal(elem->name, "Supported")
 226                         && !g_slist_find_custom(dialog->supported, elem->value, (GCompareFunc)g_ascii_strcasecmp))
 227                 {
 228                         dialog->supported = g_slist_append(dialog->supported, g_strdup(elem->value));
 229
 230                 }
 231                 hdr = g_slist_next(hdr);
 232         }
 233 }
 234
 235 static gchar *find_tag(const gchar *hdr)
 236 {
 237         gchar * tag = sipmsg_find_part_of_header (hdr, "tag=", ";", NULL);
 238         if (!tag) {
 239                 // In case it's at the end and there's no trailing ;
 240                 tag = sipmsg_find_part_of_header (hdr, "tag=", NULL, NULL);
 241         }
 242         return tag;
 243 }
 244
 245 void sipe_dialog_parse(struct sip_dialog *dialog,
 246                        const struct sipmsg *msg,
 247                        gboolean outgoing)
 248 {
 249         gchar *us = outgoing ? "From" : "To";
 250         gchar *them = outgoing ? "To" : "From";
 251         const gchar *session_expires_header;
 252
 253         g_free(dialog->ourtag);
 254         g_free(dialog->theirtag);
 255
 256         dialog->ourtag = find_tag(sipmsg_find_header(msg, us));
 257         dialog->theirtag = find_tag(sipmsg_find_header(msg, them));
 258         if (!dialog->theirepid) {
 259                 dialog->theirepid = sipmsg_find_part_of_header(sipmsg_find_header(msg, them), "epid=", ";", NULL);
 260                 if (!dialog->theirepid) {
 261                         dialog->theirepid = sipmsg_find_part_of_header(sipmsg_find_header(msg, them), "epid=", NULL, NULL);
 262                 }
 263         }
 264
 265         // Catch a tag on the end of the To Header and get rid of it.
 266         if (dialog->theirepid && strstr(dialog->theirepid, "tag=")) {
 267                 dialog->theirepid = strtok(dialog->theirepid, ";");
 268         }
 269
 270         if ((session_expires_header = sipmsg_find_header(msg, "Session-Expires"))) {
 271                 dialog->expires = atoi(session_expires_header);
 272         }
 273
 274         sipe_dialog_parse_routes(dialog, msg, outgoing);
 275         sipe_get_supported_header(msg, dialog, outgoing);
 276 }
 277
 278 /*
 279   Local Variables:
 280   mode: c
 281   c-file-style: "bsd"
 282   indent-tabs-mode: t
 283   tab-width: 8
 284   End:
 285 */