// 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( '