Send offer again when own peer is not initially connected

Signed-off-by: Daniel Calviño Sánchez <[email protected]>

Author: danxuliu

src/utils/webrtc/webrtc.js

@@ -117,22 +117,42 @@ function checkStartPublishOwnPeer(signaling) {
 	}
 
 	if (ownPeer) {
+		if (delayedConnectionToPeer[ownPeer.id]) {
+			clearInterval(delayedConnectionToPeer[ownPeer.id]);
+			delete delayedConnectionToPeer[ownPeer.id];
+		}
 		ownPeer.end()
 	}
 
-	// Create own publishing stream.
-	ownPeer = webrtc.webrtc.createPeer({
-		id: currentSessionId,
-		type: 'video',
-		enableDataChannels: true,
-		receiveMedia: {
-			offerToReceiveAudio: 0,
-			offerToReceiveVideo: 0,
-		},
-		sendVideoIfAvailable: signaling.getSendVideoIfAvailable(),
-	})
-	webrtc.emit('createdPeer', ownPeer)
-	ownPeer.start()
+	var createPeer = function() {
+		// Create own publishing stream.
+		ownPeer = webrtc.webrtc.createPeer({
+			id: currentSessionId,
+			type: 'video',
+			enableDataChannels: true,
+			receiveMedia: {
+				offerToReceiveAudio: 0,
+				offerToReceiveVideo: 0,
+			},
+			sendVideoIfAvailable: signaling.getSendVideoIfAvailable(),
+		})
+		webrtc.emit('createdPeer', ownPeer)
+		ownPeer.start()
+	}
+
+	createPeer();
+
+	delayedConnectionToPeer[ownPeer.id] = setInterval(function() {
+		// New offers are periodically sent until a connection is established.
+		// As an offer can not be sent again from an existing peer it must be
+		// removed and a new one must be created from scratch.
+		if (ownPeer) {
+			ownPeer.end();
+		}
+
+		console.debug('No answer received for own peer, sending offer again')
+		createPeer();
+	}, 10000);
 }
 
 function userHasStreams(user) {
@@ -340,6 +360,17 @@ export default function initWebRTC(signaling, _callParticipantCollection) {
 			return
 		}
 
+		// The delayed connection for the own peer needs to be explicitly
+		// stopped, as the current own session is not passed along with the
+		// sessions of the other participants as "disconnected" to
+		// "usersChanged" when a call is left.
+		// The peer, on the other hand, is automatically ended by "leaveCall"
+		// below.
+		if (ownPeer && delayedConnectionToPeer[ownPeer.id]) {
+			clearInterval(delayedConnectionToPeer[ownPeer.id]);
+			delete delayedConnectionToPeer[ownPeer.id];
+		}
+
 		webrtc.leaveCall()
 	})
 
@@ -729,6 +760,10 @@ export default function initWebRTC(signaling, _callParticipantCollection) {
 
 	const forceReconnect = function(signaling, flags) {
 		if (ownPeer) {
+			if (delayedConnectionToPeer[ownPeer.id]) {
+				clearInterval(delayedConnectionToPeer[ownPeer.id]);
+				delete delayedConnectionToPeer[ownPeer.id];
+			}
 			ownPeer.end()
 			ownPeer = null
 		}