// We import the settings.js file to know which address we should contact
// to talk to Janus, and optionally which STUN/TURN servers should be
// used as well. Specifically, that file defines the "server" and
// "iceServers" properties we'll pass when creating the Janus session.
/* global iceServers:readonly, Janus:readonly, server:readonly */
var janus = null;
var echotest = null;
var opaqueId = "echotest-" + Janus.randomString(12);
var localTracks = {},
localVideos = 0,
remoteTracks = {},
remoteVideos = 0;
var bitrateTimer = null;
var audioenabled = false;
var videoenabled = false;
var doSimulcast =
getQueryStringValue("simulcast") === "yes" ||
getQueryStringValue("simulcast") === "true";
var doSvc = getQueryStringValue("svc");
if (doSvc === "") doSvc = null;
var acodec =
getQueryStringValue("acodec") !== "" ? getQueryStringValue("acodec") : null;
var vcodec =
getQueryStringValue("vcodec") !== "" ? getQueryStringValue("vcodec") : null;
var vprofile =
getQueryStringValue("vprofile") !== ""
? getQueryStringValue("vprofile")
: null;
var stereo = false;
if (getQueryStringValue("stereo") !== "")
stereo = getQueryStringValue("stereo") === "true";
var doDtx =
getQueryStringValue("dtx") === "yes" || getQueryStringValue("dtx") === "true";
var doOpusred =
getQueryStringValue("opusred") === "yes" ||
getQueryStringValue("opusred") === "true";
var simulcastStarted = false,
svcStarted = false;
// By default we talk to the "regular" EchoTest plugin
var echotestPluginBackend = "janus.plugin.echotest";
// We can use query string arguments to talk to the Lua or Duktape EchoTest
// demo scripts instead. Notice that this assumes that the Lua or Duktape
// plugins are configured to run the sample scripts that comes with the repo
if (getQueryStringValue("plugin") === "lua")
echotestPluginBackend = "janus.plugin.echolua";
else if (getQueryStringValue("plugin") === "duktape")
echotestPluginBackend = "janus.plugin.echojs";
$(document).ready(function () {
// Initialize the library (all console debuggers enabled)
Janus.init({
debug: "all",
callback: function () {
// Use a button to start the demo
$("#start").one("click", function () {
$(this).attr("disabled", true).unbind("click");
// Make sure the browser supports WebRTC
if (!Janus.isWebrtcSupported()) {
bootbox.alert("No WebRTC support... ");
return;
}
// Create session
janus = new Janus({
server: server,
iceServers: iceServers,
// Should the Janus API require authentication, you can specify either the API secret or user token here too
// token: "mytoken",
// or
// apisecret: "serversecret",
success: function () {
// Attach to EchoTest plugin
janus.attach({
plugin: echotestPluginBackend,
opaqueId: opaqueId,
success: function (pluginHandle) {
$("#details").remove();
echotest = pluginHandle;
Janus.log(
"Plugin attached! (" +
echotest.getPlugin() +
", id=" +
echotest.getId() +
")"
);
// Negotiate WebRTC
let body = { audio: true, video: true };
// We can try and force a specific codec, by telling the plugin what we'd prefer
// For simplicity, you can set it via a query string (e.g., ?vcodec=vp9)
if (acodec) body["audiocodec"] = acodec;
if (vcodec) body["videocodec"] = vcodec;
// For the codecs that support them (VP9 and H.264) you can specify a codec
// profile as well (e.g., ?vprofile=2 for VP9, or ?vprofile=42e01f for H.264)
if (vprofile) body["videoprofile"] = vprofile;
// We can force RED for audio too, if supported by the browser
if (doOpusred) body["opusred"] = true;
Janus.debug("Sending message:", body);
echotest.send({ message: body });
Janus.debug("Trying a createOffer too (audio/video sendrecv)");
echotest.createOffer({
// We want bidirectional audio and video, plus data channels
tracks: [
{ type: "audio", capture: true, recv: true },
{
type: "video",
capture: true,
recv: true,
// We may need to enable simulcast or SVC on the video track
simulcast: doSimulcast,
// We only support SVC for VP9 and (still WIP) AV1
svc:
(vcodec === "vp9" || vcodec === "av1") && doSvc
? doSvc
: null,
},
{ type: "data" },
],
customizeSdp: function (jsep) {
// If DTX is enabled, munge the SDP
if (doDtx) {
jsep.sdp = jsep.sdp.replace(
"useinbandfec=1",
"useinbandfec=1;usedtx=1"
);
}
if (stereo && jsep.sdp.indexOf("stereo=1") == -1) {
// Make sure that our offer contains stereo too
jsep.sdp = jsep.sdp.replace(
"useinbandfec=1",
"useinbandfec=1;stereo=1"
);
}
},
success: function (jsep) {
Janus.debug("Got SDP!", jsep);
echotest.send({ message: body, jsep: jsep });
// Create a spinner waiting for the remote video
$("#videoright").html(
'
' +
'
' +
' Loading...' +
"
" +
"
"
);
},
error: function (error) {
Janus.error("WebRTC error:", error);
bootbox.alert("WebRTC error... " + error.message);
},
});
$("#start")
.removeAttr("disabled")
.html("Stop")
.click(function () {
$(this).attr("disabled", true);
if (bitrateTimer) clearInterval(bitrateTimer);
bitrateTimer = null;
janus.destroy();
});
},
error: function (error) {
console.error(" -- Error attaching plugin...", error);
bootbox.alert("Error attaching plugin... " + error);
},
consentDialog: function (on) {
Janus.debug(
"Consent dialog should be " + (on ? "on" : "off") + " now"
);
if (on) {
// Darken screen and show hint
$.blockUI({
message: '
',
baseZ: 3001,
css: {
border: "none",
padding: "15px",
backgroundColor: "transparent",
color: "#aaa",
top: "10px",
left: "100px",
},
});
} else {
// Restore screen
$.unblockUI();
}
},
iceState: function (state) {
Janus.log("ICE state changed to " + state);
},
mediaState: function (medium, on, mid) {
Janus.log(
"Janus " +
(on ? "started" : "stopped") +
" receiving our " +
medium +
" (mid=" +
mid +
")"
);
},
webrtcState: function (on) {
Janus.log(
"Janus says our WebRTC PeerConnection is " +
(on ? "up" : "down") +
" now"
);
$("#videoleft").parent().unblock();
},
slowLink: function (uplink, lost, mid) {
Janus.warn(
"Janus reports problems " +
(uplink ? "sending" : "receiving") +
" packets on mid " +
mid +
" (" +
lost +
" lost packets)"
);
},
onmessage: function (msg, jsep) {
Janus.debug(" ::: Got a message :::", msg);
if (jsep) {
Janus.debug("Handling SDP as well...", jsep);
echotest.handleRemoteJsep({ jsep: jsep });
}
let result = msg["result"];
if (result) {
if (result === "done") {
// The plugin closed the echo test
bootbox.alert("The Echo Test is over");
$("video").remove();
$("#waitingvideo").remove();
$("#toggleaudio").attr("disabled", true);
$("#togglevideo").attr("disabled", true);
$("#bitrate").attr("disabled", true);
$("#curbitrate").addClass("hide");
$("#curres").addClass("hide");
return;
}
// Any loss?
let status = result["status"];
if (status === "slow_link") {
toastr.warning(
"Janus apparently missed many packets we sent, maybe we should reduce the bitrate",
"Packet loss?",
{ timeOut: 2000 }
);
}
}
// Is simulcast in place?
let substream = msg["substream"];
let temporal = msg["temporal"];
if (
(substream !== null && substream !== undefined) ||
(temporal !== null && temporal !== undefined)
) {
if (!simulcastStarted) {
simulcastStarted = true;
addSimulcastSvcButtons(
msg["videocodec"] === "vp8" ||
msg["videocodec"] === "vp9" ||
msg["videocodec"] === "av1"
);
}
// We just received notice that there's been a switch, update the buttons
updateSimulcastSvcButtons(substream, temporal);
}
// Or maybe SVC?
let spatial = msg["spatial_layer"];
temporal = msg["temporal_layer"];
if (
(spatial !== null && spatial !== undefined) ||
(temporal !== null && temporal !== undefined)
) {
if (!svcStarted) {
svcStarted = true;
addSimulcastSvcButtons(true);
}
// We just received notice that there's been a switch, update the buttons
updateSimulcastSvcButtons(spatial, temporal);
}
},
onlocaltrack: function (track, on) {
Janus.debug(
"Local track " + (on ? "added" : "removed") + ":",
track
);
// We use the track ID as name of the element, but it may contain invalid characters
let trackId = track.id.replace(/[{}]/g, "");
if (!on) {
// Track removed, get rid of the stream and the rendering
let stream = localTracks[trackId];
if (stream) {
try {
let tracks = stream.getTracks();
for (let i in tracks) {
let mst = tracks[i];
if (mst) mst.stop();
}
// eslint-disable-next-line no-unused-vars
} catch (e) {}
}
if (track.kind === "video") {
$("#myvideo" + trackId).remove();
localVideos--;
if (localVideos === 0) {
// No video, at least for now: show a placeholder
if ($("#videoleft .no-video-container").length === 0) {
$("#videoleft").append(
'
' +
'' +
'No webcam available' +
"
"
);
}
}
}
delete localTracks[trackId];
return;
}
// If we're here, a new track was added
let stream = localTracks[trackId];
if (stream) {
// We've been here already
return;
}
if ($("#videoleft video").length === 0) {
$("#videos").removeClass("hide");
}
if (track.kind === "audio") {
// We ignore local audio tracks, they'd generate echo anyway
if (localVideos === 0) {
// No video, at least for now: show a placeholder
if ($("#videoleft .no-video-container").length === 0) {
$("#videoleft").append(
'
' +
'' +
'No webcam available' +
"
"
);
}
}
} else {
// New video track: create a stream out of it
localVideos++;
$("#videoleft .no-video-container").remove();
let stream = new MediaStream([track]);
localTracks[trackId] = stream;
Janus.log("Created local stream:", stream);
$("#videoleft").append(
''
);
Janus.attachMediaStream(
$("#myvideo" + trackId).get(0),
stream
);
}
if (
echotest.webrtcStuff.pc.iceConnectionState !== "completed" &&
echotest.webrtcStuff.pc.iceConnectionState !== "connected"
) {
$("#videoleft")
.parent()
.block({
message: "Publishing...",
css: {
border: "none",
backgroundColor: "transparent",
color: "white",
},
});
}
},
onremotetrack: function (track, mid, on, metadata) {
Janus.debug(
"Remote track (mid=" +
mid +
") " +
(on ? "added" : "removed") +
(metadata ? " (" + metadata.reason + ") " : "") +
":",
track
);
if (!on) {
// Track removed, get rid of the stream and the rendering
$("#peervideo" + mid).remove();
if (track.kind === "video") {
remoteVideos--;
if (remoteVideos === 0) {
// No video, at least for now: show a placeholder
if ($("#videoright .no-video-container").length === 0) {
$("#videoright").append(
'
' +
'' +
'No remote video available' +
"
"
);
}
}
}
delete remoteTracks[mid];
return;
}
// If we're here, a new track was added
$("#spinner").remove();
let addButtons = false;
if (
$("#videoright audio").length === 0 &&
$("#videoright video").length === 0
) {
addButtons = true;
$("#videos").removeClass("hide");
}
if (track.kind === "audio") {
// New audio track: create a stream out of it, and use a hidden