Skip to content

Commit 022b591

Browse files
author
dimaspirit
committed
review qbClient
1 parent 2e20aa3 commit 022b591

File tree

3 files changed

+18
-20
lines changed

3 files changed

+18
-20
lines changed

js/modules/webrtc/qbRTCPeerConnection.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
/*
1+
/**
22
* QuickBlox JavaScript SDK
33
* WebRTC Module (WebRTC peer connection model)
44
*/

js/modules/webrtc/qbWebRTCClient.js

Lines changed: 16 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,6 @@
1-
/*
1+
/**
22
* QuickBlox JavaScript SDK
3-
*
43
* WebRTC Module (WebRTC client)
5-
*
64
*/
75

86
/*
@@ -50,9 +48,9 @@ WebRTCClient.prototype.sessions = {};
5048

5149
/**
5250
* Creates the new session.
53-
* @param {number} Initiator ID
54-
* @param {array} Opponents IDs
55-
* @param {enum} Call type
51+
* @param {array} opponentsIDs Opponents IDs
52+
* @param {number} ct Call type
53+
* @param {number} cID Initiator ID
5654
*/
5755
WebRTCClient.prototype.createNewSession = function(opponentsIDs, ct, cID) {
5856
var opponentsIdNASessions = getOpponentsIdNASessions(this.sessions),
@@ -76,7 +74,7 @@ WebRTCClient.prototype.createNewSession = function(opponentsIDs, ct, cID) {
7674
WebRTCClient.prototype._createAndStoreSession = function(sessionID, callerID, opponentsIDs, callType) {
7775
var newSession = new WebRTCSession(sessionID, callerID, opponentsIDs, callType, this.signalingProvider, Helpers.getIdFromNode(this.connection.jid));
7876

79-
// set callbacks
77+
/** set callbacks */
8078
newSession.onUserNotAnswerListener = this.onUserNotAnswerListener;
8179
newSession.onRemoteStreamListener = this.onRemoteStreamListener;
8280
newSession.onSessionConnectionStateChangedListener = this.onSessionConnectionStateChangedListener;
@@ -100,7 +98,6 @@ WebRTCClient.prototype.clearSession = function(sessionId){
10098
* @returns {boolean} if active or new session exist
10199
*/
102100
WebRTCClient.prototype.isExistNewOrActiveSessionExceptSessionID = function(sessionID){
103-
104101
var self = this;
105102
var exist = false;
106103

@@ -115,13 +112,13 @@ WebRTCClient.prototype.isExistNewOrActiveSessionExceptSessionID = function(sessi
115112
}
116113
});
117114
}
115+
118116
return exist;
119117
};
120118

121119
/**
122120
* DELEGATE (signaling)
123121
*/
124-
125122
WebRTCClient.prototype._onCallListener = function(userID, sessionID, extension) {
126123
Helpers.trace("onCall. UserID:" + userID + ". SessionID: " + sessionID);
127124

@@ -146,15 +143,16 @@ WebRTCClient.prototype._onCallListener = function(userID, sessionID, extension)
146143
this.onCallListener(session, extensionClone);
147144
}
148145
}
146+
149147
session.processOnCall(userID, extension);
150148
}
151149
};
152150

153151
WebRTCClient.prototype._onAcceptListener = function(userID, sessionID, extension) {
154-
Helpers.trace("onAccept. UserID:" + userID + ". SessionID: " + sessionID);
155-
156152
var session = this.sessions[sessionID];
157153

154+
Helpers.trace("onAccept. UserID:" + userID + ". SessionID: " + sessionID);
155+
158156
if(session){
159157
if(session.state === WebRTCSession.State.ACTIVE ) {
160158
var extensionClone = JSON.parse(JSON.stringify(extension));
@@ -174,10 +172,10 @@ WebRTCClient.prototype._onAcceptListener = function(userID, sessionID, extension
174172
};
175173

176174
WebRTCClient.prototype._onRejectListener = function(userID, sessionID, extension) {
177-
Helpers.trace("onReject. UserID:" + userID + ". SessionID: " + sessionID);
178-
179175
var session = this.sessions[sessionID];
180176

177+
Helpers.trace("onReject. UserID:" + userID + ". SessionID: " + sessionID);
178+
181179
if(session){
182180
var extensionClone = JSON.parse(JSON.stringify(extension));
183181
this._cleanupExtension(extensionClone);
@@ -212,10 +210,10 @@ WebRTCClient.prototype._onStopListener = function(userID, sessionID, extension)
212210
};
213211

214212
WebRTCClient.prototype._onIceCandidatesListener = function(userID, sessionID, extension) {
215-
Helpers.trace("onIceCandidates. UserID:" + userID + ". SessionID: " + sessionID + ". ICE candidates count: " + extension.iceCandidates.length);
216-
217213
var session = this.sessions[sessionID];
218214

215+
Helpers.trace("onIceCandidates. UserID:" + userID + ". SessionID: " + sessionID + ". ICE candidates count: " + extension.iceCandidates.length);
216+
219217
if(session){
220218
if(session.state === WebRTCSession.State.ACTIVE) {
221219
session.processOnIceCandidates(userID, extension);
@@ -228,10 +226,10 @@ WebRTCClient.prototype._onIceCandidatesListener = function(userID, sessionID, ex
228226
};
229227

230228
WebRTCClient.prototype._onUpdateListener = function(userID, sessionID, extension) {
231-
Helpers.trace("onUpdate. UserID:" + userID + ". SessionID: " + sessionID + ". Extension: " + JSON.stringify(extension));
232-
233229
var session = this.sessions[sessionID];
234230

231+
Helpers.trace("onUpdate. UserID:" + userID + ". SessionID: " + sessionID + ". Extension: " + JSON.stringify(extension));
232+
235233
if (typeof this.onUpdateCallListener === 'function'){
236234
this.onUpdateCallListener(session, userID, extension);
237235
}
@@ -280,4 +278,4 @@ function getOpponentsIdNASessions(sessions) {
280278
}
281279

282280
return opponents;
283-
}
281+
}

0 commit comments

Comments
 (0)