573 lines
16 KiB
JavaScript
573 lines
16 KiB
JavaScript
const isFirefox = typeof window.InstallTrigger !== 'undefined';
|
|
const isOpera = !!window.opera || navigator.userAgent.indexOf(' OPR/') >= 0;
|
|
const isChrome = !!window.chrome && !isOpera;
|
|
const isSafari = navigator.userAgent.indexOf('Safari') >= 0 && !isChrome;
|
|
const kurentoHandler = null;
|
|
const SEND_ROLE = "send";
|
|
const RECV_ROLE = "recv";
|
|
const SFU_APP = "screenshare";
|
|
const ON_ICE_CANDIDATE_MSG = "onIceCandidate";
|
|
const START_MSG = "start";
|
|
const START_RESPONSE_MSG = "startResponse";
|
|
const PING_INTERVAL = 15000;
|
|
|
|
Kurento = function (
|
|
tag,
|
|
voiceBridge,
|
|
conferenceUsername,
|
|
internalMeetingId,
|
|
onFail = null,
|
|
chromeExtension = null,
|
|
) {
|
|
this.ws = null;
|
|
this.video = null;
|
|
this.screen = null;
|
|
this.webRtcPeer = null;
|
|
this.mediaCallback = null;
|
|
|
|
this.voiceBridge = `${voiceBridge}-SCREENSHARE`;
|
|
this.internalMeetingId = internalMeetingId;
|
|
|
|
// Limiting max resolution to 1080p
|
|
// In FireFox we force full screen share and in the case
|
|
// of multiple screens the total area shared becomes too large
|
|
this.vid_max_width = 1920;
|
|
this.vid_max_height = 1080;
|
|
|
|
// TODO properly generate a uuid
|
|
this.sessid = Math.random().toString();
|
|
|
|
this.renderTag = 'remote-media';
|
|
|
|
this.caller_id_name = conferenceUsername;
|
|
this.caller_id_number = conferenceUsername;
|
|
|
|
this.kurentoPort = 'bbb-webrtc-sfu';
|
|
this.hostName = window.location.hostname;
|
|
this.socketUrl = `wss://${this.hostName}/${this.kurentoPort}`;
|
|
this.pingInterval = null;
|
|
|
|
this.iceServers = null;
|
|
|
|
if (chromeExtension != null) {
|
|
this.chromeExtension = chromeExtension;
|
|
window.chromeExtension = chromeExtension;
|
|
}
|
|
|
|
if (onFail != null) {
|
|
this.onFail = Kurento.normalizeCallback(onFail);
|
|
} else {
|
|
const _this = this;
|
|
this.onFail = function () {
|
|
_this.logError('Default error handler');
|
|
};
|
|
}
|
|
|
|
};
|
|
|
|
this.KurentoManager = function () {
|
|
this.kurentoVideo = null;
|
|
this.kurentoScreenshare = null;
|
|
};
|
|
|
|
KurentoManager.prototype.exitScreenShare = function () {
|
|
console.log(' [exitScreenShare] Exiting screensharing');
|
|
if (typeof this.kurentoScreenshare !== 'undefined' && this.kurentoScreenshare) {
|
|
if (this.kurentoScreenshare.ws !== null) {
|
|
this.kurentoScreenshare.ws.onclose = function () {};
|
|
this.kurentoScreenshare.ws.close();
|
|
}
|
|
|
|
if (this.kurentoScreenshare.pingInterval) {
|
|
clearInterval(this.kurentoScreenshare.pingInterval);
|
|
}
|
|
|
|
this.kurentoScreenshare.disposeScreenShare();
|
|
this.kurentoScreenshare = null;
|
|
}
|
|
|
|
if (typeof this.kurentoVideo !== 'undefined' && this.kurentoVideo) {
|
|
this.exitVideo();
|
|
}
|
|
};
|
|
|
|
KurentoManager.prototype.exitVideo = function () {
|
|
console.log(' [exitScreenShare] Exiting screensharing viewing');
|
|
if (typeof this.kurentoVideo !== 'undefined' && this.kurentoVideo) {
|
|
if (this.kurentoVideo.ws !== null) {
|
|
this.kurentoVideo.ws.onclose = function () {};
|
|
this.kurentoVideo.ws.close();
|
|
}
|
|
|
|
if (this.kurentoVideo.pingInterval) {
|
|
clearInterval(this.kurentoVideo.pingInterval);
|
|
}
|
|
|
|
this.kurentoVideo.disposeScreenShare();
|
|
this.kurentoVideo = null;
|
|
}
|
|
};
|
|
|
|
KurentoManager.prototype.shareScreen = function (tag) {
|
|
this.exitScreenShare();
|
|
const obj = Object.create(Kurento.prototype);
|
|
Kurento.apply(obj, arguments);
|
|
this.kurentoScreenshare = obj;
|
|
this.kurentoScreenshare.setScreensharing(tag);
|
|
};
|
|
|
|
KurentoManager.prototype.joinWatchVideo = function (tag) {
|
|
this.exitVideo();
|
|
const obj = Object.create(Kurento.prototype);
|
|
Kurento.apply(obj, arguments);
|
|
this.kurentoVideo = obj;
|
|
this.kurentoVideo.setWatchVideo(tag);
|
|
};
|
|
|
|
|
|
Kurento.prototype.setScreensharing = function (tag) {
|
|
this.mediaCallback = this.startScreensharing.bind(this);
|
|
this.create(tag);
|
|
};
|
|
|
|
Kurento.prototype.create = function (tag) {
|
|
this.setRenderTag(tag);
|
|
this.iceServers = true;
|
|
this.init();
|
|
};
|
|
|
|
Kurento.prototype.downscaleResolution = function (oldWidth, oldHeight) {
|
|
const factorWidth = this.vid_max_width / oldWidth;
|
|
const factorHeight = this.vid_max_height / oldHeight;
|
|
let width, height;
|
|
|
|
if (factorWidth < factorHeight) {
|
|
width = Math.trunc(oldWidth * factorWidth);
|
|
height = Math.trunc(oldHeight * factorWidth);
|
|
}
|
|
else {
|
|
width = Math.trunc(oldWidth * factorHeight);
|
|
height = Math.trunc(oldHeight * factorHeight);
|
|
}
|
|
|
|
return { width, height };
|
|
};
|
|
|
|
Kurento.prototype.init = function () {
|
|
const self = this;
|
|
if ('WebSocket' in window) {
|
|
console.log('this browser supports websockets');
|
|
this.ws = new WebSocket(this.socketUrl);
|
|
|
|
this.ws.onmessage = this.onWSMessage.bind(this);
|
|
this.ws.onclose = (close) => {
|
|
kurentoManager.exitScreenShare();
|
|
self.onFail('Websocket connection closed');
|
|
};
|
|
this.ws.onerror = (error) => {
|
|
kurentoManager.exitScreenShare();
|
|
self.onFail('Websocket connection error');
|
|
};
|
|
this.ws.onopen = function () {
|
|
self.pingInterval = setInterval(self.ping.bind(self), PING_INTERVAL);
|
|
self.mediaCallback();
|
|
};
|
|
} else { console.log('this browser does not support websockets'); }
|
|
};
|
|
|
|
Kurento.prototype.onWSMessage = function (message) {
|
|
const parsedMessage = JSON.parse(message.data);
|
|
switch (parsedMessage.id) {
|
|
case 'startResponse':
|
|
this.startResponse(parsedMessage);
|
|
break;
|
|
case 'stopSharing':
|
|
kurentoManager.exitScreenShare();
|
|
break;
|
|
case 'iceCandidate':
|
|
this.webRtcPeer.addIceCandidate(parsedMessage.candidate);
|
|
break;
|
|
case 'pong':
|
|
break;
|
|
default:
|
|
console.error('Unrecognized message', parsedMessage);
|
|
}
|
|
};
|
|
|
|
Kurento.prototype.setRenderTag = function (tag) {
|
|
this.renderTag = tag;
|
|
};
|
|
|
|
Kurento.prototype.startResponse = function (message) {
|
|
if (message.response !== 'accepted') {
|
|
const errorMsg = message.message ? message.message : 'Unknow error';
|
|
console.warn(`Call not accepted for the following reason: ${errorMsg}`);
|
|
kurentoManager.exitScreenShare();
|
|
} else {
|
|
console.debug(`Screenshare procedure was accepted with SDP => ${message.sdpAnswer}`);
|
|
this.webRtcPeer.processAnswer(message.sdpAnswer);
|
|
}
|
|
};
|
|
|
|
Kurento.prototype.onOfferPresenter = function (error, offerSdp) {
|
|
const self = this;
|
|
let resolution;
|
|
|
|
if (error) {
|
|
console.log(`Kurento.prototype.onOfferPresenter Error ${error}`);
|
|
this.onFail(error);
|
|
return;
|
|
}
|
|
|
|
const track = this.webRtcPeer.getLocalStream().getVideoTracks()[0];
|
|
const settings = track.getSettings();
|
|
let { width, height } = settings;
|
|
console.debug("Screenshare track dimensions are", width, "x", height);
|
|
|
|
if (width > this.vid_max_width || height > this.vid_max_height) {
|
|
resolution = this.downscaleResolution(width, height);
|
|
width = resolution.width;
|
|
height = resolution.height;
|
|
console.debug("Screenshare track dimensions have been resized to", width, "x", height);
|
|
}
|
|
|
|
const message = {
|
|
id: 'start',
|
|
type: SFU_APP,
|
|
role: SEND_ROLE,
|
|
internalMeetingId: self.internalMeetingId,
|
|
voiceBridge: self.voiceBridge,
|
|
callerName: self.caller_id_name,
|
|
sdpOffer: offerSdp,
|
|
vh: height,
|
|
vw: width,
|
|
};
|
|
|
|
console.log(`onOfferPresenter sending to screenshare server => ${JSON.stringify(message, null, 2)}`);
|
|
this.sendMessage(message);
|
|
};
|
|
|
|
Kurento.prototype.startScreensharing = function () {
|
|
if (window.chrome) {
|
|
if (!this.chromeExtension) {
|
|
this.logError({
|
|
status: 'failed',
|
|
message: 'Missing Chrome Extension key',
|
|
});
|
|
this.onFail();
|
|
return;
|
|
}
|
|
}
|
|
|
|
const options = {
|
|
localVideo: document.getElementById(this.renderTag),
|
|
onicecandidate: (candidate) => {
|
|
this.onIceCandidate(candidate, SEND_ROLE);
|
|
},
|
|
sendSource: 'desktop',
|
|
};
|
|
|
|
console.log(` Peer options => ${JSON.stringify(options, null, 2)}`);
|
|
|
|
this.webRtcPeer = kurentoUtils.WebRtcPeer.WebRtcPeerSendonly(options, (error) => {
|
|
if (error) {
|
|
console.log(`WebRtcPeerSendonly constructor error ${JSON.stringify(error, null, 2)}`);
|
|
this.onFail(error);
|
|
return kurentoManager.exitScreenShare();
|
|
}
|
|
|
|
this.webRtcPeer.generateOffer(this.onOfferPresenter.bind(this));
|
|
console.log(`Generated peer offer w/ options ${JSON.stringify(options)}`);
|
|
|
|
const localStream = this.webRtcPeer.peerConnection.getLocalStreams()[0];
|
|
localStream.getVideoTracks()[0].onended = function () {
|
|
return kurentoManager.exitScreenShare();
|
|
};
|
|
|
|
localStream.getVideoTracks()[0].oninactive = function () {
|
|
return kurentoManager.exitScreenShare();
|
|
};
|
|
});
|
|
};
|
|
|
|
Kurento.prototype.onIceCandidate = function (candidate, role) {
|
|
const self = this;
|
|
console.log(`Local candidate${JSON.stringify(candidate)}`);
|
|
|
|
const message = {
|
|
id: ON_ICE_CANDIDATE_MSG,
|
|
role: role,
|
|
type: SFU_APP,
|
|
voiceBridge: self.voiceBridge,
|
|
candidate,
|
|
callerName: self.caller_id_name,
|
|
};
|
|
|
|
this.sendMessage(message);
|
|
};
|
|
|
|
Kurento.prototype.setWatchVideo = function (tag) {
|
|
this.useVideo = true;
|
|
this.useCamera = 'none';
|
|
this.useMic = 'none';
|
|
this.mediaCallback = this.viewer;
|
|
this.create(tag);
|
|
};
|
|
|
|
Kurento.prototype.viewer = function () {
|
|
const self = this;
|
|
if (!this.webRtcPeer) {
|
|
const options = {
|
|
mediaConstraints: {
|
|
audio: false
|
|
},
|
|
remoteVideo: document.getElementById(this.renderTag),
|
|
onicecandidate: (candidate) => {
|
|
this.onIceCandidate(candidate, RECV_ROLE);
|
|
}
|
|
}
|
|
|
|
self.webRtcPeer = kurentoUtils.WebRtcPeer.WebRtcPeerRecvonly(options, function (error) {
|
|
if (error) {
|
|
return self.onFail(error);
|
|
}
|
|
|
|
this.generateOffer(self.onOfferViewer.bind(self));
|
|
});
|
|
}
|
|
};
|
|
|
|
Kurento.prototype.onOfferViewer = function (error, offerSdp) {
|
|
const self = this;
|
|
if (error) {
|
|
console.log(`Kurento.prototype.onOfferViewer Error ${error}`);
|
|
return this.onFail();
|
|
}
|
|
const message = {
|
|
id: 'start',
|
|
type: SFU_APP,
|
|
role: RECV_ROLE,
|
|
internalMeetingId: self.internalMeetingId,
|
|
voiceBridge: self.voiceBridge,
|
|
callerName: self.caller_id_name,
|
|
sdpOffer: offerSdp,
|
|
};
|
|
|
|
console.log(`onOfferViewer sending to screenshare server => ${JSON.stringify(message, null, 2)}`);
|
|
this.sendMessage(message);
|
|
};
|
|
|
|
Kurento.prototype.pauseTrack = function (message) {
|
|
const localStream = this.webRtcPeer.peerConnection.getLocalStreams()[0];
|
|
const track = localStream.getVideoTracks()[0];
|
|
|
|
if (track) {
|
|
track.enabled = false;
|
|
}
|
|
}
|
|
|
|
Kurento.prototype.resumeTrack = function (message) {
|
|
const localStream = this.webRtcPeer.peerConnection.getLocalStreams()[0];
|
|
const track = localStream.getVideoTracks()[0];
|
|
|
|
if (track) {
|
|
track.enabled = true;
|
|
}
|
|
}
|
|
|
|
Kurento.prototype.stop = function () {
|
|
// if (this.webRtcPeer) {
|
|
// var message = {
|
|
// id : 'stop',
|
|
// type : 'screenshare',
|
|
// voiceBridge: kurentoHandler.voiceBridge
|
|
// }
|
|
// kurentoHandler.sendMessage(message);
|
|
// kurentoHandler.disposeScreenShare();
|
|
// }
|
|
};
|
|
|
|
Kurento.prototype.dispose = function () {
|
|
if (this.webRtcPeer) {
|
|
this.webRtcPeer.dispose();
|
|
this.webRtcPeer = null;
|
|
}
|
|
};
|
|
|
|
Kurento.prototype.disposeScreenShare = function () {
|
|
if (this.webRtcPeer) {
|
|
this.webRtcPeer.dispose();
|
|
this.webRtcPeer = null;
|
|
}
|
|
};
|
|
|
|
Kurento.prototype.ping = function () {
|
|
const message = {
|
|
id: 'ping'
|
|
};
|
|
this.sendMessage(message);
|
|
}
|
|
|
|
Kurento.prototype.sendMessage = function (message) {
|
|
const jsonMessage = JSON.stringify(message);
|
|
console.log(`Sending message: ${jsonMessage}`);
|
|
this.ws.send(jsonMessage);
|
|
};
|
|
|
|
Kurento.prototype.logger = function (obj) {
|
|
console.log(obj);
|
|
};
|
|
|
|
Kurento.prototype.logError = function (obj) {
|
|
console.error(obj);
|
|
};
|
|
|
|
|
|
Kurento.normalizeCallback = function (callback) {
|
|
if (typeof callback === 'function') {
|
|
return callback;
|
|
}
|
|
console.log(document.getElementById('BigBlueButton')[callback]);
|
|
return function (args) {
|
|
document.getElementById('BigBlueButton')[callback](args);
|
|
};
|
|
};
|
|
|
|
/* Global methods */
|
|
|
|
// this function explains how to use above methods/objects
|
|
window.getScreenConstraints = function (sendSource, callback) {
|
|
const screenConstraints = { video: {}, audio: false };
|
|
|
|
// Limiting FPS to a range of 5-10 (5 ideal)
|
|
screenConstraints.video.frameRate = { ideal: 5, max: 10 };
|
|
|
|
screenConstraints.video.height = { max: this.vid_max_height };
|
|
screenConstraints.video.width = { max: this.vid_max_width };
|
|
|
|
if (isChrome) {
|
|
getChromeScreenConstraints((constraints) => {
|
|
if (!constraints) {
|
|
document.dispatchEvent(new Event('installChromeExtension'));
|
|
return;
|
|
}
|
|
|
|
const sourceId = constraints.streamId;
|
|
|
|
kurentoManager.kurentoScreenshare.extensionInstalled = true;
|
|
|
|
// this statement sets gets 'sourceId" and sets "chromeMediaSourceId"
|
|
screenConstraints.video.chromeMediaSource = { exact: [sendSource] };
|
|
screenConstraints.video.chromeMediaSourceId = sourceId;
|
|
screenConstraints.optional = [
|
|
{ googCpuOveruseDetection: true },
|
|
{ googCpuOveruseEncodeUsage: true },
|
|
{ googCpuUnderuseThreshold: 55 },
|
|
{ googCpuOveruseThreshold: 100},
|
|
{ googPayloadPadding: true },
|
|
{ googScreencastMinBitrate: 600 },
|
|
{ googHighStartBitrate: true },
|
|
{ googHighBitrate: true },
|
|
{ googVeryHighBitrate: true }
|
|
];
|
|
|
|
console.log('getScreenConstraints for Chrome returns => ', screenConstraints);
|
|
// now invoking native getUserMedia API
|
|
callback(null, screenConstraints);
|
|
}, chromeExtension);
|
|
} else if (isFirefox) {
|
|
screenConstraints.video.mediaSource = 'screen';
|
|
|
|
console.log('getScreenConstraints for Firefox returns => ', screenConstraints);
|
|
// now invoking native getUserMedia API
|
|
callback(null, screenConstraints);
|
|
} else if (isSafari) {
|
|
screenConstraints.video.mediaSource = 'screen';
|
|
|
|
console.log('getScreenConstraints for Safari returns => ', screenConstraints);
|
|
// now invoking native getUserMedia API
|
|
callback(null, screenConstraints);
|
|
}
|
|
};
|
|
|
|
window.kurentoInitialize = function () {
|
|
if (window.kurentoManager == null || window.KurentoManager === undefined) {
|
|
window.kurentoManager = new KurentoManager();
|
|
}
|
|
};
|
|
|
|
window.kurentoShareScreen = function () {
|
|
window.kurentoInitialize();
|
|
window.kurentoManager.shareScreen.apply(window.kurentoManager, arguments);
|
|
};
|
|
|
|
|
|
window.kurentoExitScreenShare = function () {
|
|
window.kurentoInitialize();
|
|
window.kurentoManager.exitScreenShare();
|
|
};
|
|
|
|
window.kurentoWatchVideo = function () {
|
|
window.kurentoInitialize();
|
|
window.kurentoManager.joinWatchVideo.apply(window.kurentoManager, arguments);
|
|
};
|
|
|
|
window.kurentoExitVideo = function () {
|
|
window.kurentoInitialize();
|
|
window.kurentoManager.exitVideo();
|
|
};
|
|
|
|
window.getChromeScreenConstraints = function (callback, extensionId) {
|
|
chrome.runtime.sendMessage(
|
|
extensionId, {
|
|
getStream: true,
|
|
sources: [
|
|
'window',
|
|
'screen',
|
|
],
|
|
},
|
|
(response) => {
|
|
console.log(response);
|
|
callback(response);
|
|
},
|
|
);
|
|
};
|
|
|
|
// a function to check whether the browser (Chrome only) is in an isIncognito
|
|
// session. Requires 1 mandatory callback that only gets called if the browser
|
|
// session is incognito. The callback for not being incognito is optional.
|
|
// Attempts to retrieve the chrome filesystem API.
|
|
/* window.checkIfIncognito = function(isIncognito, isNotIncognito = function () {}) {
|
|
isIncognito = Kurento.normalizeCallback(isIncognito);
|
|
isNotIncognito = Kurento.normalizeCallback(isNotIncognito);
|
|
|
|
var fs = window.RequestFileSystem || window.webkitRequestFileSystem;
|
|
if (!fs) {
|
|
isNotIncognito();
|
|
return;
|
|
}
|
|
fs(window.TEMPORARY, 100, function(){isNotIncognito()}, function(){isIncognito()});
|
|
};
|
|
|
|
window.checkChromeExtInstalled = function (callback, chromeExtensionId) {
|
|
callback = Kurento.normalizeCallback(callback);
|
|
|
|
if (typeof chrome === "undefined" || !chrome || !chrome.runtime) {
|
|
// No API, so no extension for sure
|
|
callback(false);
|
|
return;
|
|
}
|
|
chrome.runtime.sendMessage(
|
|
chromeExtensionId,
|
|
{ getVersion: true },
|
|
function (response) {
|
|
if (!response || !response.version) {
|
|
// Communication failure - assume that no endpoint exists
|
|
callback(false);
|
|
return;
|
|
}
|
|
callback(true);
|
|
}
|
|
);
|
|
}*/
|