NotifyMe/commands/channels/channels.js

const { configDotenv } = require('dotenv');
configDotenv
const { SlashCommandBuilder, EmbedBuilder } = require('discord.js');
const { tClient, mClient } = require('../../index');

function escapeMarkdown(input){
    return input.replace(/([*_#\[!\]()`>+\-.|])/g, '\\$1');
}
async function SubscribeChannel(interaction) {
    const channelName = encodeURI(await interaction.options.getString('channel')).toLowerCase()
    const userID = interaction.user.id
    try {
        let streamData = await tClient.getStreams({ name: channelName })
        //console.log(await tClient.searchChannels({query: `${channelName}`})) // returns too many results and not exact match first
    } catch (error) {
        return interaction.editReply({
            content: `**[ERROR]:** Could not validate channel name for *${escapeMarkdown(channelName)}*!\r\n${error}`,
            ephemeral: true
        }).then(setTimeout(() => {
            interaction.deleteReply()
        }, 5000))
    }

    const db = mClient.db('notifyme')
    const channelsColl = db.collection('channels')

    const find = await channelsColl.find({ name: channelName }).toArray()

    if (find[0]) {
        if (find[0]?.subscribers?.includes(userID)) {
            return interaction.editReply({
                content: `**[WARNING]:** You are already subscribed to *${escapeMarkdown(channelName)}*!`,
                ephemeral: true
            }).then(setTimeout(() => {
                interaction.deleteReply()
            }, 5000))
        }
    }

    try {
        const res = await channelsColl.findOneAndUpdate({
            name: channelName
        }, {
            $set: {
                name: channelName,
            },
            $push: {
                subscribers: userID
            }
        }, {
            upsert: true,
            returnDocument: 'after'
        })
    } catch (error) {
        return interaction.editReply({
            content: `**[ERROR]:** There was an issue updating the database!\r\n${error}`,
            ephemeral: true
        }).then(setTimeout(() => {
            interaction.deleteReply()
        }, 5000))
    }
    //console.log(res) // debug
    return interaction.editReply({
        content: `**[SUCCESS]:** You are now subscribed to *${escapeMarkdown(channelName)}*!`,
        ephemeral: true
    }).then(setTimeout(() => {
        interaction.deleteReply()
    }, 5000))
}

async function UnsubscribeChannel(interaction) {
    const channelName = encodeURI(await interaction.options.getString('channel')).toLowerCase()
    const userID = interaction.user.id

    const db = mClient.db('notifyme')
    const channelsColl = db.collection('channels')

    const find = await channelsColl.find({ name: channelName }).toArray()

    if (find[0]) {
        if (!find[0]?.subscribers?.includes(userID)) {
            return interaction.editReply({
                content: `**[WARNING]:** You were not subscribed to *${escapeMarkdown(channelName)}*!`,
                ephemeral: true
            }).then(setTimeout(() => {
                interaction.deleteReply()
            }, 5000))
        }
    }

    try {
        const res = await channelsColl.findOneAndUpdate({
            name: channelName
        }, {
            $set: {
                name: channelName,
            },
            $pull: {
                subscribers: userID
            }
        }, {
            upsert: true,
            returnDocument: 'after'
        })
        if(!res.subscribers[0]){
            const newRes = await channelsColl.findOneAndDelete({
                name: channelName
            })
        }
    } catch (error) {
        return interaction.editReply({
            content: `**[ERROR]:** There was an issue with the database!\r\n${error}`,
            ephemeral: true
        }).then(setTimeout(() => {
            interaction.deleteReply()
        }, 5000))
    }

    
    //console.log(res) // debug
    return interaction.editReply({
        content: `**[SUCCESS]:** You are no longer subscribed to *${escapeMarkdown(channelName)}*!`,
        ephemeral: true
    }).then(setTimeout(() => {
        interaction.deleteReply()
    }, 5000))
}

async function ListChannel(interaction) {
    const userID = interaction.user.id

    const db = mClient.db('notifyme')
    const channelsColl = db.collection('channels')

    const find = await channelsColl.find({ subscribers: userID }).toArray()
    if (!find[0]) {
        return interaction.editReply({
            content: `You are not subscribed to any channels!`,
            ephemeral: true
        }).then(setTimeout(() => {
            interaction.deleteReply()
        }, 5000))
    }
    var channelList = []
    find.forEach((document) => {
        channelList.push(escapeMarkdown(document.name))
    })
    const embed = new EmbedBuilder()
        .setTitle('List of Subscribed Channels:')
        .setDescription(channelList.join("\n"))

    return interaction.followUp({
        embeds: [embed],
        ephemeral: true
    }).then(setTimeout(() => {
        interaction.deleteReply()
    }, 60000))
}

async function InfoChannel(interaction) {
    const channelName = encodeURI(await interaction.options.getString('channel')).toLowerCase()
    try {
        let streamData = await tClient.getStreams({ channel: channelName })
        if (streamData?.data[0]) {
            let liveData = {
                streamer: streamData.data[0].user_name,
                game: streamData.data[0].game_name,
                title: streamData.data[0].title,
                thumbnail: streamData.data[0].thumbnail_url.replace('-{width}x{height}', ''),
                tags: streamData.data[0].tags
            }
            const embed = new EmbedBuilder()
                .setTitle(`${escapeMarkdown(liveData.streamer)} is live!`)
                .setDescription(`They're playing ${liveData.game}`)
                .addFields(
                    { name: '\u200B', value: `${liveData.title}` })
                .setImage(liveData.thumbnail)
                .setURL(`https://twitch.tv/${channelName}`)
            let footer = ""
            liveData.tags.forEach((tag) => {
                footer += `#${tag} `
            })
            embed.setFooter({
                text: footer
            })

            return interaction.editReply({
                embeds: [embed],
                ephemeral: true
            }).then(setTimeout(() => {
                interaction.deleteReply()
            }, 60000))
        } else {
            const embed = new EmbedBuilder()
                .setTitle(`${channelName} is currently offline!`)
                .setImage('https://media.discordapp.net/attachments/1061304429724319794/1319800268770250883/no-signal-tv-descendant-network-rainbow-bars-abstract-background-vector.jpg?ex=67674748&is=6765f5c8&hm=d539944a67fccec461b0183a9f0300e19ac485deda7b23090165088567f2c84f&=&format=webp')
                .setURL(`https://twitch.tv/${channelName}`)
            return interaction.editReply({
                embeds: [embed],
                ephemeral: true
            })
        }
    } catch (error) {
        console.error(error)
        return interaction.editReply({
            content: `**[ERROR]:** Could not validate channel name for *${escapeMarkdown(channelName)}*!\r\n${error}`,
            ephemeral: true
        }).then(setTimeout(() => {
            interaction.deleteReply()
        }, 5000))
    }
}

module.exports = {
    data: new SlashCommandBuilder()
        .setName('channel')
        .setDescription('channel related commands')
        .addSubcommand(s =>
            s
                .setName('subscribe')
                .setDescription('subscribe to notifications when this channel goes live')
                .addStringOption(o =>
                    o
                        .setName('channel')
                        .setDescription('channel name')
                        .setRequired(true)
                )
        )
        .addSubcommand(s =>
            s
                .setName('unsubscribe')
                .setDescription('unsubscribe to notifications when this channel goes live')
                .addStringOption(o =>
                    o
                        .setName('channel')
                        .setDescription('channel name')
                        .setRequired(true)
                )
        )
        .addSubcommand(s =>
            s
                .setName('list')
                .setDescription('list your subscribed channels')
        )
        .addSubcommand(s =>
            s
                .setName('info')
                .setDescription('get information on a live channel')
                .addStringOption(o =>
                    o
                        .setName('channel')
                        .setDescription('channel name')
                        .setRequired(true)
                )
        ),
    async execute(interaction) {
        await interaction.deferReply()
        switch (interaction.options._subcommand) {
            case 'subscribe':
                SubscribeChannel(interaction)
                break;
            case 'unsubscribe':
                UnsubscribeChannel(interaction)
                break;
            case 'list':
                ListChannel(interaction)
                break;
            case 'info':
                InfoChannel(interaction)
                break;
            default:
                break;
        }
    }
}