src/core/sdpmsg.c

   1 /**
   2  * @file sdpmsg.c
   3  *
   4  * pidgin-sipe
   5  *
   6  * Copyright (C) 2013-2015 SIPE Project <http://sipe.sourceforge.net/>
   7  * Copyright (C) 2010 Jakub Adam <jakub.adam@ktknet.cz>
   8  *
   9  * This program is free software; you can redistribute it and/or modify
  10  * it under the terms of the GNU General Public License as published by
  11  * the Free Software Foundation; either version 2 of the License, or
  12  * (at your option) any later version.
  13  *
  14  * This program is distributed in the hope that it will be useful,
  15  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  16  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  17  * GNU General Public License for more details.
  18  *
  19  * You should have received a copy of the GNU General Public License
  20  * along with this program; if not, write to the Free Software
  21  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  22  */
  23
  24 #include <stdio.h>
  25 #include <stdlib.h>
  26 #include <string.h>
  27
  28 #include <glib.h>
  29
  30 #include "sipe-backend.h"
  31 #include "sipe-core.h"
  32 #include "sdpmsg.h"
  33 #include "sipe-utils.h"
  34
  35 static gboolean
  36 append_attribute(struct sdpmedia *media, gchar *attr)
  37 {
  38         gchar **parts = g_strsplit(attr + 2, ":", 2);
  39
  40         if(!parts[0]) {
  41                 g_strfreev(parts);
  42                 return FALSE;
  43         }
  44
  45         media->attributes = sipe_utils_nameval_add(media->attributes,
  46                                                    parts[0],
  47                                                    parts[1] ? parts[1] : "");
  48         g_strfreev(parts);
  49         return TRUE;
  50 }
  51
  52 static gboolean
  53 parse_attributes(struct sdpmsg *smsg, gchar *msg) {
  54         gchar           **lines = g_strsplit(msg, "\r\n", 0);
  55         gchar           **ptr = lines;
  56
  57         while (*ptr != NULL) {
  58                 if (g_str_has_prefix(*ptr, "o=")) {
  59                         gchar **parts = g_strsplit(*ptr + 2, " ", 6);
  60                         smsg->ip = g_strdup(parts[5]);
  61                         g_strfreev(parts);
  62                 } else if (g_str_has_prefix(*ptr, "m=")) {
  63                         gchar **parts = g_strsplit(*ptr + 2, " ", 3);
  64                         struct sdpmedia *media = g_new0(struct sdpmedia, 1);
  65
  66                         smsg->media = g_slist_append(smsg->media, media);
  67
  68                         media->name = g_strdup(parts[0]);
  69                         media->port = atoi(parts[1]);
  70                         media->encryption_active =
  71                                         g_strstr_len(parts[2], -1, "/SAVP") != NULL;
  72
  73                         g_strfreev(parts);
  74
  75                         while (*(++ptr) && !g_str_has_prefix(*ptr, "m=")) {
  76
  77                                 if (g_str_has_prefix(*ptr, "a=")) {
  78                                         if (!append_attribute(media, *ptr)) {
  79                                                 g_strfreev(lines);
  80                                                 return FALSE;
  81                                         }
  82                                 }
  83                         }
  84                         continue;
  85                 }
  86
  87                 ++ptr;
  88         }
  89
  90         g_strfreev(lines);
  91
  92         return TRUE;
  93 }
  94
  95 static struct sdpcandidate * sdpcandidate_copy(struct sdpcandidate *candidate);
  96
  97 static SipeComponentType
  98 parse_component(const gchar *str)
  99 {
 100         switch (atoi(str)) {
 101                 case 1: return  SIPE_COMPONENT_RTP;
 102                 case 2: return  SIPE_COMPONENT_RTCP;
 103                 default: return SIPE_COMPONENT_NONE;
 104         }
 105 }
 106
 107 static gchar *
 108 base64_pad(const gchar* str)
 109 {
 110         size_t str_len = strlen(str);
 111         int mod = str_len % 4;
 112
 113         if (mod > 0) {
 114                 gchar *result = NULL;
 115                 int pad = 4 - mod;
 116                 gchar *ptr = result = g_malloc(str_len + pad + 1);
 117
 118                 memcpy(ptr, str, str_len);
 119                 ptr += str_len;
 120                 memset(ptr, '=', pad);
 121                 ptr += pad;
 122                 *ptr = '\0';
 123
 124                 return result;
 125         } else
 126                 return g_strdup(str);
 127 }
 128
 129 static GSList *
 130 parse_append_candidate_draft_6(gchar **tokens, GSList *candidates)
 131 {
 132         struct sdpcandidate *candidate = g_new0(struct sdpcandidate, 1);
 133
 134         candidate->username = base64_pad(tokens[0]);
 135         candidate->component = parse_component(tokens[1]);
 136         candidate->password = base64_pad(tokens[2]);
 137
 138         if (sipe_strequal(tokens[3], "UDP"))
 139                 candidate->protocol = SIPE_NETWORK_PROTOCOL_UDP;
 140         else if (sipe_strequal(tokens[3], "TCP"))
 141                 candidate->protocol = SIPE_NETWORK_PROTOCOL_TCP_ACTIVE;
 142         else {
 143                 sdpcandidate_free(candidate);
 144                 return candidates;
 145         }
 146
 147         candidate->priority = atoi(tokens[4] + 2);
 148         candidate->ip = g_strdup(tokens[5]);
 149         candidate->port = atoi(tokens[6]);
 150
 151         candidates = g_slist_append(candidates, candidate);
 152
 153         // draft 6 candidates are both active and passive
 154         if (candidate->protocol == SIPE_NETWORK_PROTOCOL_TCP_ACTIVE) {
 155                 candidate = sdpcandidate_copy(candidate);
 156                 candidate->protocol = SIPE_NETWORK_PROTOCOL_TCP_PASSIVE;
 157                 candidates = g_slist_append(candidates, candidate);
 158         }
 159
 160         return candidates;
 161 }
 162
 163 static GSList *
 164 parse_append_candidate_rfc_5245(gchar **tokens, GSList *candidates)
 165 {
 166         struct sdpcandidate *candidate = g_new0(struct sdpcandidate, 1);
 167
 168         candidate->foundation = g_strdup(tokens[0]);
 169         candidate->component = parse_component(tokens[1]);
 170
 171         if (sipe_strcase_equal(tokens[2], "UDP"))
 172                 candidate->protocol = SIPE_NETWORK_PROTOCOL_UDP;
 173         else if (sipe_strcase_equal(tokens[2], "TCP-ACT"))
 174                 candidate->protocol = SIPE_NETWORK_PROTOCOL_TCP_ACTIVE;
 175         else if (sipe_strcase_equal(tokens[2], "TCP-PASS"))
 176                 candidate->protocol = SIPE_NETWORK_PROTOCOL_TCP_PASSIVE;
 177         else {
 178                 sdpcandidate_free(candidate);
 179                 return candidates;
 180         }
 181
 182         candidate->priority = atoi(tokens[3]);
 183         candidate->ip = g_strdup(tokens[4]);
 184         candidate->port = atoi(tokens[5]);
 185
 186         if (sipe_strcase_equal(tokens[7], "host"))
 187                 candidate->type = SIPE_CANDIDATE_TYPE_HOST;
 188         else if (sipe_strcase_equal(tokens[7], "relay"))
 189                 candidate->type = SIPE_CANDIDATE_TYPE_RELAY;
 190         else if (sipe_strcase_equal(tokens[7], "srflx"))
 191                 candidate->type = SIPE_CANDIDATE_TYPE_SRFLX;
 192         else if (sipe_strcase_equal(tokens[7], "prflx"))
 193                 candidate->type = SIPE_CANDIDATE_TYPE_PRFLX;
 194         else {
 195                 sdpcandidate_free(candidate);
 196                 return candidates;
 197         }
 198
 199         candidates = g_slist_append(candidates, candidate);
 200
 201         // TCP-ACT candidates are both active and passive
 202         if (candidate->protocol == SIPE_NETWORK_PROTOCOL_TCP_ACTIVE) {
 203                 candidate = sdpcandidate_copy(candidate);
 204                 candidate->protocol = SIPE_NETWORK_PROTOCOL_TCP_PASSIVE;
 205                 candidates = g_slist_append(candidates, candidate);
 206         }
 207         return candidates;
 208 }
 209
 210 static GSList *
 211 parse_candidates(GSList *attrs, SipeIceVersion *ice_version)
 212 {
 213         GSList *candidates = NULL;
 214         const gchar *attr;
 215         int i = 0;
 216
 217         while ((attr = sipe_utils_nameval_find_instance(attrs, "candidate", i++))) {
 218                 gchar **tokens = g_strsplit_set(attr, " ", 0);
 219
 220                 if (sipe_strequal(tokens[6], "typ")) {
 221                         candidates = parse_append_candidate_rfc_5245(tokens, candidates);
 222                         if (candidates)
 223                                 *ice_version = SIPE_ICE_RFC_5245;
 224                 } else {
 225                         candidates = parse_append_candidate_draft_6(tokens, candidates);
 226                         if (candidates)
 227                                 *ice_version = SIPE_ICE_DRAFT_6;
 228                 }
 229
 230                 g_strfreev(tokens);
 231         }
 232
 233         if (!candidates)
 234                 *ice_version = SIPE_ICE_NO_ICE;
 235
 236         if (*ice_version == SIPE_ICE_RFC_5245) {
 237                 const gchar *username = sipe_utils_nameval_find(attrs, "ice-ufrag");
 238                 const gchar *password = sipe_utils_nameval_find(attrs, "ice-pwd");
 239
 240                 if (username && password) {
 241                         GSList *i;
 242                         for (i = candidates; i; i = i->next) {
 243                                 struct sdpcandidate *c = i->data;
 244                                 c->username = g_strdup(username);
 245                                 c->password = g_strdup(password);
 246                         }
 247                 }
 248         }
 249
 250         return candidates;
 251 }
 252
 253 static GSList *
 254 create_legacy_candidates(gchar *ip, guint16 port)
 255 {
 256         struct sdpcandidate *candidate;
 257         GSList *candidates = NULL;
 258
 259         candidate = g_new0(struct sdpcandidate, 1);
 260         candidate->foundation = g_strdup("1");
 261         candidate->component = SIPE_COMPONENT_RTP;
 262         candidate->type = SIPE_CANDIDATE_TYPE_HOST;
 263         candidate->protocol = SIPE_NETWORK_PROTOCOL_UDP;
 264         candidate->ip = g_strdup(ip);
 265         candidate->port = port;
 266
 267         candidates = g_slist_append(candidates, candidate);
 268
 269         candidate = g_new0(struct sdpcandidate, 1);
 270         candidate->foundation = g_strdup("1");
 271         candidate->component = SIPE_COMPONENT_RTCP;
 272         candidate->type = SIPE_CANDIDATE_TYPE_HOST;
 273         candidate->protocol = SIPE_NETWORK_PROTOCOL_UDP;
 274         candidate->ip = g_strdup(ip);
 275         candidate->port = port + 1;
 276
 277         candidates = g_slist_append(candidates, candidate);
 278
 279         return candidates;
 280 }
 281
 282 static GSList *
 283 parse_codecs(GSList *attrs, SipeMediaType type)
 284 {
 285         int i = 0;
 286         const gchar *attr;
 287         GSList *codecs = NULL;
 288
 289         while ((attr = sipe_utils_nameval_find_instance(attrs, "rtpmap", i++))) {
 290                 struct sdpcodec *codec = g_new0(struct sdpcodec, 1);
 291                 gchar **tokens = g_strsplit_set(attr, " /", 3);
 292
 293                 int j = 0;
 294                 const gchar* params;
 295
 296                 codec->id = atoi(tokens[0]);
 297                 codec->name = g_strdup(tokens[1]);
 298                 codec->clock_rate = atoi(tokens[2]);
 299                 codec->type = type;
 300
 301                 // TODO: more secure and effective implementation
 302                 while((params = sipe_utils_nameval_find_instance(attrs, "fmtp", j++))) {
 303                         gchar **tokens = g_strsplit_set(params, " ", 0);
 304                         gchar **next = tokens + 1;
 305
 306                         if (atoi(tokens[0]) == codec->id) {
 307                                 while (*next) {
 308                                         gchar name[50];
 309                                         gchar value[50];
 310
 311                                         if (sscanf(*next, "%[a-zA-Z0-9]=%s", name, value) == 2)
 312                                                 codec->parameters = sipe_utils_nameval_add(codec->parameters, name, value);
 313
 314                                         ++next;
 315                                 }
 316                         }
 317
 318                         g_strfreev(tokens);
 319                 }
 320
 321                 codecs = g_slist_append(codecs, codec);
 322                 g_strfreev(tokens);
 323         }
 324
 325         return codecs;
 326 }
 327
 328 static void
 329 parse_encryption_key(GSList *attrs, guchar **key, int *key_id)
 330 {
 331         int i = 0;
 332         const gchar *attr;
 333
 334         while ((attr = sipe_utils_nameval_find_instance(attrs, "crypto", i++))) {
 335                 gchar **tokens = g_strsplit_set(attr, " :|", 6);
 336
 337                 if (tokens[0] && tokens[1] && tokens[2] && tokens[3] && tokens[4] &&
 338                     sipe_strcase_equal(tokens[1], "AES_CM_128_HMAC_SHA1_80") &&
 339                     sipe_strequal(tokens[2], "inline") &&
 340                     !tokens[5]) {
 341                         gsize key_len;
 342                         *key = g_base64_decode(tokens[3], &key_len);
 343                         if (key_len != SIPE_SRTP_KEY_LEN) {
 344                                 g_free(*key);
 345                                 *key = NULL;
 346                         }
 347                         *key_id = atoi(tokens[0]);
 348                 }
 349
 350                 g_strfreev(tokens);
 351
 352                 if (*key) {
 353                         break;
 354                 }
 355         }
 356 }
 357
 358 struct sdpmsg *
 359 sdpmsg_parse_msg(gchar *msg)
 360 {
 361         struct sdpmsg *smsg = g_new0(struct sdpmsg, 1);
 362         GSList *i;
 363
 364         if (!parse_attributes(smsg, msg)) {
 365                 sdpmsg_free(smsg);
 366                 return NULL;
 367         }
 368
 369         for (i = smsg->media; i; i = i->next) {
 370                 struct sdpmedia *media = i->data;
 371                 SipeMediaType type;
 372
 373                 media->candidates = parse_candidates(media->attributes,
 374                                                      &smsg->ice_version);
 375
 376                 if (!media->candidates && media->port != 0) {
 377                         // No a=candidate in SDP message, this seems to be MSOC 2005
 378                         media->candidates = create_legacy_candidates(smsg->ip, media->port);
 379                 }
 380
 381                 if (sipe_strequal(media->name, "audio"))
 382                         type = SIPE_MEDIA_AUDIO;
 383                 else if (sipe_strequal(media->name, "video"))
 384                         type = SIPE_MEDIA_VIDEO;
 385                 else if (sipe_strequal(media->name, "data"))
 386                         type = SIPE_MEDIA_APPLICATION;
 387                 else {
 388                         // Unknown media type
 389                         sdpmsg_free(smsg);
 390                         return NULL;
 391                 }
 392
 393                 media->codecs = parse_codecs(media->attributes, type);
 394                 parse_encryption_key(media->attributes, &media->encryption_key,
 395                                 &media->encryption_key_id);
 396         }
 397
 398         return smsg;
 399 }
 400
 401 static gchar *
 402 codecs_to_string(GSList *codecs)
 403 {
 404         GString *result = g_string_new(NULL);
 405
 406         for (; codecs; codecs = codecs->next) {
 407                 struct sdpcodec *c = codecs->data;
 408                 GSList *params = c->parameters;
 409
 410                 g_string_append_printf(result,
 411                                        "a=rtpmap:%d %s/%d\r\n",
 412                                        c->id,
 413                                        c->name,
 414                                        c->clock_rate);
 415
 416                 if (params) {
 417                         GString *param_str = g_string_new(NULL);
 418                         int written_params = 0;
 419
 420                         g_string_append_printf(param_str, "a=fmtp:%d", c->id);
 421
 422                         for (; params; params = params->next) {
 423                                 struct sipnameval* par = params->data;
 424                                 if (sipe_strequal(par->name, "farsight-send-profile")) {
 425                                         // Lync AVMCU doesn't like this property.
 426                                         continue;
 427                                 }
 428
 429                                 g_string_append_printf(param_str, " %s=%s",
 430                                                        par->name, par->value);
 431                                 ++written_params;
 432                         }
 433
 434                         g_string_append(param_str, "\r\n");
 435
 436                         if (written_params > 0) {
 437                                 g_string_append(result, param_str->str);
 438                         }
 439
 440                         g_string_free(param_str, TRUE);
 441                 }
 442         }
 443
 444         return g_string_free(result, FALSE);
 445 }
 446
 447 static gchar *
 448 codec_ids_to_string(GSList *codecs)
 449 {
 450         GString *result = g_string_new(NULL);
 451
 452         for (; codecs; codecs = codecs->next) {
 453                 struct sdpcodec *c = codecs->data;
 454                 g_string_append_printf(result, " %d", c->id);
 455         }
 456
 457         return g_string_free(result, FALSE);
 458 }
 459
 460 static gchar *
 461 base64_unpad(const gchar *str)
 462 {
 463         gchar *result = g_strdup(str);
 464         gchar *ptr;
 465
 466         for (ptr = result + strlen(result); ptr != result; --ptr) {
 467                 if (*(ptr - 1) != '=') {
 468                         *ptr = '\0';
 469                         break;
 470                 }
 471         }
 472
 473         return result;
 474 }
 475
 476 static gchar *
 477 candidates_to_string(GSList *candidates, SipeIceVersion ice_version)
 478 {
 479         GString *result = g_string_new("");
 480         GSList *i;
 481         GSList *processed_tcp_candidates = NULL;
 482
 483         for (i = candidates; i; i = i->next) {
 484                 struct sdpcandidate *c = i->data;
 485                 const gchar *protocol;
 486                 const gchar *type;
 487                 gchar *related = NULL;
 488
 489                 if (ice_version == SIPE_ICE_RFC_5245) {
 490
 491                         switch (c->protocol) {
 492                                 case SIPE_NETWORK_PROTOCOL_TCP_ACTIVE:
 493                                         protocol = "TCP-ACT";
 494                                         break;
 495                                 case SIPE_NETWORK_PROTOCOL_TCP_PASSIVE:
 496                                         protocol = "TCP-PASS";
 497                                         break;
 498                                 case SIPE_NETWORK_PROTOCOL_UDP:
 499                                         protocol = "UDP";
 500                                         break;
 501                                 default:
 502                                         /* error unknown/unsupported type */
 503                                         protocol = "UNKNOWN";
 504                                         break;
 505                         }
 506
 507                         switch (c->type) {
 508                                 case SIPE_CANDIDATE_TYPE_HOST:
 509                                         type = "host";
 510                                         break;
 511                                 case SIPE_CANDIDATE_TYPE_RELAY:
 512                                         type = "relay";
 513                                         break;
 514                                 case SIPE_CANDIDATE_TYPE_SRFLX:
 515                                         type = "srflx";
 516                                         break;
 517                                 case SIPE_CANDIDATE_TYPE_PRFLX:
 518                                         type = "prflx";
 519                                         break;
 520                                 default:
 521                                         /* error unknown/unsupported type */
 522                                         type = "unknown";
 523                                         break;
 524                         }
 525
 526                         switch (c->type) {
 527                                 case SIPE_CANDIDATE_TYPE_RELAY:
 528                                 case SIPE_CANDIDATE_TYPE_SRFLX:
 529                                 case SIPE_CANDIDATE_TYPE_PRFLX:
 530                                         related = g_strdup_printf("raddr %s rport %d",
 531                                                                   c->base_ip,
 532                                                                   c->base_port);
 533                                         break;
 534                                 default:
 535                                         break;
 536                         }
 537
 538                         g_string_append_printf(result,
 539                                                "a=candidate:%s %u %s %u %s %d typ %s %s\r\n",
 540                                                c->foundation,
 541                                                c->component,
 542                                                protocol,
 543                                                c->priority,
 544                                                c->ip,
 545                                                c->port,
 546                                                type,
 547                                                related ? related : "");
 548                         g_free(related);
 549
 550                 } else if (ice_version == SIPE_ICE_DRAFT_6) {
 551                         gchar *username;
 552                         gchar *password;
 553
 554                         switch (c->protocol) {
 555                                 case SIPE_NETWORK_PROTOCOL_TCP_ACTIVE:
 556                                 case SIPE_NETWORK_PROTOCOL_TCP_PASSIVE: {
 557                                         GSList *prev_cand = processed_tcp_candidates;
 558                                         for (; prev_cand; prev_cand = prev_cand->next) {
 559                                                 struct sdpcandidate *c2 = (struct sdpcandidate *)prev_cand->data;
 560
 561                                                 if (sipe_strequal(c->ip, c2->ip) &&
 562                                                     c->component == c2->component) {
 563                                                         break;
 564                                                 }
 565                                         }
 566
 567                                         if (prev_cand) {
 568                                                 protocol = NULL;
 569                                         } else {
 570                                                 protocol = "TCP";
 571                                                 processed_tcp_candidates =
 572                                                         g_slist_append(processed_tcp_candidates, c);
 573                                         }
 574                                         break;
 575                                 }
 576                                 case SIPE_NETWORK_PROTOCOL_UDP:
 577                                         protocol = "UDP";
 578                                         break;
 579                                 default:
 580                                         /* unknown/unsupported type, ignore */
 581                                         protocol = NULL;
 582                                         break;
 583                         }
 584
 585                         if (!protocol) {
 586                                 continue;
 587                         }
 588
 589                         username = base64_unpad(c->username);
 590                         password = base64_unpad(c->password);
 591
 592                         g_string_append_printf(result,
 593                                                "a=candidate:%s %u %s %s 0.%u %s %d\r\n",
 594                                                username,
 595                                                c->component,
 596                                                password,
 597                                                protocol,
 598                                                c->priority,
 599                                                c->ip,
 600                                                c->port);
 601
 602                         g_free(username);
 603                         g_free(password);
 604                 }
 605         }
 606
 607         g_slist_free(processed_tcp_candidates);
 608
 609         return g_string_free(result, FALSE);
 610 }
 611
 612 static gchar *
 613 remote_candidates_to_string(GSList *candidates, SipeIceVersion ice_version)
 614 {
 615         GString *result = g_string_new("");
 616
 617         if (candidates) {
 618                 if (ice_version == SIPE_ICE_RFC_5245) {
 619                         GSList *i;
 620                         g_string_append(result, "a=remote-candidates:");
 621
 622                         for (i = candidates; i; i = i->next) {
 623                                 struct sdpcandidate *c = i->data;
 624                                 g_string_append_printf(result, "%u %s %u ",
 625                                                        c->component, c->ip, c->port);
 626                         }
 627
 628                         g_string_append(result, "\r\n");
 629                 } else if (ice_version == SIPE_ICE_DRAFT_6) {
 630                         struct sdpcandidate *c = candidates->data;
 631                         g_string_append_printf(result, "a=remote-candidate:%s\r\n",
 632                                                c->username);
 633                 }
 634         }
 635
 636         return g_string_free(result, FALSE);
 637 }
 638
 639 static gchar *
 640 attributes_to_string(GSList *attributes)
 641 {
 642         GString *result = g_string_new("");
 643
 644         for (; attributes; attributes = attributes->next) {
 645                 struct sipnameval *a = attributes->data;
 646                 g_string_append_printf(result, "a=%s", a->name);
 647                 if (!sipe_strequal(a->value, ""))
 648                         g_string_append_printf(result, ":%s", a->value);
 649                 g_string_append(result, "\r\n");
 650         }
 651
 652         return g_string_free(result, FALSE);
 653 }
 654
 655 static gchar *
 656 media_to_string(const struct sdpmsg *msg, const struct sdpmedia *media)
 657 {
 658         gchar *media_str;
 659
 660         gchar *transport_profile = NULL;
 661
 662         gchar *media_conninfo = NULL;
 663
 664         gchar *codecs_str = NULL;
 665         gchar *codec_ids_str = codec_ids_to_string(media->codecs);
 666
 667         gchar *candidates_str = NULL;
 668         gchar *remote_candidates_str = NULL;
 669
 670         gchar *attributes_str = NULL;
 671         gchar *credentials = NULL;
 672
 673         gchar *crypto = NULL;
 674
 675         gboolean uses_tcp_transport = TRUE;
 676
 677         if (media->port != 0) {
 678                 if (!sipe_strequal(msg->ip, media->ip)) {
 679                         media_conninfo = g_strdup_printf("c=IN IP4 %s\r\n", media->ip);
 680                 }
 681
 682                 codecs_str = codecs_to_string(media->codecs);
 683                 candidates_str = candidates_to_string(media->candidates, msg->ice_version);
 684                 remote_candidates_str = remote_candidates_to_string(media->remote_candidates,
 685                                                                     msg->ice_version);
 686
 687                 if (media->remote_candidates) {
 688                         struct sdpcandidate *c = media->remote_candidates->data;
 689                         uses_tcp_transport =
 690                                 c->protocol == SIPE_NETWORK_PROTOCOL_TCP_ACTIVE ||
 691                                 c->protocol == SIPE_NETWORK_PROTOCOL_TCP_PASSIVE ||
 692                                 c->protocol == SIPE_NETWORK_PROTOCOL_TCP_SO;
 693                 } else {
 694                         GSList *candidates = media->candidates;
 695                         for (; candidates; candidates = candidates->next) {
 696                                 struct sdpcandidate *c = candidates->data;
 697                                 if (c->protocol == SIPE_NETWORK_PROTOCOL_UDP) {
 698                                         uses_tcp_transport = FALSE;
 699                                         break;
 700                                 }
 701                         }
 702                 }
 703
 704                 attributes_str = attributes_to_string(media->attributes);
 705
 706                 if (msg->ice_version == SIPE_ICE_RFC_5245 && media->candidates) {
 707                         struct sdpcandidate *c = media->candidates->data;
 708
 709                         credentials = g_strdup_printf("a=ice-ufrag:%s\r\n"
 710                                                       "a=ice-pwd:%s\r\n",
 711                                                       c->username,
 712                                                       c->password);
 713                 }
 714
 715                 if (media->encryption_key) {
 716                         gchar *key_encoded = g_base64_encode(media->encryption_key, SIPE_SRTP_KEY_LEN);
 717                         crypto = g_strdup_printf("a=crypto:%d AES_CM_128_HMAC_SHA1_80 inline:%s|2^31\r\n",
 718                                         media->encryption_key_id, key_encoded);
 719                         g_free(key_encoded);
 720                 }
 721         }
 722
 723         transport_profile = g_strdup_printf("%sRTP/%sAVP",
 724                                             uses_tcp_transport ? "TCP/" : "",
 725                                             media->encryption_active ? "S" : "");
 726
 727         media_str = g_strdup_printf("m=%s %d %s%s\r\n"
 728                                     "%s"
 729                                     "%s"
 730                                     "%s"
 731                                     "%s"
 732                                     "%s"
 733                                     "%s"
 734                                     "%s",
 735                                     media->name, media->port, transport_profile, codec_ids_str,
 736                                     media_conninfo ? media_conninfo : "",
 737                                     candidates_str ? candidates_str : "",
 738                                     crypto ? crypto : "",
 739                                     remote_candidates_str ? remote_candidates_str : "",
 740                                     codecs_str ? codecs_str : "",
 741                                     attributes_str ? attributes_str : "",
 742                                     credentials ? credentials : "");
 743
 744         g_free(transport_profile);
 745         g_free(media_conninfo);
 746         g_free(codecs_str);
 747         g_free(codec_ids_str);
 748         g_free(candidates_str);
 749         g_free(remote_candidates_str);
 750         g_free(attributes_str);
 751         g_free(credentials);
 752         g_free(crypto);
 753
 754         return media_str;
 755 }
 756
 757 gchar *
 758 sdpmsg_to_string(const struct sdpmsg *msg)
 759 {
 760         GString *body = g_string_new(NULL);
 761         GSList *i;
 762
 763         g_string_append_printf(
 764                 body,
 765                 "v=0\r\n"
 766                 "o=- 0 0 IN IP4 %s\r\n"
 767                 "s=session\r\n"
 768                 "c=IN IP4 %s\r\n"
 769                 "b=CT:99980\r\n"
 770                 "t=0 0\r\n",
 771                 msg->ip, msg->ip);
 772
 773
 774         for (i = msg->media; i; i = i->next) {
 775                 gchar *media_str = media_to_string(msg, i->data);
 776                 g_string_append(body, media_str);
 777                 g_free(media_str);
 778         }
 779
 780         return g_string_free(body, FALSE);
 781 }
 782
 783 static struct sdpcandidate *
 784 sdpcandidate_copy(struct sdpcandidate *candidate)
 785 {
 786         if (candidate) {
 787                 struct sdpcandidate *copy = g_new0(struct sdpcandidate, 1);
 788
 789                 copy->foundation = g_strdup(candidate->foundation);
 790                 copy->component  = candidate->component;
 791                 copy->type       = candidate->type;
 792                 copy->protocol   = candidate->protocol;
 793                 copy->priority   = candidate->priority;
 794                 copy->ip         = g_strdup(candidate->ip);
 795                 copy->port       = candidate->port;
 796                 copy->base_ip    = g_strdup(candidate->base_ip);
 797                 copy->base_port  = candidate->base_port;
 798                 copy->username   = g_strdup(candidate->username);
 799                 copy->password   = g_strdup(candidate->password);
 800
 801                 return copy;
 802         } else
 803                 return NULL;
 804 }
 805
 806 void
 807 sdpcandidate_free(struct sdpcandidate *candidate)
 808 {
 809         if (candidate) {
 810                 g_free(candidate->foundation);
 811                 g_free(candidate->ip);
 812                 g_free(candidate->base_ip);
 813                 g_free(candidate->username);
 814                 g_free(candidate->password);
 815                 g_free(candidate);
 816         }
 817 }
 818
 819 void
 820 sdpcodec_free(struct sdpcodec *codec)
 821 {
 822         if (codec) {
 823                 g_free(codec->name);
 824                 sipe_utils_nameval_free(codec->parameters);
 825                 g_free(codec);
 826         }
 827 }
 828
 829 void
 830 sdpmedia_free(struct sdpmedia *media)
 831 {
 832         if (media) {
 833                 g_free(media->name);
 834                 g_free(media->ip);
 835
 836                 sipe_utils_nameval_free(media->attributes);
 837
 838                 sipe_utils_slist_free_full(media->candidates,
 839                                   (GDestroyNotify) sdpcandidate_free);
 840                 sipe_utils_slist_free_full(media->codecs,
 841                                   (GDestroyNotify) sdpcodec_free);
 842                 sipe_utils_slist_free_full(media->remote_candidates,
 843                                   (GDestroyNotify) sdpcandidate_free);
 844
 845                 g_free(media->encryption_key);
 846
 847                 g_free(media);
 848         }
 849 }
 850
 851 void
 852 sdpmsg_free(struct sdpmsg *msg)
 853 {
 854         if (msg) {
 855                 g_free(msg->ip);
 856                 sipe_utils_slist_free_full(msg->media,
 857                                   (GDestroyNotify) sdpmedia_free);
 858                 g_free(msg);
 859         }
 860 }
 861
 862 /*
 863   Local Variables:
 864   mode: c
 865   c-file-style: "bsd"
 866   indent-tabs-mode: t
 867   tab-width: 8
 868   End:
 869 */