comparison libpurple/protocols/jabber/jingle.c @ 23825:c984acc6c392

Added the "media" attribute to the Jingle description element according to changes to XEP-0167.

23824:bfaad8393463

#ifdef USE_VV

#include <gst/farsight/fs-candidate.h>

#define JINGLE "urn:xmpp:tmp:jingle"
#define JINGLE_AUDIO "urn:xmpp:tmp:jingle:apps:audio-rtp"
#define JINGLE_VIDEO "urn:xmpp:tmp:jingle:apps:video-rtp"
#define TRANSPORT_ICEUDP "urn:xmpp:tmp:jingle:transports:ice-udp"

typedef struct {
	char *id;
	JabberStream *js;

	JingleSession *session;
	gchar *creator;
	gchar *sender;
	gchar *transport_type;
	gchar *type;
} JingleSessionContent;

static void
jabber_jingle_session_content_create_internal(JingleSession *session,
					      const gchar *name,
					      const gchar *creator,
					      const gchar *sender,
					      const gchar *transport_type,
					      const gchar *type)
{
	JingleSessionContent *content = g_new0(JingleSessionContent, 1);
	content->session = session;
	content->name = g_strdup(name);
	content->creator = g_strdup(creator);
	content->sender = g_strdup(sender);
	content->transport_type = g_strdup(transport_type);
	content->type = g_strdup(type);

	if (!session->contents) {
		purple_debug_info("jingle", "Creating hash table for contents\n");
		session->contents = g_hash_table_new(g_str_hash, g_str_equal);
	}

	g_free(content->name);
	g_free(content->creator);
	g_free(content->sender);
	g_free(content->transport_type);
	g_free(content->type);
	g_free(content);
}

static const gchar *
jabber_jingle_session_content_get_name(const JingleSessionContent *jsc)

				      const gchar *type)
{
	return !strcmp(jabber_jingle_session_content_get_type(jsc), type);
}

static gboolean
jabber_jingle_session_content_is_vv(const JingleSessionContent *jsc)
{
	return jabber_jingle_session_content_is_type(jsc, JINGLE_AUDIO) ||
			jabber_jingle_session_content_is_type(jsc, JINGLE_VIDEO);
}

static void
jabber_jingle_session_content_set_sender(JingleSessionContent *jsc,
					    const char *sender)

{
	GList *codecs = NULL;
	xmlnode *codec_element = NULL;
	const char *encoding_name,*id, *clock_rate;
	FsCodec *codec;
	FsMediaType type = !strcmp(xmlnode_get_namespace(description), JINGLE_VIDEO) ?
			FS_MEDIA_TYPE_VIDEO : FS_MEDIA_TYPE_AUDIO;

	for (codec_element = xmlnode_get_child(description, "payload-type") ;
		 codec_element ;
		 codec_element = xmlnode_get_next_twin(codec_element)) {
		encoding_name = xmlnode_get_attrib(codec_element, "name");

static xmlnode *
jabber_jingle_session_add_description_vv(const JingleSessionContent *jsc,
					 xmlnode *description)
{
	xmlnode_set_attrib(description, "profile", "RTP/AVP");
	return description;
}

static xmlnode *

{
	xmlnode *description = xmlnode_new_child(content, "description");
	xmlnode_set_namespace(description,
			jabber_jingle_session_content_get_type(jsc));

	if (jabber_jingle_session_content_is_vv(jsc))
		return jabber_jingle_session_add_description_vv(jsc, description);
	else
		return description;
}

	for (; contents; contents = contents->next) {
		JingleSessionContent *jsc = contents->data;
		xmlnode *content = jabber_jingle_session_add_content(jsc, jingle);
		xmlnode *description = jabber_jingle_session_add_description(jsc, content);
		xmlnode *transport = jabber_jingle_session_add_transport(jsc, content);
		if (jabber_jingle_session_content_is_vv(jsc))
			jabber_jingle_session_add_payload_types(jsc, description);
		if (jabber_jingle_session_content_is_transport_type(jsc, TRANSPORT_ICEUDP))
			jabber_jingle_session_add_candidate_iceudp(transport, local, remote);
	}

	JabberIq *request = jabber_jingle_session_create_iq(session);
	xmlnode *jingle =
		jabber_jingle_session_add_jingle(session, request,
						 "session-info");
	xmlnode *info = xmlnode_new_child(jingle, type);
	xmlnode_set_namespace(info, JINGLE_AUDIO ":info");
	return request;
}

static JabberIq *
jabber_jingle_session_create_session_initiate(const JingleSession *session)

	for (; contents; contents = contents->next) {
		JingleSessionContent *jsc = contents->data;
		xmlnode *content = jabber_jingle_session_add_content(jsc, jingle);
		xmlnode *description = jabber_jingle_session_add_description(jsc, content);
		if (jabber_jingle_session_content_is_vv(jsc))
			jabber_jingle_session_add_payload_types(jsc, description);
		jabber_jingle_session_add_transport(jsc, content);
	}

	return request;

			strcpy(sender, "responder");
		else
			strcpy(sender, "both");
		jabber_jingle_session_content_create_internal(session,
				"audio-content", "initiator", sender,
				TRANSPORT_ICEUDP, JINGLE_AUDIO);
	}
	if (type & PURPLE_MEDIA_VIDEO) {
		if (type == PURPLE_MEDIA_SEND_VIDEO)
			strcpy(sender, "initiator");
		else if (type == PURPLE_MEDIA_RECV_VIDEO)
			strcpy(sender, "responder");
		else
			strcpy(sender, "both");
		jabber_jingle_session_content_create_internal(session,
				"video-content", "initiator", sender,
				TRANSPORT_ICEUDP, JINGLE_VIDEO);
	}
}

static void
jabber_jingle_session_content_create_parse(JingleSession *session,

	xmlnode *description = xmlnode_get_child(content, "description");
	xmlnode *transport = xmlnode_get_child(content, "transport");

	const gchar *creator = xmlnode_get_attrib(content, "creator");
	const gchar *sender = xmlnode_get_attrib(content, "sender");

	jabber_jingle_session_content_create_internal(session,
						      xmlnode_get_attrib(content, "name"),
						      creator ? creator : "initiator",
						      sender ? sender : "both",
						      xmlnode_get_namespace(transport),
						      xmlnode_get_namespace(description));
}

/* callback called when new local transport candidate(s) are available on the
	Farsight stream */
static void

	for (; contents; contents = contents->next) {
		JingleSessionContent *jsc = contents->data;
		gboolean result = FALSE;

		/* these will need to be changed to "nice" once the libnice transmitter is finished */
		if (jabber_jingle_session_content_is_type(jsc, JINGLE_AUDIO)) {
			result = purple_media_add_stream(media, "audio-content", remote_jid,
							 PURPLE_MEDIA_AUDIO, "rawudp");
			purple_debug_info("jingle", "Created Jingle audio session\n");
		}
		else if (jabber_jingle_session_content_is_type(jsc, JINGLE_VIDEO)) {
			result = purple_media_add_stream(media, "video-content", remote_jid,
							 PURPLE_MEDIA_VIDEO, "rawudp");
			purple_debug_info("jingle", "Created Jingle video session\n");
		}

23825:c984acc6c392

#ifdef USE_VV

#include <gst/farsight/fs-candidate.h>

#define JINGLE "urn:xmpp:tmp:jingle"
#define JINGLE_RTP "urn:xmpp:tmp:jingle:apps:rtp"
#define JINGLE_RTP_INFO "urn:xmpp:tmp:jingle:apps:rtp:info"
#define TRANSPORT_ICEUDP "urn:xmpp:tmp:jingle:transports:ice-udp"

typedef struct {
	char *id;
	JabberStream *js;

	JingleSession *session;
	gchar *creator;
	gchar *sender;
	gchar *transport_type;
	gchar *type;
	gchar *subtype;
} JingleSessionContent;

static void
jabber_jingle_session_content_create_internal(JingleSession *session,
					      const gchar *name,
					      const gchar *creator,
					      const gchar *sender,
					      const gchar *transport_type,
					      const gchar *type,
					      const gchar *subtype)
{
	JingleSessionContent *content = g_new0(JingleSessionContent, 1);
	content->session = session;
	content->name = g_strdup(name);
	content->creator = g_strdup(creator);
	content->sender = g_strdup(sender);
	content->transport_type = g_strdup(transport_type);
	content->type = g_strdup(type);
	content->subtype = g_strdup(subtype);

	if (!session->contents) {
		purple_debug_info("jingle", "Creating hash table for contents\n");
		session->contents = g_hash_table_new(g_str_hash, g_str_equal);
	}

	g_free(content->name);
	g_free(content->creator);
	g_free(content->sender);
	g_free(content->transport_type);
	g_free(content->type);
	g_free(content->subtype);
	g_free(content);
}

static const gchar *
jabber_jingle_session_content_get_name(const JingleSessionContent *jsc)

				      const gchar *type)
{
	return !strcmp(jabber_jingle_session_content_get_type(jsc), type);
}

static gchar *
jabber_jingle_session_content_get_subtype(const JingleSessionContent *jsc)
{
	return jsc->subtype;
}

static gboolean
jabber_jingle_session_content_is_vv_type(const JingleSessionContent *jsc,
					 const gchar *media_type)
{
	return jabber_jingle_session_content_is_type(jsc, JINGLE_RTP) &&
			!strcmp(jabber_jingle_session_content_get_subtype(jsc),
				media_type);
}

static void
jabber_jingle_session_content_set_sender(JingleSessionContent *jsc,
					    const char *sender)

{
	GList *codecs = NULL;
	xmlnode *codec_element = NULL;
	const char *encoding_name,*id, *clock_rate;
	FsCodec *codec;
	const gchar *media = xmlnode_get_attrib(description, "media");
	FsMediaType type = !strcmp(media, "video") ? FS_MEDIA_TYPE_VIDEO :
			!strcmp(media, "audio") ? FS_MEDIA_TYPE_AUDIO : 
			FS_MEDIA_TYPE_APPLICATION;

	for (codec_element = xmlnode_get_child(description, "payload-type") ;
		 codec_element ;
		 codec_element = xmlnode_get_next_twin(codec_element)) {
		encoding_name = xmlnode_get_attrib(codec_element, "name");

static xmlnode *
jabber_jingle_session_add_description_vv(const JingleSessionContent *jsc,
					 xmlnode *description)
{
	xmlnode_set_attrib(description, "media", 
			jabber_jingle_session_content_get_subtype(jsc));
	xmlnode_set_attrib(description, "profile", "RTP/AVP");
	return description;
}

static xmlnode *

{
	xmlnode *description = xmlnode_new_child(content, "description");
	xmlnode_set_namespace(description,
			jabber_jingle_session_content_get_type(jsc));

	if (jabber_jingle_session_content_is_type(jsc, JINGLE_RTP))
		return jabber_jingle_session_add_description_vv(jsc, description);
	else
		return description;
}

	for (; contents; contents = contents->next) {
		JingleSessionContent *jsc = contents->data;
		xmlnode *content = jabber_jingle_session_add_content(jsc, jingle);
		xmlnode *description = jabber_jingle_session_add_description(jsc, content);
		xmlnode *transport = jabber_jingle_session_add_transport(jsc, content);
		if (jabber_jingle_session_content_is_type(jsc, JINGLE_RTP))
			jabber_jingle_session_add_payload_types(jsc, description);
		if (jabber_jingle_session_content_is_transport_type(jsc, TRANSPORT_ICEUDP))
			jabber_jingle_session_add_candidate_iceudp(transport, local, remote);
	}

	JabberIq *request = jabber_jingle_session_create_iq(session);
	xmlnode *jingle =
		jabber_jingle_session_add_jingle(session, request,
						 "session-info");
	xmlnode *info = xmlnode_new_child(jingle, type);
	xmlnode_set_namespace(info, JINGLE_RTP_INFO);
	return request;
}

static JabberIq *
jabber_jingle_session_create_session_initiate(const JingleSession *session)

	for (; contents; contents = contents->next) {
		JingleSessionContent *jsc = contents->data;
		xmlnode *content = jabber_jingle_session_add_content(jsc, jingle);
		xmlnode *description = jabber_jingle_session_add_description(jsc, content);
		if (jabber_jingle_session_content_is_type(jsc, JINGLE_RTP))
			jabber_jingle_session_add_payload_types(jsc, description);
		jabber_jingle_session_add_transport(jsc, content);
	}

	return request;

			strcpy(sender, "responder");
		else
			strcpy(sender, "both");
		jabber_jingle_session_content_create_internal(session,
				"audio-content", "initiator", sender,
				TRANSPORT_ICEUDP, JINGLE_RTP, "audio");
	}
	if (type & PURPLE_MEDIA_VIDEO) {
		if (type == PURPLE_MEDIA_SEND_VIDEO)
			strcpy(sender, "initiator");
		else if (type == PURPLE_MEDIA_RECV_VIDEO)
			strcpy(sender, "responder");
		else
			strcpy(sender, "both");
		jabber_jingle_session_content_create_internal(session,
				"video-content", "initiator", sender,
				TRANSPORT_ICEUDP, JINGLE_RTP, "video");
	}
}

static void
jabber_jingle_session_content_create_parse(JingleSession *session,

	xmlnode *description = xmlnode_get_child(content, "description");
	xmlnode *transport = xmlnode_get_child(content, "transport");

	const gchar *creator = xmlnode_get_attrib(content, "creator");
	const gchar *sender = xmlnode_get_attrib(content, "sender");
	const gchar *subtype = xmlnode_get_attrib(description, "media");

	jabber_jingle_session_content_create_internal(session,
						      xmlnode_get_attrib(content, "name"),
						      creator ? creator : "initiator",
						      sender ? sender : "both",
						      xmlnode_get_namespace(transport),
						      xmlnode_get_namespace(description),
						      subtype);
}

/* callback called when new local transport candidate(s) are available on the
	Farsight stream */
static void

	for (; contents; contents = contents->next) {
		JingleSessionContent *jsc = contents->data;
		gboolean result = FALSE;

		/* these will need to be changed to "nice" once the libnice transmitter is finished */
		if (jabber_jingle_session_content_is_vv_type(jsc, "audio")) {
			result = purple_media_add_stream(media, "audio-content", remote_jid,
							 PURPLE_MEDIA_AUDIO, "rawudp");
			purple_debug_info("jingle", "Created Jingle audio session\n");
		}
		else if (jabber_jingle_session_content_is_vv_type(jsc, "video")) {
			result = purple_media_add_stream(media, "video-content", remote_jid,
							 PURPLE_MEDIA_VIDEO, "rawudp");
			purple_debug_info("jingle", "Created Jingle video session\n");
		}