// 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 */ /* global SelfieSegmentation:readonly */ var janus = null; var echotest = null; var opaqueId = "canvas-" + Janus.randomString(12); var localTracks = {}, localVideos = 0, remoteTracks = {}, remoteVideos = 0; var bitrateTimer = null; var doSimulcast = getQueryStringValue("simulcast") === "yes" || getQueryStringValue("simulcast") === "true"; var acodec = getQueryStringValue("acodec") !== "" ? getQueryStringValue("acodec") : null; var vcodec = getQueryStringValue("vcodec") !== "" ? getQueryStringValue("vcodec") : null; var vprofile = getQueryStringValue("vprofile") !== "" ? getQueryStringValue("vprofile") : null; var simulcastStarted = false; // Canvas object var canvas = null; var context = null; var canvasStream = null; var width = doSimulcast ? 1280 : 640, height = doSimulcast ? 720 : 360; // We can use a few different images as our virtual background var bg = "synthwave"; var images = { synthwave: "./background/retro.webp", office: "./background/office.jpeg", brickwall: "./background/brick-wall.jpeg", }; const image = new Image(); image.src = images[bg]; $(document).ready(function () { canvas = document.getElementById("canvas"); context = canvas.getContext("2d"); // 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: "janus.plugin.echotest", opaqueId: opaqueId, success: function (pluginHandle) { $("#details").remove(); echotest = pluginHandle; Janus.log( "Plugin attached! (" + echotest.getPlugin() + ", id=" + echotest.getId() + ")" ); // We're connected to the plugin, create and populate the canvas element createCanvas(); $("#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(); $("#peervideo").remove(); $("#background").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; addSimulcastButtons(msg["videocodec"] === "vp8"); } // We just received notice that there's been a switch, update the buttons updateSimulcastButtons(substream, temporal); } }, onlocaltrack: function (track, on) { // 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(); stream = new MediaStream([track]); localTracks[trackId] = stream; Janus.log("Created local stream:", stream); $("#videoleft").append( '