bigbluebutton-Github/bigbluebutton-client/resources/prod/lib/bbb_webrtc_bridge_sip.js
Lucas Zawacki 2bf4b30b10 Use hostname instead of host on javascript webrtc bridge client code
This prevents it from appending the port number when a request is made from
the HTML5 client
2014-12-17 22:58:06 +00:00

421 lines
11 KiB
JavaScript
Executable File

var callerIdName, conferenceVoiceBridge, userAgent, userMicMedia, userWebcamMedia, currentSession, callTimeout, callActive, callICEConnected, callFailCounter, callPurposefullyEnded, uaConnected;
function callIntoConference(voiceBridge, callback) {
if (!callerIdName) {
BBB.getMyUserInfo(function(userInfo) {
console.log("User info callback [myUserID=" + userInfo.myUserID
+ ",myUsername=" + userInfo.myUsername + ",myAvatarURL=" + userInfo.myAvatarURL
+ ",myRole=" + userInfo.myRole + ",amIPresenter=" + userInfo.amIPresenter
+ ",dialNumber=" + userInfo.dialNumber + ",voiceBridge=" + userInfo.voiceBridge + "].");
callerIdName = userInfo.myUserID + "-bbbID-" + userInfo.myUsername;
conferenceVoiceBridge = userInfo.voiceBridge
voiceBridge = voiceBridge || conferenceVoiceBridge;
console.log(callerIdName);
webrtc_call(callerIdName, voiceBridge, callback);
});
} else {
voiceBridge = voiceBridge || conferenceVoiceBridge;
webrtc_call(callerIdName, voiceBridge, callback);
}
}
function joinWebRTCVoiceConference() {
console.log("Joining to the voice conference");
var callback = function(message) {
switch (message.status) {
case 'failed':
BBB.webRTCConferenceCallFailed(message.errorcode);
break;
case 'ended':
BBB.webRTCConferenceCallEnded();
break;
case 'started':
BBB.webRTCConferenceCallStarted();
break;
case 'connecting':
BBB.webRTCConferenceCallConnecting();
break;
case 'waitingforice':
BBB.webRTCConferenceCallWaitingForICE();
break;
case 'mediarequest':
BBB.webRTCMediaRequest();
break;
case 'mediasuccess':
BBB.webRTCMediaSuccess();
break;
case 'mediafail':
BBB.webRTCMediaFail();
break;
case 'websocketSucceded':
BBB.webRTCConferenceCallWebsocketSucceeded();
break;
case 'websocketFailed':
BBB.webRTCConferenceCallWebsocketFailed(message.errorcode);
break;
}
}
callIntoConference(conferenceVoiceBridge, callback);
}
function leaveWebRTCVoiceConference() {
console.log("Leaving the voice conference");
webrtc_hangup();
}
function startWebRTCAudioTest(){
console.log("Testing webrtc audio");
var callback = function(message) {
switch(message.status) {
case 'failed':
BBB.webRTCEchoTestFailed(message.errorcode);
break;
case 'ended':
BBB.webRTCEchoTestEnded();
break;
case 'started':
BBB.webRTCEchoTestStarted();
break;
case 'connecting':
BBB.webRTCEchoTestConnecting();
break;
case 'waitingforice':
BBB.webRTCEchoTestWaitingForICE();
break;
case 'mediarequest':
BBB.webRTCMediaRequest();
break;
case 'mediasuccess':
BBB.webRTCMediaSuccess();
break;
case 'mediafail':
BBB.webRTCMediaFail();
break;
case 'websocketSucceded':
BBB.webRTCEchoTestWebsocketSucceeded();
break;
case 'websocketFailed':
BBB.webRTCEchoTestWebsocketFailed(message.errorcode);
break;
}
}
callIntoConference("9196", callback);
}
function stopWebRTCAudioTest(){
console.log("Stopping webrtc audio test");
webrtc_hangup();
}
function stopWebRTCAudioTestJoinConference(){
console.log("Stopping webrtc audio test and joining conference afterwards");
var callback = function(request) {
joinWebRTCVoiceConference();
}
webrtc_hangup(callback);
}
function requestWebRTCWebcam(){
var callback = function(message) {
switch(message.status) {
case 'mediarequest':
BBB.webRTCWebcamRequest();
break;
case 'mediasuccess':
BBB.webRTCWebcamRequestSuccess();
break;
case 'mediafail':
BBB.webRTCWebcamRequestFail(message.cause);
break;
}
}
makeWebRTCWebcamRequest(callback);
}
function makeWebRTCWebcamRequest(callback)
{
console.log("Requesting webcam permissions on Chrome ");
callback({'status':'mediarequest'});
getUserWebcamMedia(function(stream) {
console.log("getUserWebcamMedia: success");
userWebcamMedia = stream;
callback({'status':'mediasuccess'});
}, function(error) {
console.error("getUserWebcamMedia: failure - " + error.name);
callback({'status':'mediafail', 'cause': error.name});
}
);
}
function createUA(username, server, callback) {
if (userAgent) {
console.log("User agent already created");
return;
}
console.log("Creating new user agent");
/* VERY IMPORTANT
* - You must escape the username because spaces will cause the connection to fail
* - We are connecting to the websocket through an nginx redirect instead of directly to 5066
*/
var configuration = {
uri: 'sip:' + encodeURIComponent(username) + '@' + server,
wsServers: 'ws://' + server + '/ws',
displayName: username,
register: false,
traceSip: true,
autostart: false,
userAgentString: "BigBlueButton",
stunServers: "stun:stun.freeswitch.org"
};
uaConnected = false;
userAgent = new SIP.UA(configuration);
userAgent.on('connected', function() {
uaConnected = true;
callback({'status':'websocketSucceded'});
});
userAgent.on('disconnected', function() {
if (userAgent) {
userAgent.stop();
userAgent = null;
if (uaConnected) {
callback({'status':'websocketFailed', 'errorcode': 1001}); // WebSocket disconnected
} else {
callback({'status':'websocketFailed', 'errorcode': 1002}); // Could not make a WebSocket connection
}
}
});
userAgent.start();
};
function getUserWebcamMedia(getUserWebcamMediaSuccess, getUserWebcamMediaFailure) {
if (userWebcamMedia == undefined) {
if (SIP.WebRTC.isSupported()) {
SIP.WebRTC.getUserMedia({audio:false, video:true}, getUserWebcamMediaSuccess, getUserWebcamMediaFailure);
} else {
console.log("getUserWebcamMedia: webrtc not supported");
getUserWebcamMediaFailure("WebRTC is not supported");
}
} else {
console.log("getUserWebcamMedia: webcam already set");
getUserWebcamMediaSuccess(userWebcamMedia);
}
};
function getUserMicMedia(getUserMicMediaSuccess, getUserMicMediaFailure) {
if (userMicMedia == undefined) {
if (SIP.WebRTC.isSupported()) {
SIP.WebRTC.getUserMedia({audio:true, video:false}, getUserMicMediaSuccess, getUserMicMediaFailure);
} else {
console.log("getUserMicMedia: webrtc not supported");
getUserMicMediaFailure("WebRTC is not supported");
}
} else {
console.log("getUserMicMedia: mic already set");
getUserMicMediaSuccess(userMicMedia);
}
};
function webrtc_call(username, voiceBridge, callback) {
if (!isWebRTCAvailable()) {
callback({'status': 'failed', 'errorcode': 1003}); // Browser version not supported
return;
}
var server = window.document.location.hostname;
console.log("user " + username + " calling to " + voiceBridge);
if (!userAgent) {
createUA(username, server, callback);
}
if (userMicMedia !== undefined) {
make_call(username, voiceBridge, server, callback, false);
} else {
callback({'status':'mediarequest'});
getUserMicMedia(function(stream) {
console.log("getUserMicMedia: success");
userMicMedia = stream;
callback({'status':'mediasuccess'});
make_call(username, voiceBridge, server, callback, false);
}, function(e) {
console.error("getUserMicMedia: failure - " + e);
callback({'status':'mediafail', 'cause': e});
}
);
}
}
function make_call(username, voiceBridge, server, callback, recall) {
if (!userAgent.isConnected()) {
console.log("Trying to make call, but UserAgent hasn't connected yet. Delaying call");
userAgent.once('connected', function() {
console.log("UserAgent has now connected, retrying the call");
make_call(username, voiceBridge, server, callback, recall);
});
return;
}
if (currentSession) {
console.log('Active call detected ignoring second make_call');
return;
}
// Make an audio/video call:
console.log("Setting options.. ");
var options = {
media: {
stream: userMicMedia,
render: {
remote: {
audio: document.getElementById('remote-media')
}
}
}
};
callTimeout = setTimeout(function() {
console.log('Ten seconds without updates sending timeout code');
callback({'status':'failed', 'errorcode': 1006}); // Failure on call
currentSession = null;
var userAgentTemp = userAgent;
userAgent = null;
userAgentTemp.stop();
}, 10000);
callActive = false;
callICEConnected = false;
callPurposefullyEnded = false;
callFailCounter = 0;
console.log("Calling to " + voiceBridge + "....");
currentSession = userAgent.invite('sip:' + voiceBridge + '@' + server, options);
// Only send the callback if it's the first try
if (recall === false) {
console.log('call connecting');
callback({'status':'connecting'});
} else {
console.log('call connecting again');
}
// The connecting event fires before the listener can be added
currentSession.on('connecting', function(){
clearTimeout(callTimeout);
});
currentSession.on('progress', function(response){
console.log('call progress: ' + response);
clearTimeout(callTimeout);
});
currentSession.on('failed', function(response, cause){
console.log('call failed with cause: '+ cause);
if (currentSession) {
if (callActive === false) {
callback({'status':'failed', 'errorcode': 1004}); // Failure on call
currentSession = null;
var userAgentTemp = userAgent;
userAgent = null;
userAgentTemp.stop();
} else {
callActive = false;
//currentSession.bye();
currentSession = null;
userAgent.stop();
}
}
clearTimeout(callTimeout);
});
currentSession.on('bye', function(request){
callActive = false;
if (currentSession) {
console.log('call ended ' + currentSession.endTime);
if (callPurposefullyEnded === true) {
callback({'status':'ended'});
} else {
callback({'status':'failed', 'errorcode': 1005}); // Call ended unexpectedly
}
clearTimeout(callTimeout);
currentSession = null;
} else {
console.log('bye event already received');
}
});
currentSession.on('accepted', function(data){
callActive = true;
console.log('BigBlueButton call accepted');
if (callICEConnected === true) {
callback({'status':'started'});
} else {
callback({'status':'waitingforice'});
}
clearTimeout(callTimeout);
});
currentSession.mediaHandler.on('iceFailed', function() {
console.log('received ice negotiation failed');
callback({'status':'failed', 'errorcode': 1007}); // Failure on call
currentSession = null;
var userAgentTemp = userAgent;
userAgent = null;
userAgentTemp.stop();
clearTimeout(callTimeout);
});
// Some browsers use status of 'connected', others use 'completed', and a couple use both
currentSession.mediaHandler.on('iceConnected', function() {
console.log('Received ICE status changed to connected');
if (callICEConnected === false) {
callICEConnected = true;
if (callActive === true) {
callback({'status':'started'});
}
clearTimeout(callTimeout);
}
});
currentSession.mediaHandler.on('iceCompleted', function() {
console.log('Received ICE status changed to completed');
if (callICEConnected === false) {
callICEConnected = true;
if (callActive === true) {
callback({'status':'started'});
}
clearTimeout(callTimeout);
}
});
}
function webrtc_hangup(callback) {
callPurposefullyEnded = true;
console.log("Hanging up current session");
if (callback) {
currentSession.on('bye', callback);
}
currentSession.bye();
}
function isWebRTCAvailable() {
return SIP.WebRTC.isSupported();
}