// 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 acodec =
  getQueryStringValue("acodec") !== "" ? getQueryStringValue("acodec") : null;
var vcodec =
  getQueryStringValue("vcodec") !== "" ? getQueryStringValue("vcodec") : null;
var simulcastStarted = false;

$(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;
        }
        // Make sure Insertable Streams are supported too
        if (
          !RTCRtpSender.prototype.createEncodedStreams &&
          !RTCRtpSender.prototype.createEncodedAudioStreams &&
          !RTCRtpSender.prototype.createEncodedVideoStreams
        ) {
          bootbox.alert("Insertable Streams not supported by this browser... ");
          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() +
                    ")"
                );
                $("#start")
                  .removeAttr("disabled")
                  .html("Stop")
                  .click(function () {
                    $(this).attr("disabled", true);
                    if (bitrateTimer) clearInterval(bitrateTimer);
                    bitrateTimer = null;
                    janus.destroy();
                  });
                // Before starting, we prompt for a secret
                promptCryptoKey();
              },
              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: '<div><img src="up_arrow.png"/></div>',
                    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 !== undefined && jsep !== null) {
                  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") {
                    //~ let bitrate = result["bitrate"];
                    //~ toastr.warning("The bitrate has been cut to " + (bitrate/1000) + "kbps", "Packet loss?", {timeOut: 2000});
                    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) {
                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(
                          '<div class="no-video-container">' +
                            '<i class="fa-solid fa-video fa-xl no-video-icon"></i>' +
                            '<span class="no-video-text">No webcam available</span>' +
                            "</div>"
                        );
                      }
                    }
                  }
                  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(
                        '<div class="no-video-container">' +
                          '<i class="fa-solid fa-video fa-xl no-video-icon"></i>' +
                          '<span class="no-video-text">No webcam available</span>' +
                          "</div>"
                      );
                    }
                  }
                } 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(
                    '<video class="rounded centered" id="myvideo' +
                      trackId +
                      '" width="100%" height="100%" autoplay playsinline muted="muted"/>'
                  );
                  Janus.attachMediaStream(
                    $("#myvideo" + trackId).get(0),
                    stream
                  );
                }
                if (
                  echotest.webrtcStuff.pc.iceConnectionState !== "completed" &&
                  echotest.webrtcStuff.pc.iceConnectionState !== "connected"
                ) {
                  $("#videoleft")
                    .parent()
                    .block({
                      message: "<b>Publishing...</b>",
                      css: {
                        border: "none",
                        backgroundColor: "transparent",
                        color: "white",
                      },
                    });
                }
              },
              onremotetrack: function (track, mid, on) {
                Janus.debug(
                  "Remote track (mid=" +
                    mid +
                    ") " +
                    (on ? "added" : "removed") +
                    ":",
                  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(
                          '<div class="no-video-container">' +
                            '<i class="fa-solid fa-video fa-xl no-video-icon"></i>' +
                            '<span class="no-video-text">No remote video available</span>' +
                            "</div>"
                        );
                      }
                    }
                  }
                  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 <audio> element
                  let stream = new MediaStream([track]);
                  remoteTracks[mid] = stream;
                  Janus.log("Created remote audio stream:", stream);
                  if ($("#peervideo" + mid).length === 0)
                    $("#videoright").append(
                      '<audio class="hide" id="peervideo' +
                        mid +
                        '" autoplay playsinline/>'
                    );
                  Janus.attachMediaStream($("#peervideo" + mid).get(0), stream);
                  if (remoteVideos === 0) {
                    // No video, at least for now: show a placeholder
                    if ($("#videoright .no-video-container").length === 0) {
                      $("#videoright").append(
                        '<div class="no-video-container">' +
                          '<i class="fa-solid fa-video fa-xl no-video-icon"></i>' +
                          '<span class="no-video-text">No webcam available</span>' +
                          "</div>"
                      );
                    }
                  }
                } else {
                  // New video track: create a stream out of it
                  remoteVideos++;
                  $("#videoright .no-video-container").remove();
                  let stream = new MediaStream([track]);
                  remoteTracks[mid] = stream;
                  Janus.log("Created remote video stream:", stream);
                  if ($("#peervideo" + mid).length === 0)
                    $("#videoright").append(
                      '<video class="rounded centered" id="peervideo' +
                        mid +
                        '" width="100%" height="100%" autoplay playsinline/>'
                    );
                  Janus.attachMediaStream($("#peervideo" + mid).get(0), stream);
                  // FIXME we'll need this for additional videos too
                  if (!bitrateTimer) {
                    $("#curbitrate").removeClass("hide");
                    bitrateTimer = setInterval(function () {
                      if (!$("#peervideo" + mid).get(0)) return;
                      // Display updated bitrate, if supported
                      let bitrate = echotest.getBitrate();
                      //~ Janus.debug("Current bitrate is " + echotest.getBitrate());
                      $("#curbitrate").text(bitrate);
                      // Check if the resolution changed too
                      let width = $("#peervideo" + mid).get(0).videoWidth;
                      let height = $("#peervideo" + mid).get(0).videoHeight;
                      if (width > 0 && height > 0)
                        $("#curres")
                          .removeClass("hide")
                          .text(width + "x" + height)
                          .removeClass("hide");
                    }, 1000);
                  }
                }
                if (!addButtons) return;
                // Enable audio/video buttons and bitrate limiter
                audioenabled = true;
                videoenabled = true;
                $("#toggleaudio").click(function () {
                  audioenabled = !audioenabled;
                  if (audioenabled)
                    $("#toggleaudio")
                      .html("Disable audio")
                      .removeClass("btn-success")
                      .addClass("btn-danger");
                  else
                    $("#toggleaudio")
                      .html("Enable audio")
                      .removeClass("btn-danger")
                      .addClass("btn-success");
                  echotest.send({ message: { audio: audioenabled } });
                });
                $("#togglevideo").click(function () {
                  videoenabled = !videoenabled;
                  if (videoenabled)
                    $("#togglevideo")
                      .html("Disable video")
                      .removeClass("btn-success")
                      .addClass("btn-danger");
                  else
                    $("#togglevideo")
                      .html("Enable video")
                      .removeClass("btn-danger")
                      .addClass("btn-success");
                  echotest.send({ message: { video: videoenabled } });
                });
                $("#toggleaudio").parent().removeClass("hide");
                $("#bitrate a").click(function () {
                  $(".dropdown-toggle").dropdown("hide");
                  let id = $(this).attr("id");
                  let bitrate = parseInt(id) * 1000;
                  if (bitrate === 0) {
                    Janus.log("Not limiting bandwidth via REMB");
                  } else {
                    Janus.log("Capping bandwidth to " + bitrate + " via REMB");
                  }
                  $("#bitrateset")
                    .text($(this).text())
                    .parent()
                    .removeClass("open");
                  echotest.send({ message: { bitrate: bitrate } });
                  return false;
                });
              },
              // eslint-disable-next-line no-unused-vars
              ondataopen: function (label, protocol) {
                Janus.log("The DataChannel is available!");
                $("#videos").removeClass("hide");
                $("#datasend").removeAttr("disabled");
              },
              ondata: function (data) {
                Janus.debug("We got data from the DataChannel!", data);
                $("#datarecv").val(data);
              },
              oncleanup: function () {
                Janus.log(" ::: Got a cleanup notification :::");
                if (bitrateTimer) clearInterval(bitrateTimer);
                bitrateTimer = null;
                $("video").remove();
                $("#waitingvideo").remove();
                $("#videoleft").empty().parent().unblock();
                $("#videoright").empty();
                $("#toggleaudio").attr("disabled", true);
                $("#togglevideo").attr("disabled", true);
                $("#bitrate").attr("disabled", true);
                $("#curbitrate").addClass("hide");
                $("#curres").addClass("hide");
                $("#datasend").attr("disabled", true);
                simulcastStarted = false;
                $("#simulcast").remove();
                localTracks = {};
                localVideos = 0;
                remoteTracks = {};
                remoteVideos = 0;
              },
            });
          },
          error: function (error) {
            Janus.error(error);
            bootbox.alert(error, function () {
              window.location.reload();
            });
          },
          destroyed: function () {
            window.location.reload();
          },
        });
      });
    },
  });
});

// eslint-disable-next-line no-unused-vars
function checkEnter(event) {
  let theCode = event.keyCode
    ? event.keyCode
    : event.which
    ? event.which
    : event.charCode;
  if (theCode == 13) {
    sendData();
    return false;
  } else {
    return true;
  }
}

function sendData() {
  let data = $("#datasend").val();
  if (data === "") {
    bootbox.alert("Insert a message to send on the DataChannel");
    return;
  }
  echotest.data({
    text: data,
    error: function (reason) {
      bootbox.alert(reason);
    },
    success: function () {
      $("#datasend").val("");
    },
  });
}

// Helper to parse query string
function getQueryStringValue(name) {
  name = name.replace(/[[]/, "\\[").replace(/[\]]/, "\\]");
  let regex = new RegExp("[\\?&]" + name + "=([^&#]*)"),
    results = regex.exec(location.search);
  return results === null
    ? ""
    : decodeURIComponent(results[1].replace(/\+/g, " "));
}

// Helpers to create Simulcast-related UI, if enabled
function addSimulcastButtons(temporal) {
  $("#curres")
    .parent()
    .append(
      '<div id="simulcast" class="btn-group-vertical btn-group-xs top-right">' +
        '	<div class="btn-group btn-group-xs d-flex" style="width: 100%">' +
        '		<button id="sl-2" type="button" class="btn btn-primary" data-bs-toggle="tooltip" title="Switch to higher quality">SL 2</button>' +
        '		<button id="sl-1" type="button" class="btn btn-primary" data-bs-toggle="tooltip" title="Switch to normal quality">SL 1</button>' +
        '		<button id="sl-0" type="button" class="btn btn-primary" data-bs-toggle="tooltip" title="Switch to lower quality">SL 0</button>' +
        "	</div>" +
        '	<div class="btn-group btn-group-xs d-flex hide" style="width: 100%">' +
        '		<button id="tl-2" type="button" class="btn btn-primary" data-bs-toggle="tooltip" title="Cap to temporal layer 2">TL 2</button>' +
        '		<button id="tl-1" type="button" class="btn btn-primary" data-bs-toggle="tooltip" title="Cap to temporal layer 1">TL 1</button>' +
        '		<button id="tl-0" type="button" class="btn btn-primary" data-bs-toggle="tooltip" title="Cap to temporal layer 0">TL 0</button>' +
        "	</div>" +
        "</div>"
    );
  if (Janus.webRTCAdapter.browserDetails.browser !== "firefox") {
    // Chromium-based browsers only have two temporal layers
    $("#tl-2").remove();
  }
  // Enable the simulcast selection buttons
  $("#sl-0")
    .removeClass("btn-primary btn-success")
    .addClass("btn-primary")
    .unbind("click")
    .click(function () {
      toastr.info(
        "Switching simulcast substream, wait for it... (lower quality)",
        null,
        { timeOut: 2000 }
      );
      if (!$("#sl-2").hasClass("btn-success"))
        $("#sl-2").removeClass("btn-primary btn-info").addClass("btn-primary");
      if (!$("#sl-1").hasClass("btn-success"))
        $("#sl-1").removeClass("btn-primary btn-info").addClass("btn-primary");
      $("#sl-0")
        .removeClass("btn-primary btn-info btn-success")
        .addClass("btn-info");
      echotest.send({ message: { substream: 0 } });
    });
  $("#sl-1")
    .removeClass("btn-primary btn-success")
    .addClass("btn-primary")
    .unbind("click")
    .click(function () {
      toastr.info(
        "Switching simulcast substream, wait for it... (normal quality)",
        null,
        { timeOut: 2000 }
      );
      if (!$("#sl-2").hasClass("btn-success"))
        $("#sl-2").removeClass("btn-primary btn-info").addClass("btn-primary");
      $("#sl-1")
        .removeClass("btn-primary btn-info btn-success")
        .addClass("btn-info");
      if (!$("#sl-0").hasClass("btn-success"))
        $("#sl-0").removeClass("btn-primary btn-info").addClass("btn-primary");
      echotest.send({ message: { substream: 1 } });
    });
  $("#sl-2")
    .removeClass("btn-primary btn-success")
    .addClass("btn-primary")
    .unbind("click")
    .click(function () {
      toastr.info(
        "Switching simulcast substream, wait for it... (higher quality)",
        null,
        { timeOut: 2000 }
      );
      $("#sl-2")
        .removeClass("btn-primary btn-info btn-success")
        .addClass("btn-info");
      if (!$("#sl-1").hasClass("btn-success"))
        $("#sl-1").removeClass("btn-primary btn-info").addClass("btn-primary");
      if (!$("#sl-0").hasClass("btn-success"))
        $("#sl-0").removeClass("btn-primary btn-info").addClass("btn-primary");
      echotest.send({ message: { substream: 2 } });
    });
  if (!temporal)
    // No temporal layer support
    return;
  $("#tl-0").parent().removeClass("hide");
  $("#tl-0")
    .removeClass("btn-primary btn-success")
    .addClass("btn-primary")
    .unbind("click")
    .click(function () {
      toastr.info(
        "Capping simulcast temporal layer, wait for it... (lowest FPS)",
        null,
        { timeOut: 2000 }
      );
      if (!$("#tl-2").hasClass("btn-success"))
        $("#tl-2").removeClass("btn-primary btn-info").addClass("btn-primary");
      if (!$("#tl-1").hasClass("btn-success"))
        $("#tl-1").removeClass("btn-primary btn-info").addClass("btn-primary");
      $("#tl-0")
        .removeClass("btn-primary btn-info btn-success")
        .addClass("btn-info");
      echotest.send({ message: { temporal: 0 } });
    });
  $("#tl-1")
    .removeClass("btn-primary btn-success")
    .addClass("btn-primary")
    .unbind("click")
    .click(function () {
      toastr.info(
        "Capping simulcast temporal layer, wait for it... (medium FPS)",
        null,
        { timeOut: 2000 }
      );
      if (!$("#tl-2").hasClass("btn-success"))
        $("#tl-2").removeClass("btn-primary btn-info").addClass("btn-primary");
      $("#tl-1").removeClass("btn-primary btn-info").addClass("btn-info");
      if (!$("#tl-0").hasClass("btn-success"))
        $("#tl-0").removeClass("btn-primary btn-info").addClass("btn-primary");
      echotest.send({ message: { temporal: 1 } });
    });
  $("#tl-2")
    .removeClass("btn-primary btn-success")
    .addClass("btn-primary")
    .unbind("click")
    .click(function () {
      toastr.info(
        "Capping simulcast temporal layer, wait for it... (highest FPS)",
        null,
        { timeOut: 2000 }
      );
      $("#tl-2")
        .removeClass("btn-primary btn-info btn-success")
        .addClass("btn-info");
      if (!$("#tl-1").hasClass("btn-success"))
        $("#tl-1").removeClass("btn-primary btn-info").addClass("btn-primary");
      if (!$("#tl-0").hasClass("btn-success"))
        $("#tl-0").removeClass("btn-primary btn-info").addClass("btn-primary");
      echotest.send({ message: { temporal: 2 } });
    });
}

function updateSimulcastButtons(substream, temporal) {
  // Check the substream
  if (substream === 0) {
    toastr.success("Switched simulcast substream! (lower quality)", null, {
      timeOut: 2000,
    });
    $("#sl-2").removeClass("btn-primary btn-success").addClass("btn-primary");
    $("#sl-1").removeClass("btn-primary btn-success").addClass("btn-primary");
    $("#sl-0")
      .removeClass("btn-primary btn-info btn-success")
      .addClass("btn-success");
  } else if (substream === 1) {
    toastr.success("Switched simulcast substream! (normal quality)", null, {
      timeOut: 2000,
    });
    $("#sl-2").removeClass("btn-primary btn-success").addClass("btn-primary");
    $("#sl-1")
      .removeClass("btn-primary btn-info btn-success")
      .addClass("btn-success");
    $("#sl-0").removeClass("btn-primary btn-success").addClass("btn-primary");
  } else if (substream === 2) {
    toastr.success("Switched simulcast substream! (higher quality)", null, {
      timeOut: 2000,
    });
    $("#sl-2")
      .removeClass("btn-primary btn-info btn-success")
      .addClass("btn-success");
    $("#sl-1").removeClass("btn-primary btn-success").addClass("btn-primary");
    $("#sl-0").removeClass("btn-primary btn-success").addClass("btn-primary");
  }
  // Check the temporal layer
  if (temporal === 0) {
    toastr.success("Capped simulcast temporal layer! (lowest FPS)", null, {
      timeOut: 2000,
    });
    $("#tl-2").removeClass("btn-primary btn-success").addClass("btn-primary");
    $("#tl-1").removeClass("btn-primary btn-success").addClass("btn-primary");
    $("#tl-0")
      .removeClass("btn-primary btn-info btn-success")
      .addClass("btn-success");
  } else if (temporal === 1) {
    toastr.success("Capped simulcast temporal layer! (medium FPS)", null, {
      timeOut: 2000,
    });
    $("#tl-2").removeClass("btn-primary btn-success").addClass("btn-primary");
    $("#tl-1")
      .removeClass("btn-primary btn-info btn-success")
      .addClass("btn-success");
    $("#tl-0").removeClass("btn-primary btn-success").addClass("btn-primary");
  } else if (temporal === 2) {
    toastr.success("Capped simulcast temporal layer! (highest FPS)", null, {
      timeOut: 2000,
    });
    $("#tl-2")
      .removeClass("btn-primary btn-info btn-success")
      .addClass("btn-success");
    $("#tl-1").removeClass("btn-primary btn-success").addClass("btn-primary");
    $("#tl-0").removeClass("btn-primary btn-success").addClass("btn-primary");
  }
}

// Custom functions to use with Insertable streams: the senderTransform
// function is what we use to "encrypt" the media we send, while the
// receiverTransform is what we use to "decrypt" the media we receive.
// Both functions will use a secret that we'll prompt for when opening
// the page, meaning that, ideally, we'll be the only one able to decrypt
// it: Janus will not have access to the media. In a scenario involving
// multiple participants (e.g., a video call or conference), to use these
// same functions you'll want to distribute the secret among all participants
// using an out of band mechanism, so that they can encrypt and decrypt
// the media and keep Janus out of the loop. Notice that these functions
// are just an example, and are basically exact copies from this demo:
// 		https://github.com/webrtc/samples/blob/gh-pages/src/content/peerconnection/endtoend-encryption/js/main.js
// That said, you're free (or actually, encouraged) to try and use other
// custom, and more advanced, transform functions as well (e.g., SFrames).
var currentCryptoKey = null;
var currentKeyIdentifier = 0;
function promptCryptoKey() {
  bootbox.prompt(
    "Insert crypto key (e.g., 'mysecret') to use",
    function (result) {
      if (!result || result === "") {
        promptCryptoKey();
        return;
      }
      // Take note of the secret
      currentCryptoKey = result;
      currentKeyIdentifier++;
      // Negotiate the WebRTC PeerConnection, now (clone of EchoTest demo code)
      Janus.debug("Trying a createOffer too (audio/video sendrecv)");
      echotest.createOffer({
        // We want bidirectional audio and video, plus data channels,
        // and since we want to use Insertable Streams as well, we
        // specify the transform functions to use for audio and video
        tracks: [
          {
            type: "audio",
            capture: true,
            recv: true,
            transforms: {
              sender: senderTransforms["audio"],
              receiver: receiverTransforms["audio"],
            },
          },
          {
            type: "video",
            capture: true,
            recv: true,
            simulcast: doSimulcast,
            transforms: {
              sender: senderTransforms["video"],
              receiver: receiverTransforms["video"],
            },
          },
          { type: "data" },
        ],
        success: function (jsep) {
          Janus.debug("Got SDP!", jsep);
          let body = { audio: true, video: true, data: 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;
          echotest.send({ message: body, jsep: jsep });
          // Create a spinner waiting for the remote video
          $("#videoright").html(
            '<div class="text-center">' +
              '	<div id="spinner" class="spinner-border" role="status">' +
              '		<span class="visually-hidden">Loading...</span>' +
              "	</div>" +
              "</div>"
          );
        },
        error: function (error) {
          Janus.error("WebRTC error:", error);
          bootbox.alert("WebRTC error... " + error.message);
        },
      });
    }
  );
}
var senderTransforms = {},
  receiverTransforms = {};
for (var m of ["audio", "video"]) {
  senderTransforms[m] = new TransformStream({
    start() {
      // Called on startup.
      console.log("[Sender transform)] Startup");
    },
    transform(chunk, controller) {
      // Copy of the above mentioned demo's encodeFunction()
      const view = new DataView(chunk.data);
      const newData = new ArrayBuffer(chunk.data.byteLength + 5);
      const newView = new DataView(newData);
      for (let i = 0; i < 10; ++i) {
        newView.setInt8(i, view.getInt8(i));
      }
      // This is a bitwise xor of the key with the payload. This is not strong encryption, just a demo.
      for (let i = 10; i < chunk.data.byteLength; ++i) {
        const keyByte = currentCryptoKey.charCodeAt(
          i % currentCryptoKey.length
        );
        newView.setInt8(i, view.getInt8(i) ^ keyByte);
      }
      newView.setUint8(chunk.data.byteLength, currentKeyIdentifier % 0xff);
      newView.setUint32(chunk.data.byteLength + 1, 0xdeadbeef);
      chunk.data = newData;
      controller.enqueue(chunk);
    },
    flush() {
      // Called when the stream is about to be closed
      console.log("[Sender transform] Closing");
    },
  });
  receiverTransforms[m] = new TransformStream({
    start() {
      // Called on startup.
      console.log("[Receiver transform] Startup");
    },
    transform(chunk, controller) {
      // Copy of the above mentioned demo's decodeFunction()
      const view = new DataView(chunk.data);
      const checksum = view.getUint32(chunk.data.byteLength - 4);
      if (checksum !== 0xdeadbeef) {
        console.log("Corrupted frame received");
        console.log(checksum.toString(16));
        return;
      }
      const keyIdentifier = view.getUint8(chunk.data.byteLength - 5);
      if (keyIdentifier !== currentKeyIdentifier) {
        console.log(
          `Key identifier mismatch, got ${keyIdentifier} expected ${currentKeyIdentifier}.`
        );
        return;
      }
      const newData = new ArrayBuffer(chunk.data.byteLength - 5);
      const newView = new DataView(newData);
      for (let i = 0; i < 10; ++i) {
        newView.setInt8(i, view.getInt8(i));
      }
      for (let i = 10; i < chunk.data.byteLength - 5; ++i) {
        const keyByte = currentCryptoKey.charCodeAt(
          i % currentCryptoKey.length
        );
        newView.setInt8(i, view.getInt8(i) ^ keyByte);
      }
      chunk.data = newData;
      controller.enqueue(chunk);
    },
    flush() {
      // Called when the stream is about to be closed
      console.log("[Receiver transform] Closing");
    },
  });
}