summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMarcus Lundblad <malu@pidgin.im>2009-12-06 19:06:42 +0000
committerMarcus Lundblad <malu@pidgin.im>2009-12-06 19:06:42 +0000
commitd8d317dd56201f928d21051d2239f7985b7cfe0b (patch)
treefef305bf30482d2c0d8df1ae16603390cf0bed48
parent8e5e7b6e1c4a978cd0efc41bacf7c23ac55a7a56 (diff)
parent5e46afce403501ad2bf2576a21e4796e80d83fcc (diff)
downloadpidgin-d8d317dd56201f928d21051d2239f7985b7cfe0b.tar.gz
propagate from branch 'im.pidgin.pidgin' (head aa5f5f35a8623c467e518ebe8d27c03ae7dfb3e3)
to branch 'im.pidgin.cpw.malu.xmpp.google_relay' (head 94ef289c55877a23b6fb11adfff448bcc02b9234)
-rw-r--r--libpurple/media.c21
-rw-r--r--libpurple/protocols/jabber/Makefile.am10
-rw-r--r--libpurple/protocols/jabber/google.c337
-rw-r--r--libpurple/protocols/jabber/jabber.c30
-rw-r--r--libpurple/protocols/jabber/jabber.h7
-rw-r--r--libpurple/protocols/jabber/jingle/jingle.c94
-rw-r--r--libpurple/protocols/jabber/jingle/jingle.h6
-rw-r--r--libpurple/protocols/jabber/jingle/rtp.c3
8 files changed, 403 insertions, 105 deletions
diff --git a/libpurple/media.c b/libpurple/media.c
index 4f6356b618..a1029773c9 100644
--- a/libpurple/media.c
+++ b/libpurple/media.c
@@ -2449,7 +2449,7 @@ purple_media_candidate_pair_established_cb(FsStream *fsstream,
FsParticipant *participant;
PurpleMediaStream *stream;
GList *iter;
-
+
g_return_if_fail(FS_IS_STREAM(fsstream));
g_return_if_fail(session != NULL);
@@ -2755,9 +2755,22 @@ purple_media_add_stream(PurpleMedia *media, const gchar *sess_id,
const gchar *stun_ip = purple_network_get_stun_ip();
const gchar *turn_ip = purple_network_get_turn_ip();
- if (stun_ip || turn_ip) {
+ /* check if the prpl has already specified a relay-info
+ we need to do this to allow them to override when using non-standard
+ TURN modes, like Google f.ex. */
+ gboolean got_turn_from_prpl = FALSE;
+ int i;
+
+ for (i = 0 ; i < num_params ; i++) {
+ if (purple_strequal(params[i].name, "relay-info")) {
+ got_turn_from_prpl = TRUE;
+ break;
+ }
+ }
+
+ if (stun_ip || (turn_ip && !got_turn_from_prpl)) {
guint new_num_params =
- (stun_ip && is_nice) && turn_ip ?
+ (stun_ip && is_nice && turn_ip && !got_turn_from_prpl) ?
num_params + 2 : num_params + 1;
guint next_param_index = num_params;
GParameter *param = g_new0(GParameter, new_num_params);
@@ -2773,7 +2786,7 @@ purple_media_add_stream(PurpleMedia *media, const gchar *sess_id,
next_param_index++;
}
- if (turn_ip && is_nice) {
+ if (turn_ip && !got_turn_from_prpl && is_nice) {
GValueArray *relay_info = g_value_array_new(0);
GValue value;
gint turn_port =
diff --git a/libpurple/protocols/jabber/Makefile.am b/libpurple/protocols/jabber/Makefile.am
index ff88986a82..3b8baadee8 100644
--- a/libpurple/protocols/jabber/Makefile.am
+++ b/libpurple/protocols/jabber/Makefile.am
@@ -98,7 +98,10 @@ else
st =
pkg_LTLIBRARIES = libjabber.la libxmpp.la
libjabber_la_SOURCES = $(JABBERSOURCES)
-libjabber_la_LIBADD = $(GLIB_LIBS) $(SASL_LIBS) $(LIBXML_LIBS) $(IDN_LIBS)
+libjabber_la_LIBADD = $(GLIB_LIBS) $(SASL_LIBS) $(LIBXML_LIBS) $(IDN_LIBS)\
+ $(FARSIGHT_LIBS) \
+ $(GSTREAMER_LIBS) \
+ $(GSTINTERFACES_LIBS)
libxmpp_la_SOURCES = libxmpp.c
libxmpp_la_LIBADD = libjabber.la
@@ -111,4 +114,7 @@ AM_CPPFLAGS = \
$(DEBUG_CFLAGS) \
$(GLIB_CFLAGS) \
$(IDN_CFLAGS) \
- $(LIBXML_CFLAGS)
+ $(LIBXML_CFLAGS) \
+ $(FARSIGHT_CFLAGS) \
+ $(GSTREAMER_CFLAGS) \
+ $(GSTINTERFACES_CFLAGS)
diff --git a/libpurple/protocols/jabber/google.c b/libpurple/protocols/jabber/google.c
index 04d73c7532..46ee79543b 100644
--- a/libpurple/protocols/jabber/google.c
+++ b/libpurple/protocols/jabber/google.c
@@ -58,6 +58,7 @@ typedef struct {
JabberStream *js;
char *remote_jid;
gboolean video;
+ char *iq_id;
} GoogleSession;
static gboolean
@@ -75,6 +76,7 @@ google_session_destroy(GoogleSession *session)
g_free(session->id.id);
g_free(session->id.initiator);
g_free(session->remote_jid);
+ g_free(session->iq_id);
g_free(session);
}
@@ -322,10 +324,14 @@ google_session_stream_info_cb(PurpleMedia *media, PurpleMediaInfoType type,
}
static GParameter *
-jabber_google_session_get_params(JabberStream *js, guint *num)
+jabber_google_session_get_params(JabberStream *js, const gchar *relay_ip,
+ guint16 relay_udp, guint16 relay_tcp, guint16 relay_ssltcp,
+ const gchar *relay_username, const gchar *relay_password, guint *num)
{
guint num_params;
- GParameter *params = jingle_get_params(js, &num_params);
+ GParameter *params =
+ jingle_get_params(js, relay_ip, relay_udp, relay_tcp, relay_ssltcp,
+ relay_username, relay_password, &num_params);
GParameter *new_params = g_new0(GParameter, num_params + 1);
memcpy(new_params, params, sizeof(GParameter) * num_params);
@@ -340,46 +346,81 @@ jabber_google_session_get_params(JabberStream *js, guint *num)
return new_params;
}
+static void
+jabber_google_relay_parse_response(const gchar *response, gchar **ip,
+ guint *udp, guint *tcp, guint *ssltcp, gchar **username, gchar **password)
+{
+ gchar **lines = g_strsplit(response, "\n", -1);
+ int i = 0;
+
+ for (; lines[i] ; i++) {
+ gchar *line = lines[i];
+ gchar **parts = g_strsplit(line, "=", 2);
+
+ if (parts[0] && parts[1]) {
+ if (purple_strequal(parts[0], "relay.ip")) {
+ *ip = g_strdup(parts[1]);
+ } else if (purple_strequal(parts[0], "relay.udp_port")) {
+ *udp = atoi(parts[1]);
+ } else if (purple_strequal(parts[0], "relay.tcp_port")) {
+ *tcp = atoi(parts[1]);
+ } else if (purple_strequal(parts[0], "relay.ssltcp_port")) {
+ *ssltcp = atoi(parts[1]);
+ } else if (purple_strequal(parts[0], "username")) {
+ *username = g_strdup(parts[1]);
+ } else if (purple_strequal(parts[0], "password")) {
+ *password = g_strdup(parts[1]);
+ }
+ }
+ g_strfreev(parts);
+ }
-gboolean
-jabber_google_session_initiate(JabberStream *js, const gchar *who, PurpleMediaSessionType type)
+ g_strfreev(lines);
+}
+
+static void
+jabber_google_relay_remove_url_data(JabberStream *js,
+ PurpleUtilFetchUrlData *url_data)
{
- GoogleSession *session;
- JabberBuddy *jb;
- JabberBuddyResource *jbr;
- gchar *jid;
- GParameter *params;
- guint num_params;
+ GList *iter = js->google_relay_requests;
- /* construct JID to send to */
- jb = jabber_buddy_find(js, who, FALSE);
- if (!jb) {
- purple_debug_error("jingle-rtp",
- "Could not find Jabber buddy\n");
- return FALSE;
- }
- jbr = jabber_buddy_find_resource(jb, NULL);
- if (!jbr) {
- purple_debug_error("jingle-rtp",
- "Could not find buddy's resource\n");
+ while (iter) {
+ if (iter->data == url_data) {
+ js->google_relay_requests =
+ g_list_delete_link(js->google_relay_requests, iter);
+ break;
+ }
}
+}
- if ((strchr(who, '/') == NULL) && jbr && (jbr->name != NULL)) {
- jid = g_strdup_printf("%s/%s", who, jbr->name);
- } else {
- jid = g_strdup(who);
+static void
+jabber_google_relay_response_session_initiate_cb(PurpleUtilFetchUrlData *url_data,
+ gpointer user_data, const gchar *url_text, gsize len,
+ const gchar *error_message)
+{
+ GoogleSession *session = (GoogleSession *) user_data;
+ GParameter *params;
+ guint num_params;
+ JabberStream *js = session->js;
+ gchar *relay_ip = NULL;
+ guint relay_udp = 0;
+ guint relay_tcp = 0;
+ guint relay_ssltcp = 0;
+ gchar *relay_username = NULL;
+ gchar *relay_password = NULL;
+
+ if (url_data) {
+ jabber_google_relay_remove_url_data(js, url_data);
}
- session = g_new0(GoogleSession, 1);
- session->id.id = jabber_get_next_id(js);
- session->id.initiator = g_strdup_printf("%s@%s/%s", js->user->node,
- js->user->domain, js->user->resource);
- session->state = SENT_INITIATE;
- session->js = js;
- session->remote_jid = jid;
+ purple_debug_info("jabber", "got response on HTTP request to relay server\n");
- if (type & PURPLE_MEDIA_VIDEO)
- session->video = TRUE;
+ if (url_text && len > 0) {
+ purple_debug_info("jabber", "got Google relay request response:\n%s\n",
+ url_text);
+ jabber_google_relay_parse_response(url_text, &relay_ip, &relay_udp,
+ &relay_tcp, &relay_ssltcp, &relay_username, &relay_password);
+ }
session->media = purple_media_manager_create_media(
purple_media_manager_get(),
@@ -398,8 +439,14 @@ jabber_google_session_initiate(JabberStream *js, const gchar *who, PurpleMediaSe
g_signal_connect(G_OBJECT(session->media), "stream-info",
G_CALLBACK(google_session_stream_info_cb), session);
- params = jabber_google_session_get_params(js, &num_params);
+ params =
+ jabber_google_session_get_params(js, relay_ip, relay_udp, relay_tcp,
+ relay_ssltcp, relay_username, relay_password, &num_params);
+ g_free(relay_ip);
+ g_free(relay_username);
+ g_free(relay_password);
+
if (purple_media_add_stream(session->media, "google-voice",
session->remote_jid, PURPLE_MEDIA_AUDIO,
TRUE, "nice", num_params, params) == FALSE ||
@@ -410,61 +457,130 @@ jabber_google_session_initiate(JabberStream *js, const gchar *who, PurpleMediaSe
purple_media_error(session->media, "Error adding stream.");
purple_media_end(session->media, NULL, NULL);
g_free(params);
- return FALSE;
}
- g_free(params);
+ g_free(params);
+}
- return (session->media != NULL) ? TRUE : FALSE;
+static void
+jabber_google_do_relay_request(JabberStream *js, GoogleSession *session,
+ PurpleUtilFetchUrlCallback cb)
+{
+ PurpleUtilFetchUrlData *url_data = NULL;
+ gchar *url = g_strdup_printf("http://%s", js->google_relay_host);
+ gchar *request =
+ g_strdup_printf("GET /create_session HTTP/1.0\r\n"
+ "Host: %s\r\n"
+ "X-Talk-Google-Relay-Auth: %s\r\n"
+ "X-Google-Relay-Auth: %s\r\n\r\n",
+ js->google_relay_host, js->google_relay_token, js->google_relay_token);
+ purple_debug_info("jabber",
+ "sending Google relay request %s to %s\n", request, url);
+ url_data =
+ purple_util_fetch_url_request(url, FALSE, NULL, FALSE, request, FALSE,
+ cb, session);
+ if (url_data) {
+ js->google_relay_requests =
+ g_list_prepend(js->google_relay_requests, url_data);
+ } else {
+ purple_debug_error("jabber", "unable to create Google relay request\n");
+ cb(NULL, session, NULL, 0, NULL);
+ }
+ g_free(url);
+ g_free(request);
}
-static gboolean
-google_session_handle_initiate(JabberStream *js, GoogleSession *session, xmlnode *sess, const char *iq_id)
+gboolean
+jabber_google_session_initiate(JabberStream *js, const gchar *who, PurpleMediaSessionType type)
{
- JabberIq *result;
- GList *codecs = NULL, *video_codecs = NULL;
- xmlnode *desc_element, *codec_element;
- PurpleMediaCodec *codec;
- const char *xmlns;
- GParameter *params;
- guint num_params;
+ GoogleSession *session;
+ JabberBuddy *jb;
+ JabberBuddyResource *jbr;
+ gchar *jid;
- if (session->state != UNINIT) {
- purple_debug_error("jabber", "Received initiate for active session.\n");
+ /* construct JID to send to */
+ jb = jabber_buddy_find(js, who, FALSE);
+ if (!jb) {
+ purple_debug_error("jingle-rtp",
+ "Could not find Jabber buddy\n");
return FALSE;
}
+ jbr = jabber_buddy_find_resource(jb, NULL);
+ if (!jbr) {
+ purple_debug_error("jingle-rtp",
+ "Could not find buddy's resource\n");
+ }
- desc_element = xmlnode_get_child(sess, "description");
- xmlns = xmlnode_get_namespace(desc_element);
+ if ((strchr(who, '/') == NULL) && jbr && (jbr->name != NULL)) {
+ jid = g_strdup_printf("%s/%s", who, jbr->name);
+ } else {
+ jid = g_strdup(who);
+ }
- if (purple_strequal(xmlns, NS_GOOGLE_SESSION_PHONE))
- session->video = FALSE;
- else if (purple_strequal(xmlns, NS_GOOGLE_SESSION_VIDEO))
+ session = g_new0(GoogleSession, 1);
+ session->id.id = jabber_get_next_id(js);
+ session->id.initiator = g_strdup_printf("%s@%s/%s", js->user->node,
+ js->user->domain, js->user->resource);
+ session->state = SENT_INITIATE;
+ session->js = js;
+ session->remote_jid = jid;
+
+ if (type & PURPLE_MEDIA_VIDEO)
session->video = TRUE;
- else {
- purple_debug_error("jabber", "Received initiate with "
- "invalid namespace %s.\n", xmlns);
- return FALSE;
+
+ /* if we got a relay token and relay host in google:jingleinfo, issue an
+ HTTP request to get that data */
+ if (js->google_relay_host && js->google_relay_token) {
+ jabber_google_do_relay_request(js, session,
+ jabber_google_relay_response_session_initiate_cb);
+ } else {
+ jabber_google_relay_response_session_initiate_cb(NULL, session, NULL, 0,
+ NULL);
}
+
+ /* we don't actually know yet wether it succeeded... maybe this is very
+ wrong... */
+ return TRUE;
+}
- session->media = purple_media_manager_create_media(
- purple_media_manager_get(),
- purple_connection_get_account(js->gc),
- "fsrtpconference", session->remote_jid, FALSE);
+static void
+jabber_google_relay_response_session_handle_initiate_cb(
+ PurpleUtilFetchUrlData *url_data,
+ gpointer user_data, const gchar *url_text, gsize len,
+ const gchar *error_message)
+{
+ GoogleSession *session = (GoogleSession *) user_data;
+ GParameter *params;
+ guint num_params;
+ JabberStream *js = session->js;
+ gchar *relay_ip = NULL;
+ guint relay_udp = 0;
+ guint relay_tcp = 0;
+ guint relay_ssltcp = 0;
+ gchar *relay_username = NULL;
+ gchar *relay_password = NULL;
+ xmlnode *codec_element;
+ xmlnode *desc_element;
+ const gchar *xmlns;
+ PurpleMediaCodec *codec;
+ GList *video_codecs = NULL;
+ GList *codecs = NULL;
+ JabberIq *result;
- purple_media_set_prpl_data(session->media, session);
+ if (url_data) {
+ jabber_google_relay_remove_url_data(js, url_data);
+ }
- g_signal_connect_swapped(G_OBJECT(session->media),
- "candidates-prepared",
- G_CALLBACK(google_session_ready), session);
- g_signal_connect_swapped(G_OBJECT(session->media), "codecs-changed",
- G_CALLBACK(google_session_ready), session);
- g_signal_connect(G_OBJECT(session->media), "state-changed",
- G_CALLBACK(google_session_state_changed_cb), session);
- g_signal_connect(G_OBJECT(session->media), "stream-info",
- G_CALLBACK(google_session_stream_info_cb), session);
+ if (url_text && len > 0) {
+ purple_debug_info("jabber", "got Google relay request response:\n%s\n",
+ url_text);
+ jabber_google_relay_parse_response(url_text, &relay_ip, &relay_udp,
+ &relay_tcp, &relay_ssltcp, &relay_username, &relay_password);
+ }
- params = jabber_google_session_get_params(js, &num_params);
+ params =
+ jabber_google_session_get_params(js, relay_ip, relay_udp, relay_tcp,
+ relay_ssltcp, relay_username, relay_password, &num_params);
if (purple_media_add_stream(session->media, "google-voice",
session->remote_jid, PURPLE_MEDIA_AUDIO, FALSE,
@@ -477,7 +593,6 @@ google_session_handle_initiate(JabberStream *js, GoogleSession *session, xmlnode
purple_media_stream_info(session->media,
PURPLE_MEDIA_INFO_REJECT, NULL, NULL, TRUE);
g_free(params);
- return FALSE;
}
g_free(params);
@@ -533,9 +648,61 @@ google_session_handle_initiate(JabberStream *js, GoogleSession *session, xmlnode
purple_media_codec_list_free(video_codecs);
result = jabber_iq_new(js, JABBER_IQ_RESULT);
- jabber_iq_set_id(result, iq_id);
+ jabber_iq_set_id(result, session->iq_id);
xmlnode_set_attrib(result->node, "to", session->remote_jid);
jabber_iq_send(result);
+}
+
+static gboolean
+google_session_handle_initiate(JabberStream *js, GoogleSession *session, xmlnode *sess, const char *iq_id)
+{
+ xmlnode *desc_element;
+ const gchar *xmlns;
+
+ if (session->state != UNINIT) {
+ purple_debug_error("jabber", "Received initiate for active session.\n");
+ return FALSE;
+ }
+
+ desc_element = xmlnode_get_child(sess, "description");
+ xmlns = xmlnode_get_namespace(desc_element);
+
+ if (purple_strequal(xmlns, NS_GOOGLE_SESSION_PHONE))
+ session->video = FALSE;
+ else if (purple_strequal(xmlns, NS_GOOGLE_SESSION_VIDEO))
+ session->video = TRUE;
+ else {
+ purple_debug_error("jabber", "Received initiate with "
+ "invalid namespace %s.\n", xmlns);
+ return FALSE;
+ }
+
+ session->media = purple_media_manager_create_media(
+ purple_media_manager_get(),
+ purple_connection_get_account(js->gc),
+ "fsrtpconference", session->remote_jid, FALSE);
+
+ purple_media_set_prpl_data(session->media, session);
+
+ g_signal_connect_swapped(G_OBJECT(session->media),
+ "candidates-prepared",
+ G_CALLBACK(google_session_ready), session);
+ g_signal_connect_swapped(G_OBJECT(session->media), "codecs-changed",
+ G_CALLBACK(google_session_ready), session);
+ g_signal_connect(G_OBJECT(session->media), "state-changed",
+ G_CALLBACK(google_session_state_changed_cb), session);
+ g_signal_connect(G_OBJECT(session->media), "stream-info",
+ G_CALLBACK(google_session_stream_info_cb), session);
+
+ session->iq_id = g_strdup(iq_id);
+
+ if (js->google_relay_host && js->google_relay_token) {
+ jabber_google_do_relay_request(js, session,
+ jabber_google_relay_response_session_handle_initiate_cb);
+ } else {
+ jabber_google_relay_response_session_handle_initiate_cb(NULL, session,
+ NULL, 0, NULL);
+ }
return TRUE;
}
@@ -1346,6 +1513,7 @@ jabber_google_jingle_info_common(JabberStream *js, const char *from,
JabberIqType type, xmlnode *query)
{
const xmlnode *stun = xmlnode_get_child(query, "stun");
+ const xmlnode *relay = xmlnode_get_child(query, "relay");
gchar *my_bare_jid;
/*
@@ -1389,8 +1557,23 @@ jabber_google_jingle_info_common(JabberStream *js, const char *from,
}
}
}
- /* should perhaps handle relays later on, or maybe wait until
- Google supports a common standard... */
+
+ if (relay) {
+ xmlnode *token = xmlnode_get_child(relay, "token");
+ xmlnode *server = xmlnode_get_child(relay, "server");
+
+ if (token) {
+ gchar *relay_token = xmlnode_get_data(token);
+
+ /* we let js own the string returned from xmlnode_get_data */
+ js->google_relay_token = relay_token;
+ }
+
+ if (server) {
+ js->google_relay_host =
+ g_strdup(xmlnode_get_attrib(server, "host"));
+ }
+ }
}
static void
diff --git a/libpurple/protocols/jabber/jabber.c b/libpurple/protocols/jabber/jabber.c
index 930750c95c..fc7d0e9a5e 100644
--- a/libpurple/protocols/jabber/jabber.c
+++ b/libpurple/protocols/jabber/jabber.c
@@ -857,6 +857,9 @@ jabber_stream_new(PurpleAccount *account)
js->stun_ip = NULL;
js->stun_port = 0;
js->stun_query = NULL;
+ js->google_relay_token = NULL;
+ js->google_relay_host = NULL;
+ js->google_relay_requests = NULL;
/* if we are idle, set idle-ness on the stream (this could happen if we get
disconnected and the reconnects while being idle. I don't think it makes
@@ -1561,6 +1564,21 @@ void jabber_close(PurpleConnection *gc)
js->stun_query = NULL;
}
+ /* remove Google relay-related stuff */
+ g_free(js->google_relay_token);
+ g_free(js->google_relay_host);
+ if (js->google_relay_requests) {
+ while (js->google_relay_requests) {
+ PurpleUtilFetchUrlData *url_data =
+ (PurpleUtilFetchUrlData *) js->google_relay_requests->data;
+ purple_util_fetch_url_cancel(url_data);
+ g_free(url_data);
+ js->google_relay_requests =
+ g_list_delete_link(js->google_relay_requests,
+ js->google_relay_requests);
+ }
+ }
+
g_free(js);
gc->proto_data = NULL;
@@ -3020,10 +3038,14 @@ jabber_initiate_media(PurpleAccount *account, const char *who,
jbr = jabber_buddy_find_resource(jb, resource);
g_free(resource);
- if (type & PURPLE_MEDIA_AUDIO &&
- !jabber_resource_has_capability(jbr,
- JINGLE_APP_RTP_SUPPORT_AUDIO) &&
- jabber_resource_has_capability(jbr, NS_GOOGLE_VOICE))
+ /* if we are on a Google Talk connection and the remote supports
+ Google Jingle, we will go with that */
+ if (((js->googletalk && js->google_relay_token) ||
+ !jabber_resource_has_capability(jbr, JINGLE_APP_RTP_SUPPORT_AUDIO))
+ && (((type & PURPLE_MEDIA_AUDIO) &&
+ jabber_resource_has_capability(jbr, NS_GOOGLE_VOICE))
+ || ((type & PURPLE_MEDIA_VIDEO) &&
+ jabber_resource_has_capability(jbr, NS_GOOGLE_VIDEO))))
return jabber_google_session_initiate(js, who, type);
else
return jingle_rtp_initiate_media(js, who, type);
diff --git a/libpurple/protocols/jabber/jabber.h b/libpurple/protocols/jabber/jabber.h
index c23469b19f..74f8990b33 100644
--- a/libpurple/protocols/jabber/jabber.h
+++ b/libpurple/protocols/jabber/jabber.h
@@ -263,7 +263,12 @@ struct _JabberStream
gchar *stun_ip;
int stun_port;
PurpleDnsQueryData *stun_query;
- /* later add stuff to handle TURN relays... */
+
+ /* stuff for Google's relay handling */
+ gchar *google_relay_token;
+ gchar *google_relay_host;
+ GList *google_relay_requests; /* the HTTP requests to get */
+ /* relay info */
};
typedef gboolean (JabberFeatureEnabled)(JabberStream *js, const gchar *namespace);
diff --git a/libpurple/protocols/jabber/jingle/jingle.c b/libpurple/protocols/jabber/jingle/jingle.c
index 2eb30a20b1..d87dc5ae41 100644
--- a/libpurple/protocols/jabber/jingle/jingle.c
+++ b/libpurple/protocols/jabber/jingle/jingle.c
@@ -35,6 +35,11 @@
#include "rawudp.h"
#include "rtp.h"
+#ifdef USE_VV
+#include <gst/farsight/fs-conference-iface.h>
+#include <gst/farsight/fs-element-added-notifier.h>
+#endif
+
GType
jingle_get_type(const gchar *type)
{
@@ -430,32 +435,91 @@ jingle_terminate_sessions(JabberStream *js)
jingle_terminate_sessions_gh, NULL);
}
+#ifdef USE_VV
+static GValueArray *
+jingle_create_relay_info(const gchar *ip, guint port, const gchar *username,
+ const gchar *password, const gchar *relay_type, GValueArray *relay_info)
+{
+ GValue value;
+ GstStructure *turn_setup = gst_structure_new("relay-info",
+ "ip", G_TYPE_STRING, ip,
+ "port", G_TYPE_UINT, port,
+ "username", G_TYPE_STRING, username,
+ "password", G_TYPE_STRING, password,
+ "relay-type", G_TYPE_STRING, relay_type,
+ NULL);
+ purple_debug_info("jabber", "created gst_structure %" GST_PTR_FORMAT "\n",
+ turn_setup);
+ if (turn_setup) {
+ memset(&value, 0, sizeof(GValue));
+ g_value_init(&value, GST_TYPE_STRUCTURE);
+ gst_value_set_structure(&value, turn_setup);
+ relay_info = g_value_array_append(relay_info, &value);
+ gst_structure_free(turn_setup);
+ }
+ return relay_info;
+}
+
GParameter *
-jingle_get_params(JabberStream *js, guint *num)
+jingle_get_params(JabberStream *js, const gchar *relay_ip, guint relay_udp,
+ guint relay_tcp, guint relay_ssltcp, const gchar *relay_username,
+ const gchar *relay_password, guint *num)
{
/* don't set a STUN server if one is set globally in prefs, in that case
this will be handled in media.c */
gboolean has_account_stun = js->stun_ip && !purple_network_get_stun_ip();
- guint num_params = has_account_stun ? 2 : 0;
+ guint num_params = has_account_stun ?
+ (relay_ip ? 3 : 2) : (relay_ip ? 1 : 0);
GParameter *params = NULL;
-
+ int next_index = 0;
+
if (num_params > 0) {
params = g_new0(GParameter, num_params);
- purple_debug_info("jabber",
- "setting param stun-ip for stream using auto-discovered IP: %s\n",
- js->stun_ip);
- params[0].name = "stun-ip";
- g_value_init(&params[0].value, G_TYPE_STRING);
- g_value_set_string(&params[0].value, js->stun_ip);
- purple_debug_info("jabber",
- "setting param stun-port for stream using auto-discovered port: %d\n",
- js->stun_port);
- params[1].name = "stun-port";
- g_value_init(&params[1].value, G_TYPE_UINT);
- g_value_set_uint(&params[1].value, js->stun_port);
+ if (has_account_stun) {
+ purple_debug_info("jabber",
+ "setting param stun-ip for stream using Google auto-config: %s\n",
+ js->stun_ip);
+ params[next_index].name = "stun-ip";
+ g_value_init(&params[next_index].value, G_TYPE_STRING);
+ g_value_set_string(&params[next_index].value, js->stun_ip);
+ purple_debug_info("jabber",
+ "setting param stun-port for stream using Google auto-config: %d\n",
+ js->stun_port);
+ next_index++;
+ params[next_index].name = "stun-port";
+ g_value_init(&params[next_index].value, G_TYPE_UINT);
+ g_value_set_uint(&params[next_index].value, js->stun_port);
+ next_index++;
+ }
+
+ if (relay_ip) {
+ GValueArray *relay_info = g_value_array_new(0);
+
+ if (relay_udp) {
+ relay_info =
+ jingle_create_relay_info(relay_ip, relay_udp, relay_username,
+ relay_password, "udp", relay_info);
+ }
+ if (relay_tcp) {
+ relay_info =
+ jingle_create_relay_info(relay_ip, relay_tcp, relay_username,
+ relay_password, "tcp", relay_info);
+ }
+ if (relay_ssltcp) {
+ relay_info =
+ jingle_create_relay_info(relay_ip, relay_ssltcp, relay_username,
+ relay_password, "tls", relay_info);
+ }
+ params[next_index].name = "relay-info";
+ g_value_init(&params[next_index].value, G_TYPE_VALUE_ARRAY);
+ g_value_set_boxed(&params[next_index].value, relay_info);
+ g_value_array_free(relay_info);
+ }
}
*num = num_params;
return params;
}
+#endif
+
diff --git a/libpurple/protocols/jabber/jingle/jingle.h b/libpurple/protocols/jabber/jingle/jingle.h
index 7ccdc55fe2..3813529f8d 100644
--- a/libpurple/protocols/jabber/jingle/jingle.h
+++ b/libpurple/protocols/jabber/jingle/jingle.h
@@ -78,9 +78,13 @@ void jingle_parse(JabberStream *js, const char *from, JabberIqType type,
void jingle_terminate_sessions(JabberStream *js);
+#ifdef USE_VV
/* create a GParam array given autoconfigured STUN (and later perhaps TURN).
if google_talk is TRUE, set compatability mode to GOOGLE_TALK */
-GParameter *jingle_get_params(JabberStream *js, guint *num_params);
+GParameter *jingle_get_params(JabberStream *js, const gchar *relay_ip,
+ guint relay_udp, guint relay_tcp, guint relay_ssltcp,
+ const gchar *relay_username, const gchar *relay_password, guint *num_params);
+#endif
#ifdef __cplusplus
}
diff --git a/libpurple/protocols/jabber/jingle/rtp.c b/libpurple/protocols/jabber/jingle/rtp.c
index 5d46f39a9a..e38f8d4909 100644
--- a/libpurple/protocols/jabber/jingle/rtp.c
+++ b/libpurple/protocols/jabber/jingle/rtp.c
@@ -602,7 +602,8 @@ jingle_rtp_init_media(JingleContent *content)
: PURPLE_MEDIA_RECV_VIDEO;
params =
- jingle_get_params(jingle_session_get_js(session), &num_params);
+ jingle_get_params(jingle_session_get_js(session), NULL, 0, 0, 0,
+ NULL, NULL, &num_params);
creator = jingle_content_get_creator(content);
if (!strcmp(creator, "initiator"))