";
}
}
}
} catch (e) {
errorlog(e);
}
//if (session.optimize){
if (navigator.userAgent.indexOf('Mac OS X') != -1) {
session.codec = "h264"; // default the codec to h264 if OBS and macOS
}
//}
window.addEventListener('obsSceneChanged', function(event) {
log("OBS EVENT");
log(event.detail.name);
window.obsstudio.getCurrentScene(function(scene) {
log("OBS SCENE");
log(scene);
});
window.obsstudio.getStatus(function(status) {
log("OBS STATUS:");
log(status);
});
});
}
window.onload = function winonLoad() { // This just keeps people from killing the live stream accidentally. Also give me a headsup that the stream is ending
window.addEventListener("beforeunload", function(e) {
try {
session.ws.close();
if (session.videoElement.recording) {
session.videoElement.recorder.writer.close();
session.videoElement.recording = false;
}
for (var i in session.rpcs) {
if (session.rpcs[i].videoElement) {
if (session.rpcs[i].videoElement.recording) {
session.rpcs[i].videoElement.recorder.writer.close();
session.rpcs[i].videoElement.recording = false;
}
}
}
} catch (e) {}
//setTimeout(function(){session.hangup();},0);
return undefined; // ADDED OCT 29th; get rid of popup. Just close the socket connection if the user is refreshing the page. It's one or the other.
});
};
getById("credits").innerHTML = "Version: " + session.version + " - " + getById("credits").innerHTML;
var lastTouchEnd = 0;
document.addEventListener('touchend', function(event) {
var now = (new Date()).getTime();
if (now - lastTouchEnd <= 300) {
event.preventDefault();
}
lastTouchEnd = now;
}, false);
document.addEventListener('click', function(event) {
if (session.firstPlayTriggered == false) {
playAllVideos();
session.firstPlayTriggered = true;
history.pushState({}, '');
}
});
var Callbacks = [];
var CtrlPressed = false; // global
var AltPressed = false;
document.addEventListener("keydown", event => {
if ((event.ctrlKey) || (event.metaKey)) { // detect if CTRL is pressed
CtrlPressed = true;
} else {
CtrlPressed = false;
}
if (event.altKey) {
AltPressed = true;
} else {
AltPressed = false;
}
if (CtrlPressed && event.keyCode) {
if (event.keyCode == 77) { // m
if (event.metaKey) {
if (AltPressed) {
toggleMute(); // macOS
}
} else {
toggleMute(); // Windows
}
// } else if (event.keyCode == 69) { // e
// hangup();
} else if (event.keyCode == 66) { // b
toggleVideoMute();
}
}
});
document.addEventListener("keyup", event => {
if (!((event.ctrlKey) || (event.metaKey))) {
if (CtrlPressed) {
CtrlPressed = false;
for (var i in Callbacks) {
var cb = Callbacks[i];
log(cb.slice(1));
cb[0](...cb.slice(1)); // https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Operators/Spread_syntax#A_better_apply
}
Callbacks = [];
}
}
if (!(event.altKey)) {
AltPressed = false;
}
});
window.onpopstate = function() {
if (session.firstPlayTriggered) {
window.location.reload(true);
}
};
if (typeof session === 'undefined') { // make sure to init the WebRTC if not exists.
var session = WebRTC.Media;
session.streamID = session.generateStreamID();
errorlog("Serious error: WebRTC session didn't load in time");
}
function makeDraggableElement(elmnt) {
try {
elmnt.dragElement = false;
elmnt.style.bottom = "auto";
elmnt.style.cursor = "grab";
elmnt.stashonmouseup = null;
elmnt.stashonmousemove = null;
} catch (e) {
errorlog(e);
return;
}
var pos1 = 0;
var pos2 = 0;
var pos3 = 0;
var pos4 = 0;
function dragMouseDown(e) {
e = e || window.event;
e.preventDefault();
pos3 = e.clientX;
pos4 = e.clientY;
elmnt.stashonmouseup = document.onmouseup; // I don't want to interfere with other drag events.
elmnt.stashonmousemove = document.onmousemove;
document.onmouseup = closeDragElement;
document.onmousemove = elementDrag;
}
function elementDrag(e) {
e = e || window.event;
e.preventDefault();
elmnt.dragElement = true;
pos1 = pos3 - e.clientX;
pos2 = pos4 - e.clientY;
pos3 = e.clientX;
pos4 = e.clientY;
var topDrag = (elmnt.offsetTop - pos2);
if (topDrag > -3) {
topDrag = -3;
}
elmnt.style.top = topDrag + "px";
elmnt.style.left = (elmnt.offsetLeft - pos1) + "px";
}
elmnt.onmousedown = dragMouseDown;
function closeDragElement() {
document.onmouseup = elmnt.stashonmouseup;
document.onmousemove = elmnt.stashonmousemove;
}
}
function setCookie(cname, cvalue, exdays) {
var d = new Date();
d.setTime(d.getTime() + (exdays * 24 * 60 * 60 * 1000));
var expires = "expires=" + d.toUTCString();
document.cookie = cname + "=" + cvalue + ";" + expires + ";path=/";
}
function getCookie(cname) {
var name = cname + "=";
var ca = document.cookie.split(';');
for (var i = 0; i < ca.length; i++) {
var c = ca[i];
while (c.charAt(0) == ' ') {
c = c.substring(1);
}
if (c.indexOf(name) == 0) {
return c.substring(name.length, c.length);
}
}
return "";
}
if (getCookie("redirect") == "yes") {
setCookie("redirect", "", 0);
session.sticky = true;
} else if (getCookie("settings") != "") {
session.sticky = confirm("Would you like you load your previous session's settings?");
if (!session.sticky) {
setCookie("settings", "", 0);
log("deleting cookie as user said no");
} else {
var cookieSettings = decodeURI(getCookie("settings"));
setCookie("redirect", "yes", 1);
window.location.replace(cookieSettings);
}
}
if (urlParams.has('sticky')) {
if (getCookie("permission") == "") {
session.sticky = confirm("Would you allow us to store a cookie to keep your session settings persistent?");
} else {
session.sticky = true;
}
if (session.sticky) {
setCookie("permission", "yes", 999);
setCookie("settings", encodeURI(window.location.href), 90);
}
}
if (urlParams.has('retrytimeout')) {
session.retryTimeout = parseInt(urlParams.get('retrytimeout'));
}
var screensharebutton = true;
var screensharesupport = true;
if (urlParams.has('nosettings') || urlParams.has('ns')) {
screensharebutton = false;
session.showSettings = false;
}
if (urlParams.has('screenshareid') || urlParams.has('ssid')) {
if (urlParams.get('screenshareid') || urlParams.get('ssid')) {
session.screenshareid = urlParams.get('screenshareid') || urlParams.get('ssid');
session.screenshareid = sanitizeStreamID(session.screenshareid);
}
}
if (/Android|webOS|iPhone|iPad|iPod|BlackBerry|IEMobile|Opera Mini/i.test(navigator.userAgent)) {
//session.webcamonly = true;
getById("shareScreenGear").style.display = "none";
screensharebutton = false;
screensharesupport = false;
getById("container-2").className = 'column columnfade advanced'; // Hide screen share on mobile
getById("dropButton").style.display = "none";
//session.disableWebAudio = true; // default true; might be useful to disable on slow or old computers?
session.audioEffects = false; // disable audio inbound effects also.
session.audioMeterGuest = false;
} else if ((iOS) || (iPad)) {
getById("shareScreenGear").style.display = "none";
screensharebutton = false;
screensharesupport = false;
getById("container-2").className = 'column columnfade advanced'; // Hide screen share on mobile
getById("dropButton").style.display = "none";
//session.audiobitrate = false; // iOS devices seem to get distortion with custom audio bitrates. Disable for now.
//session.maxiosbitrate = 10; // this is 10-kbps by default already.
//session.disableWebAudio = true; // default true; might be useful to disable on slow or old computers?
session.audioEffects = false; // disable audio inbound effects also.
session.audioMeterGuest = false;
} else {
log("MAKE DRAGGABLE");
setTimeout(function(){makeDraggableElement(document.getElementById("subControlButtons"));},100);
}
if (/CriOS/i.test(navigator.userAgent) && (iOS || iPad)) {
if (!(session.cleanOutput)) {
try {
navigator.mediaDevices.getUserMedia;
} catch (e) {
alert("Chrome on this device does not support the required technology to use this site.\n\nPlease use Safari instead or update your iOS and browser version.");
}
}
}
if (urlParams.has('broadcast') || urlParams.has('bc')) {
log("Broadcast flag set");
session.broadcast = urlParams.get('broadcast') || urlParams.get('bc');
if ((iOS) || (iPad)) {
session.nopreview = false;
} else {
session.nopreview = true;
}
session.style = 1;
getById("header").style.display = "none";
getById("header").style.opacity = 0;
}
var directorLanding = false;
if (urlParams.has('director') || urlParams.has('dir')) {
directorLanding = urlParams.get('director') || urlParams.get('dir');
if (directorLanding === null) {
directorLanding = true;
} else if (directorLanding.length === 0) {
directorLanding = true;
} else {
directorLanding = false;
}
} else if (filename === "director") {
directorLanding = true;
filename = false;
}
if (urlParams.has('rooms')) {
session.rooms = urlParams.get('rooms').split(",").map(function(e) {
return sanitizeRoomName(e);
});
}
if (urlParams.has('showdirector')) {
session.showDirector = true;
}
if (urlParams.has('midi') || urlParams.has('hotkeys')) {
session.midiHotkeys = urlParams.get('midi') || urlParams.get ('hotkeys') || 1;
session.midiHotkeys = parseInt(session.midiHotkeys);
}
var loadedQRCode = false;
function loadQR(){
if (loadedQRCode==false){
loadedQRCode=true;
var script = document.createElement('script');
script.src = "./thirdparty/qrcode.min.js"; // dynamically load this only if its needed. Keeps loading time down.
document.head.appendChild(script);
}
}
if (urlParams.has('webcam') || urlParams.has('wc')) {
session.webcamonly = true;
screensharebutton = false;
} else if (urlParams.has('screenshare') || urlParams.has('ss')) {
session.screenshare = true;
} else if (urlParams.has('fileshare') || urlParams.has('fs')) {
getById("container-5").classList.remove('advanced');
getById("container-5").classList.add("skip-animation");
getById("container-5").classList.remove('pointer');
} else if (directorLanding) {
getById("container-1").classList.remove('advanced');
getById("container-1").classList.add("skip-animation");
getById("container-1").classList.remove('pointer');
} else if (urlParams.has('website') || urlParams.has('iframe')) {
getById("container-6").classList.remove('advanced');
getById("container-6").classList.add("skip-animation");
getById("container-6").classList.remove('pointer');
}
if (urlParams.has('ssb')) {
screensharebutton = true;
}
if (urlParams.has('mute') || urlParams.has('muted') || urlParams.has('m')) {
session.muted = true;
}
if (urlParams.has('videomute') || urlParams.has('videomuted') || urlParams.has('vm')) {
session.videoMutedFlag = true;
}
if (urlParams.has('deaf') || urlParams.has('deafen')) {
session.directorSpeakerMuted=true; // false == true in this case.
}
if (urlParams.has('blind')) {
session.directorDisplayMuted=true; // false == true in this case.
}
if (urlParams.has('dpi') || urlParams.has('dpr')) {
session.devicePixelRatio = urlParams.get('dpi') || urlParams.get('dpr') || 2.0;
} else if (window.devicePixelRatio && window.devicePixelRatio!==1){
session.devicePixelRatio = window.devicePixelRatio; // this annoys me to no end.
}
if (urlParams.has('speakermute') || urlParams.has('mutespeaker') || urlParams.has('sm') || urlParams.has('ms')) {
session.speakerMuted = true;
getById("mutespeakertoggle").className = "las la-volume-mute my-float toggleSize";
//getById("mutespeakerbutton").className="advanced float2 red";
getById("mutespeakerbutton").classList.add("red");
getById("mutespeakerbutton").classList.add("float2");
getById("mutespeakerbutton").classList.remove("float");
var sounds = document.getElementsByTagName("video");
for (var i = 0; i < sounds.length; ++i) {
sounds[i].muted = session.speakerMuted;
}
}
if (urlParams.has('chatbutton') || urlParams.has('chat') || urlParams.has('cb')) {
session.chatbutton = urlParams.get('chatbutton') || urlParams.get('chat') || urlParams.get('cb');
if (session.chatbutton === "false") {
session.chatbutton = false;
} else if (session.chatbutton === "0") {
session.chatbutton = false;
} else if (session.chatbutton === "no") {
session.chatbutton = false;
} else if (session.chatbutton === "off") {
session.chatbutton = false;
} else {
session.chatbutton = true;
getById("chatbutton").classList.remove("advanced");
getById("controlButtons").style.display = "inherit";
}
}
if (session.screenshare == true) {
getById("container-3").className = 'column columnfade advanced'; // Hide screen share on mobile
getById("container-2").classList.add("skip-animation");
getById("container-2").classList.remove('pointer');
}
if (urlParams.has('manual')) {
session.manual = true;
}
if (urlParams.has('hands') || urlParams.has('hand')) {
session.raisehands = true;
}
if (urlParams.has('portrait') || urlParams.has('916') || urlParams.has('vertical')) {
session.aspectratio = 1; // 9:16 (default of 0 is 16:9)
} else if (urlParams.has('square') || urlParams.has('11')) {
session.aspectratio = 2; // 9:16 (default of 0 is 16:9)
}
if (urlParams.has('record')) {
if (safariVersion()) {
if (!(session.cleanOutput)) {
alert("Your browser or device is not supported. Try Chrome if on macOS.");
}
} else {
session.recordLocal = urlParams.get('record');
if (session.recordLocal !== parseInt(session.recordLocal)) {
session.recordLocal = 6000;
} else {
session.recordLocal = parseInt(session.recordLocal);
}
}
}
if (urlParams.has('bigbutton')) {
session.bigmutebutton = true;
getById("mutebutton").style.width = "min(40vh,40vw)";
getById("mutebutton").style.height = "min(40vh,40vw)";
getById("mutetoggle").style.width = "min(40vh,40vw)";
getById("mutetoggle").style.height = "min(40vh,40vw)";
}
if (urlParams.has('scene')) {
session.scene = parseInt(urlParams.get('scene')) || 0;
session.disableWebAudio = true;
session.audioEffects = false;
session.audioMeterGuest = false;
}
if (urlParams.has('mediasettings')) {
session.forceMediaSettings = true;
}
if (urlParams.has('transcript') || urlParams.has('transcribe') || urlParams.has('trans')) {
session.transcript = urlParams.get('transcript') || urlParams.get('transcribe') || urlParams.get('trans') || "en-US";
}
if (urlParams.has('cc') || urlParams.has('closedcaptions') || urlParams.has('captions')) {
session.closedCaptions = true;
}
if (session.webcamonly == true) {
getById("container-2").className = 'column columnfade advanced'; // Hide screen share on mobile
getById("container-3").classList.add("skip-animation");
getById("container-3").classList.remove('pointer');
setTimeout(function() {
previewWebcam();
}, 100);
}
getById("main").classList.remove('hidden');
if (urlParams.has('password') || urlParams.has('pass') || urlParams.has('pw') || urlParams.has('p')) {
session.password = urlParams.get('password') || urlParams.get('pass') || urlParams.get('pw') || urlParams.get('p');
if (!session.password) {
session.password = prompt("Please enter the password below: \n\n(Note: Passwords are case-sensitive and you will not be alerted if it is incorrect.)");
} else if (session.password === "false") {
session.password = false;
session.defaultPassword = false;
} else if (session.password === "0") {
session.password = false;
session.defaultPassword = false;
} else if (session.password === "off") {
session.password = false;
session.defaultPassword = false;
}
}
if (session.password) {
session.password = sanitizePassword(session.password);
getById("passwordRoom").value = session.password;
session.defaultPassword = false;
}
if (urlParams.has('hash') || urlParams.has('crc') || urlParams.has('check')) { // could be brute forced in theory, so not as safe as just not using a hash check.
session.taintedSession = null; // waiting to see if valid or not.
var hash_input = urlParams.get('hash') || urlParams.get('crc') || urlParams.get('check');
if (session.password === false) {
session.password = prompt("Please enter the password below: \n\n(Note: Passwords are case-sensitive and you will not be alerted if it is incorrect.)");
session.password = sanitizePassword(session.password);
getById("passwordRoom").value = session.password;
session.defaultPassword = false;
}
session.generateHash(session.password + session.salt, 6).then(function(hash) { // million to one error.
log("hash is " + hash);
if (hash.substring(0, 4) !== hash_input) { // hash crc checks are just first 4 characters.
session.taintedSession = true;
if (!(session.cleanOutput)) {
getById("request_info_prompt").innerHTML = "The password was incorrect.\n\nRefresh and try again.";
getById("request_info_prompt").style.display = "block";
getById("mainmenu").style.display = "none";
getById("head1").style.display = "none";
session.cleanOutput = true;
} else {
getById("request_info_prompt").innerHTML = "";
getById("request_info_prompt").style.display = "block";
getById("mainmenu").style.display = "none";
getById("head1").style.display = "none";
}
} else {
session.taintedSession = false;
session.hash = hash;
}
});
}
if (session.defaultPassword !== false) {
session.password = session.defaultPassword; // no user entered password; let's use the default password if its not disabled.
}
if (urlParams.has('showlabels') || urlParams.has('showlabel') || urlParams.has('sl')) {
session.showlabels = urlParams.get('showlabels') || urlParams.get('showlabel') || urlParams.get('sl') || "";
session.showlabels = sanitizeLabel(session.showlabels.replace(/[\W]+/g, "_").replace(/_+/g, '_'));
if (session.showlabels == "") {
session.showlabels = true;
session.labelstyle = false;
} else {
session.labelstyle = session.showlabels;
session.showlabels = true;
}
}
if (urlParams.has('sizelabel') || urlParams.has('labelsize') || urlParams.has('fontsize')) {
session.labelsize = urlParams.get('sizelabel') || urlParams.get('labelsize') || urlParams.get('fontsize') || 100;
session.labelsize = parseInt(session.labelsize);
}
if (urlParams.has('label') || urlParams.has('l')) {
session.label = urlParams.get('label') || urlParams.get('l');
var updateURLAsNeed = true;
if (session.label == null || session.label.length == 0) {
session.label = prompt("Please enter your display name:");
} else {
var updateURLAsNeed = false;
session.label = decodeURIComponent(session.label);
}
if (session.label != null) {
session.label = sanitizeLabel(session.label); // alphanumeric was too strict.
document.title = session.label; // what the result is.
if (updateURLAsNeed) {
var label = encodeURIComponent(session.label);
if (urlParams.has('l')) {
updateURL("l=" + label, true, false);
} else {
updateURL("label=" + label, true, false);
}
}
}
}
if (urlParams.has('transparent')) { // sets the window to be transparent - useful for IFRAMES?
getById("main").style.backgroundColor = "rgba(0,0,0,0)";
}
if (urlParams.has('stereo') || urlParams.has('s') || urlParams.has('proaudio')) { // both peers need this enabled for HD stereo to be on. If just pub, you get no echo/noise cancellation. if just viewer, you get high bitrate mono
log("STEREO ENABLED");
session.stereo = urlParams.get('stereo') || urlParams.get('s') || urlParams.get('proaudio');
if (session.stereo) {
session.stereo = session.stereo.toLowerCase();
}
//var supportedConstraints = navigator.mediaDevices.getSupportedConstraints();
//supportedConstraints.channelCount;
if (session.stereo === "false") {
session.stereo = 0;
session.audioInputChannels = 1;
} else if (session.stereo === "0") {
session.stereo = 0;
session.audioInputChannels = 1;
} else if (session.stereo === "no") {
session.stereo = 0;
session.audioInputChannels = 1;
} else if (session.stereo === "off") {
session.stereo = 0;
session.audioInputChannels = 1;
} else if (session.stereo === "1") {
session.stereo = 1;
} else if (session.stereo === "both") {
session.stereo = 1;
} else if (session.stereo === "3") {
session.stereo = 3;
} else if (session.stereo === "out") {
session.stereo = 3;
} else if (session.stereo === "mono") {
session.stereo = 3;
session.audiobitrate = 128;
} else if (session.stereo === "4") {
session.stereo = 4;
} else if (session.stereo === "multi") {
session.stereo = 4;
} else if (session.stereo === "2") {
session.stereo = 2;
} else if (session.stereo === "in") {
session.stereo = 2;
} else {
session.stereo = 5; // guests; no stereo in, no high bitrate in, but otherwise like stereo=1
}
}
if ((session.stereo == 1) || (session.stereo == 3) || (session.stereo == 4) || (session.stereo == 5)) {
session.echoCancellation = false;
session.autoGainControl = false;
session.noiseSuppression = false;
}
if (urlParams.has('mono')) {
session.mono = true;
if ((session.stereo == 1) || (session.stereo == 4)) {
session.stereo = 3;
session.audiobitrate = 128;
} else if (session.stereo == 5) {
session.stereo = 3;
session.audiobitrate = 128;
} else if (session.stereo == 2) {
session.stereo = 0;
session.audiobitrate = 128;
}
}
if (urlParams.has("channelcount") || urlParams.has("ac")) {
session.audioInputChannels = urlParams.get('channelcount') || urlParams.get('ac');
session.audioInputChannels = parseInt(session.audioInputChannels);
if (!session.audioInputChannels) {
session.audioInputChannels = false;
}
}
if (urlParams.has("aec") || urlParams.has("ec")) {
session.echoCancellation = urlParams.get('aec') || urlParams.get('ec');
if (session.echoCancellation) {
session.echoCancellation = session.echoCancellation.toLowerCase();
}
if (session.echoCancellation == "false") {
session.echoCancellation = false;
} else if (session.echoCancellation == "0") {
session.echoCancellation = false;
} else if (session.echoCancellation == "no") {
session.echoCancellation = false;
} else if (session.echoCancellation == "off") {
session.echoCancellation = false;
} else {
session.echoCancellation = true;
}
}
if (urlParams.has("autogain") || urlParams.has("ag")) {
session.autoGainControl = urlParams.get('autogain') || urlParams.get('ag');
if (session.autoGainControl) {
session.autoGainControl = session.autoGainControl.toLowerCase();
}
if (session.autoGainControl == "false") {
session.autoGainControl = false;
} else if (session.autoGainControl == "0") {
session.autoGainControl = false;
} else if (session.autoGainControl == "no") {
session.autoGainControl = false;
} else if (session.autoGainControl == "off") {
session.autoGainControl = false;
} else {
session.autoGainControl = true;
}
}
if (urlParams.has("denoise") || urlParams.has("dn")) {
session.noiseSuppression = urlParams.get('denoise') || urlParams.get('dn');
if (session.noiseSuppression) {
session.noiseSuppression = session.noiseSuppression.toLowerCase();
}
if (session.noiseSuppression == "false") {
session.noiseSuppression = false;
} else if (session.noiseSuppression == "0") {
session.noiseSuppression = false;
} else if (session.noiseSuppression == "no") {
session.noiseSuppression = false;
} else if (session.noiseSuppression == "off") {
session.noiseSuppression = false;
} else {
session.noiseSuppression = true;
}
}
if (urlParams.has('roombitrate') || urlParams.has('roomvideobitrate') || urlParams.has('rbr')) {
log("Room BITRATE SET");
session.roombitrate = urlParams.get('roombitrate') || urlParams.get('rbr') || urlParams.get('roomvideobitrate');
session.roombitrate = parseInt(session.roombitrate);
if (session.roombitrate < 1) {
session.roombitrate = 0;
}
}
if (urlParams.has('audiobitrate') || urlParams.has('ab')) { // both peers need this enabled for HD stereo to be on. If just pub, you get no echo/noise cancellation. if just viewer, you get high bitrate mono
log("AUDIO BITRATE SET");
session.audiobitrate = urlParams.get('audiobitrate') || urlParams.get('ab');
session.audiobitrate = parseInt(session.audiobitrate);
if (session.audiobitrate < 1) {
session.audiobitrate = false;
} else if (session.audiobitrate > 510) {
session.audiobitrate = 510;
} // this is to just prevent abuse
}
if ((iOS) || (iPad)) {
session.audiobitrate = false; // iOS devices seem to get distortion with custom audio bitrates. Disable for now.
}
/* if (urlParams.has('whitebalance') || urlParams.has('temp')){ // Need to be applied after the camera is selected. bleh. not enforcible. remove for now.
var temperature = urlParams.get('whitebalance') || urlParams.get('temp');
try{
updateCameraConstraints('colorTemperature', parseFloat(temperature));
} catch (e){errorlog(e);}
} */
if (urlParams.has('streamid') || urlParams.has('view') || urlParams.has('v') || urlParams.has('pull')) { // the streams we want to view; if set, but let blank, we will request no streams to watch.
session.view = urlParams.get('streamid') || urlParams.get('view') || urlParams.get('v') || urlParams.get('pull'); // this value can be comma seperated for multiple streams to pull
getById("headphonesDiv2").style.display = "inline-block";
getById("headphonesDiv").style.display = "inline-block";
if (session.view == null) {
session.view = "";
}
if (session.view) {
if (session.view.split(",").length > 1) {
session.view_set = session.view.split(",");
}
}
}
if (urlParams.has('nopreview') || urlParams.has('np')) {
log("preview OFF");
session.nopreview = true;
} else if ((urlParams.has('preview')) || (urlParams.has('showpreview'))) {
log("preview ON");
session.nopreview = false;
}
if (urlParams.has('obsfix')) {
session.obsfix = urlParams.get('obsfix');
if (session.obsfix) {
session.obsfix = session.obsfix.toLowerCase();
}
if (session.obsfix == "false") {
session.obsfix = false;
} else if (session.obsfix == "0") {
session.obsfix = false;
} else if (session.obsfix == "no") {
session.obsfix = false;
} else if (session.obsfix == "off") {
session.obsfix = false;
} else if (parseInt(session.obsfix) > 0) {
session.obsfix = parseInt(session.obsfix);
} else {
session.obsfix = 1; // aggressive.
}
}
if (urlParams.has('controlroombitrate') || urlParams.has('crb')) {
session.controlRoomBitrate = true;
}
if (urlParams.has('remote') || urlParams.has('rem')) {
log("remote ENABLED");
session.remote = urlParams.get('remote') || urlParams.get('rem');
session.remote = session.remote.trim();
}
if (urlParams.has('latency') || urlParams.has('al') || urlParams.has('audiolatency')) {
log("latency ENABLED");
session.audioLatency = urlParams.get('latency') || urlParams.get('al') || urlParams.get('audiolatency');
session.audioLatency = parseInt(session.audioLatency) || 0;
session.disableWebAudio = false;
}
if (urlParams.has('audiogain') || urlParams.has('gain') || urlParams.has('g')) {
log("audio gain ENABLED");
session.audioGain = urlParams.get('audiogain') || urlParams.get('gain') || urlParams.get('g');
session.audioGain = parseInt(session.audioGain) || 0;
session.disableWebAudio = false;
}
if (urlParams.has('compressor') || urlParams.has('comp')) {
log("audio gain ENABLED");
session.compressor = 1;
session.disableWebAudio = false;
} else if (urlParams.has('limiter')) {
log("audio gain ENABLED");
session.compressor = 2;
session.disableWebAudio = false;
}
if ((urlParams.has('equalizer')) || (urlParams.has('eq'))) {
session.equalizer = true;
session.disableWebAudio = false;
}
if ((urlParams.has('lowcut')) || (urlParams.has('lc')) || (urlParams.has('higpass'))) {
session.lowcut = urlParams.get('lowcut') || urlParams.get('lc') || urlParams.get('higpass') || 100;
session.lowcut = parseInt(session.lowcut);
session.disableWebAudio = false;
}
if (urlParams.has('keyframeinterval') || urlParams.has('keyframerate') || urlParams.has('keyframe') || urlParams.has('fki')) {
log("keyframerate ENABLED");
session.keyframerate = parseInt(urlParams.get('keyframeinterval') || urlParams.get('keyframerate') || urlParams.get('keyframe') || urlParams.get('fki')) || 0;
}
if (urlParams.has('tallyoff') || urlParams.has('obsoff') || urlParams.has('oo')) {
log("OBS feedback disabled");
session.disableOBS = true;
}
if (urlParams.has('chroma')) {
log("Chroma ENABLED");
getById("main").style.backgroundColor = "#" + (urlParams.get('chroma') || "000");
}
if (urlParams.has("videodevice") || urlParams.has("vdevice") || urlParams.has("vd") || urlParams.has("device") || urlParams.has("d")) {
session.videoDevice = urlParams.get("videodevice") || urlParams.get("vdevice") || urlParams.get("vd") || urlParams.get("device") || urlParams.get("d");
if (session.videoDevice === null) {
session.videoDevice = "1";
} else if (session.videoDevice) {
session.videoDevice = session.videoDevice.toLowerCase().replace(/[\W]+/g, "_");
}
if (session.videoDevice == "false") {
session.videoDevice = 0;
} else if (session.videoDevice == "0") {
session.videoDevice = 0;
} else if (session.videoDevice == "no") {
session.videoDevice = 0;
} else if (session.videoDevice == "off") {
session.videoDevice = 0;
} else if (session.videoDevice == "snapcam") {
session.videoDevice = "snap_camera";
} else if (session.videoDevice == "canon") {
session.videoDevice = "eos";
} else if (session.videoDevice == "camlink") {
session.videoDevice = "cam_link";
} else if (session.videoDevice == "ndi") {
session.videoDevice = "newtek_ndi_video";
} else if (session.videoDevice == "") {
session.videoDevice = 1;
} else if (session.videoDevice == "1") {
session.videoDevice = 1;
} else if (session.videoDevice == "default") {
session.videoDevice = 1;
} else {
// whatever the user entered I guess, santitized.
session.videoDevice = session.videoDevice.replace(/[\W]+/g, "_").toLowerCase();
}
if (session.videoDevice === 0) {
getById("add_camera").innerHTML = "Share your Microphone";
miniTranslate(getById("add_camera"), "share-your-mic");
}
getById("videoMenu").style.display = "none";
log("session.videoDevice:" + session.videoDevice);
}
// audioDevice
if (urlParams.has("audiodevice") || urlParams.has("adevice") || urlParams.has("ad") || urlParams.has("device") || urlParams.has("d")) {
session.audioDevice = urlParams.get("audiodevice") || urlParams.get("adevice") || urlParams.get("ad") || urlParams.get("device") || urlParams.get("d");
if (session.audioDevice === null) {
session.audioDevice = "1";
} else if (session.audioDevice) {
session.audioDevice = session.audioDevice.toLowerCase().replace(/[\W]+/g, "_");
}
if (session.audioDevice == "false") {
session.audioDevice = 0;
} else if (session.audioDevice == "0") {
session.audioDevice = 0;
} else if (session.audioDevice == "no") {
session.audioDevice = 0;
} else if (session.audioDevice == "off") {
session.audioDevice = 0;
} else if (session.audioDevice == "") {
session.audioDevice = 1;
} else if (session.audioDevice == "1") {
session.audioDevice = 1;
} else if (session.audioDevice == "default") {
session.audioDevice = 1;
} else if (session.audioDevice == "ndi") {
session.audioDevice = "line_newtek_ndi_audio";
} else {
// whatever the user entered I guess
session.audioDevice = session.audioDevice.replace(/[\W]+/g, "_").toLowerCase();
}
if (session.videoDevice === 0) {
if (session.audioDevice === 0) {
getById("add_camera").innerHTML = "Click Start to Join";
miniTranslate(getById("add_camera"), "click-start-to-join");
getById("container-2").className = 'column columnfade advanced'; // Hide screen share on mobile
getById("container-3").classList.add("skip-animation");
getById("container-3").classList.remove('pointer');
setTimeout(function() {
previewWebcam();
}, 100);
session.webcamonly = true;
}
}
log("session.audioDevice:" + session.audioDevice);
getById("audioMenu").style.display = "none";
getById("headphonesDiv").style.display = "none";
getById("headphonesDiv2").style.display = "none";
getById("audioScreenShare1").style.display = "none";
}
if (urlParams.has("autojoin") || urlParams.has("autostart") || urlParams.has('aj') || urlParams.has('as')) {
session.autostart = true;
if (session.screenshare) {
setTimeout(function() {
publishScreen();
}, 200);
}
}
if (urlParams.has('noiframe') || urlParams.has('noiframes') || urlParams.has('nif')) {
session.noiframe = urlParams.get('noiframe') || urlParams.get('noiframes') || urlParams.get('nif');
if (!(session.noiframe)) {
session.noiframe = [];
} else {
session.noiframe = session.noiframe.split(",");
}
log("disable iframe playback");
log(session.noiframe);
}
if (urlParams.has('exclude') || urlParams.has('ex')) {
session.exclude = urlParams.get('exclude') || urlParams.get('ex');
if (!(session.exclude)) {
session.exclude = false;
} else {
session.exclude = session.exclude.split(",");
}
log("exclude video playback");
log(session.exclude);
}
if (urlParams.has('novideo') || urlParams.has('nv') || urlParams.has('hidevideo') || urlParams.has('showonly')) {
session.novideo = urlParams.get('novideo') || urlParams.get('nv') || urlParams.get('hidevideo') || urlParams.get('showonly');
if (!(session.novideo)) {
session.novideo = [];
} else {
session.novideo = session.novideo.split(",");
}
log("disable video playback");
log(session.novideo);
}
if (urlParams.has('noaudio') || urlParams.has('na') || urlParams.has('hideaudio')) {
session.noaudio = urlParams.get('noaudio') || urlParams.get('na') || urlParams.get('hideaudio');
if (!(session.noaudio)) {
session.noaudio = [];
} else {
session.noaudio = session.noaudio.split(",");
}
log("disable audio playback");
}
if (urlParams.has('forceios')) {
log("allow iOS to work in video group chat; for this user at least");
session.forceios = true;
}
if (urlParams.has('nocursor')) {
session.nocursor = true;
log("DISABLE CURSOR");
var style = document.createElement('style');
style.innerHTML = `
video {
margin: 0;
padding: 0;
overflow: hidden;
cursor: url(data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAQAAAC1HAwCAAAAC0lEQVR42mNkYAAAAAYAAjCB0C8AAAAASUVORK5CYII=), none;
user-select: none;
}
`;
document.head.appendChild(style);
}
if (urlParams.has('vbr')) {
session.cbr = 0;
}
if (urlParams.has('order')) {
session.order = parseInt(urlParams.get('order')) || 0;
}
if (urlParams.has('sensors') || urlParams.has('sensor') || urlParams.has('gyro') || urlParams.has('gyros') || urlParams.has('accelerometer')) {
session.sensorData = urlParams.get('sensors') || urlParams.get('sensor') || urlParams.get('gyro') || urlParams.get('gyros') || urlParams.get('accelerometer') || 30;
session.sensorData = parseInt(session.sensorData);
}
if (urlParams.has('minptime')) {
session.minptime = parseInt(urlParams.get('minptime')) || 10;
if (session.minptime < 10) {
session.minptime = 10;
}
if (session.minptime > 300) {
session.minptime = 300;
}
}
if (urlParams.has('maxptime')) {
session.maxptime = parseInt(urlParams.get('maxptime')) || 60;
if (session.maxptime < 10) {
session.maxptime = 10;
}
if (session.maxptime > 300) {
session.maxptime = 300;
}
}
if (urlParams.has('ptime')) {
session.ptime = parseInt(urlParams.get('ptime')) || 20;
if (session.minptime < 10) {
session.ptime = 10;
}
if (session.minptime > 300) {
session.ptime = 300;
}
}
if (urlParams.has('codec')) {
log("CODEC CHANGED");
session.codec = urlParams.get('codec').toLowerCase();
} //else if (window.obsstudio){
//if (session.obsfix===false){
// session.codec = "h264"; // H264 --- It's too laggy!!! FUCKEEEEEEE
//}
//}
if (urlParams.has('scale')) {
if (urlParams.get('scale') == "false") {} else if (urlParams.get('scale') == "0") {} else if (urlParams.get('scale') == "no") {} else if (urlParams.get('scale') == "off") {} else {
log("Resolution scale requested");
session.scale = parseInt(urlParams.get('scale')) || 100;
}
session.dynamicScale = false; // default true
}
var ConfigSettings = getById("main-js");
var ln_template = false;
var translation = false;
try {
if (ConfigSettings) {
ln_template = ConfigSettings.getAttribute('data-translation'); // Translations
if (typeof ln_template === "undefined") {
ln_template = false;
} else if (ln_template === null) {
ln_template = false;
}
}
if (urlParams.has('ln')) {
ln_template = urlParams.get('ln');
}
} catch (e) {
errorlog(e);
}
if (ln_template) { // checking if manual lanuage override enabled
try {
log("Template: " + ln_template);
fetch("./translations/" + ln_template + '.json').then(function(response) {
if (response.status !== 200) {
log('Looks like there was a problem. Status Code: ' +
response.status);
return;
}
response.json().then(function(data) {
log(data);
translation = data;
var trans = data.innerHTML;
var allItems = document.querySelectorAll('[data-translate]');
allItems.forEach(function(ele) {
if (ele.dataset.translate in trans) {
ele.innerHTML = trans[ele.dataset.translate];
}
});
trans = data.titles;
var allTitles = document.querySelectorAll('[title]');
allTitles.forEach(function(ele) {
var key = ele.title.replace(/[\W]+/g, "-").toLowerCase();
if (key in trans) {
ele.title = trans[key];
}
});
trans = data.placeholders;
var allPlaceholders = document.querySelectorAll('[placeholder]');
allPlaceholders.forEach(function(ele) {
var key = ele.placeholder.replace(/[\W]+/g, "-").toLowerCase();
if (key in trans) {
ele.placeholder = trans[key];
}
});
getById("mainmenu").style.opacity = 1;
}).catch(function(err) {
errorlog(err);
getById("mainmenu").style.opacity = 1;
});
}).catch(function(err) {
errorlog(err);
getById("mainmenu").style.opacity = 1;
});
} catch (error) {
errorlog(error);
getById("mainmenu").style.opacity = 1;
}
} else if (location.hostname !== "obs.ninja") {
if (location.hostname === "rtc.ninja") {
try {
if (session.label === false) {
document.title = "";
}
getById("qos").innerHTML = "";
getById("logoname").innerHTML = "";
getById("helpbutton").style.display = "none";
getById("helpbutton").style.opacity = 0;
getById("reportbutton").style.display = "none";
getById("reportbutton").style.opacity = 0;
getById("mainmenu").style.opacity = 1;
getById("mainmenu").style.margin = "30px 0";
getById("translateButton").style.display = "none";
getById("translateButton").style.opacity = 0;
getById("info").style.display = "none";
getById("info").style.opacity = 0;
getById("chatBody").innerHTML = "";
} catch (e) {}
}
try {
fetch("./translations/blank.json").then(function(response) {
if (response.status !== 200) {
log('Looks like there was a problem. Status Code: ' +
response.status);
return;
}
response.json().then(function(data) {
log(data);
var trans = data.innerHTML;
var allItems = document.querySelectorAll('[data-translate]');
allItems.forEach(function(ele) {
if (ele.dataset.translate in trans) {
ele.innerHTML = trans[ele.dataset.translate];
}
});
trans = data.titles;
var allTitles = document.querySelectorAll('[title]');
allTitles.forEach(function(ele) {
var key = ele.title.replace(/[\W]+/g, "-").toLowerCase();
if (key in trans) {
ele.title = trans[key];
}
});
trans = data.placeholders;
var allPlaceholders = document.querySelectorAll('[placeholder]');
allPlaceholders.forEach(function(ele) {
var key = ele.placeholder.replace(/[\W]+/g, "-").toLowerCase();
if (key in trans) {
ele.placeholder = trans[key];
}
});
if (session.label === false) {
document.title = location.hostname;
}
getById("qos").innerHTML = location.hostname;
getById("logoname").innerHTML = getById("qos").outerHTML;
getById("helpbutton").style.display = "none";
getById("reportbutton").style.display = "none";
getById("mainmenu").style.opacity = 1;
}).catch(function(err) {
errorlog(err);
getById("mainmenu").style.opacity = 1;
});
}).catch(function(err) {
errorlog(err);
getById("mainmenu").style.opacity = 1;
});
if (session.label === false) {
document.title = location.hostname;
}
getById("qos").innerHTML = location.hostname;
getById("logoname").innerHTML = getById("qos").outerHTML;
getById("helpbutton").style.display = "none";
getById("reportbutton").style.display = "none";
getById("chatBody").innerHTML = "";
} catch (error) {
errorlog(error);
}
} else { // check if automatic language translation is available
getById("mainmenu").style.opacity = 1;
}
try {
if (location.hostname === "rtc.ninja") { // an extra-brand-free version of OBS.Ninja
if (session.label === false) {
document.title = "";
}
getById("qos").innerHTML = "";
getById("logoname").innerHTML = "";
getById("helpbutton").style.display = "none";
getById("helpbutton").style.opacity = 0;
getById("reportbutton").style.display = "none";
getById("reportbutton").style.opacity = 0;
getById("mainmenu").style.opacity = 1;
getById("mainmenu").style.margin = "30px 0";
getById("translateButton").style.display = "none";
getById("translateButton").style.opacity = 0;
getById("info").style.display = "none";
getById("info").style.opacity = 0;
getById("chatBody").innerHTML = "";
} else if (location.hostname !== "obs.ninja") {
if (session.label === false) {
document.title = location.hostname;
}
getById("qos").innerHTML = sanitizeLabel(location.hostname);
getById("logoname").innerHTML = getById("qos").outerHTML;
getById("helpbutton").style.display = "none";
getById("reportbutton").style.display = "none";
}
} catch (e) {}
if (isIFrame) {
getById("helpbutton").style.display = "none";
getById("helpbutton").style.opacity = 0;
getById("reportbutton").style.display = "none";
getById("reportbutton").style.opacity = 0;
getById("chatBody").innerHTML = "";
}
function miniTranslate(ele, ident = false) {
if (ident) {
ele.dataset.translate = ident;
} else {
ident = ele.dataset.translate;
}
try {
if (ident in translation.innerHTML) {
ele.innerHTML = translation.innerHTML[ident];
}
} catch (e) {}
}
function changeLg(lang) {
fetch("./translations/" + lang + '.json').then(function(response) {
if (response.status !== 200) {
logerror('Language translation file not found.' + response.status);
return;
}
response.json().then(function(data) {
log(data);
translation = data; // translation.innerHTML[ele.dataset.translate]
var trans = data.innerHTML;
var allItems = document.querySelectorAll('[data-translate]');
allItems.forEach(function(ele) {
if (ele.dataset.translate in trans) {
ele.innerHTML = trans[ele.dataset.translate];
}
});
trans = data.titles;
var allTitles = document.querySelectorAll('[title]');
allTitles.forEach(function(ele) {
var key = ele.title.replace(/[\W]+/g, "-").toLowerCase();
if (key in trans) {
ele.title = trans[key];
}
});
trans = data.placeholders;
var allPlaceholders = document.querySelectorAll('[placeholder]');
allPlaceholders.forEach(function(ele) {
var key = ele.placeholder.replace(/[\W]+/g, "-").toLowerCase();
if (key in trans) {
ele.placeholder = trans[key];
}
});
});
}).catch(function(err) {
errorlog(err);
});
}
if (urlParams.has('beep') || urlParams.has('notify') || urlParams.has('tone')) {
session.beepToNotify = true;
}
if (urlParams.has('r2d2')) {
getById("testtone").innerHTML = "";
getById("testtone").src = "./media/robot.mp3";
session.beepToNotify = true;
}
if (urlParams.has('videobitrate') || urlParams.has('bitrate') || urlParams.has('vb')) {
session.bitrate = urlParams.get('videobitrate') || urlParams.get('bitrate') || urlParams.get('vb');
if (session.bitrate) {
if ((session.view_set) && (session.bitrate.split(",").length > 1)) {
session.bitrate_set = session.bitrate.split(",");
session.bitrate = parseInt(session.bitrate_set[0]);
} else {
session.bitrate = parseInt(session.bitrate);
}
if (session.bitrate < 1) {
session.bitrate = false;
}
log("BITRATE ENABLED");
log(session.bitrate);
}
}
if (urlParams.has('maxvideobitrate') || urlParams.has('maxbitrate') || urlParams.has('mvb')) {
session.maxvideobitrate = urlParams.get('maxvideobitrate') || urlParams.get('maxbitrate') || urlParams.get('mvb');
session.maxvideobitrate = parseInt(session.maxvideobitrate);
if (session.maxvideobitrate < 1) {
session.maxvideobitrate = false;
}
log("maxvideobitrate ENABLED");
log(session.maxvideobitrate);
}
if (urlParams.has('totalroombitrate') || urlParams.has('totalroomvideobitrate') || urlParams.has('trb')) {
session.totalRoomBitrate = urlParams.get('totalroombitrate') || urlParams.get('totalroomvideobitrate') || urlParams.get('trb');
session.totalRoomBitrate = parseInt(session.totalRoomBitrate);
if (session.totalRoomBitrate < 1) {
session.totalRoomBitrate = false;
}
log("totalRoomBitrate ENABLED");
log(session.totalRoomBitrate);
}
if (urlParams.has('height') || urlParams.has('h')) {
session.height = urlParams.get('height') || urlParams.get('h');
session.height = parseInt(session.height);
}
if (urlParams.has('width') || urlParams.has('w')) {
session.width = urlParams.get('width') || urlParams.get('w');
session.width = parseInt(session.width);
}
if (urlParams.has('quality') || urlParams.has('q')) {
try {
session.quality = urlParams.get('quality') || urlParams.get('q') || 0;
session.quality = parseInt(session.quality);
getById("gear_screen").parentNode.removeChild(getById("gear_screen"));
getById("gear_webcam").parentNode.removeChild(getById("gear_webcam"));
} catch (e) {
errorlog(e);
}
}
if (urlParams.has('sink')) {
session.sink = urlParams.get('sink');
} else if (urlParams.has('outputdevice') || urlParams.has('od') || urlParams.has('audiooutput')) {
session.outputDevice = urlParams.get('outputdevice') || urlParams.get('od') || urlParams.get('audiooutput');
if (session.outputDevice) {
session.outputDevice = session.outputDevice.toLowerCase().replace(/[\W]+/g, "_");
} else {
session.outputDevice = false;
}
if (session.outputDevice) {
try {
enumerateDevices().then(function(deviceInfos) {
for (let i = 0; i !== deviceInfos.length; ++i) {
if (deviceInfos[i].kind === 'audiooutput') {
if (deviceInfos[i].label.replace(/[\W]+/g, "_").toLowerCase().includes(session.outputDevice)) {
session.sink = deviceInfos[i].deviceId;
log("AUDIO OUT DEVICE: " + deviceInfos[i].deviceId);
break;
}
}
}
});
} catch (e) {}
}
}
if (urlParams.has('fullscreen')) {
session.fullscreen = true;
}
if (urlParams.has('stats')) {
session.statsMenu = true;
}
if (urlParams.has('cleandirector') || urlParams.has('cdv')) {
session.cleanDirector = true;
}
if (urlParams.has('cleanoutput') || urlParams.has('clean') || urlParams.has('cleanish')) {
session.cleanOutput = true;
getById("translateButton").style.display = "none";
getById("credits").style.display = "none";
getById("header").style.display = "none";
getById("controlButtons").style.display = "none";
var style = document.createElement('style');
style.innerHTML = `
video {
background-image: none;
}
`;
document.head.appendChild(style);
}
if (urlParams.has('cleanish')) {
session.cleanish = true;
}
if (urlParams.has('channels')) { // must be loaded before channelOffset
session.audioChannels = parseInt(urlParams.get('channels'));
session.offsetChannel = 0;
log("max channels is 32; channels offset");
session.audioEffects = true;
}
if (urlParams.has('channeloffset')) {
session.offsetChannel = parseInt(urlParams.get('channeloffset'));
log("max channels is 32; channels offset");
session.audioEffects = true;
}
if (urlParams.has('enhance')) {
//if (parseInt(urlParams.get('enhance')>0){
session.enhance = true; //parseInt(urlParams.get('enhance'));
//}
}
if (urlParams.has('maxviewers') || urlParams.has('mv')) {
session.maxviewers = urlParams.get('maxviewers') || urlParams.get('mv');
if (session.maxviewers.length == 0) {
session.maxviewers = 1;
} else {
session.maxviewers = parseInt(session.maxviewers);
}
log("maxviewers set");
}
if (urlParams.has('maxpublishers') || urlParams.has('mp')) {
session.maxpublishers = urlParams.get('maxpublishers') || urlParams.get('mp');
if (session.maxpublishers.length == 0) {
session.maxpublishers = 1;
} else {
session.maxpublishers = parseInt(session.maxpublishers);
}
log("maxpublishers set");
}
if (urlParams.has('maxconnections') || urlParams.has('mc')) {
session.maxconnections = urlParams.get('maxconnections') || urlParams.get('maxconnections');
if (session.maxconnections.length == 0) {
session.maxconnections = 1;
} else {
session.maxconnections = parseInt(session.maxconnections);
}
log("maxconnections set");
}
if (urlParams.has('secure')) {
session.security = true;
if (!(session.cleanOutput)) {
setTimeout(function() {
alert("Enhanced Security Mode Enabled.");
}, 100);
}
}
if (urlParams.has('random') || urlParams.has('randomize')) {
session.randomize = true;
}
if (urlParams.has('framerate') || urlParams.has('fr') || urlParams.has('fps')) {
session.framerate = urlParams.get('framerate') || urlParams.get('fr') || urlParams.get('fps');
session.framerate = parseInt(session.framerate);
log("framerate Changed");
log(session.framerate);
}
if (urlParams.has('buffer')) { // needs to be before sync
session.buffer = parseFloat(urlParams.get('buffer')) || 0;
log("buffer Changed: " + session.buffer);
session.sync = 0;
session.audioEffects = true;
}
if (urlParams.has('sync')) {
session.sync = parseFloat(urlParams.get('sync'));
log("sync Changed; in milliseconds. If not set, defaults to auto.");
log(session.sync);
session.audioEffects = true;
if (session.buffer === false) {
session.buffer = 0;
}
}
if (urlParams.has('mirror')) {
if (urlParams.get('mirror') == "3") {
getById("main").classList.add("mirror");
} else if (urlParams.get('mirror') == "2") {
session.mirrored = 2;
} else if (urlParams.get('mirror') == "0") {
session.mirrored = 0;
} else if (urlParams.get('mirror') == "false") {
session.mirrored = 0;
} else if (urlParams.get('mirror') == "off") {
session.mirrored = 0;
} else {
session.mirrored = 1;
}
}
if (urlParams.has('flip')) {
if (urlParams.get('flip') == "0") {
session.flipped = false;
} else if (urlParams.get('flip') == "false") {
session.flipped = false;
} else if (urlParams.get('flip') == "off") {
session.flipped = false;
} else {
session.flipped = true;
}
}
if ((session.mirrored) && (session.flipped)) {
try {
log("Mirror all videos");
var mirrorStyle = document.createElement('style');
mirrorStyle.innerHTML = "video {transform: scaleX(-1) scaleY(-1); }";
document.getElementsByTagName("head")[0].appendChild(mirrorStyle);
} catch (e) {
errorlog(e);
}
} else if (session.mirrored) { // mirror the video horizontally
try {
log("Mirror all videos");
var mirrorStyle = document.createElement('style');
mirrorStyle.innerHTML = "video {transform: scaleX(-1);}";
document.getElementsByTagName("head")[0].appendChild(mirrorStyle);
} catch (e) {
errorlog(e);
}
} else if (session.flipped) { // mirror the video vertically
try {
log("Mirror all videos");
var mirrorStyle = document.createElement('style');
mirrorStyle.innerHTML = "video {transform: scaleY(-1);}";
document.getElementsByTagName("head")[0].appendChild(mirrorStyle);
} catch (e) {
errorlog(e);
}
}
if (urlParams.has('icefilter')) {
log("ICE FILTER ENABLED");
session.icefilter = urlParams.get('icefilter');
}
if (urlParams.has('effects') || urlParams.has('effect')) {
session.effects = urlParams.get('effects') || urlParams.get('effect');
session.effects = parseInt(session.effects);
if (session.effects <= 0) {
sesson.effects = false;
}
// mirror == 2
// face == 1
}
if (urlParams.has('style') || urlParams.has('st')) {
session.style = urlParams.get('style') || urlParams.get('st') || 1;
if ((parseInt(session.style) == 1) || (session.style == "justvideo")) { // no audio only
session.style = 1;
} else if ((parseInt(session.style) == 2) || (session.style == "waveform")) { // audio waveform
session.style = 2;
session.audioEffects = true; ////!!!!!!! Do I want to enable the audioEffects myself? or do it here?
} else if ((parseInt(session.style) == 3) || (session.style == "volume")) { // photo is taken? upload option? canvas?
session.style = 3;
session.audioEffects = true;
} else {
sesson.style = 1;
}
}
if (urlParams.has('samplerate') || urlParams.has('sr')) {
session.sampleRate = parseInt(urlParams.get('samplerate')) || parseInt(urlParams.get('samplerate')) || 48000;
if (session.audioCtx) {
session.audioCtx.close(); // close the default audio context.
}
session.audioCtx = new AudioContext({ // create a new audio context with a higher sample rate.
sampleRate: session.sampleRate
});
session.audioEffects = true;
}
if (urlParams.has('noaudioprocessing') || urlParams.has('noap')) {
session.disableWebAudio = true; // default true; might be useful to disable on slow or old computers?
session.audioEffects = false; // disable audio inbound effects also.
session.audioMeterGuest = false;
}
if (urlParams.has('turn')) {
var turnstring = urlParams.get('turn');
if (turnstring == "twilio") {
try {
var request = new XMLHttpRequest();
request.open('GET', 'https://api.obs.ninja/twilio', false); // `false` makes the request synchronous
request.send(null);
if (request.status === 200) {
log(request.responseText);
var res = JSON.parse(request.responseText);
session.configuration = {
iceServers: [{
"username": res["1"],
"credential": res["2"],
"url": "turn:global.turn.twilio.com:3478?transport=tcp",
"urls": "turn:global.turn.twilio.com:3478?transport=tcp"
},
{
"username": res["1"],
"credential": res["2"],
"url": "turn:global.turn.twilio.com:443?transport=tcp",
"urls": "turn:global.turn.twilio.com:443?transport=tcp"
}
],
sdpSemantics: 'unified-plan' // future-proofing
};
}
} catch (e) {
errorlog("Twilio Failed");
}
} else if ((turnstring == "false") || (turnstring == "off") || (turnstring == "0")) { // disable TURN servers
session.configuration.iceServers = [{
urls: ["stun:stun.l.google.com:19302", "stun:stun4.l.google.com:19302"]
}];
//session.configuration.iceServers.push(turn);
} else {
try {
turnstring = turnstring.split(";");
if (turnstring !== "false") { // false disables the TURN server. Useful for debuggin
var turn = {};
turn.username = turnstring[0]; // myusername
turn.credential = turnstring[1]; //mypassword
turn.urls = [turnstring[2]]; // ["turn:turn.obs.ninja:443"];
session.configuration.iceServers = [{
urls: ["stun:stun.l.google.com:19302", "stun:stun4.l.google.com:19302"]
}];
session.configuration.iceServers.push(turn);
}
} catch (e) {
if (!(session.cleanOutput)) {
alert("TURN server parameters were wrong.");
}
errorlog(e);
}
}
}
if (urlParams.has('privacy') || urlParams.has('private') || urlParams.has('relay')) { // please only use if you are also using your own TURN service.
try {
session.configuration.iceTransportPolicy = "relay"; // https://developer.mozilla.org/en-US/docs/Web/API/RTCIceCandidate/address
} catch (e) {
if (!(session.cleanOutput)) {
alert("Privacy mode failed to configure.");
}
errorlog(e);
}
if (urlParams.has('speedtest')){
if (session.maxvideobitrate !== false) {
if (session.maxvideobitrate > 6000) {
session.maxvideobitrate = 6000; // Please feel free to get rid of this if using your own TURN servers...
}
} else {
session.maxvideobitrate = 6000; // don't let people pull more than 2500 from you
}
if (session.bitrate !== false) {
if (session.bitrate > 6000) {
session.bitrate = 6000; // Please feel free to get rid of this if using your own TURN servers...
}
}
} else {
if (session.maxvideobitrate !== false) {
if (session.maxvideobitrate > 2500) {
session.maxvideobitrate = 2500; // Please feel free to get rid of this if using your own TURN servers...
}
} else {
session.maxvideobitrate = 2500; // don't let people pull more than 2500 from you
}
if (session.bitrate !== false) {
if (session.bitrate > 2500) {
session.bitrate = 2500; // Please feel free to get rid of this if using your own TURN servers...
}
}
}
}
if (urlParams.has('wss')) {
if (urlParams.get('wss')) {
session.wss = "wss://" + urlParams.get('wss');
}
}
if (urlParams.has('queue')) {
session.queue = true;
}
if (isIFrame) { // reduce CPU load if not needed.
window.onmessage = function(e) { // iFRAME support
log(e);
try {
if ("function" in e.data) { // these are calling in-app functions, with perhaps a callback -- TODO: add callbacks
var ret = null;
if (e.data.function === "previewWebcam") {
ret = previewWebcam();
} else if (e.data.function === "changeHTML") {
ret = getById(e.data.target);
ret.innerHTML = e.data.value;
} else if (e.data.function === "publishScreen") {
ret = publishScreen();
} else if (e.data.function === "eval") {
eval(e.data.value); // eval == evil ; feedback welcomed
}
}
} catch (err) {
errorlog(err);
}
if ("sendChat" in e.data) {
sendChat(e.data.sendChat); // sends to all peers; more options down the road
}
// Chat out gets called via getChatMessage function
// Related code: parent.postMessage({"chat": {"msg":-----,"type":----,"time":---} }, "*");
if ("mic" in e.data) { // this should work for the director's mic mute button as well. Needs to be manually enabled the first time still tho.
if (e.data.mic === true) { // unmute
session.muted = false; // set
log(session.muted);
toggleMute(true); // apply
} else if (e.data.mic === false) { // mute
session.muted = true; // set
log(session.muted);
toggleMute(true); // apply
} else if (e.data.mic === "toggle") { // toggle
toggleMute();
}
}
if ("camera" in e.data) { // this should work for the director's mic mute button as well. Needs to be manually enabled the first time still tho.
if (e.data.camera === true) { // unmute
session.videoMuted = false; // set
log(session.videoMuted);
toggleVideoMute(true); // apply
} else if (e.data.camera === false) { // mute
session.videoMuted = true; // set
log(session.videoMuted);
toggleVideoMute(true); // apply
} else if (e.data.camera === "toggle") { // toggle
toggleVideoMute();
}
}
if ("mute" in e.data) {
if (e.data.mute === true) { // unmute
session.speakerMuted = true; // set
toggleSpeakerMute(true); // apply
} else if (e.data.mute === false) { // mute
session.speakerMuted = false; // set
toggleSpeakerMute(true); // apply
} else if (e.data.mute === "toggle") { // toggle
toggleSpeakerMute();
}
} else if ("speaker" in e.data) { // same thing as mute.
if (e.data.speaker === true) { // unmute
session.speakerMuted = false; // set
toggleSpeakerMute(true); // apply
} else if (e.data.speaker === false) { // mute
session.speakerMuted = true; // set
toggleSpeakerMute(true); // apply
} else if (e.data.speaker === "toggle") { // toggle
toggleSpeakerMute();
}
}
if ("volume" in e.data) {
for (var i in session.rpcs) {
try {
session.rpcs[i].videoElement.volume = parseFloat(e.data.volume);
} catch (e) {
errorlog(e);
}
}
}
if ("bitrate" in e.data) {
for (var i in session.rpcs) {
try {
session.requestRateLimit(parseInt(e.data.bitrate), i);
} catch (e) {
errorlog(e);
}
}
}
if ("sceneState" in e.data) { // TRUE OR FALSE - tells the connected peers if they are live or not via a tally light change.
var visibility = e.data.sceneState;
var bundle = {};
bundle.sceneUpdate = [];
for (var UUID in session.rpcs) {
if (session.rpcs[UUID].visibility !== visibility) { // only move forward if there is a change; the event likes to double fire you see.
session.rpcs[UUID].visibility = visibility;
var msg = {};
msg.visibility = visibility;
if (session.rpcs[UUID].videoElement.style.display == "none") { // Flag will be left alone, but message will say its disabled.
msg.visibility = false;
}
msg.UUID = UUID;
session.sendRequest(msg, UUID);
bundle.sceneUpdate.push(msg);
}
}
session.sendRequest(bundle); // we want all publishing peers to know the state
}
if ("sendMessage" in e.data) { // webrtc send to viewers
session.sendMessage(e.data);
}
if ("sendRequest" in e.data) { // webrtc send to publishers
session.sendRequest(e.data);
}
if ("sendPeers" in e.data) { // webrtc send message to every connected peer; like send and request; a hammer vs a knife.
session.sendPeers(e.data);
}
if ("reload" in e.data) {
location.reload();
}
if ("getStats" in e.data) {
var stats = {};
stats.total_outbound_connections = Object.keys(session.pcs).length;
stats.total_inbound_connections = Object.keys(session.rpcs).length;
stats.inbound_stats = {};
for (var i in session.rpcs) {
stats.inbound_stats[session.rpcs[i].streamID] = session.rpcs[i].stats;
}
for (var uuid in session.pcs) {
setTimeout(function(UUID) {
session.pcs[UUID].getStats().then(function(stats) {
stats.forEach(stat => {
if (stat.type == "outbound-rtp") {
if (stat.kind == "video") {
if ("qualityLimitationReason" in stat) {
session.pcs[UUID].stats.quality_Limitation_Reason = stat.qualityLimitationReason;
}
if ("framesPerSecond" in stat) {
session.pcs[UUID].stats.resolution = stat.frameWidth + " x " + stat.frameHeight + " @ " + stat.framesPerSecond;
}
if ("encoderImplementation" in stat) {
session.pcs[UUID].stats.encoder = stat.encoderImplementation;
}
}
} else if (stat.type == "remote-candidate") {
if ("relayProtocol" in stat) {
if ("ip" in stat) {
session.pcs[UUID].stats.remote_relay_IP = stat.ip;
}
session.pcs[UUID].stats.remote_relayProtocol = stat.relayProtocol;
}
if ("candidateType" in stat) {
session.pcs[UUID].stats.remote_candidateType = stat.candidateType;
}
} else if (stat.type == "local-candidate") {
if ("relayProtocol" in stat) {
if ("ip" in stat) {
session.pcs[UUID].stats.local_relayIP = stat.ip;
}
session.pcs[UUID].stats.local_relayProtocol = stat.relayProtocol;
}
if ("candidateType" in stat) {
session.pcs[UUID].stats.local_candidateType = stat.candidateType;
}
}
return;
});
return;
});
}, 0, uuid);
}
setTimeout(function() {
stats.outbound_stats = {};
for (var i in session.pcs) {
stats.outbound_stats[i] = session.pcs[i].stats;
}
parent.postMessage({
"stats": stats
}, "*");
}, 1000);
}
if ("getLoudness" in e.data) {
log("GOT LOUDNESS REQUEST");
if (e.data.getLoudness == true) {
session.pushLoudness = true;
var loudness = {};
for (var i in session.rpcs) {
loudness[session.rpcs[i].streamID] = session.rpcs[i].stats.Audio_Loudness;
}
parent.postMessage({
"loudness": loudness
}, "*");
} else {
session.pushLoudness = false;
}
}
if ("getStreamIDs" in e.data) {
if (e.data.getStreamIDs == true) {
var streamIDs = {};
for (var i in session.rpcs) {
streamIDs[session.rpcs[i].streamID] = session.rpcs[i].label;
}
parent.postMessage({
"streamIDs": streamIDs
}, "*");
}
}
if ("close" in e.data) {
for (var i in session.rpcs) {
try {
session.rpcs[i].close();
} catch (e) {
errorlog(e);
}
}
}
if ("style" in e.data) {
try {
const style = document.createElement('style');
style.textContent = e.data.style;
document.head.append(style);
log(style);
} catch (e) {
errorlog(e);
}
}
if ("automixer" in e.data) {
if (e.data.automixer == true) {
session.manual = false;
try {
updateMixer();
} catch (e) {}
} else if (e.data.automixer == false) {
session.manual = true;
}
}
if ("target" in e.data) {
log(e.data);
for (var i in session.rpcs) {
try {
if ("streamID" in session.rpcs[i]) {
if ((session.rpcs[i].streamID == e.data.target) || (e.data.target == "*")) {
try {
if ("settings" in e.data) {
for (const property in e.data.settings) {
session.rpcs[i].videoElement[property] = e.data.settings[property];
}
}
if ("add" in e.data) {
getById("gridlayout").appendChild(session.rpcs[i].videoElement);
} else if ("remove" in e.data) {
try {
session.rpcs[i].videoElement.parentNode.removeChild(session.rpcs[i].videoElement);
} catch (e) {
try {
session.rpcs[i].videoElement.parentNode.parentNode.removeChild(session.rpcs[i].videoElement.parentNode);
} catch (e) {}
}
}
} catch (e) {
errorlog(e);
}
}
}
} catch (e) {
errorlog(e);
}
}
}
};
}
var eventMethod = window.addEventListener ? "addEventListener" : "attachEvent";
var eventer = window[eventMethod];
var messageEvent = eventMethod === "attachEvent" ? "onmessage" : "message";
eventer(messageEvent, function(e) { // this listens for child IFRAMES.
if ("action" in e.data) {
if (e.data.action == "screen-share-ended") {
if (session.screenShareElement) {
if (e.source == session.screenShareElement.contentWindow) { // reject messages send from other iframes
warnlog(e);
session.screenShareElement.contentWindow.postMessage({
"close": true
}, '*');
session.screenShareElement.parentNode.removeChild(session.screenShareElement);
session.screenShareElement = false;
updateMixer();
getById("screenshare2button").classList.add("float");
getById("screenshare2button").classList.remove("float2");
}
}
}
}
});
function pokeIframeAPI(action, value = null, UUID = null) {
if (!isIFrame){return;}
try {
var data = {};
data.action = action;
if (value !== null) {
data.value = value;
}
if (UUID !== null) {
data.UUID = UUID;
}
if (isIFrame) {
parent.postMessage(data, "*");
}
} catch (e) {
errorlog(e);
}
}
function jumptoroom(event = null) {
if (event) {
if (event.which !== 13) {
return;
}
}
var arr = window.location.href.split('?');
var roomname = getById("joinroomID").value;
roomname = sanitizeRoomName(roomname);
if (roomname.length) {
var passStr = "";
var pass = prompt("Enter a password if provided, otherwise just click cancel"); //sanitizePassword(session.password);
if (pass && pass.length) {
session.password = sanitizePassword(pass);
passStr = "&password=" + session.password;
} else {
session.password = false;
}
if (arr.length > 1 && arr[1] !== '') {
window.location += "&room=" + roomname + passStr;
} else {
window.location += "?room=" + roomname + passStr;
}
}
}
function sleep(ms = 0) {
return new Promise(r => setTimeout(r, ms)); // LOLz!
}
// session.volume = 100; // needs to be set after?
////////// Canvas Effects ///////////////
function drawFrameMirrored() {
session.canvasCtx.save();
session.canvasCtx.scale(-1, 1);
session.canvasCtx.drawImage(session.canvasSource, 0, 0, session.canvas.width * -1, session.canvas.height);
session.canvasCtx.restore();
}
function setupCanvas(eleName) {
if (session.canvas === null) {
session.canvas = document.createElement("canvas");
session.canvas.width = "1280";
session.canvas.height = "720";
session.canvasCtx = session.canvas.getContext('2d');
session.canvasSource = document.createElement("video");
session.canvasSource.autoplay = true;
session.canvasSource.srcObject = new MediaStream();
session.streamSrc = session.canvas.captureStream(30);
session.videoElement.srcObject = session.streamSrc;
}
}
function addTracks(eleName) {
if (session.canvas === null) {
session.canvas = document.createElement("canvas");
session.canvas.width = "1280";
session.canvas.height = "720";
session.canvasCtx = session.canvas.getContext('2d');
session.canvasSource = document.createElement("video");
session.canvasSource.autoplay = true;
session.canvasSource.srcObject = new MediaStream();
session.streamSrc = session.canvas.captureStream(30);
session.videoElement.srcObject = session.streamSrc;
}
}
function applyEffects(eleName, track, stream) {
if (session.effects == 1) {
setupCanvas(eleName);
session.canvasSource.srcObject.addTrack(track, stream);
session.canvas.width = track.getSettings().width;
session.canvas.height = track.getSettings().height;
if (session.effects == 1) {
setTimeout(function() {
drawFace();
}, 100);
}
} else if (session.effects == 2) {
setupCanvas(eleName);
session.canvasSource.srcObject.addTrack(track, stream);
session.canvas.width = track.getSettings().width;
session.canvas.height = track.getSettings().height;
var drawRate = parseInt(1000 / track.getSettings().frameRate) + 1;
if (session.canvasInterval !== null) {
clearInterval(session.canvasInterval);
}
session.canvasInterval = setInterval(function() {
drawFrameMirrored();
}, drawRate);
} else {
session.streamSrc.addTrack(track, stream);
session.videoElement.srcObject.addTrack(track, stream);
//session.videoElement.srcObject = outboundAudioPipeline(session.streamSrc); // WE don't do this unless we are prepared re-send all the audio tracks again also; this breaks the audio senders.
}
}
function drawFace() {
var faceAlignment = (function() {
var vid = session.canvasSource;
var canvas = session.canvas;
var ctx = session.canvasCtx;
var canvas_tmp = document.createElement("canvas");
var ctx_tmp = canvas_tmp.getContext('2d');
//var stream = canvas.captureStream(30);
var image = new Image();
var zoom = 10;
var scale = 1;
var lastFace = {};
var w = vid.videoWidth;
var h = vid.videoHeight;
var x = vid.videoWidth / 2;
var y = vid.videoHeight / 2;
lastFace.x = vid.videoWidth / 2;
lastFace.y = vid.videoHeight / 2;
lastFace.w = vid.videoWidth;
lastFace.h = vid.videoHeight;
var yoffset = 0;
if (window.FaceDetector == undefined) {
//console.error('Face Detection not supported');
var faceDetector = false;
} else {
var faceDetector = new FaceDetector();
//console.log('FaceD Loaded');
setTimeout(function() {
detect();
}, 300);
setTimeout(function() {
draw();
}, 33);
}
canvas.height = vid.videoHeight;
canvas.width = vid.videoWidth;
canvas_tmp.height = vid.videoHeight;
canvas_tmp.width = vid.videoWidth;
image.src = canvas_tmp.toDataURL();
scale = canvas.width / image.width;
lastFace.x = 0;
lastFace.y = 0;
lastFace.w = 1280 / 3 / 16 * zoom;
lastFace.h = 720 / 3 / 9 * zoom;
w = 1280 / 5;
h = 720 / 5;
x = 1280 / 2;
y = 720 / 2 - w * 9 / zoom / 2;
async function detect() {
ctx_tmp.drawImage(vid, 0, 0, vid.videoWidth, vid.videoHeight);
image.src = canvas_tmp.toDataURL();
await faceDetector.detect(image).then(faces => {
if (faces.length === 0) {
log("NO FACES");
setTimeout(function() {
detect();
}, 10);
return;
}
for (let face of faces) {
lastFace.x = (face.boundingBox.x + lastFace.x) / 2 || face.boundingBox.x;
lastFace.y = (face.boundingBox.y + lastFace.y) / 2 || face.boundingBox.y;
lastFace.w = (face.boundingBox.width + lastFace.w) / 2 || face.boundingBox.width;
lastFace.h = (face.boundingBox.height + lastFace.h) / 2 || face.boundingBox.height;
}
setTimeout(function() {
detect();
}, 300);
}).catch((e) => {
console.error("Boo, Face Detection failed: " + e);
});
}
function draw() {
canvas.height = vid.videoHeight;
canvas.width = vid.videoWidth;
if (lastFace.w - w < 0.15 * lastFace.w) {
w = w * 0.999 + 0.001 * lastFace.w;
}
if (lastFace.h - h < 0.15 * lastFace.h) {
h = h * 0.999 + 0.001 * lastFace.h;
}
if (Math.abs(x - (lastFace.x + lastFace.w / 2)) > 0.15 * (lastFace.x + lastFace.w / 2.0)) {
x = x * 0.999 + 0.001 * (lastFace.x + lastFace.w / 2.0);
}
if (Math.abs(y - (lastFace.y + lastFace.h / 2)) > 0.15 * (lastFace.y + lastFace.h / 2.0)) {
y = y * 0.999 + 0.001 * (lastFace.y + lastFace.h / 2.0);
}
yoffset = w * 9 / zoom / 2;
var yyy = y - w * 9 / zoom - yoffset;
var hhh = w * 3 * 9 / zoom;
var www = w * 3 * 16 / zoom;
var xxx = x - w * 16 / zoom * 1.5;
if (www + xxx < 1280) {
xxx = 1280 - www;
}
if (hhh + yyy < 720) {
yyy = 720 - hhh;
}
if (www + xxx > 1280) {
xxx = 1280 - www;
}
if (hhh + yyy > 720) {
yyy = 720 - hhh;
}
if (yyy < 0) {
yyy = 0;
}
if (xxx < 0) {
xxx = 0;
}
ctx.drawImage(vid, xxx, yyy, www, hhh, 0, 0, vid.videoWidth, vid.videoHeight);
setTimeout(function() {
draw();
}, 30);
}
})();
}
//////// END CANVAS EFFECTS ///////////////////
var permaid = false;
if (urlParams.has('permaid') || urlParams.has('push')) {
permaid = urlParams.get('push') || urlParams.get('permaid');
if (permaid) {
session.streamID = sanitizeStreamID(permaid);
} else {
permaid = null;
}
if (urlParams.has('permaid')) {
updateURL("permaid=" + session.streamID, true, false); // I'm not deleting the permaID first tho...
} else {
updateURL("push=" + session.streamID, true, false); // I'm not deleting the permaID first tho...
}
if (urlParams.has('director') || urlParams.has('dir')) { // if I do a short form of this, it will cause duplications in the code elsewhere.
//var director_room_input = urlParams.get('director');
//director_room_input = sanitizeRoomName(director_room_input);
//createRoom(director_room_input);
permaid = false; // used to avoid a trigger later on.
} else {
getById("container-1").className = 'column columnfade advanced';
getById("container-4").className = 'column columnfade advanced';
getById("dropButton").className = 'column columnfade advanced';
getById("info").innerHTML = "";
if (session.videoDevice === 0) {
getById("add_camera").innerHTML = "Share your Microphone";
miniTranslate(getById("add_camera"), "share-your-mic");
} else {
getById("add_camera").innerHTML = "Share your Camera";
miniTranslate(getById("add_camera"), "share-your-camera");
}
getById("add_screen").innerHTML = "Share your Screen";
miniTranslate(getById("add_screen"), "share-your-screen");
getById("passwordRoom").value = "";
getById("videoname1").value = "";
getById("dirroomid").innerHTML = "";
getById("roomid").innerHTML = "";
getById("mainmenu").style.alignSelf = "center";
getById("mainmenu").classList.add("mainmenuclass");
getById("header").style.alignSelf = "center";
if ((iOS) || (iPad)) {
getById("header").style.display = "none"; // just trying to free up space.
}
if (session.webcamonly == true) { // mobile or manual flag 'webcam' pflag set
getById("head1").innerHTML = '- Please accept any camera permissions';
} else {
getById("head1").innerHTML = ' - Please select which you wish to share';
}
}
}
if ((session.roomid) || (urlParams.has('roomid')) || (urlParams.has('r')) || (urlParams.has('room')) || (filename) || (permaid !== false)) {
var roomid = "";
if (filename) {
roomid = filename;
} else if (urlParams.has('room')) {
roomid = urlParams.get('room');
} else if (urlParams.has('roomid')) {
roomid = urlParams.get('roomid');
} else if (urlParams.has('r')) {
roomid = urlParams.get('r');
} else if (session.roomid) {
roomid = session.roomid;
}
session.roomid = sanitizeRoomName(roomid);
if (!(session.cleanOutput)) {
if (session.roomid === "test") {
if (session.password === session.defaultPassword) {
var testRoomResponse = confirm("The room name 'test' is very commonly used and may not be secure.\n\nAre you sure you wish to proceed?");
if (testRoomResponse == false) {
hangup();
throw new Error("User requested to not enter room 'room'.");
}
}
}
}
if (session.audioDevice === false) {
getById("headphonesDiv2").style.display = "inline-block";
getById("headphonesDiv").style.display = "inline-block";
}
getById("info").innerHTML = "";
getById("info").style.color = "#CCC";
getById("videoname1").value = session.roomid;
getById("dirroomid").innerText = session.roomid;
getById("roomid").innerText = session.roomid;
getById("container-1").className = 'column columnfade advanced';
getById("container-4").className = 'column columnfade advanced';
getById("container-7").style.display = 'none';
getById("container-8").style.display = 'none';
getById("mainmenu").style.alignSelf = "center";
getById("mainmenu").classList.add("mainmenuclass");
getById("header").style.alignSelf = "center";
if (session.webcamonly == true) { // mobile or manual flag 'webcam' pflag set
getById("head1").innerHTML = '';
} else {
getById("head1").innerHTML = 'Please select an option to join.';
}
if (session.roomid.length > 0) {
if (session.videoDevice === 0) {
getById("add_camera").innerHTML = "Join room with Microphone";
miniTranslate(getById("add_camera"), "join-room-with-mic");
} else {
getById("add_camera").innerHTML = "Join Room with Camera";
miniTranslate(getById("add_camera"), "join-room-with-camera");
}
getById("add_screen").innerHTML = "Screenshare with Room";
miniTranslate(getById("add_screen"), "share-screen-with-room");
} else {
if (session.videoDevice === 0) {
getById("add_camera").innerHTML = "Share your Microphone";
miniTranslate(getById("add_camera"), "share-your-mic");
} else {
getById("add_camera").innerHTML = "Share your Camera";
miniTranslate(getById("add_camera"), "share-your-camera");
}
getById("add_screen").innerHTML = "Share your Screen";
miniTranslate(getById("add_screen"), "share-your-screen");
}
getById("head3").className = 'advanced';
if (session.scene !== false) {
getById("container-4").className = 'column columnfade';
getById("container-3").className = 'column columnfade';
getById("container-2").className = 'column columnfade';
getById("container-1").className = 'column columnfade';
getById("header").className = 'advanced';
getById("info").className = 'advanced';
getById("head1").className = 'advanced';
getById("head2").className = 'advanced';
getById("mainmenu").style.display = "none";
getById("translateButton").style.display = "none";
log("Update Mixer Event on REsize SET");
window.addEventListener("resize", updateMixer);
window.addEventListener("orientationchange", function() {
setTimeout(updateMixer, 200);
});
joinRoom(session.roomid); // this is a scene, so we want high resolutions
getById("main").style.overflow = "hidden";
} else {
if ((permaid === null) && (session.roomid == "")) {
if (!(session.cleanOutput)) {
getById("head3").className = '';
}
}
}
} else if (urlParams.has('director') || urlParams.has('dir')) { // if I do a short form of this, it will cause duplications in the code elsewhere.
if (directorLanding == false) {
var director_room_input = urlParams.get('director') || urlParams.get('dir');
director_room_input = sanitizeRoomName(director_room_input);
log("director_room_input:" + director_room_input);
createRoom(director_room_input);
}
} else if ((session.view) && (permaid === false)) {
session.audioMeterGuest = false;
if (session.audioEffects === null) {
session.audioEffects = false;
}
log("Update Mixer Event on REsize SET");
getById("translateButton").style.display = "none";
window.addEventListener("resize", updateMixer);
window.addEventListener("orientationchange", function() {
setTimeout(updateMixer, 200);
});
getById("main").style.overflow = "hidden";
}
if (session.audioEffects === null) {
session.audioEffects = true;
}
if (urlParams.has('hidemenu') || urlParams.has('hm')) { // needs to happen the room and permaid applications
getById("mainmenu").style.display = "none";
getById("header").style.display = "none";
getById("mainmenu").style.opacity = 0;
getById("header").style.opacity = 0;
}
if (urlParams.has('hideheader') || urlParams.has('noheader') || urlParams.has('hh')) { // needs to happen the room and permaid applications
getById("header").style.display = "none";
getById("header").style.opacity = 0;
}
function checkConnection() {
if (session.ws === null) {
return;
}
if (document.getElementById("qos")) { // true or false; null might cause problems?
if ((session.ws) && (session.ws.readyState === WebSocket.OPEN)) {
getById("qos").style.color = "white";
} else {
getById("qos").style.color = "red";
}
}
}
setInterval(function() {
checkConnection();
}, 5000);
function printViewStats(menu, statsObj, streamID) { // Stats for viewing a remote video
var scrollLeft = menu.scrollLeft;
var scrollTop = menu.scrollTop;
//menu.innerHTML="rae:"+session.audioEffects+ ", lae:"+ !session.disableWebAudio;
menu.innerHTML = "StreamID: " + streamID + " ";
menu.innerHTML += printValues(statsObj);
menu.scrollTop = scrollTop;
menu.scrollLeft = scrollLeft;
}
function printValues(obj) { // see: printViewStats
var out = "";
for (var key in obj) {
if (typeof obj[key] === "object") {
if (obj[key] != null) {
var tmp = key;
tmp = sanitizeChat((tmp));
out += "
" + tmp + "
"
out += printValues(obj[key]);
}
} else {
if (key.startsWith("_")) {
// if it starts with _, we don't want to show it.
} else {
try {
var unit = '';
var value = obj[key];
var stat = sanitizeChat(key);
if (typeof obj[key] == "string") {
value = sanitizeChat((value));
}
if (key == 'Bitrate_in_kbps') {
var unit = " kbps";
stat = "Bitrate";
}
if (key == 'type') {
var unit = "";
stat = 'Type';
if (value == "Audio Track") {
value = "🔊 " + value;
//out += "";
}
if (value == "Video Track") {
value = "📺 " + value;
}
}
if (key == 'packetLoss_in_percentage') {
var unit = " %";
stat = 'Packet Loss 📶';
value = parseInt(parseFloat(value) * 10000) / 10000.0;
}
if (key == 'local_relayIP') {
value = "" + value + "";
}
if (key == 'remote_relay_IP') {
value = "" + value + "";
}
if (key == 'local_candidateType') {
if (value == "relay") {
value = "💸 relay server";
}
}
if (key == 'remote_candidateType') {
if (value == "relay") {
value = "💸 relay server";
}
}
if (key == 'height_url') {
if (value == false) {
continue;
}
}
if (key == 'width_url') {
if (value == false) {
continue;
}
}
if (key == 'height_url') {
if (value == false) {
continue;
}
}
if (key == 'version') {
stat = "OBS.Ninja Version";
}
if (key == 'platform') {
stat = "Platform (OS)";
}
if (key == 'aec_url') {
stat = "Echo-Cancellation";
}
if (key == 'agc_url') {
stat = "Auto-Gain (agc)";
}
if (key == 'denoise_url') {
stat = "De-noising ";
}
if (key == 'audio_level') {
stat = "Audio Level";
}
if (key == 'Buffer_Delay_in_ms') {
var unit = " ms";
stat = 'Buffer Delay';
}
if (value === null) {
value = "null";
}
if (key == "stereo_url") {
stat = "Pro-Audio (Stereo-mode)";
if (value == 3) {
value = "3 (outbound hi-fi) Use Headphones";
} else if (value == 1) {
value = "1 (in & out hi-fi) Use Headphones";
} else if (value == 2) {
value = "3 (inbound hi-fi)";
} else if (value == 4) {
value = "3 (multichannel) Use Headphones";
} else if (value == 5) {
value = "5 (auto-mode) Use Headphones";
}
}
out += "
" + stat + "" + value + unit + "
";
} catch (e) {
warnlog(e);
}
}
}
}
return out;
}
function printMyStats(menu) { // see: setupStatsMenu
var scrollLeft = getById("menuStatsBox").scrollLeft;
var scrollTop = getById("menuStatsBox").scrollTop;
menu.innerHTML = "";
session.stats.outbound_connections = Object.keys(session.pcs).length;
session.stats.inbound_connections = Object.keys(session.rpcs).length;
printViewValues(session.stats);
function printViewValues(obj) {
for (var key in obj) {
if (typeof obj[key] === "object") {
printViewValues(obj[key]);
} else {
var stat = sanitizeChat(key);
var value = obj[key];
if (typeof value == "string") {
value = sanitizeChat((value));
}
if (key == 'local_relayIP') {
value = "" + value + "";
}
if (key == 'remote_relay_IP') {
value = "" + value + "";
}
if (key == 'local_candidateType') {
if (value == "relay") {
value = "💸 relay server";
}
}
if (key == 'remote_candidateType') {
if (value == "relay") {
value = "💸 relay server";
}
}
menu.innerHTML += "
" + stat + "" + value + "
";
}
}
}
menu.innerHTML += "";
for (var uuid in session.pcs) {
setTimeout(function(UUID) {
session.pcs[UUID].getStats().then(function(stats) {
stats.forEach(stat => {
if (stat.type == "outbound-rtp") {
if (stat.kind == "video") {
if ("qualityLimitationReason" in stat) {
session.pcs[UUID].stats.quality_Limitation_Reason = stat.qualityLimitationReason;
}
if ("framesPerSecond" in stat) {
session.pcs[UUID].stats.resolution = stat.frameWidth + " x " + stat.frameHeight + " @ " + stat.framesPerSecond;
}
if ("encoderImplementation" in stat) {
session.pcs[UUID].stats.encoder = stat.encoderImplementation;
}
}
} else if (stat.type == "remote-candidate") {
if ("relayProtocol" in stat) {
if ("ip" in stat) {
session.pcs[UUID].stats.remote_relay_IP = stat.ip;
}
session.pcs[UUID].stats.remote_relayProtocol = stat.relayProtocol;
}
if ("candidateType" in stat) {
session.pcs[UUID].stats.remote_candidateType = stat.candidateType;
}
} else if (stat.type == "local-candidate") {
if ("relayProtocol" in stat) {
if ("ip" in stat) {
session.pcs[UUID].stats.local_relayIP = stat.ip;
}
session.pcs[UUID].stats.local_relayProtocol = stat.relayProtocol;
}
if ("candidateType" in stat) {
session.pcs[UUID].stats.local_candidateType = stat.candidateType;
}
}
return;
});
printViewValues(session.pcs[UUID].stats);
menu.innerHTML += "";
try {
getById("menuStatsBox").scrollLeft = scrollLeft;
getById("menuStatsBox").scrollTop = scrollTop;
} catch (e) {}
return;
}).catch(() => {
printViewValues(session.pcs[UUID].stats);
menu.innerHTML += "";
});
}, 0, uuid);
}
try {
getById("menuStatsBox").scrollLeft = scrollLeft;
getById("menuStatsBox").scrollTop = scrollTop;
} catch (e) {}
}
function updateStats(obsvc = false) {
log('updateStats - resolution found');
if (getById('previewWebcam') === null) {
return;
} // Don't show unless preview (or new stats pane is added)
try {
getById("webcamstats").innerHTML = "";
getById('previewWebcam').srcObject.getVideoTracks().forEach(
function(track) {
if ((obsvc) && (parseInt(track.getSettings().frameRate) == 30)) {
getById("webcamstats").innerHTML = "Video Settings: " + (track.getSettings().width || 0) + "x" + (track.getSettings().height || 0) + " @ up to 60fps";
} else {
getById("webcamstats").innerHTML = "Current Video Settings: " + (track.getSettings().width || 0) + "x" + (track.getSettings().height || 0) + "@" + (parseInt(track.getSettings().frameRate * 10) / 10) + "fps";
}
}
);
} catch (e) {
errorlog(e);
}
}
function toggleMute(apply = false) { // TODO: I need to have this be MUTE, toggle, with volume not touched.
log("muting");
if (session.director) {
if (!session.directorEnabledPPT) {
log("Director doesn't have PPT enabled yet");
// director has not enabled PTT yet.
return;
}
}
if (apply) {
session.muted = !session.muted;
}
//try{var ptt = getById("press2talk");} catch(e){var ptt=false;}
if (session.muted == false) {
session.muted = true;
getById("mutetoggle").className = "las la-microphone-slash my-float toggleSize";
getById("mutebutton").className = "float2 red";
if (session.streamSrc) {
session.streamSrc.getAudioTracks().forEach((track) => {
track.enabled = false;
});
}
//if (ptt){
// ptt.innerHTML = "🔇 Push to Talk";
//}
} else {
session.muted = false;
getById("mutetoggle").className = "las la-microphone my-float toggleSize";
getById("mutebutton").className = "float";
if (session.streamSrc) {
session.streamSrc.getAudioTracks().forEach((track) => {
track.enabled = true;
});
}
//if (ptt){
// ptt.innerHTML = "🔴 Push to Mute";
//}
}
if (document.getElementById("screensharesource")){
document.getElementById("screensharesource").contentWindow.postMessage({"mic":!session.muted}, '*');
}
if (!apply) { // only if they are changing states do we bother to spam.
data = {};
data.muteState = session.muted;
session.sendMessage(data);
log("SEND DATA");
}
}
function toggleSpeakerMute(apply = false) { // TODO: I need to have this be MUTE, toggle, with volume not touched.
if (CtrlPressed) {
resetupAudioOut();
}
if (apply) {
session.speakerMuted = !session.speakerMuted;
}
if (session.speakerMuted == false) {
session.speakerMuted = true;
getById("mutespeakertoggle").className = "las la-volume-mute my-float toggleSize";
getById("mutespeakerbutton").className = "float2 red";
var sounds = document.getElementsByTagName("video");
for (var i = 0; i < sounds.length; ++i) {
sounds[i].muted = session.speakerMuted;
}
} else {
session.speakerMuted = false;
getById("mutespeakertoggle").className = "las la-volume-up my-float toggleSize";
getById("mutespeakerbutton").className = "float";
var sounds = document.getElementsByTagName("video");
for (var i = 0; i < sounds.length; ++i) {
if (sounds[i].id === "videosource") { // don't unmute ourselves. feedback galore if so.
continue;
} else if (sounds[i].id === "previewWebcam") {
continue;
} else if (sounds[i].id === "screenshare") {
continue;
} else {
sounds[i].muted = session.speakerMuted;
}
}
}
for (var UUID in session.rpcs) {
if (session.rpcs[UUID].videoElement) {
//if (UUID === session.directorUUID) {
// session.rpcs[UUID].videoElement.muted = false; // unmute director
// log("MAKE SURE DIRECTOR ISN'T MUTED");
//} else {
session.rpcs[UUID].videoElement.muted = session.speakerMuted;
// }
}
}
if ((iOS) || (iPad)) {
resetupAudioOut();
}
}
function toggleChat(event = null) { // TODO: I need to have this be MUTE, toggle, with volume not touched.
if (session.chat == false) {
setTimeout(function() {
document.addEventListener("click", toggleChat);
}, 10);
getById("chatModule").addEventListener("click", function(e) {
e.stopPropagation();
return false;
});
session.chat = true;
getById("chattoggle").className = "las la-comment-dots my-float toggleSize";
getById("chatbutton").className = "float2";
getById("chatModule").style.display = "block";
getById("chatInput").focus(); // give it keyboard focus
} else {
session.chat = false;
getById("chattoggle").className = "las la-comment-alt my-float toggleSize";
getById("chatbutton").className = "float";
getById("chatModule").style.display = "none";
document.removeEventListener("click", toggleChat);
getById("chatModule").removeEventListener("click", function(e) {
e.stopPropagation();
return false;
});
}
if (getById("chatNotification").value) {
getById("chatNotification").value = 0;
}
getById("chatNotification").classList.remove("notification");
}
function directorAdvanced(ele) {
var target = document.createElement("div");
target.style = "position:absolute;float:left;width:270px;height:222px;background-color:#7E7E7E;";
var closeButton = document.createElement("button");
closeButton.innerHTML = " close";
closeButton.style.left = "5px";
closeButton.style.position = "relative";
closeButton.onclick = function() {
target.parentNode.removeChild(target);
};
target.appendChild(closeButton);
var someButton = document.createElement("button");
someButton.innerHTML = " some action ";
someButton.style.left = "5px";
someButton.style.position = "relative";
someButton.onclick = function() {
var actionMsg = {};
session.sendRequest(actionMsg, ele.dataset.UUID);
};
target.appendChild(someButton);
ele.parentNode.appendChild(target);
}
function directorSendMessage(ele) {
var target = document.createElement("div");
target.style = "position:absolute;float:left;width:270px;height:222px;background-color:#7E7E7E;";
var inputField = document.createElement("textarea");
inputField.placeholder = "Enter your message here";
inputField.style.width = "255px";
inputField.style.height = "170px";
inputField.style.margin = "5px 10px 5px 10px";
inputField.style.padding = "5px";
target.appendChild(inputField);
var sendButton = document.createElement("button");
sendButton.innerHTML = " send message ";
sendButton.style.left = "5px";
sendButton.style.position = "relative";
sendButton.onclick = function() {
var chatMsg = {};
chatMsg.chat = inputField.value;
if (sendButton.parentNode.overlay) {
chatMsg.overlay = sendButton.parentNode.overlay;
}
session.sendRequest(chatMsg, ele.dataset.UUID);
inputField.value = "";
//target.parentNode.removeChild(target);
};
var closeButton = document.createElement("button");
closeButton.innerHTML = " close";
closeButton.style.left = "5px";
closeButton.style.position = "relative";
closeButton.onclick = function() {
inputField.value = "";
target.parentNode.removeChild(target);
};
var overlayMsg = document.createElement("span");
overlayMsg.style.left = "16px";
overlayMsg.style.top = "6px";
overlayMsg.style.position = "relative";
overlayMsg.innerHTML = "";
target.overlay = true;
overlayMsg.onclick = function(e) {
log(e.target.parentNode.parentNode);
if (e.target.parentNode.parentNode.overlay === true) {
e.target.parentNode.parentNode.overlay = false;
e.target.parentNode.innerHTML = "";
} else {
e.target.parentNode.parentNode.overlay = true;
e.target.parentNode.innerHTML = "";
}
}
inputField.addEventListener("keydown", function(e) {
if (e.keyCode == 13) {
e.preventDefault();
sendButton.click();
} else if (e.keyCode == 27) {
e.preventDefault();
inputField.value = "";
target.parentNode.removeChild(target);
}
});
target.appendChild(closeButton);
target.appendChild(sendButton);
target.appendChild(overlayMsg);
ele.parentNode.appendChild(target);
inputField.focus();
inputField.select();
}
function toggleVideoMute(apply = false) { // TODO: I need to have this be MUTE, toggle, with volume not touched.
if (apply) {
session.videoMuted = !session.videoMuted;
}
if (session.videoMuted == false) {
session.videoMuted = true;
getById("mutevideotoggle").className = "las la-eye-slash my-float toggleSize";
getById("mutevideobutton").className = "float2 red";
if (session.streamSrc) {
session.streamSrc.getVideoTracks().forEach((track) => {
track.enabled = false;
});
}
} else {
session.videoMuted = false;
getById("mutevideotoggle").className = "las la-eye my-float toggleSize";
getById("mutevideobutton").className = "float";
if (session.streamSrc) {
session.streamSrc.getVideoTracks().forEach((track) => {
track.enabled = true;
});
}
}
var msg = {};
msg.videoMuted = session.videoMuted;
session.sendMessage(msg);
}
var toggleSettingsState = false;
function toggleSettings(forceShow = false) { // TODO: I need to have this be MUTE, toggle, with volume not touched.
getById("multiselect-trigger3").dataset.state = "0";
getById("multiselect-trigger3").classList.add('closed');
getById("multiselect-trigger3").classList.remove('open');
getById("chevarrow2").classList.add('bottom');
if (toggleSettingsState == true) {
if (forceShow == true) {
enumerateDevices().then(gotDevices2);
return;
}
} // don't close if already open
if (getById("popupSelector").style.display == "none") {
updateConstraintSliders();
setTimeout(function() {
document.addEventListener("click", toggleSettings);
}, 10);
getById("popupSelector").addEventListener("click", function(e) {
e.stopPropagation();
return false;
});
if (navigator.userAgent.indexOf('Chrome') != -1) {
try {
navigator.permissions.query({
name: "camera"
}).then(function(promise) {
if (promise && promise.state) {
if (promise.state == "prompt") {
navigator.mediaDevices.getUserMedia({
video: true
, audio: false
}).then(function(streamm) {
enumerateDevices().then(gotDevices2).then(function() {
streamm.getTracks().forEach(function(track) {
track.stop(); // clean up?
});
});
}).catch(function(err) {
enumerateDevices().then(gotDevices2).then(function() {});
});
} else {
enumerateDevices().then(gotDevices2).then(function() {});
}
// console.log(promise.state); //"granted", "prompt" or "rejected"
} else {
enumerateDevices().then(gotDevices2).then(function() {});
}
});
} catch (e) {
enumerateDevices().then(gotDevices2).then(function() {});
}
} else {
enumerateDevices().then(gotDevices2).then(function() {});
}
getById("popupSelector").style.display = "inline-block"
getById("settingsbutton").classList.add("float2");
getById("settingsbutton").classList.remove("float");
setTimeout(function() {
getById("popupSelector").style.right = "0px";
}, 1);
toggleSettingsState = true;
} else {
document.removeEventListener("click", toggleSettings);
getById("popupSelector").removeEventListener("click", function(e) {
e.stopPropagation();
return false;
});
getById("popupSelector").style.right = "-400px";
getById("settingsbutton").classList.add("float");
getById("settingsbutton").classList.remove("float2");
setTimeout(function() {
getById("popupSelector").style.display = "none";
}, 200);
toggleSettingsState = false;
}
}
function hangup() { // TODO: I need to have this be MUTE, toggle, with volume not touched.
getById("main").innerHTML = "👋";
setTimeout(function() {
session.hangup();
}, 0);
}
function hangup2() {
session.hangupDirector();
getById("miniPerformer").innerHTML = "";
getById("press2talk").dataset.enabled = "false";
getById("screensharebutton").classList.add("advanced");
getById("settingsbutton").classList.add("advanced");
getById("mutebutton").classList.add("advanced");
getById("hangupbutton2").classList.add("advanced");
//getById("chatbutton").classList.remove("advanced");
getById("controlButtons").style.display = "inherit";
//getById("mutespeakerbutton").classList.add("advanced");
getById("mutevideobutton").classList.add("advanced");
getById("screenshare2button").classList.add("advanced");
getById("screensharebutton").classList.add("float");
getById("screensharebutton").classList.remove("float2");
if (session.showDirector == false) {
getById("miniPerformer").innerHTML = '';
} else {
getById("miniPerformer").innerHTML = '';
}
getById("miniPerformer").className = "";
}
function hangupComplete() {
getById("main").innerHTML = "👋";
}
function raisehand() {
if (session.directorUUID == false) {
log("no director in room yet");
return;
}
var data = {};
data.UUID = session.directorUUID;
log(data);
if (getById("raisehandbutton").dataset.raised == "0") {
getById("raisehandbutton").dataset.raised = "1";
getById("raisehandbutton").classList.add("raisedHand");
data.chat = "Raised hand";
log("hand raised");
} else {
log("hand lowered");
getById("raisehandbutton").dataset.raised = "0";
getById("raisehandbutton").classList.remove("raisedHand");
data.chat = "Lowered hand";
}
session.sendMessage(data, data.UUID);
}
function lowerhand() {
log("hand lowered");
getById("raisehandbutton").dataset.raised = "0";
getById("raisehandbutton").classList.remove("raisedHand");
}
var previousRoom = "";
var stillNeedRoom = true;
var transferCancelled = false;
var armedTransfer = true;
function directMigrate(ele, event) { // everyone in the room will hangup this guest also? I like that idea. What about the STREAM ID? I suppose we don't kick out if the viewID matches.
if (event === false) {
if (previousRoom === null) { // user cancelled in previous callback
ele.innerHTML = ' Transfer';
ele.style.backgroundColor = null;
return;
}
if (transferCancelled === true) {
ele.innerHTML = ' Transfer';
ele.style.backgroundColor = null;
return;
}
migrateRoom = previousRoom
} else if ((event.ctrlKey) || (event.metaKey)) {
ele.innerHTML = ' Armed';
ele.style.backgroundColor = "#BF3F3F";
transferCancelled = false;
Callbacks.push([directMigrate, ele, stillNeedRoom]);
stillNeedRoom = false;
log("Migrate queued");
return;
} else if (armedTransfer){
migrateRoom = sanitizeRoomName(previousRoom);
} else {
var migrateRoom = prompt("Transfer guests to room:\n\n(Please note rooms must share the same password)", previousRoom);
stillNeedRoom = true;
if (migrateRoom === null) { // user cancelled
ele.innerHTML = ' Transfer';
ele.style.backgroundColor = null;
transferCancelled = true;
return;
}
try {
migrateRoom = sanitizeRoomName(migrateRoom);
previousRoom = migrateRoom;
} catch (e) {}
}
ele.innerHTML = ' Transfer';
ele.style.backgroundColor = null;
if (migrateRoom) {
previousRoom = migrateRoom;
var msg = {};
msg.request = "migrate";
if (session.password) {
return session.generateHash(migrateRoom + session.password + session.salt, 16).then(function(rid) {
var msg = {};
msg.request = "migrate";
msg.roomid = rid;
msg.target = ele.dataset.UUID;
session.sendMsg(msg); // send to everyone in the room, so they know if they are on air or not.
});
} else {
var msg = {};
msg.request = "migrate";
msg.roomid = migrateRoom;
msg.target = ele.dataset.UUID;
session.sendMsg(msg); // send to everyone in the room, so they know if they are on air or not.
}
}
}
var stillNeedHangupTarget = 1;
function directHangup(ele, event) { // everyone in the room will hangup this guest? I like that idea.
if (event == false) {
if (stillNeedHangupTarget === 1) {
var confirmHangup = confirm("Are you sure you wish to disconnect these users?");
stillNeedHangupTarget = confirmHangup;
} else {
confirmHangup = stillNeedHangupTarget;
}
} else if ((event.ctrlKey) || (event.metaKey)) {
ele.innerHTML = ' ARMED';
ele.style.backgroundColor = "#BF3F3F";
stillNeedHangupTarget = 1;
Callbacks.push([directHangup, ele, false]);
log("Hangup queued");
return;
} else {
var confirmHangup = confirm("Are you sure you wish to disconnect this user?");
}
if (confirmHangup) {
var msg = {};
//msg.request = "sendroom";
msg.hangup = true;
//msg.target = ele.dataset.UUID;
log(msg);
log(ele.dataset.UUID);
session.sendRequest(msg, ele.dataset.UUID);
//session.anysend(msg); // send to everyone in the room, so they know if they are on air or not.
} else {
ele.innerHTML = ' Hangup';
ele.style.backgroundColor = null;
}
}
function directEnable(ele, event) { // A directing room only is controlled by the Director, with the exception of MUTE.
if (!((event.ctrlKey) || (event.metaKey))) {
if (ele.dataset.enable == 1) {
ele.dataset.enable = 0;
ele.className = "";
ele.children[1].innerHTML = "Add to Scene";
getById("container_" + ele.dataset.UUID).style.backgroundColor = null;
} else {
getById("container_" + ele.dataset.UUID).style.backgroundColor = "#649166";
ele.dataset.enable = 1;
ele.className = "pressed";
ele.children[1].innerHTML = "Remove";
}
}
var msg = {};
msg.request = "sendroom";
//msg.roomid = session.roomid;
msg.scene = "1"; // scene
msg.action = "display";
msg.value = ele.dataset.enable;
msg.target = ele.dataset.UUID;
session.sendMsg(msg); // send to everyone in the room, so they know if they are on air or not.
}
function directMute(ele, event) { // A directing room only is controlled by the Director, with the exception of MUTE.
log("mute");
if (!((event.ctrlKey) || (event.metaKey))) {
if (ele.dataset.mute == 0) {
ele.dataset.mute = 1;
ele.className = "";
ele.children[1].innerHTML = "Mute in scene";
} else {
ele.dataset.mute = 0;
ele.className = "pressed";
ele.children[1].innerHTML = "Un-mute";
}
}
var msg = {};
msg.request = "sendroom";
//msg.roomid = session.roomid;
msg.scene = "1";
msg.action = "mute";
msg.value = ele.dataset.mute;
msg.target = ele.dataset.UUID;
session.sendMsg(msg); // send to everyone in the room, so they know if they are on air or not.
}
function remoteSpeakerMute(ele, event) {
log("speaker mute");
if (!((event.ctrlKey) || (event.metaKey))) {
if (ele.dataset.mute == 1) {
ele.dataset.mute = 0;
ele.className = "";
ele.children[1].innerHTML = "deafen guest";
} else {
ele.dataset.mute = 1;
ele.className = "pressed";
ele.children[1].innerHTML = "Un-deafen";
}
}
var msg = {};
if (ele.dataset.mute == 0) {
msg.speakerMute = false;
} else {
msg.speakerMute = true;
}
msg.UUID = ele.dataset.UUID;
session.sendRequest(msg, ele.dataset.UUID);
}
function updateRemoteSpeakerMute(UUID) {
var ele = document.querySelectorAll('[data-action-type="toggle-remote-speaker"][data--u-u-i-d="' + UUID + '"]');
if (ele[0]) {
ele[0].classList.add("pressed");
ele[0].dataset.mute = 1;
ele[0].className = "pressed";
ele[0].children[1].innerHTML = "Un-deafen";
}
}
function updateRemoteDisplayMute(UUID) {
var ele = document.querySelectorAll('[data-action-type="toggle-remote-display"][data--u-u-i-d="' + UUID + '"]');
if (ele[0]) {
ele[0].classList.add("pressed");
ele[0].dataset.mute = 1;
ele[0].className = "pressed";
ele[0].children[1].innerHTML = "Un-blind";
}
}
function remoteDisplayMute(ele, event) {
log("display mute");
if (!((event.ctrlKey) || (event.metaKey))) {
if (ele.dataset.mute == 1) {
ele.dataset.mute = 0;
ele.className = "";
ele.children[1].innerHTML = "blind guest";
} else {
ele.dataset.mute = 1;
ele.className = "pressed";
ele.children[1].innerHTML = "Un-blind";
}
}
var msg = {};
if (ele.dataset.mute == 0) {
msg.displayMute = false;
} else {
msg.displayMute = true;
}
msg.UUID = ele.dataset.UUID;
session.sendRequest(msg, ele.dataset.UUID);
}
function remoteLowerhands(UUID) {
var msg = {};
msg.lowerhand = true;
msg.UUID = UUID;
session.sendRequest(msg, UUID);
}
function remoteMute(ele, event) {
log("mute");
if (!((event.ctrlKey) || (event.metaKey))) {
if (ele.dataset.mute == 1) {
ele.dataset.mute = 0;
ele.className = "";
ele.children[1].innerHTML = "mute guest";
} else {
ele.dataset.mute = 1;
ele.className = "pressed";
ele.children[1].innerHTML = "Un-mute guest";
}
}
try {
session.rpcs[ele.dataset.UUID].directorMutedState = ele.dataset.mute;
var volume = session.rpcs[ele.dataset.UUID].directorVolumeState;
} catch (e) {
errorlog(e);
var volume = 100;
}
var msg = {};
if (ele.dataset.mute == 0) {
msg.volume = volume;
} else {
msg.volume = 0;
}
msg.UUID = ele.dataset.UUID;
session.sendRequest(msg, ele.dataset.UUID);
}
function directVolume(ele) { // A directing room only is controlled by the Director, with the exception of MUTE.
log("volume");
var msg = {};
msg.request = "sendroom";
//msg.roomid = session.roomid;
msg.scene = "1";
msg.action = "volume";
msg.target = ele.dataset.UUID; // i want to focus on the STREAM ID, not the UUID...
msg.value = ele.value;
session.sendMsg(msg); // send to everyone in the room, so they know if they are on air or not.
}
function remoteVolumeUI(ele){
ele.nextSibling.innerHTML = ele.value;
}
function remoteVolume(ele) { // A directing room only is controlled by the Director, with the exception of MUTE.
log("volume");
var msg = {};
var muted = session.rpcs[ele.dataset.UUID].directorMutedState;
if (muted == 1) { // 1 is a string, not an int, so == and not ===. this happens in a few places :/
session.rpcs[ele.dataset.UUID].directorVolumeState = ele.value;
} else {
session.rpcs[ele.dataset.UUID].directorVolumeState = ele.value;
msg.volume = ele.value;
msg.UUID = ele.dataset.UUID;
session.sendRequest(msg, ele.dataset.UUID);
}
}
function sendChat(chatmessage = "hi") { // A directing room only is controlled by the Director, with the exception of MUTE.
log("Chat message");
var msg = {};
msg.chat = chatmessage;
session.sendPeers(msg);
}
var activatedStream = false;
function publishScreen() {
if (activatedStream == true) {
return;
}
activatedStream = true;
setTimeout(function() {
activatedStream = false;
}, 1000);
var title = "ScreenShare"; //getById("videoname2").value;
formSubmitting = false;
var quality = parseInt(getById("webcamquality2").elements.namedItem("resolution2").value);
if (session.quality !== false) {
quality = session.quality; // override the user's setting
}
if (quality == 0) {
var width = {
ideal: 1920
};
var height = {
ideal: 1080
};
} else if (quality == 1) {
var width = {
ideal: 1280
};
var height = {
ideal: 720
};
} else if (quality == 2) {
var width = {
ideal: 640
};
var height = {
ideal: 360
};
} else if (quality >= 3) { // lowest
var width = {
ideal: 320
};
var height = {
ideal: 180
};
}
if (session.width) {
width = {
ideal: session.width
};
}
if (session.height) {
height = {
ideal: session.height
};
}
var constraints = window.constraints = {
audio: {
echoCancellation: false
, autoGainControl: false
, noiseSuppression: false
}
, video: {
width: width
, height: height
, mediaSource: "screen"
}
};
if (session.noiseSuppression === true) {
constraints.audio.noiseSuppression = true;; // the defaults for screen publishing should be off.
}
if (session.autoGainControl === true) {
constraints.audio.autoGainControl = true; // the defaults for screen publishing should be off.
}
if (session.echoCancellation === true) {
constraints.audio.echoCancellation = true; // the defaults for screen publishing should be off.
}
if (session.nocursor) {
constraints.video.cursor = {
exact: "none"
}; // Not sure this does anything, but whatever.
}
if (session.framerate !== false) {
constraints.video.frameRate = session.framerate;
} else {
constraints.video.frameRate = {
ideal: 60
};
}
var audioSelect = document.querySelector('select#audioSourceScreenshare');
var outputSelect = document.querySelector('select#outputSourceScreenshare');
session.sink = outputSelect.options[outputSelect.selectedIndex].value;
log("Session SInk: " + session.sink);
if (session.sink == "default") {
session.sink = false;
}
/* if (session.sink ===false){
if (session.outputDevice){
try {
for (var i in outputSelect.options){
log(outputSelect.options[i].label.replace(/[\W]+/g,"_").toLowerCase());
log(session.outputDevice);
if (outputSelect.options[i].label.replace(/[\W]+/g,"_").toLowerCase().includes(session.outputDevice)){
session.sink = outputSelect.options[i].value;
break;
}
}
} catch (e){}
}
} */
log("*");
session.publishScreen(constraints, title, audioSelect).then((res) => {
if (res == false) {
return;
} // no screen selected
log("streamID is: " + session.streamID);
if (session.transcript) {
setTimeout(function() {
setupClosedCaptions();
}, 0);
}
//ScreenShareState=true;
if (!(session.cleanOutput)) {
getById("mutebutton").className = "float";
getById("mutespeakerbutton").classList.remove("advanced");
//getById("mutespeakerbutton").className="float";
getById("chatbutton").className = "float";
getById("mutevideobutton").className = "float";
getById("hangupbutton").className = "float";
if (session.showSettings) {
getById("settingsbutton").className = "float";
}
if (session.raisehands) {
getById("raisehandbutton").className = "float";
}
if (session.recordLocal !== false) {
getById("recordLocalbutton").className = "float";
}
if (screensharebutton) {
getById("screensharebutton").className = "float2";
}
getById("controlButtons").style.display = "flex";
getById("helpbutton").style.display = "inherit";
getById("reportbutton").style.display = "";
} else {
getById("controlButtons").style.display = "none";
}
if (session.chatbutton === true) {
getById("chatbutton").classList.remove("advanced");
getById("controlButtons").style.display = "inherit";
} else if (session.chatbutton === false) {
getById("chatbutton").classList.add("advanced");
}
getById("head1").className = 'advanced';
getById("head2").className = 'advanced';
}).catch(() => {});
}
function publishWebcam(btn = false) {
if (btn) {
if (btn.dataset.ready == "false") {
warnlog("Clicked too quickly; button not enabled yet");
return;
}
}
if (activatedStream == true) {
return;
}
activatedStream = true;
log("PRESSED PUBLISH WEBCAM!!");
var title = "Webcam"; // getById("videoname3").value;
var ele = getById("previewWebcam");
formSubmitting = false;
window.scrollTo(0, 0); // iOS has a nasty habit of overriding the CSS when changing camaera selections, so this addresses that.
getById("head2").className = 'advanced';
if (session.roomid !== false) {
if ((session.roomid === "") && ((!(session.view)) || (session.view === ""))) {
// no room, no viewing, viewing disabled
session.manual = true;
window.addEventListener("resize", updateMixer);
window.addEventListener("orientationchange", function() {
setTimeout(updateMixer, 200);
});
} else {
log("ROOM ID ENABLED");
log("Update Mixer Event on REsize SET");
window.addEventListener("resize", updateMixer);
window.addEventListener("orientationchange", function() {
setTimeout(updateMixer, 200);
});
getById("main").style.overflow = "hidden";
//session.cbr=0; // we're just going to override it
if (session.stereo == 5) {
if (session.roomid === "") {
session.stereo = 1;
} else {
session.stereo = 3;
}
}
joinRoom(session.roomid);
if (session.roomid !== "") {
if (!(session.cleanOutput)) {
getById("head2").className = '';
}
}
getById("head3").className = 'advanced';
log("4");
}
} else {
getById("head3").className = '';
getById("logoname").style.display = 'none';
}
log("streamID is: " + session.streamID);
getById("head1").className = 'advanced';
if (!(session.cleanOutput)) {
getById("mutebutton").className = "float";
getById("mutespeakerbutton").classList.remove("advanced");
//getById("mutespeakerbutton").className="float";
getById("chatbutton").className = "float";
getById("mutevideobutton").className = "float";
getById("hangupbutton").className = "float";
if (session.showSettings) {
getById("settingsbutton").className = "float";
}
if (session.raisehands) {
getById("raisehandbutton").className = "float";
}
if (session.recordLocal !== false) {
getById("recordLocalbutton").className = "float";
}
if (screensharebutton) {
if (session.roomid) {
getById("screenshare2button").className = "float";
getById("screensharebutton").className = "float advanced";
} else {
getById("screensharebutton").className = "float";
getById("screenshare2button").className = "float advanced";
}
}
getById("controlButtons").style.display = "flex";
getById("helpbutton").style.display = "inherit";
getById("reportbutton").style.display = "";
} else {
getById("controlButtons").style.display = "none";
}
if (session.chatbutton === true) {
getById("chatbutton").classList.remove("advanced");
getById("controlButtons").style.display = "inherit";
} else if (session.chatbutton === false) {
getById("chatbutton").classList.add("advanced");
}
if (urlParams.has('permaid')) {
updateURL("permaid=" + session.streamID);
} else {
updateURL("push=" + session.streamID);
}
session.publishStream(ele, title);
}
function outboundAudioPipeline(stream) {
if (session.disableWebAudio) {
return stream;
}
//if ((iOS) || (iPad)){
// return stream
//} else {
try {
log("Web Audio");
var tracks = stream.getAudioTracks();
if (tracks.length) {
for (var waid in session.webAudios) { // TODO: EXCLUDE CURRENT TRACK IF ALREADY EXISTS ... if (track.id === wa.id){..
session.webAudios[waid].stop();
delete session.webAudios[waid];
}
var webAudio = {};
webAudio.compressor = false;
webAudio.analyser = false;
webAudio.gainNode = false;
webAudio.lowEQ = false;
webAudio.midEQ = false;
webAudio.highEQ = false;
webAudio.id = tracks[0].id; // first track is used.
if (session.audioLatency !== false) { // session.audioLatency could be useful for fixing clicking issues?
var audioContext = new AudioContext({
latencyHint: session.audioLatency / 1000.0 //, // needs to be in seconds, but OBSN user input is via milliseconds
// sampleRate: 48000 // not sure this is a great idea, but might as well add this here, versus later on since it is needed anyways.
});
} else {
var audioContext = new AudioContext();
}
webAudio.audioContext = audioContext;
webAudio.mediaStreamSource = audioContext.createMediaStreamSource(stream); // clone to fix iOS issue
webAudio.destination = audioContext.createMediaStreamDestination();
webAudio.gainNode = audioGainNode(webAudio.mediaStreamSource, audioContext);
var anonNode = webAudio.gainNode;
if (session.audioInputChannels == 1) {
webAudio.splitter = audioContext.createChannelSplitter(6);
anonNode.connect(webAudio.splitter);
webAudio.merger = audioContext.createChannelMerger(6);
webAudio.splitter.connect(webAudio.merger, 0, 0);
webAudio.splitter.connect(webAudio.merger, 0, 1);
webAudio.splitter.connect(webAudio.merger, 0, 2);
webAudio.splitter.connect(webAudio.merger, 0, 3);
webAudio.splitter.connect(webAudio.merger, 0, 4);
webAudio.splitter.connect(webAudio.merger, 0, 5);
anonNode = webAudio.merger;
}
if (session.lowcut) { // https://webaudioapi.com/samples/frequency-response/ for a tool to help set values
webAudio.lowcut1 = audioContext.createBiquadFilter();
webAudio.lowcut1.type = "highpass";
webAudio.lowcut1.frequency.value = session.lowcut;
webAudio.lowcut2 = audioContext.createBiquadFilter();
webAudio.lowcut2.type = "highpass";
webAudio.lowcut2.frequency.value = session.lowcut;
webAudio.lowcut3 = audioContext.createBiquadFilter();
webAudio.lowcut3.type = "highpass";
webAudio.lowcut3.frequency.value = session.lowcut;
anonNode.connect(webAudio.lowcut1);
webAudio.lowcut1.connect(webAudio.lowcut2);
webAudio.lowcut2.connect(webAudio.lowcut3);
anonNode = webAudio.lowcut3;
}
if (session.equalizer) { // https://webaudioapi.com/samples/frequency-response/ for a tool to help set values
webAudio.lowEQ = audioContext.createBiquadFilter();
webAudio.lowEQ.type = "lowshelf";
webAudio.lowEQ.frequency.value = 100;
webAudio.lowEQ.gain.value = 0;
webAudio.midEQ = audioContext.createBiquadFilter();
webAudio.midEQ.type = "peaking";
webAudio.midEQ.frequency.value = 1000;
webAudio.midEQ.Q.value = 0.5;
webAudio.midEQ.gain.value = 0;
webAudio.highEQ = audioContext.createBiquadFilter();
webAudio.highEQ.type = "highshelf";
webAudio.highEQ.frequency.value = 10000;
webAudio.highEQ.gain.value = 0;
anonNode.connect(webAudio.lowEQ);
webAudio.lowEQ.connect(webAudio.midEQ);
webAudio.midEQ.connect(webAudio.highEQ);
anonNode = webAudio.highEQ;
}
if (session.compressor === 1) {
webAudio.compressor = audioCompressor(anonNode, audioContext);
anonNode = webAudio.compressor;
} else if (session.compressor === 2) {
webAudio.compressor = audioLimiter(anonNode, audioContext);
anonNode = webAudio.compressor;
}
webAudio.analyser = audioMeter(anonNode, audioContext);
webAudio.analyser.connect(webAudio.destination);
webAudio.stop = function() {
try {
webAudio.destination.disconnect();
} catch (e) {}
try {
clearInterval(webAudio.analyser.interval);
} catch (e) {}
try {
webAudio.analyser.disconnect();
} catch (e) {}
try {
webAudio.splitter.disconnect();
} catch (e) {}
try {
webAudio.merger.disconnect();
} catch (e) {}
try {
webAudio.lowcut1.disconnect();
webAudio.lowcut2.disconnect();
webAudio.lowcut3.disconnect();
} catch (e) {}
try {
webAudio.lowEQ.disconnect();
} catch (e) {}
try {
webAudio.midEQ.disconnect();
} catch (e) {}
try {
webAudio.highEQ.disconnect();
} catch (e) {}
try {
webAudio.gainNode.disconnect();
} catch (e) {}
try {
webAudio.compressor.disconnect();
} catch (e) {}
try {
webAudio.mediaStreamSource.context.close();
} catch (e) {}
}
webAudio.mediaStreamSource.onended = function() {
webAudio.stop();
};
session.webAudios[webAudio.id] = webAudio;
stream.getTracks().forEach(function(track) {
if (webAudio.id != track.id) {
webAudio.destination.stream.addTrack(track, stream);
}
});
return webAudio.destination.stream;
} else {
return stream; // no audio track
}
} catch (e) {
errorlog(e);
return stream;
}
}
function changeLowCut(freq, trackid = 0) {
if (trackid != 0) {
errorlog("EQ Doesn't work for anything but track 0. yet");
}
log("LOW EQ");
for (var webAudio in session.webAudios) {
if (!session.webAudios[webAudio].lowcut1) {
errorlog("EQ not setup");
return;
}
if (!session.webAudios[webAudio].lowcut2) {
errorlog("EQ not setup");
return;
}
if (!session.webAudios[webAudio].lowcut3) {
errorlog("EQ not setup");
return;
}
session.webAudios[webAudio].lowcut1.frequency.setValueAtTime(freq, session.webAudios[webAudio].audioContext.currentTime);
session.webAudios[webAudio].lowcut2.frequency.setValueAtTime(freq, session.webAudios[webAudio].audioContext.currentTime);
session.webAudios[webAudio].lowcut3.frequency.setValueAtTime(freq, session.webAudios[webAudio].audioContext.currentTime);
}
}
function changeLowEQ(lowEQ, trackid = 0) {
if (trackid != 0) {
errorlog("EQ Doesn't work for anything but track 0. yet");
}
log("LOW EQ");
for (var webAudio in session.webAudios) {
if (!session.webAudios[webAudio].lowEQ) {
errorlog("EQ not setup");
return;
}
session.webAudios[webAudio].lowEQ.gain.setValueAtTime(lowEQ, session.webAudios[webAudio].audioContext.currentTime);
}
}
function changeMidEQ(midEQ, trackid = 0) {
if (trackid != 0) {
errorlog("EQ Doesn't work for anything but track 0. yet");
}
for (var webAudio in session.webAudios) {
if (!session.webAudios[webAudio].midEQ) {
errorlog("EQ not setup");
return;
}
session.webAudios[webAudio].midEQ.gain.setValueAtTime(midEQ, session.webAudios[webAudio].audioContext.currentTime);
}
}
function changeHighEQ(highEQ, trackid = 0) {
if (trackid != 0) {
errorlog("EQ Doesn't work for anything but track 0. yet");
}
for (var webAudio in session.webAudios) {
if (!session.webAudios[webAudio].highEQ) {
errorlog("EQ not setup");
return;
}
session.webAudios[webAudio].highEQ.gain.setValueAtTime(highEQ, session.webAudios[webAudio].audioContext.currentTime);
}
}
function audioGainNode(mediaStreamSource, audioContext) {
var gainNode = audioContext.createGain();
if (session.audioGain !== false) {
var gain = parseFloat(session.audioGain / 100.0) || 0;
} else {
var gain = 1.0;
}
gainNode.gain.value = gain;
mediaStreamSource.connect(gainNode);
return gainNode;
}
function audioMeter(mediaStreamSource, audioContext) {
var analyser = audioContext.createAnalyser();
mediaStreamSource.connect(analyser);
analyser.fftSize = 256;
analyser.smoothingTimeConstant = 0.05;
var bufferLength = analyser.frequencyBinCount;
var dataArray = new Uint8Array(bufferLength);
function draw() {
analyser.getByteFrequencyData(dataArray);
var total = 0;
for (var i = 0; i < dataArray.length; i++) {
total += dataArray[i];
}
total = total / 100;
if (document.getElementById("meter1")) {
if (total == 0) {
getById("meter1").style.width = "1px";
getById("meter2").style.width = "0px";
} else if (total <= 1) {
getById("meter1").style.width = "1px";
getById("meter2").style.width = "0px";
} else if (total <= 150) {
getById("meter1").style.width = total + "px";
getById("meter2").style.width = "0px";
} else if (total > 150) {
if (total > 200) {
total = 200;
}
getById("meter1").style.width = "150px";
getById("meter2").style.width = (total - 150) + "px";
}
} else if (document.getElementById("mutetoggle")) {
if (total > 200) {
total = 200;
}
total = parseInt(total);
document.getElementById("mutetoggle").style.color = "rgb(" + (255 - total) + ",255," + (255 - total) + ")";
} else {
clearInterval(analyser.interval);
warnlog("METERS NOT FOUND");
return;
}
};
analyser.interval = setInterval(function() {
draw();
}, 100);
return analyser;
}
function audioCompressor(mediaStreamSource, audioContext) {
var compressor = audioContext.createDynamicsCompressor();
compressor.threshold.value = -50;
compressor.knee.value = 40;
compressor.ratio.value = 12;
compressor.attack.value = 0;
compressor.release.value = 0.25;
mediaStreamSource.connect(compressor);
return compressor;
}
function audioLimiter(mediaStreamSource, audioContext) {
var compressor = audioContext.createDynamicsCompressor();
compressor.threshold.value = -5;
compressor.knee.value = 0;
compressor.ratio.value = 20.0; // 1 to 20
compressor.attack.value = 0.001;
compressor.release.value = 0.1;
mediaStreamSource.connect(compressor);
return compressor;
}
function activeSpeaker() {
var changed = false;
for (var UUID in session.rpcs) {
if (session.rpcs[UUID].stats.Audio_Loudness_average) {
session.rpcs[UUID].stats.Audio_Loudness_average = parseFloat(session.rpcs[UUID].stats.Audio_Loudness + session.rpcs[UUID].stats.Audio_Loudness_average) / 2;
} else {
session.rpcs[UUID].stats.Audio_Loudness_average = 1;
}
log(session.rpcs[UUID].stats.Audio_Loudness_average);
if (session.rpcs[UUID].stats.Audio_Loudness_average > 10) {
if (session.rpcs[UUID].videoElement.style.display != "block") {
session.rpcs[UUID].videoElement.style.display = "block";
changed = true;
}
} else {
if (session.rpcs[UUID].videoElement) {
if (session.rpcs[UUID].videoElement.style.display != "none") {
changed = true;
session.rpcs[UUID].videoElement.style.display = "none";
}
} else {
session.rpcs[UUID].videoElement.style.display = "none";
}
}
}
if (changed) {
updateMixer();
}
}
//setInterval(function(){activeSpeaker()},1000);
function randomizeArray(unshuffled) {
var arr = unshuffled.map((a) => ({
sort: Math.random(), value: a
})).sort((a, b) => a.sort - b.sort).map((a) => a.value); // shuffle once
for (var i = arr.length - 1; i > 0; i--) { // shuffle twice
var j = Math.floor(Math.random() * (i + 1));
var tmp = arr[i];
arr[i] = arr[j];
arr[j] = tmp;
}
return arr
}
function joinRoom(roomname) {
if (roomname.length) {
roomname = sanitizeRoomName(roomname);
log("Join room");
log(roomname);
session.joinRoom(roomname).then(function(response) { // callback from server; we've joined the room. Just the listing is returned
if (session.joiningRoom === "seedPlz") { // allow us to seed, now that we have joined the room.
session.joiningRoom = false; // joined
session.seedStream();
} else {
session.joiningRoom = false; // no seeding callback
}
log("Members in Room");
log(response);
if (session.randomize === true) {
response = randomizeArray(response);
log("Randomized List of Viewers");
log(response);
for (var i in response) {
if ("UUID" in response[i]) {
if ("streamID" in response[i]) {
if (response[i].UUID in session.rpcs) {
log("RTC already connected"); /// lets just say instead of Stream, we have
} else {
log(response[i].streamID);
var streamID = session.desaltStreamID(response[i].streamID);
if (session.queue){
if (session.directorUUID === response[i].UUID){
play(streamID);
} else if (session.queueList.length<5000){
if (!session.queueList.includes(streamID)){
session.queueList.push(streamID);
}
}
} else {
log("STREAM ID DESALTED 3: " + streamID);
setTimeout(function(sid) {
play(sid);
}, (Math.floor(Math.random() * 100)), streamID); // add some furtherchance with up to 100ms added latency
}
}
}
}
}
} else {
for (var i in response) {
if ("UUID" in response[i]) {
if ("streamID" in response[i]) {
if (response[i].UUID in session.rpcs) {
log("RTC already connected"); /// lets just say instead of Stream, we have
} else {
log(response[i].streamID);
var streamID = session.desaltStreamID(response[i].streamID);
if (session.queue){
if (session.directorUUID === response[i].UUID){
play(streamID);
} else if (session.queueList.length<5000){
if (!session.queueList.includes(streamID)){
session.queueList.push(streamID);
}
}
} else {
log("STREAM ID DESALTED 3: " + streamID);
play(streamID); // play handles the group room mechanics here
}
}
}
}
}
}
session.updateQueue();
}, function(error) {
return {};
});
} else {
log("Room name not long enough or contained all bad characaters");
}
}
function createRoom(roomname = false) {
if (roomname == false) {
roomname = getById("videoname1").value;
roomname = sanitizeRoomName(roomname);
if (roomname.length != 0) {
if (urlParams.has('dir')){
updateURL("dir=" + roomname, true, false); // make the link reloadable.
} else {
updateURL("director=" + roomname, true, false); // make the link reloadable.
}
}
}
if (roomname.length == 0) {
if (!(session.cleanOutput)) {
alert("Please enter a room name before continuing");
}
return;
}
log(roomname);
session.roomid = roomname;
getById("dirroomid").innerHTML = decodeURIComponent(session.roomid);
getById("roomid").innerHTML = session.roomid;
var passwordRoom = getById("passwordRoom").value;
passwordRoom = sanitizePassword(passwordRoom);
if (passwordRoom.length) {
session.password = passwordRoom;
session.defaultPassword = false;
if (urlParams.has('pass')) {
updateURL("pass=" + session.password);
} else if (urlParams.has('pw')) {
updateURL("pw=" + session.password);
} else if (urlParams.has('p')) {
updateURL("p=" + session.password);
} else {
updateURL("password=" + session.password);
}
}
var passAdd = "";
var passAdd2 = "";
if ((session.defaultPassword === false) && (session.password)) {
passAdd2 = "&password=" + session.password;
return session.generateHash(session.password + session.salt, 4).then(function(hash) {
passAdd = "&hash=" + hash;
createRoomCallback(passAdd, passAdd2);
});
} else {
createRoomCallback(passAdd, passAdd2);
}
}
function hideDirectorinvites(ele) {
if (getById("directorLinks2").style.display == "none") {
ele.innerHTML = ' LINKS (GUEST INVITES & SCENES)';
getById("directorLinks2").style.display = "inline-block";
getById("customizeLinks").classList.remove("advanced");
} else {
ele.innerHTML = ' LINKS (GUEST INVITES & SCENES)'
getById("directorLinks2").style.display = "none";
getById("help_directors_room").style.display = "none";
getById("roomnotes2").style.display = "none";
getById("customizeLinks").classList.add("advanced");
}
if (getById("directorLinks1").style.display == "none") {
getById("directorLinks1").style.display = "inline-block";
getById("customizeLinks").classList.remove("advanced");
} else {
getById("directorLinks1").style.display = "none";
getById("help_directors_room").style.display = "none";
getById("roomnotes2").style.display = "none";
getById("customizeLinks").classList.add("advanced");
}
//document.querySelector(".directorContainer.half").style.display="none";
//document.querySelector(".directorContainer").style.display="none";
}
function createRoomCallback(passAdd, passAdd2) {
var gridlayout = getById("gridlayout");
gridlayout.classList.add("directorsgrid");
var broadcastFlag = getById("broadcastFlag");
try {
if (broadcastFlag.checked) {
broadcastFlag = true;
} else {
broadcastFlag = false;
}
} catch (e) {
broadcastFlag = false;
}
var broadcastString = "";
if (broadcastFlag) {
broadcastString = "&broadcast";
getById("broadcastSlider").checked = true;
}
var showdirectorFlag = getById("showdirectorFlag");
try {
if (showdirectorFlag.checked) {
showdirectorFlag = true;
} else {
showdirectorFlag = false;
}
} catch (e) {
showdirectorFlag = false;
}
if (showdirectorFlag) {
updateURL("showdirector", true, false);
session.showDirector = true;
//getById("broadcastSlider").checked=true;
}
var codecGroupFlag = getById("codecGroupFlag");
if (codecGroupFlag.value) {
if (codecGroupFlag.value === "vp9") {
codecGroupFlag = "&codec=vp9";
} else if (codecGroupFlag.value === "h264") {
codecGroupFlag = "&codec=h264";
} else if (codecGroupFlag.value === "vp8") {
codecGroupFlag = "&codec=vp8";
} else {
codecGroupFlag = "";
}
} else {
codecGroupFlag = "";
}
if (codecGroupFlag) {
session.codecGroupFlag = codecGroupFlag;
}
formSubmitting = false;
var m = getById("mainmenu");
m.remove();
getById("head1").className = 'advanced';
getById("head2").className = 'advanced';
//getById("head3").className = 'advanced';
getById("head4").className = '';
try {
if (session.label === false) {
if (document.title == "") {
document.title = "Control Room";
} else {
document.title += " - Control Room";
}
}
} catch (e) {
errorlog(e);
};
session.director = true;
screensharesupport = false;
window.addEventListener("resize", updateMixer);
window.addEventListener("orientationchange", updateMixer);
getById("reshare").parentNode.removeChild(getById("reshare"));
//getById("mutespeakerbutton").style.display = null;
session.speakerMuted = true; // the director will start with audio playback muted.
toggleSpeakerMute(true);
if (session.cleanDirector == false) {
getById("roomHeader").style.display = "";
//getById("directorLinks").style.display = "";
getById("directorLinks1").style.display = "inline-block";
getById("directorLinks2").style.display = "inline-block";
getById("director_block_1").dataset.raw = "https://" + location.host + location.pathname + "?room=" + session.roomid + broadcastString + passAdd;
getById("director_block_1").href = "https://" + location.host + location.pathname + "?room=" + session.roomid + broadcastString + passAdd;
getById("director_block_1").innerText = "https://" + location.host + location.pathname + "?room=" + session.roomid + broadcastString + passAdd;
getById("director_block_3").dataset.raw = "https://" + location.host + location.pathname + "?scene&room=" + session.roomid + codecGroupFlag + passAdd2;
getById("director_block_3").href = "https://" + location.host + location.pathname + "?scene&room=" + session.roomid + codecGroupFlag + passAdd2;
getById("director_block_3").innerText = "https://" + location.host + location.pathname + "?scene&room=" + session.roomid + codecGroupFlag + passAdd2;
} else {
getById("guestFeeds").innerHTML = '';
}
getById("guestFeeds").style.display = "";
if (!(session.cleanOutput)) {
if (session.queue){
getById("queuebutton").classList.remove("advanced");
}
getById("chatbutton").classList.remove("advanced");
getById("controlButtons").style.display = "inherit";
getById("mutespeakerbutton").classList.remove("advanced");
if (session.showDirector == false) {
getById("miniPerformer").innerHTML = '';
} else {
getById("miniPerformer").innerHTML = '';
}
getById("miniPerformer").className = "";
var tabindex = 26;
if(session.rooms && session.rooms.length > 0){
var container = getById("rooms");
container.innerHTML += 'Arm Transfer: ';
session.rooms.forEach(function (r) {
if(session.roomid == r) return; //don't include self
container.innerHTML += '';
tabindex++;
});
}
} else {
getById("miniPerformer").style.display = "none";
getById("controlButtons").style.display = "none";
}
if (session.chatbutton === true) {
getById("chatbutton").classList.remove("advanced");
getById("controlButtons").style.display = "inherit";
} else if (session.chatbutton === false) {
getById("chatbutton").classList.add("advanced");
}
joinRoom(session.roomid);
}
/**
* Handles click actions on the room selection buttons in #controlButtons
* @param {string} room - Room name to select/deselect for the next transfer call
*/
function handleRoomSelect(room) {
var elems = document.querySelectorAll(".btnArmTransferRoom");
[].forEach.call(elems, function(el) {
el.classList.remove("selected");
});
if (previousRoom == room) {
previousRoom = undefined;
armedTransfer = false;
stillNeedRoom = true;
} else {
previousRoom = room;
stillNeedRoom = false;
armedTransfer = true;
getById("roomselect_" + room).classList.add('selected');
}
}
function requestAudioSettings(ele) {
var UUID = ele.dataset.UUID;
if (ele.dataset.active == "true") {
ele.dataset.active = "false";
ele.classList.remove("pressed");
getById("advanced_audio_director_" + UUID).innerHTML = "";
getById("advanced_audio_director_" + UUID).className = "advanced";
} else {
ele.dataset.active = "true";
ele.classList.add("pressed");
getById("advanced_audio_director_" + UUID).innerHTML = "";
var actionMsg = {};
actionMsg.getAudioSettings = true;
session.sendRequest(actionMsg, UUID);
}
}
function requestVideoSettings(ele) {
var UUID = ele.dataset.UUID;
if (ele.dataset.active == "true") {
ele.dataset.active = "false";
ele.classList.remove("pressed");
getById("advanced_video_director_" + UUID).innerHTML = "";
getById("advanced_video_director_" + UUID).className = "advanced";
} else {
ele.dataset.active = "true";
ele.classList.add("pressed");
getById("advanced_video_director_" + UUID).innerHTML = "";
var actionMsg = {};
actionMsg.getVideoSettings = true;
session.sendRequest(actionMsg, UUID);
}
}
function createControlBox(UUID, soloLink, streamID) {
if (document.getElementById("deleteme")) {
getById("deleteme").parentNode.removeChild(getById("deleteme"));
}
var controls = getById("controls_blank").cloneNode(true);
var container = document.createElement("div");
container.id = "container_" + UUID; // needed to delete on user disconnect
container.className = "vidcon";
container.style.margin = "15px 20px 0 0 ";
controls.style.display = "block";
controls.id = "controls_" + UUID;
getById("guestFeeds").appendChild(container);
var buttons = "