Skip to content

Commit

Permalink
Merge branch 'master' into extendFieldsInJoinRoom
Browse files Browse the repository at this point in the history
  • Loading branch information
@mustafaboleken
mustafaboleken authored Dec 8, 2024
2 parents 04ea0d0 + dcc3e0b commit 68a2de0
Show file tree
Hide file tree
Showing 4 changed files with 277 additions and 63 deletions.
153 changes: 97 additions & 56 deletions src/main/js/webrtc_adaptor.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -358,6 +358,11 @@ export class WebRTCAdaptor {
* This is the time info for the last reconnection attempt
*/
this.lastReconnectiontionTrialTime = 0;

/**
* TimerId for the pending try again call
*/
this.pendingTryAgainTimerId = -1;

/**
* All media management works for teh local stream are made by @MediaManager class.
Expand Down Expand Up @@ -516,15 +521,8 @@ export class WebRTCAdaptor {
}
//init peer connection for reconnectIfRequired
this.initPeerConnection(streamId, "publish");
setTimeout(() => {
//check if it is connected or not
//this resolves if the server responds with some error message
if (this.iceConnectionState(this.publishStreamId) != "checking" && this.iceConnectionState(this.publishStreamId) != "connected" && this.iceConnectionState(this.publishStreamId) != "completed") {
//if it is not connected, try to reconnect
this.reconnectIfRequired(0);
}
}, 3000);


this.reconnectIfRequired(3000, false);
}

sendPublishCommand(streamId, token, subscriberId, subscriberCode, streamName, mainTrack, metaData, role, videoEnabled, audioEnabled) {
Expand Down Expand Up @@ -605,49 +603,51 @@ export class WebRTCAdaptor {
subscriberCode: typeof subscriberCode !== undefined && subscriberId != null ? subscriberCode : "",
viewerInfo: typeof metaData !== undefined && metaData != null ? metaData : "",
role: (typeof role !== undefined && role != null) ? role : "",
userPublishId: typeof this.publishStreamId !== undefined && this.publishStreamId != null ? this.publishStreamId : "",
}

this.webSocketAdaptor.send(JSON.stringify(jsCmd));

//init peer connection for reconnectIfRequired
this.initPeerConnection(streamId, "play");

setTimeout(() => {
//check if it is connected or not
//this resolves if the server responds with some error message
if (this.iceConnectionState(streamId) != "checking" &&
this.iceConnectionState(streamId) != "connected" &&
this.iceConnectionState(streamId) != "completed") {
//if it is not connected, try to reconnect
this.reconnectIfRequired(0);
}
}, 3000);
this.reconnectIfRequired(3000, false);
}

/**
* Reconnects to the stream if it is not stopped on purpose
* @param {number} [delayMs]
* @returns
*/
reconnectIfRequired(delayMs = 3000) {
reconnectIfRequired(delayMs = 3000, forceReconnect = false) {
if (this.reconnectIfRequiredFlag) {
//It's important to run the following methods after 3000 ms because the stream may be stopped by the user in the meantime
if (delayMs > 0) {
setTimeout(() => {
this.tryAgain();
}, delayMs);
if (delayMs <= 0) {
delayMs = 500;
//clear the timer because there is a demand to reconnect without delay
clearTimeout(this.pendingTryAgainTimerId);
this.pendingTryAgainTimerId = -1;
}
else {
this.tryAgain()

if (this.pendingTryAgainTimerId == -1)
{
this.pendingTryAgainTimerId = setTimeout(() =>
{
this.pendingTryAgainTimerId = -1;
this.tryAgain(forceReconnect);
},
delayMs);
}
}
}

tryAgain() {
tryAgain(forceReconnect) {

const now = Date.now();
//to prevent too many trial from different paths
if (now - this.lastReconnectiontionTrialTime < 3000) {
const timeDiff = now - this.lastReconnectiontionTrialTime;;
if (timeDiff < 3000 && forceReconnect == false) {
//check again 1 seconds later if it is not stopped on purpose
Logger.debug("Reconnection request received after "+ timeDiff+" ms. It should be at least 3000ms. It will try again after 1000ms");
this.reconnectIfRequired(1000, forceReconnect);
return;
}
this.lastReconnectiontionTrialTime = now;
Expand All @@ -656,10 +656,10 @@ export class WebRTCAdaptor {
//if remotePeerConnection has a peer connection for the stream id, it means that it is not stopped on purpose

if (this.remotePeerConnection[this.publishStreamId] != null &&
(forceReconnect ||
//check connection status to not stop streaming an active stream
this.iceConnectionState(this.publishStreamId) != "checking" &&
this.iceConnectionState(this.publishStreamId) != "connected" &&
this.iceConnectionState(this.publishStreamId) != "completed") {
["checking", "connected", "completed"].indexOf(this.iceConnectionState(this.publishStreamId)) === -1)
) {
// notify that reconnection process started for publish
this.notifyEventListeners("reconnection_attempt_for_publisher", this.publishStreamId);

Expand All @@ -675,11 +675,12 @@ export class WebRTCAdaptor {
//reconnect play
for (var index in this.playStreamId) {
let streamId = this.playStreamId[index];
if (this.remotePeerConnection[streamId] != "null" &&
//check connection status to not stop streaming an active stream
this.iceConnectionState(streamId) != "checking" &&
this.iceConnectionState(streamId) != "connected" &&
this.iceConnectionState(streamId) != "completed") {
if (this.remotePeerConnection[streamId] != null &&
(forceReconnect ||
//check connection status to not stop streaming an active stream
["checking", "connected", "completed"].indexOf(this.iceConnectionState(streamId)) === -1
)
) {
// notify that reconnection process started for play
this.notifyEventListeners("reconnection_attempt_for_player", streamId);

Expand Down Expand Up @@ -886,6 +887,22 @@ export class WebRTCAdaptor {
this.webSocketAdaptor.send(JSON.stringify(jsCmd));
}

/**
* Called to get the subtrack count for a specific maintrack. AMS responds with the subtrackCount callback.
* @param {string} streamId : main track id
* @param {string} role : filter the subtracks with the role
* @param {string} status : filter the subtracks with the status
*/
getSubtrackCount(streamId, role, status) {
let jsCmd = {
command: "getSubtracksCount",
streamId: streamId,
role: role,
status: status,
};
this.webSocketAdaptor.send(JSON.stringify(jsCmd));
}

/**
* Called to enable/disable data flow from the AMS for a specific track under a main track.
* Parameters:
Expand Down Expand Up @@ -1144,27 +1161,38 @@ export class WebRTCAdaptor {

this.remotePeerConnection[streamId].oniceconnectionstatechange = event => {
var obj = { state: this.remotePeerConnection[streamId].iceConnectionState, streamId: streamId };
if (obj.state == "failed" || obj.state == "disconnected" || obj.state == "closed") {
this.reconnectIfRequired(3000);
}
this.notifyEventListeners("ice_connection_state_changed", obj);

//
if (!this.isPlayMode && !this.playStreamId.includes(streamId)) {
if (this.remotePeerConnection[streamId].iceConnectionState == "connected") {

this.mediaManager.changeBandwidth(this.mediaManager.bandwidth, streamId).then(() => {
Logger.debug("Bandwidth is changed to " + this.mediaManager.bandwidth);
})
.catch(e => Logger.warn(e));
}
}
this.oniceconnectionstatechangeCallback(obj);
}

}

return this.remotePeerConnection[streamId];
}

oniceconnectionstatechangeCallback(obj)
{
Logger.debug("ice connection state is " +obj.state + " for streamId: " + obj.streamId);
if (obj.state == "failed" || obj.state == "disconnected" || obj.state == "closed") {
//try immediately
Logger.debug("ice connection state is failed, disconnected or closed for streamId: " + obj.streamId + " it will try to reconnect immediately");
this.reconnectIfRequired(0, false);
}
this.notifyEventListeners("ice_connection_state_changed", obj);

//
if (!this.isPlayMode && !this.playStreamId.includes(obj.streamId)) {
if (this.remotePeerConnection[obj.streamId] != null && this.remotePeerConnection[obj.streamId].iceConnectionState == "connected") {

this.mediaManager.changeBandwidth(this.mediaManager.bandwidth, obj.streamId).then(() => {
Logger.debug("Bandwidth is changed to " + this.mediaManager.bandwidth);
})
.catch(e => Logger.warn(e));
}
}
}



/**
* Called internally to close PeerConnection.
Expand Down Expand Up @@ -1753,10 +1781,7 @@ export class WebRTCAdaptor {
websocket_url: this.websocketURL,
webrtcadaptor: this,
callback: (info, obj) => {
if (info == "closed") {
this.reconnectIfRequired();
}
this.notifyEventListeners(info, obj);
this.websocketCallback(info, obj)
},
callbackError: (error, message) => {
this.notifyErrorEventListeners(error, message)
Expand All @@ -1765,6 +1790,22 @@ export class WebRTCAdaptor {
});
}
}

websocketCallback(info, obj) {

if (info == "closed" || info == "server_will_stop") {
Logger.info("Critical response from server:"+ info +". It will reconnect immediately if there is an active connection");

//close websocket reconnect again
if (info == "server_will_stop") {
this.webSocketAdaptor.close();
}
//try with forcing reconnect because webrtc will be closed as well
this.reconnectIfRequired(0, true);
}

this.notifyEventListeners(info, obj);
}

/**
* Called to stop Web Socket connection
Expand Down
13 changes: 7 additions & 6 deletions src/main/webapp/conference.html
View file
Original file line number Diff line number Diff line change
Expand Up @@ -687,12 +687,12 @@ <h3 class="col text-muted">WebRTC Multitrack Conference</h3>
var state = webRTCAdaptor
.signallingState(publishStreamId);
if (state != null
&& state != "closed") {
&& state != "closed")
{
var iceState = webRTCAdaptor
.iceConnectionState(publishStreamId);
if (iceState != null
&& iceState != "failed"
&& iceState != "disconnected") {
if (iceState != null && iceState != "new" && iceState != "closed" && iceState != "failed" && iceState != "disconnected")
{
startAnimation();
}
}
Expand Down Expand Up @@ -864,10 +864,11 @@ <h3 class="col text-muted">WebRTC Multitrack Conference</h3>
}
else {
//errorHandler(error, message);
$('video').notify("Warning: " + errorHandler(error, message), {

$('#roomName').notify("Warning: " + errorHandler(error, message), {
autoHideDelay: 5000,
className: 'error',
position: 'top right'
position: 'top center'
});
}

Expand Down
2 changes: 1 addition & 1 deletion src/main/webapp/samples/publish_webrtc.html
View file
Original file line number Diff line number Diff line change
Expand Up @@ -490,7 +490,7 @@
var state = webRTCAdaptor.signallingState(streamId);
if (state != null && state != "closed") {
var iceState = webRTCAdaptor.iceConnectionState(streamId);
if (iceState != null && iceState != "failed" && iceState != "disconnected") {
if (iceState != null && iceState != "new" && iceState != "closed" && iceState != "failed" && iceState != "disconnected") {
startAnimation();
}
else {
Expand Down
Loading

0 comments on commit 68a2de0

Please sign in to comment.