async function onStartedSpeaking(userId, voiceChannel) {
    let user = await getUserById(userId);

    let opusStream = voiceReceiver.subscribe(userId, {
        end: {
            behavior: EndBehaviorType.AfterSilence,
            duration: allowedPauseDurationForInputVoice
        }
    });
    const oggStream = new opus.OggLogicalBitstream({
        opusHead: new opus.OpusHead({
            channelCount: 2,
            sampleRate: 48000
        }),
        pageSizeControl: {
            maxPackets: 10
        }
    });

    let buffer = [];
    oggStream.on("data", (chunk) => {
        buffer.push(chunk);
    });

    opusStream.on("end", async () => {
        oggStream.destroy()
        let ws = fs.createWriteStream('output.ogg')
        ws.write(Buffer.concat(buffer))
        logReliably("Finished writing output.ogg")
        ws.end()
        buffer = []

        exec("ffmpeg -y -i output.ogg -ar 48000 -ac 2 -codec:a libmp3lame output.mp3")
    });

    opusStream.pipe(oggStream)
}

async function onStartedSpeaking(userId, voiceChannel) {
    let user = await getUserById(userId);

    let opusStream = voiceReceiver.subscribe(userId, {
        end: {
            behavior: EndBehaviorType.AfterSilence,
            duration: allowedPauseDurationForInputVoice
        }
    });
    const oggStream = new opus.OggLogicalBitstream({
        opusHead: new opus.OpusHead({
            channelCount: 2,
            sampleRate: 48000
        }),
        pageSizeControl: {
            maxPackets: 10
        }
    });

    let buffer = [];
    oggStream.on("data", (chunk) => {
        buffer.push(chunk);
    });

    opusStream.on("end", async () => {
        oggStream.destroy()
        let ws = fs.createWriteStream('output.ogg')
        ws.write(Buffer.concat(buffer))
        logReliably("Finished writing output.ogg")
        ws.end()
        buffer = []

        exec("ffmpeg -y -i output.ogg -ar 48000 -ac 2 -codec:a libmp3lame output.mp3")
    });

    opusStream.pipe(oggStream)
}

let opusStream = voiceReceiver.subscribe(userId, {
        end: {
            behavior: EndBehaviorType.AfterSilence,
            duration: allowedPauseDurationForInputVoice
        }
    });
    const oggStream = new opus.OggLogicalBitstream({
        opusHead: new opus.OpusHead({
            channelCount: 2,
            sampleRate: 48000
        }),
        pageSizeControl: {
            maxPackets: 10
        }
    });

    let buffer = [];
    oggStream.on("data", (chunk) => {
        buffer.push(chunk);
    });

    

    opusStream.on("end", async () => {
        logReliably("🟠 " + user.globalName + " stopped speaking, saving. " + getTimeElapsedSinceLastCall());
        setMuteSelectively(false, true, true, voiceChannel, user.id);

        oggStream.destroy()
        let ws = fs.createWriteStream('output.ogg')
        ws.write(Buffer.concat(buffer))
        logReliably("Finished writing output.ogg")
        ws.end()
        buffer = []

        let audioOutput = new prism.FFmpeg({
            args: ["-ar", "48000", "-ac", "2", "-codec:a", "libmp3lame", "-i", "ogg_output.ogg", "mp3_output.mp3"]
        });

        // await transcribe_and_reply(audioOutputFilename);
        setMuteSelectively(true, false, false, voiceChannel, user.id);
    });

    opusStream.pipe(oggStream)

let opusStream = voiceReceiver.subscribe(userId, {
        end: {
            behavior: EndBehaviorType.AfterSilence,
            duration: allowedPauseDurationForInputVoice
        }
    });
    const oggStream = new opus.OggLogicalBitstream({
        opusHead: new opus.OpusHead({
            channelCount: 2,
            sampleRate: 48000
        }),
        pageSizeControl: {
            maxPackets: 10
        }
    });

    let buffer = [];
    oggStream.on("data", (chunk) => {
        buffer.push(chunk);
    });

    

    opusStream.on("end", async () => {
        logReliably("🟠 " + user.globalName + " stopped speaking, saving. " + getTimeElapsedSinceLastCall());
        setMuteSelectively(false, true, true, voiceChannel, user.id);

        oggStream.destroy()
        let ws = fs.createWriteStream('output.ogg')
        ws.write(Buffer.concat(buffer))
        logReliably("Finished writing output.ogg")
        ws.end()
        buffer = []

        let audioOutput = new prism.FFmpeg({
            args: ["-ar", "48000", "-ac", "2", "-codec:a", "libmp3lame", "-i", "ogg_output.ogg", "mp3_output.mp3"]
        });

        // await transcribe_and_reply(audioOutputFilename);
        setMuteSelectively(true, false, false, voiceChannel, user.id);
    });

    opusStream.pipe(oggStream)

ffprobe version 6.1.1 Copyright (c) 2007-2023 the FFmpeg developers
  built with Apple clang version 15.0.0 (clang-1500.1.0.2.5)
  configuration: --prefix=/usr/local/Cellar/ffmpeg/6.1.1_2 --enable-shared --enable-pthreads --enable-version3 --cc=clang --host-cflags= --host-ldflags='-Wl,-ld_classic' --enable-ffplay --enable-gnutls --enable-gpl --enable-libaom --enable-libaribb24 --enable-libbluray --enable-libdav1d --enable-libharfbuzz --enable-libjxl --enable-libmp3lame --enable-libopus --enable-librav1e --enable-librist --enable-librubberband --enable-libsnappy --enable-libsrt --enable-libssh --enable-libsvtav1 --enable-libtesseract --enable-libtheora --enable-libvidstab --enable-libvmaf --enable-libvorbis --enable-libvpx --enable-libwebp --enable-libx264 --enable-libx265 --enable-libxml2 --enable-libxvid --enable-lzma --enable-libfontconfig --enable-libfreetype --enable-frei0r --enable-libass --enable-libopencore-amrnb --enable-libopencore-amrwb --enable-libopenjpeg --enable-libopenvino --enable-libspeex --enable-libsoxr --enable-libzmq --enable-libzimg --disable-libjack --disable-indev=jack --enable-videotoolbox --enable-audiotoolbox
  libavutil      58. 29.100 / 58. 29.100
  libavcodec     60. 31.102 / 60. 31.102
  libavformat    60. 16.100 / 60. 16.100
  libavdevice    60.  3.100 / 60.  3.100
  libavfilter     9. 12.100 /  9. 12.100
  libswscale      7.  5.100 /  7.  5.100
  libswresample   4. 12.100 /  4. 12.100
  libpostproc    57.  3.100 / 57.  3.100
output.opus: Invalid data found when processing input

ffprobe version 6.1.1 Copyright (c) 2007-2023 the FFmpeg developers
  built with Apple clang version 15.0.0 (clang-1500.1.0.2.5)
  configuration: --prefix=/usr/local/Cellar/ffmpeg/6.1.1_2 --enable-shared --enable-pthreads --enable-version3 --cc=clang --host-cflags= --host-ldflags='-Wl,-ld_classic' --enable-ffplay --enable-gnutls --enable-gpl --enable-libaom --enable-libaribb24 --enable-libbluray --enable-libdav1d --enable-libharfbuzz --enable-libjxl --enable-libmp3lame --enable-libopus --enable-librav1e --enable-librist --enable-librubberband --enable-libsnappy --enable-libsrt --enable-libssh --enable-libsvtav1 --enable-libtesseract --enable-libtheora --enable-libvidstab --enable-libvmaf --enable-libvorbis --enable-libvpx --enable-libwebp --enable-libx264 --enable-libx265 --enable-libxml2 --enable-libxvid --enable-lzma --enable-libfontconfig --enable-libfreetype --enable-frei0r --enable-libass --enable-libopencore-amrnb --enable-libopencore-amrwb --enable-libopenjpeg --enable-libopenvino --enable-libspeex --enable-libsoxr --enable-libzmq --enable-libzimg --disable-libjack --disable-indev=jack --enable-videotoolbox --enable-audiotoolbox
  libavutil      58. 29.100 / 58. 29.100
  libavcodec     60. 31.102 / 60. 31.102
  libavformat    60. 16.100 / 60. 16.100
  libavdevice    60.  3.100 / 60.  3.100
  libavfilter     9. 12.100 /  9. 12.100
  libswscale      7.  5.100 /  7.  5.100
  libswresample   4. 12.100 /  4. 12.100
  libpostproc    57.  3.100 / 57.  3.100
output.opus: Invalid data found when processing input