comparison libpurple/protocols/jabber/jingle.c @ 23822:a7be3074923b

Corrected debug labels s/"jabber"/"jingle"/

23816:e73b03097664

	xmlnode_set_attrib(result->node, "to",
			   jabber_jingle_session_get_remote_jid(session));

	xmlnode_insert_child(result->node, jingle);
	jabber_iq_send(result);
	purple_debug_info("jabber", "Sent session accept, starting stream\n");
	gst_element_set_state(purple_media_get_audio_pipeline(session->media), GST_STATE_PLAYING);

	session->session_started = TRUE;
}

	if (!jabber_jingle_session_is_initiator(session)) {
		/* create transport-info package */
		JabberIq *result = jabber_iq_new(jabber_jingle_session_get_js(session),
						 JABBER_IQ_SET);
		xmlnode *jingle = jabber_jingle_session_create_transport_info(session);
		purple_debug_info("jabber", "jabber_session_candidates_prepared: %d candidates\n",
				  g_list_length(purple_media_get_local_audio_candidates(session->media)));
		xmlnode_set_attrib(result->node, "to",
				   jabber_jingle_session_get_remote_jid(session));

		xmlnode_insert_child(result->node, jingle);

jabber_jingle_session_candidate_pair_established(PurpleMedia *media,
						 FsCandidate *native_candidate,
						 FsCandidate *remote_candidate,
						 JingleSession *session)
{	
	purple_debug_info("jabber", "jabber_candidate_pair_established called\n");
	/* if we are the initiator, we should send a content-modify message */
	if (jabber_jingle_session_is_initiator(session)) {
		JabberIq *result;
		xmlnode *jingle;
		
		purple_debug_info("jabber", "we are the initiator, let's send content-modify\n");

		result = jabber_iq_new(jabber_jingle_session_get_js(session), JABBER_IQ_SET);

		/* shall change this to a "content-replace" */
		jingle = jabber_jingle_session_create_content_replace(session,

	media = purple_media_manager_create_media(purple_media_manager_get(), 
						  session->js->gc, "fsrtpconference", remote_jid);

	if (!media) {
		purple_debug_error("jabber", "Couldn't create fsrtpconference\n");
		return FALSE;
	}

	/* this will need to be changed to "nice" once the libnice transmitter is finished */
	if (!purple_media_add_stream(media, remote_jid, PURPLE_MEDIA_AUDIO, "rawudp")) {
		purple_debug_error("jabber", "Couldn't create audio stream\n");
		purple_media_reject(media);
		return FALSE;
	}

	jabber_jingle_session_set_remote_jid(session, remote_jid);

	}

	/* create transport-info package */
	result = jabber_iq_new(jabber_jingle_session_get_js(session), JABBER_IQ_SET);
	jingle = jabber_jingle_session_create_transport_info(session);
	purple_debug_info("jabber", "jabber_session_candidates_prepared: %d candidates\n",
			  g_list_length(purple_media_get_local_audio_candidates(session->media)));
	xmlnode_set_attrib(result->node, "to",
			   jabber_jingle_session_get_remote_jid(session));

	xmlnode_insert_child(result->node, jingle);

	char *jid = NULL, *me = NULL;

	/* construct JID to send to */
	jb = jabber_buddy_find(js, who, FALSE);
	if (!jb) {
		purple_debug_error("jabber", "Could not find Jabber buddy\n");
		return NULL;
	}
	jbr = jabber_buddy_find_resource(jb, NULL);
	if (!jbr) {
		purple_debug_error("jabber", "Could not find buddy's resource\n");
	}

	if ((strchr(who, '/') == NULL) && jbr && (jbr->name != NULL)) {
		jid = g_strdup_printf("%s/%s", who, jbr->name);
	} else {

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

	/* fetch codecs from remote party */
	purple_debug_info("jabber", "get codecs from session-accept\n");
	remote_codecs = jabber_jingle_get_codecs(description);
	purple_debug_info("jabber", "get transport candidates from session accept\n");
	remote_transports = jabber_jingle_get_candidates(transport);

	purple_debug_info("jabber", "Got %d codecs from responder\n",
			  g_list_length(remote_codecs));
	purple_debug_info("jabber", "Got %d transport candidates from responder\n",
			  g_list_length(remote_transports));

	purple_debug_info("jabber", "Setting remote codecs on stream\n");

	purple_media_set_remote_audio_codecs(session->media, 
					     jabber_jingle_session_get_remote_jid(session),
					     remote_codecs);

	codec_intersection = purple_media_get_negotiated_audio_codecs(session->media);
	purple_debug_info("jabber", "codec_intersection contains %d elems\n",
			  g_list_length(codec_intersection));
	/* get the top codec */
	if (g_list_length(codec_intersection) > 0) {
		top = (FsCodec *) codec_intersection->data;
		purple_debug_info("jabber", "Found a suitable codec on stream = %d\n",
				  top->id);

		/* we have found a suitable codec, but we will not start the stream
		   just yet, wait for transport negotiation to complete... */
	}

	g_list_free(codec_intersection);

	if (!strcmp(action, "session-accept")) {
		purple_media_got_accept(jabber_jingle_session_get_media(session));
		purple_debug_info("jabber", "Got session-accept, starting stream\n");
		gst_element_set_state(purple_media_get_audio_pipeline(session->media),
				      GST_STATE_PLAYING);
	}

	jabber_iq_send(result);

	const char *initiator = NULL;
	GList *codecs = NULL;
	JabberIq *result = NULL;

	if (!jingle) {
		purple_debug_error("jabber", "Malformed request");
		return;
	}

	sid = xmlnode_get_attrib(jingle, "sid");
	initiator = xmlnode_get_attrib(jingle, "initiator");

	if (jabber_jingle_session_find_by_id(js, sid)) {
		/* This should only happen if you start a session with yourself */
		purple_debug_error("jabber", "Jingle session with id={%s} already exists\n", sid);
		return;
	}
	session = jabber_jingle_session_create_by_id(js, sid);

	/* init media */
	content = xmlnode_get_child(jingle, "content");
	if (!content) {
		purple_debug_error("jabber", "jingle tag must contain content tag\n");
		/* should send error here */
		return;
	}

	description = xmlnode_get_child(content, "description");

	if (!description) {
		purple_debug_error("jabber", "content tag must contain description tag\n");
		/* we should create an error iq here */
		return;
	}

	if (!jabber_jingle_session_initiate_media_internal(session, initiator, initiator)) {
		purple_debug_error("jabber", "Couldn't start media session with %s\n", initiator);
		jabber_jingle_session_destroy(session);
		/* we should create an error iq here */
		return;
	}

	xmlnode *jingle = xmlnode_get_child(packet, "jingle");
	const char *sid = xmlnode_get_attrib(jingle, "sid");
	JingleSession *session = jabber_jingle_session_find_by_id(js, sid);

	if (!session) {
		purple_debug_error("jabber", "jabber_handle_session_terminate couldn't find session\n");
		return;
	}

	xmlnode_set_attrib(result->node, "to",
			   jabber_jingle_session_get_remote_jid(session));

	GList *remote_candidates = jabber_jingle_get_candidates(transport);
	const char *sid = xmlnode_get_attrib(jingle, "sid");
	JingleSession *session = jabber_jingle_session_find_by_id(js, sid);

	if (!session)
		purple_debug_error("jabber", "jabber_handle_session_candidates couldn't find session\n");

	/* send acknowledement */
	xmlnode_set_attrib(result->node, "id", xmlnode_get_attrib(packet, "id"));
	xmlnode_set_attrib(result->node, "to", xmlnode_get_attrib(packet, "from"));
	jabber_iq_send(result);

23822:a7be3074923b

	xmlnode_set_attrib(result->node, "to",
			   jabber_jingle_session_get_remote_jid(session));

	xmlnode_insert_child(result->node, jingle);
	jabber_iq_send(result);
	purple_debug_info("jingle", "Sent session accept, starting stream\n");
	gst_element_set_state(purple_media_get_audio_pipeline(session->media), GST_STATE_PLAYING);

	session->session_started = TRUE;
}

	if (!jabber_jingle_session_is_initiator(session)) {
		/* create transport-info package */
		JabberIq *result = jabber_iq_new(jabber_jingle_session_get_js(session),
						 JABBER_IQ_SET);
		xmlnode *jingle = jabber_jingle_session_create_transport_info(session);
		purple_debug_info("jingle", "jabber_session_candidates_prepared: %d candidates\n",
				  g_list_length(purple_media_get_local_audio_candidates(session->media)));
		xmlnode_set_attrib(result->node, "to",
				   jabber_jingle_session_get_remote_jid(session));

		xmlnode_insert_child(result->node, jingle);

jabber_jingle_session_candidate_pair_established(PurpleMedia *media,
						 FsCandidate *native_candidate,
						 FsCandidate *remote_candidate,
						 JingleSession *session)
{	
	purple_debug_info("jingle", "jabber_candidate_pair_established called\n");
	/* if we are the initiator, we should send a content-modify message */
	if (jabber_jingle_session_is_initiator(session)) {
		JabberIq *result;
		xmlnode *jingle;
		
		purple_debug_info("jingle", "we are the initiator, let's send content-modify\n");

		result = jabber_iq_new(jabber_jingle_session_get_js(session), JABBER_IQ_SET);

		/* shall change this to a "content-replace" */
		jingle = jabber_jingle_session_create_content_replace(session,

	media = purple_media_manager_create_media(purple_media_manager_get(), 
						  session->js->gc, "fsrtpconference", remote_jid);

	if (!media) {
		purple_debug_error("jingle", "Couldn't create fsrtpconference\n");
		return FALSE;
	}

	/* this will need to be changed to "nice" once the libnice transmitter is finished */
	if (!purple_media_add_stream(media, remote_jid, PURPLE_MEDIA_AUDIO, "rawudp")) {
		purple_debug_error("jingle", "Couldn't create audio stream\n");
		purple_media_reject(media);
		return FALSE;
	}

	jabber_jingle_session_set_remote_jid(session, remote_jid);

	}

	/* create transport-info package */
	result = jabber_iq_new(jabber_jingle_session_get_js(session), JABBER_IQ_SET);
	jingle = jabber_jingle_session_create_transport_info(session);
	purple_debug_info("jingle", "jabber_session_candidates_prepared: %d candidates\n",
			  g_list_length(purple_media_get_local_audio_candidates(session->media)));
	xmlnode_set_attrib(result->node, "to",
			   jabber_jingle_session_get_remote_jid(session));

	xmlnode_insert_child(result->node, jingle);

	char *jid = NULL, *me = NULL;

	/* construct JID to send to */
	jb = jabber_buddy_find(js, who, FALSE);
	if (!jb) {
		purple_debug_error("jingle", "Could not find Jabber buddy\n");
		return NULL;
	}
	jbr = jabber_buddy_find_resource(jb, NULL);
	if (!jbr) {
		purple_debug_error("jingle", "Could not find buddy's resource\n");
	}

	if ((strchr(who, '/') == NULL) && jbr && (jbr->name != NULL)) {
		jid = g_strdup_printf("%s/%s", who, jbr->name);
	} else {

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

	/* fetch codecs from remote party */
	purple_debug_info("jingle", "get codecs from session-accept\n");
	remote_codecs = jabber_jingle_get_codecs(description);
	purple_debug_info("jingle", "get transport candidates from session accept\n");
	remote_transports = jabber_jingle_get_candidates(transport);

	purple_debug_info("jingle", "Got %d codecs from responder\n",
			  g_list_length(remote_codecs));
	purple_debug_info("jingle", "Got %d transport candidates from responder\n",
			  g_list_length(remote_transports));

	purple_debug_info("jingle", "Setting remote codecs on stream\n");

	purple_media_set_remote_audio_codecs(session->media, 
					     jabber_jingle_session_get_remote_jid(session),
					     remote_codecs);

	codec_intersection = purple_media_get_negotiated_audio_codecs(session->media);
	purple_debug_info("jingle", "codec_intersection contains %d elems\n",
			  g_list_length(codec_intersection));
	/* get the top codec */
	if (g_list_length(codec_intersection) > 0) {
		top = (FsCodec *) codec_intersection->data;
		purple_debug_info("jingle", "Found a suitable codec on stream = %d\n",
				  top->id);

		/* we have found a suitable codec, but we will not start the stream
		   just yet, wait for transport negotiation to complete... */
	}

	g_list_free(codec_intersection);

	if (!strcmp(action, "session-accept")) {
		purple_media_got_accept(jabber_jingle_session_get_media(session));
		purple_debug_info("jingle", "Got session-accept, starting stream\n");
		gst_element_set_state(purple_media_get_audio_pipeline(session->media),
				      GST_STATE_PLAYING);
	}

	jabber_iq_send(result);

	const char *initiator = NULL;
	GList *codecs = NULL;
	JabberIq *result = NULL;

	if (!jingle) {
		purple_debug_error("jingle", "Malformed request");
		return;
	}

	sid = xmlnode_get_attrib(jingle, "sid");
	initiator = xmlnode_get_attrib(jingle, "initiator");

	if (jabber_jingle_session_find_by_id(js, sid)) {
		/* This should only happen if you start a session with yourself */
		purple_debug_error("jingle", "Jingle session with id={%s} already exists\n", sid);
		return;
	}
	session = jabber_jingle_session_create_by_id(js, sid);

	/* init media */
	content = xmlnode_get_child(jingle, "content");
	if (!content) {
		purple_debug_error("jingle", "jingle tag must contain content tag\n");
		/* should send error here */
		return;
	}

	description = xmlnode_get_child(content, "description");

	if (!description) {
		purple_debug_error("jingle", "content tag must contain description tag\n");
		/* we should create an error iq here */
		return;
	}

	if (!jabber_jingle_session_initiate_media_internal(session, initiator, initiator)) {
		purple_debug_error("jingle", "Couldn't start media session with %s\n", initiator);
		jabber_jingle_session_destroy(session);
		/* we should create an error iq here */
		return;
	}

	xmlnode *jingle = xmlnode_get_child(packet, "jingle");
	const char *sid = xmlnode_get_attrib(jingle, "sid");
	JingleSession *session = jabber_jingle_session_find_by_id(js, sid);

	if (!session) {
		purple_debug_error("jingle", "jabber_handle_session_terminate couldn't find session\n");
		return;
	}

	xmlnode_set_attrib(result->node, "to",
			   jabber_jingle_session_get_remote_jid(session));

	GList *remote_candidates = jabber_jingle_get_candidates(transport);
	const char *sid = xmlnode_get_attrib(jingle, "sid");
	JingleSession *session = jabber_jingle_session_find_by_id(js, sid);

	if (!session)
		purple_debug_error("jingle", "jabber_handle_session_candidates couldn't find session\n");

	/* send acknowledement */
	xmlnode_set_attrib(result->node, "id", xmlnode_get_attrib(packet, "id"));
	xmlnode_set_attrib(result->node, "to", xmlnode_get_attrib(packet, "from"));
	jabber_iq_send(result);