import { Room, ExternalE2EEKeyProvider } from "livekit-client";
import { VoiceSession, liveKitAdapter } from "talos-fluxer/voice";

const adapter = liveKitAdapter(() => new Room(), {
  audioOutput: document.querySelector<HTMLElement>("#voice-audio")!,
  encryption: () => {
    const keyProvider = new ExternalE2EEKeyProvider();
    const worker = new Worker(
      new URL("livekit-client/e2ee-worker", import.meta.url),
      { type: "module" },
    );
    try {
      return {
        room: new Room({ encryption: { keyProvider, worker } }),
        keyProvider,
        dispose: () => worker.terminate(),
      };
    } catch (error) {
      worker.terminate();
      throw error;
    }
  },
});

const voice = await VoiceSession.join(gateway, adapter, {
  guildId: "guild-id",
  channelId: "channel-id",
  selfMute: true,
  recovery: { maxAttempts: 5 },
});

voice.on("speakers", (identities) => console.log(identities));
voice.on("error", (error) => console.error(error));
// Bind these actions to user gestures to satisfy browser media permission policy.
startButton.addEventListener("click", () => void voice.startAudio());
microphoneButton.addEventListener("click", () => void voice.setMuted(false));
// When finished:
await voice.disconnect();

import {
  VoiceConnection,
  VoicePlayer,
  liveKitAdapter,
} from "talos-fluxer/voice";

const voice = await VoiceConnection.join(
  gateway,
  liveKitAdapter(() => new Room()),
  {
    guildId: "guild-id",
    channelId: "channel-id",
    selfMute: true,
  },
);

// Publish any audio MediaStreamTrack, such as a Web Audio mixed stream.
const publication = await voice.publishAudio(audioTrack);
await publication.stop(); // Leaves the caller's audioTrack alive.

const player = new VoicePlayer(voice);
try {
  // Start from a user gesture if the browser requires audio context activation.
  const first = player.play("/sounds/first.wav");
  const second = player.play(fileInput.files![0]!);
  await Promise.all([first, second]); // Each promise covers its own playback.
} finally {
  await player.disconnect();
  await voice.disconnect();
}

import type { VoiceAudioTrack } from "talos-fluxer/voice";

function record(track: VoiceAudioTrack) {
  const recorder = new MediaRecorder(new MediaStream([track.mediaStreamTrack]));
  const chunks: Blob[] = [];
  recorder.ondataavailable = (event) => chunks.push(event.data);
  recorder.start();
  return {
    recorder,
    stop: () =>
      new Promise<Blob>((resolve) => {
        recorder.onstop = () =>
          resolve(new Blob(chunks, { type: recorder.mimeType }));
        recorder.stop();
      }),
  };
}

const recordings = new Map<string, ReturnType<typeof record>>();
for (const track of voice.audioTracks) recordings.set(track.id, record(track));
voice.on("audioTrack", (track) => recordings.set(track.id, record(track)));
voice.on("audioTrackRemoved", (track) => {
  const recording = recordings.get(track.id);
  if (recording?.recorder.state === "recording") recording.recorder.stop();
  recordings.delete(track.id);
});