module.exports = {
    data: new SlashCommandBuilder()
        .setName('record')
        .setDescription('Record voice channel')
        .setDefaultMemberPermissions(PermissionsBitField.Flags.Administrator),

    async execute(interaction, client) {
        const voiceChannel = interaction.member.voice.channel;
        if (!voiceChannel) {
            return interaction.reply('You need to be in a voice channel to use this command.');
        }

        const connection = joinVoiceChannel({
            channelId: voiceChannel.id,
            guildId: interaction.guild.id,
            adapterCreator: interaction.guild.voiceAdapterCreator,
        });

        let outputStream;

        connection.on(VoiceConnectionStatus.Ready, () => {
            console.log(`Connected to channel ${voiceChannel.id}`);
            outputStream = startRecording(connection);
        });

        connection.on(VoiceConnectionStatus.Disconnected, () => {
            console.log('Bot disconnected from the voice channel.');

            if (fs.existsSync(recordingFilePath)) {
                console.log(`Finalizing recording at ${recordingFilePath}`);
                outputStream.end(); // Close the file stream
            }
        });

        connection.on(VoiceConnectionStatus.Destroyed, () => {
            console.log('Voice connection was destroyed.');
            if (fs.existsSync(recordingFilePath)) {
                fs.unlinkSync(recordingFilePath);
            }
        });
    }
};

module.exports = {
    data: new SlashCommandBuilder()
        .setName('record')
        .setDescription('Record voice channel')
        .setDefaultMemberPermissions(PermissionsBitField.Flags.Administrator),

    async execute(interaction, client) {
        const voiceChannel = interaction.member.voice.channel;
        if (!voiceChannel) {
            return interaction.reply('You need to be in a voice channel to use this command.');
        }

        const connection = joinVoiceChannel({
            channelId: voiceChannel.id,
            guildId: interaction.guild.id,
            adapterCreator: interaction.guild.voiceAdapterCreator,
        });

        let outputStream;

        connection.on(VoiceConnectionStatus.Ready, () => {
            console.log(`Connected to channel ${voiceChannel.id}`);
            outputStream = startRecording(connection);
        });

        connection.on(VoiceConnectionStatus.Disconnected, () => {
            console.log('Bot disconnected from the voice channel.');

            if (fs.existsSync(recordingFilePath)) {
                console.log(`Finalizing recording at ${recordingFilePath}`);
                outputStream.end(); // Close the file stream
            }
        });

        connection.on(VoiceConnectionStatus.Destroyed, () => {
            console.log('Voice connection was destroyed.');
            if (fs.existsSync(recordingFilePath)) {
                fs.unlinkSync(recordingFilePath);
            }
        });
    }
};

const { SlashCommandBuilder, PermissionsBitField } = require('discord.js');
const { joinVoiceChannel, VoiceConnectionStatus, EndBehaviorType } = require('@discordjs/voice');
const fs = require('fs');
const path = require('path');

const recordingFilePath = path.join(__dirname, 'recording.pcm');

const startRecording = (connection) => {
    console.log(`Recording audio to ${recordingFilePath}`);

    const outputStream = fs.createWriteStream(recordingFilePath, { flags: 'w' });

    connection.receiver.speaking.on('start', (userId) => {
        console.log(`User ${userId} started speaking.`);

        const audioStream = connection.receiver.subscribe(userId, {
            end: {
                behavior: EndBehaviorType.AfterSilence,
                duration: 1000,
            },
        });

        audioStream.on('data', (chunk) => {
            console.log(`Received ${chunk.length} bytes from user ${userId}`);
            outputStream.write(chunk);
        });

        audioStream.on('end', () => {
            console.log(`Audio stream ended for user ${userId}`);
        });

        audioStream.on('error', (err) => {
            console.error('Stream error:', err);
        });
    });

    return outputStream;
};

const { SlashCommandBuilder, PermissionsBitField } = require('discord.js');
const { joinVoiceChannel, VoiceConnectionStatus, EndBehaviorType } = require('@discordjs/voice');
const fs = require('fs');
const path = require('path');

const recordingFilePath = path.join(__dirname, 'recording.pcm');

const startRecording = (connection) => {
    console.log(`Recording audio to ${recordingFilePath}`);

    const outputStream = fs.createWriteStream(recordingFilePath, { flags: 'w' });

    connection.receiver.speaking.on('start', (userId) => {
        console.log(`User ${userId} started speaking.`);

        const audioStream = connection.receiver.subscribe(userId, {
            end: {
                behavior: EndBehaviorType.AfterSilence,
                duration: 1000,
            },
        });

        audioStream.on('data', (chunk) => {
            console.log(`Received ${chunk.length} bytes from user ${userId}`);
            outputStream.write(chunk);
        });

        audioStream.on('end', () => {
            console.log(`Audio stream ended for user ${userId}`);
        });

        audioStream.on('error', (err) => {
            console.error('Stream error:', err);
        });
    });

    return outputStream;
};