import {
  AudioVideoFacade,
  AudioVideoObserver,
  ConsoleLogger,
  DefaultDeviceController,
  DefaultMeetingSession,
  LogLevel,
  MeetingSessionConfiguration,
} from "amazon-chime-sdk-js";

const BASE_URL = [
  location.protocol,
  "//",
  location.host,
  location.pathname.replace(/\/*$/, "/"),
].join("");

class MeetingManager {
  private meetingSession: DefaultMeetingSession;
  private audioVideo: AudioVideoFacade;
  private title: string;

  async initializeMeetingSession(
    configuration: MeetingSessionConfiguration
  ): Promise<any> {
    const logger = new ConsoleLogger("DEV-SDK", LogLevel.INFO);
    const deviceController = new DefaultDeviceController(logger);
    this.meetingSession = new DefaultMeetingSession(
      configuration,
      logger,
      deviceController
    );
    this.audioVideo = this.meetingSession.audioVideo;

    await this.setupAudioDevices();
  }

  async setupAudioDevices(): Promise<void> {
    const audioOutput = await this.audioVideo.listAudioOutputDevices();
    const defaultOutput = audioOutput[0] && audioOutput[0].deviceId;
    await this.audioVideo.chooseAudioOutput(defaultOutput);

    const audioInput = await this.audioVideo.listAudioInputDevices();
    const defaultInput = audioInput[0] && audioInput[0].deviceId;
    await this.audioVideo.startAudioInput(defaultInput);
  }

  addAudioVideoObserver(observer: AudioVideoObserver): void {
    this.ensureAudioVideo();
    this.audioVideo.addObserver(observer);
  }

  removeMediaObserver(observer: AudioVideoObserver): void {
    this.ensureAudioVideo();
    this.audioVideo.removeObserver(observer);
  }

  bindVideoTile(id: number, videoEl: HTMLVideoElement): void {
    this.audioVideo.bindVideoElement(id, videoEl);
  }

  async startLocalVideo(): Promise<void> {
    const videoInput = await this.audioVideo.listVideoInputDevices();
    const defaultVideo = videoInput[0];
    await this.audioVideo.startVideoInput(defaultVideo);
    this.audioVideo.startLocalVideoTile();
  }

  async stopLocalVideo(): Promise<void> {
    this.audioVideo.stopLocalVideoTile();
    await this.audioVideo.stopVideoInput();
  }

  async joinMeeting(meetingId: string, name: string): Promise<any> {
    const url = `${BASE_URL}join?title=${encodeURIComponent(
      meetingId
    )}&name=${encodeURIComponent(name)}`;
    const res = await fetch(url, { method: "POST" });
    const data = await res.json();
    this.title = meetingId;
    await this.initializeMeetingSession(
      new MeetingSessionConfiguration(
        data.JoinInfo.Meeting,
        data.JoinInfo.Attendee
      )
    );
    this.audioVideo.start();
  }

  async endMeeting(): Promise<any> {
    await fetch(`${BASE_URL}end?title=${encodeURIComponent(this.title)}`, {
      method: "POST",
    });
    await this.leaveMeeting();
  }

  async leaveMeeting(): Promise<void> {
    this.meetingSession.deviceController.destroy();
    this.audioVideo.stop();
  }

  async getAttendee(attendeeId: string): Promise<string> {
    const response = await fetch(
      `${BASE_URL}attendee?title=${encodeURIComponent(
        this.title
      )}&attendee=${encodeURIComponent(attendeeId)}`
    );
    const json = await response.json();
    return json.AttendeeInfo.Name;
  }

  bindAudioElement(ref: HTMLAudioElement) {
    this.audioVideo.bindAudioElement(ref);
  }

  unbindAudioElement(): void {
    this.audioVideo.stopAudioInput();
    this.audioVideo.unbindAudioElement();
  }

  private ensureAudioVideo() {
    if (!this.audioVideo) {
      console.error("AudioVideo not initialized. Cannot add observer");
      return;
    }
  }
}

export default new MeetingManager();