const { readable, writable } = new TransformStream<Uint8Array, Uint8Array>({
            expectedLength: offsets.length * 32 + pendingMessages.length * 32,
        })

const { readable, writable } = new TransformStream<Uint8Array, Uint8Array>({
            expectedLength: offsets.length * 32 + pendingMessages.length * 32,
        })

const resource = createAudioResource(
        "https://www.soundhelix.com/examples/mp3/SoundHelix-Song-1.mp3",
        {
          inputType: StreamType.Arbitrary,
        }
      )

const resource = createAudioResource(
        "https://www.soundhelix.com/examples/mp3/SoundHelix-Song-1.mp3",
        {
          inputType: StreamType.Arbitrary,
        }
      )

[08:42:59.931] DEBUG (17160): --------------------------------------------------
Core Dependencies
- @discordjs/voice: 0.16.1
- prism-media: 1.3.5

Opus Libraries
- @discordjs/opus: 0.9.0
- opusscript: not found

Encryption Libraries
- sodium-native: 4.3.1
- sodium: not found
- libsodium-wrappers: 0.7.15
- tweetnacl: not found

FFmpeg
- version: 7.1
- libopus: yes
--------------------------------------------------

[08:42:59.931] DEBUG (17160): --------------------------------------------------
Core Dependencies
- @discordjs/voice: 0.16.1
- prism-media: 1.3.5

Opus Libraries
- @discordjs/opus: 0.9.0
- opusscript: not found

Encryption Libraries
- sodium-native: 4.3.1
- sodium: not found
- libsodium-wrappers: 0.7.15
- tweetnacl: not found

FFmpeg
- version: 7.1
- libopus: yes
--------------------------------------------------

export const client = new Client({
  intents: [GatewayIntentBits.Guilds, GatewayIntentBits.GuildVoiceStates],
})

export const client = new Client({
  intents: [GatewayIntentBits.Guilds, GatewayIntentBits.GuildVoiceStates],
})

const audioPlayer = createAudioPlayer({
  behaviors: {
    maxMissedFrames: 1000,
    noSubscriber: NoSubscriberBehavior.Play,
  },
})

const connection = joinVoiceChannel({
        channelId: channel.id,
        guildId: interaction.guildId!,
        adapterCreator: channel.guild
          .voiceAdapterCreator as DiscordGatewayAdapterCreator,
        debug: true,
        selfDeaf: false,
        selfMute: false,
      })

      connection.on("stateChange", (oldState, newState) => {
        logger.info(
          `Connection transitioned from ${oldState.status} to ${newState.status}`
        )
      })

      audioPlayer.on("stateChange", (oldState, newState) => {
        logger.info(
          `Audio player transitioned from ${oldState.status} to ${newState.status}`
        )
      })

      let audioQueue: Buffer[] = []

      const audioStream = new Readable({
        read(size) {
          console.log("read", size)
          if (audioQueue.length > 0) {
            logger.debug("sending audio data")
            const chunk = audioQueue.shift()
            return chunk
          }
          logger.debug("no audio data")
          return null
        },
      })

      emitter.on("audio", (audioData: AudioData) => {
        audioQueue.push(audioData.audioBuffer)
        audioStream.emit("readable", audioData.audioBuffer)
        audioStream.emit("data", audioData.audioBuffer)
      })

      const resource = createAudioResource(audioStream, {
        inputType: StreamType.WebmOpus,
        inlineVolume: true,
      })

      audioPlayer.on("error", (error) => {
        logger.error({ error }, "Error in audio player")
      })

      connection.on("error", (error) => {
        logger.error({ error }, "Error in connection")
      })

      connection.subscribe(audioPlayer)

      connection.on(VoiceConnectionStatus.Ready, () => {
        logger.debug("Connection is ready, starting playback")
        audioPlayer.play(resource)
      })

const audioPlayer = createAudioPlayer({
  behaviors: {
    maxMissedFrames: 1000,
    noSubscriber: NoSubscriberBehavior.Play,
  },
})

const connection = joinVoiceChannel({
        channelId: channel.id,
        guildId: interaction.guildId!,
        adapterCreator: channel.guild
          .voiceAdapterCreator as DiscordGatewayAdapterCreator,
        debug: true,
        selfDeaf: false,
        selfMute: false,
      })

      connection.on("stateChange", (oldState, newState) => {
        logger.info(
          `Connection transitioned from ${oldState.status} to ${newState.status}`
        )
      })

      audioPlayer.on("stateChange", (oldState, newState) => {
        logger.info(
          `Audio player transitioned from ${oldState.status} to ${newState.status}`
        )
      })

      let audioQueue: Buffer[] = []

      const audioStream = new Readable({
        read(size) {
          console.log("read", size)
          if (audioQueue.length > 0) {
            logger.debug("sending audio data")
            const chunk = audioQueue.shift()
            return chunk
          }
          logger.debug("no audio data")
          return null
        },
      })

      emitter.on("audio", (audioData: AudioData) => {
        audioQueue.push(audioData.audioBuffer)
        audioStream.emit("readable", audioData.audioBuffer)
        audioStream.emit("data", audioData.audioBuffer)
      })

      const resource = createAudioResource(audioStream, {
        inputType: StreamType.WebmOpus,
        inlineVolume: true,
      })

      audioPlayer.on("error", (error) => {
        logger.error({ error }, "Error in audio player")
      })

      connection.on("error", (error) => {
        logger.error({ error }, "Error in connection")
      })

      connection.subscribe(audioPlayer)

      connection.on(VoiceConnectionStatus.Ready, () => {
        logger.debug("Connection is ready, starting playback")
        audioPlayer.play(resource)
      })