From 905d54bee48fa4fe8dcc04cd8e6b6f54e800d10b Mon Sep 17 00:00:00 2001 From: Philipp Hancke Date: Sun, 29 Dec 2013 21:14:19 +0100 Subject: [PATCH] allow focus to associate streams to participant jids --- libs/colibri.js | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/libs/colibri.js b/libs/colibri.js index 23c7e748f..437fa41e6 100644 --- a/libs/colibri.js +++ b/libs/colibri.js @@ -94,6 +94,12 @@ ColibriFocus.prototype.makeConference = function (peers) { }; this.peerconnection.onaddstream = function (event) { ob.remoteStream = event.stream; + // search the jid associated with this stream + Object.keys(ob.remotessrc).forEach(function (jid) { + if (ob.remotessrc[jid].join('\r\n').indexOf('mslabel:' + event.stream.id) != -1) { + event.peerjid = jid; + } + }); $(document).trigger('remotestreamadded.jingle', [event, ob.sid]); }; this.peerconnection.onicecandidate = function (event) { @@ -481,11 +487,11 @@ ColibriFocus.prototype.updateChannel = function (remoteSDP, participant) { // tell everyone about a new participants a=ssrc lines (isadd is true) // or a leaving participants a=ssrc lines // FIXME: should not take an SDP, but rather the a=ssrc lines and probably a=mid -ColibriFocus.prototype.sendSSRCUpdate = function (sdp, exclude, isadd) { +ColibriFocus.prototype.sendSSRCUpdate = function (sdp, jid, isadd) { var ob = this; this.peers.forEach(function (peerjid) { - if (peerjid == exclude) return; - console.log('tell', peerjid, 'about ' + (isadd ? 'new' : 'removed') + ' ssrcs from', exclude); + if (peerjid == jid) return; + console.log('tell', peerjid, 'about ' + (isadd ? 'new' : 'removed') + ' ssrcs from', jid); if (!ob.remotessrc[peerjid]) { // FIXME: this should only send to participants that are stable, i.e. who have sent a session-accept // possibly, this.remoteSSRC[session.peerjid] does not exist yet @@ -650,7 +656,6 @@ ColibriFocus.prototype.terminate = function (session, reason) { if (!this.remotessrc[session.peerjid] || participant == -1) { return; } - console.log('remote ssrcs:', this.remotessrc[session.peerjid]); var ssrcs = this.remotessrc[session.peerjid]; for (var i = 0; i < ssrcs.length; i++) { if (!this.removessrc[i]) this.removessrc[i] = '';