e2ee: also enable on p2p connections

JitsiConference.js

@@ -1113,8 +1113,6 @@ JitsiConference.prototype._setupNewTrack = function(newTrack) {
     newTrack._setConference(this);
 
     this.eventEmitter.emit(JitsiConferenceEvents.TRACK_ADDED, newTrack);
-
-    this._setupSenderE2EEForTrack(newTrack);
 };
 
 /**
@@ -1698,6 +1696,14 @@ JitsiConference.prototype.onRemoteTrackAdded = function(track) {
 JitsiConference.prototype.onCallAccepted = function(session, answer) {
     if (this.p2pJingleSession === session) {
         logger.info('P2P setAnswer');
+
+        // Setup E2EE.
+        const localTracks = this.getLocalTracks();
+
+        for (const track of localTracks) {
+            this._setupSenderE2EEForTrack(session, track);
+        }
+
         this.p2pJingleSession.setAnswer(answer);
     }
 };
@@ -1877,7 +1883,7 @@ JitsiConference.prototype._acceptJvbIncomingCall = function(
 
                 // Setup E2EE.
                 for (const track of localTracks) {
-                    this._setupSenderE2EEForTrack(track);
+                    this._setupSenderE2EEForTrack(jingleSession, track);
                 }
             },
             error => {
@@ -2637,6 +2643,11 @@ JitsiConference.prototype._acceptP2PIncomingCall = function(
         jingleOffer,
         () => {
             logger.debug('Got RESULT for P2P "session-accept"');
+
+            // Setup E2EE.
+            for (const track of localTracks) {
+                this._setupSenderE2EEForTrack(jingleSession, track);
+            }
         },
         error => {
             logger.error(
@@ -3324,17 +3335,17 @@ JitsiConference.prototype.setE2EEKey = function(key) {
  *
  * @returns {void}
  */
-JitsiConference.prototype._setupSenderE2EEForTrack = function(track) {
-    const jvbPc = this.jvbJingleSession ? this.jvbJingleSession.peerconnection : null;
-
-    if (jvbPc && this._e2eeCtx) {
-        const sender = jvbPc.findSenderForTrack(track.track);
+JitsiConference.prototype._setupSenderE2EEForTrack = function(session, track) {
+    if (!this._e2eeCtx) {
+        return;
+    }
+    const pc = session.peerconnection;
+    const sender = pc.findSenderForTrack(track.track);
 
-        if (sender) {
-            this._e2eeCtx.handleSender(sender, track.getType());
-        } else {
-            logger.warn(`Could not handle E2EE for local ${track.getType()} track: sender not found`);
-        }
+    if (sender) {
+        this._e2eeCtx.handleSender(sender, track.getType());
+    } else {
+        logger.warn(`Could not handle E2EE for local ${track.getType()} track: sender not found`);
     }
 };
 
@@ -3345,10 +3356,14 @@ JitsiConference.prototype._setupSenderE2EEForTrack = function(track) {
  * @returns {void}
  */
 JitsiConference.prototype._setupReceiverE2EEForTrack = function(track) {
-    const jvbPc = this.jvbJingleSession ? this.jvbJingleSession.peerconnection : null;
+    if (!this._e2eeCtx) {
+        return;
+    }
+    const session = track.isP2P ? this.p2pJingleSession : this.jvbJingleSession;
+    const pc = session && session.peerconnection;
 
-    if (jvbPc && this._e2eeCtx) {
-        const receiver = jvbPc.findReceiverForTrack(track.track);
+    if (pc) {
+        const receiver = pc.findReceiverForTrack(track.track);
 
         if (receiver) {
             this._e2eeCtx.handleReceiver(receiver, track.getType());

modules/RTC/RTC.js

@@ -506,7 +506,7 @@ export default class RTC extends Listenable {
 
         // FIXME: We should rename iceConfig to pcConfig.
 
-        if (!isP2P && browser.supportsInsertableStreams()) {
+        if (browser.supportsInsertableStreams()) {
             logger.debug('E2EE - setting insertable streams constraints');
             iceConfig.forceEncodedAudioInsertableStreams = true;
             iceConfig.forceEncodedVideoInsertableStreams = true;