/// <reference lib="dom" />

import { log } from "../logger.ts";
import { on_pref_changed, PREFS } from "../preferences/mod.ts";
import { RemoteUser } from "./remote.ts";
import { get_rnnoise_node } from "../rnnoise.ts";
import { Room } from "../room.ts";
import { TrackHandle } from "../track_handle.ts";
import { User } from "./mod.ts";
import { ROOM_CONTAINER } from "../index.ts";
import { ediv } from "../helper.ts";
import { ChatMessage } from "../../../common/packets.d.ts";

export class LocalUser extends User {

    constructor(room: Room, id: number) {
        super(room, id)
        this.el.classList.add("local")
        this.local = true
        this.name = PREFS.username
        this.create_controls()
        this.add_initial_tracks()
        log("usermodel", `added local user: ${this.display_name}`)
    }
    leave() { // we might never need this but ok
        this.room.local_user = undefined as unknown as LocalUser
        super.leave()
        ROOM_CONTAINER.removeChild(this.el)
    }

    add_initial_tracks() {
        if (PREFS.microphone_enabled) this.publish_track(this.create_mic_track())
        if (PREFS.camera_enabled) this.publish_track(this.create_camera_track())
        if (PREFS.screencast_enabled) this.publish_track(this.create_screencast_track())
    }

    chat(message: ChatMessage) {
        this.room.signaling.send_relay({ chat: message })
    }

    add_initial_to_remote(u: RemoteUser) {
        this.tracks.forEach(t => u.peer.addTrack(t.track))
    }
    identify(recipient?: number) {
        if (this.name) this.room.signaling.send_relay({ identify: { username: this.name } }, recipient)
    }

    create_controls() {
        const mic_toggle = document.createElement("input")
        const camera_toggle = document.createElement("input")
        const screen_toggle = document.createElement("input")
        mic_toggle.type = camera_toggle.type = screen_toggle.type = "button"
        mic_toggle.value = "Microphone"
        camera_toggle.value = "Camera"
        screen_toggle.value = "Screencast"
        mic_toggle.addEventListener("click", () => this.publish_track(this.create_mic_track()))
        camera_toggle.addEventListener("click", () => this.publish_track(this.create_camera_track()))
        screen_toggle.addEventListener("click", () => this.publish_track(this.create_screencast_track()))
        return ediv({ class: "local-controls" }, mic_toggle, camera_toggle, screen_toggle)
    }
    async publish_track(tp: Promise<TrackHandle>) {
        log("media", "awaiting track")
        let t!: TrackHandle;
        try { t = await tp }
        catch (_) { log("media", "request failed") }
        if (!t) return
        log("media", "got track")

        this.room.remote_users.forEach(u => u.peer.addTrack(t.track))
        this.add_track(t)
        t.addEventListener("ended", () => {
            this.room.remote_users.forEach(u => {
                u.peer.getSenders().forEach(s => {
                    if (s.track == t.track) u.peer.removeTrack(s)
                })
            })
        })
    }

    async create_camera_track() {
        log("media", "requesting user media (camera)")
        const user_media = await window.navigator.mediaDevices.getUserMedia({
            video: {
                facingMode: { ideal: PREFS.camera_facing_mode },
                frameRate: { ideal: PREFS.video_fps },
                width: { ideal: PREFS.video_resolution }
            }
        })
        return new TrackHandle(user_media.getVideoTracks()[0], true)
    }

    async create_screencast_track() {
        log("media", "requesting user media (screen)")
        const user_media = await window.navigator.mediaDevices.getDisplayMedia({
            video: {
                frameRate: { ideal: PREFS.video_fps },
                width: { ideal: PREFS.video_resolution }
            },
        })
        return new TrackHandle(user_media.getVideoTracks()[0], true)
    }

    async create_mic_track() {
        log("media", "requesting user media (audio)")
        const user_media = await window.navigator.mediaDevices.getUserMedia({
            audio: {
                channelCount: { ideal: 1 },
                noiseSuppression: { ideal: PREFS.rnnoise ? false : PREFS.native_noise_suppression },
                echoCancellation: { ideal: PREFS.echo_cancellation },
                autoGainControl: { ideal: PREFS.auto_gain_control },
            }
        })
        const context = new AudioContext()
        const source = context.createMediaStreamSource(user_media)
        const destination = context.createMediaStreamDestination()
        const gain = context.createGain()
        gain.gain.value = PREFS.microphone_gain
        const clear_gain_cb = on_pref_changed("microphone_gain", () => gain.gain.value = PREFS.microphone_gain)

        let rnnoise: RNNoiseNode;
        if (PREFS.rnnoise) {
            rnnoise = await get_rnnoise_node(context)
            source.connect(rnnoise)
            rnnoise.connect(gain)
        } else {
            source.connect(gain)
        }
        gain.connect(destination)

        const t = new TrackHandle(destination.stream.getAudioTracks()[0], true)
        t.addEventListener("ended", () => {
            user_media.getTracks().forEach(t => t.stop())
            source.disconnect()
            if (rnnoise) rnnoise.disconnect()
            gain.disconnect()
            clear_gain_cb()
            destination.disconnect()
        })
        return t
    }
}