/*! Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. SPDX-License-Identifier: Apache-2.0 */

(function () {
  const {
    Stage,
    StageEvents,
    SubscribeType,
    JitterBufferMinDelay
  } = IVSBroadcastClient;

  const formEl = document.querySelector("form");
  const inputEl = document.querySelector("input");
  const videoEl = document.querySelector("video");
  const spanEl = document.querySelector("span");
  const muteButton = document.getElementById("mute-toggle");
  let joinAttemptTimestamp = null;
  let stage = null;

  muteButton.addEventListener("click", () => {
    if (videoEl.muted) {
      videoEl.muted = false;
      muteButton.textContent = "Mute";
    } else {
      videoEl.muted = true;
      muteButton.textContent = "Unmute";
    }
  });

  videoEl.addEventListener("loadeddata", (e) => {
    const ttv = performance.now() - joinAttemptTimestamp;
    spanEl.textContent = ttv.toFixed(2);
  });

  formEl.addEventListener("submit", async (e) => {
    e.preventDefault();

    const strategy = {
      // Increases the jitter buffer to improve playback stability.
      // See "Changing Subscriber Jitter Buffer MinDelay":
      // https://docs.aws.amazon.com/ivs/latest/RealTimeUserGuide/real-time-streaming-optimization.html#real-time-streaming-configurations
      subscribeConfiguration: (participant) => {
        return {
          jitterBuffer: {
            minDelay: JitterBufferMinDelay.MEDIUM
          }
        };
      },

      stageStreamsToPublish() {
        return [];
      },

      shouldPublishParticipant() {
        return false;
      },

      shouldSubscribeToParticipant(participant) {
        return SubscribeType.AUDIO_VIDEO;
      }
    };

    if (stage) {
      await stage.leave();
    }

    const token = inputEl.value;
    stage = new Stage(token, strategy);

    stage.on(
      StageEvents.STAGE_PARTICIPANT_STREAMS_ADDED,
      (participant, streams) => {
        videoEl.srcObject = new MediaStream();
        streams.forEach((stream) => {
          videoEl.srcObject.addTrack(stream.mediaStreamTrack);
        });
      }
    );

    try {
      joinAttemptTimestamp = performance.now();
      await stage.join();
    } catch (error) {
      console.log(error);
    }
  });
})();