const Discord = require('discord.js')
const bot = new Discord.Client({ disableEveryone: true })
const queue = new Map()
const previous = new Map()
const ytdl = require('ytdl-core')
bot.login('NTU0NjkzODA2MjU2MDI5NzA3.D2ga1w.g6uMisx31L_qqk8yD3gYbO-B-VY')
bot.on('ready', () => {
    console.log('BOT ONLINE')
    bot.user.setActivity('ANK | Musique')
})

prefix = "!"

bot.on('message', async function (msg) {
    if (!msg.content.startsWith(prefix)) return undefined
    let args = msg.content.split(' ')
    const serverQueue = queue.get(msg.guild.id)
    const serverPrevious = previous.get(msg.guild.id)
    if (args[0].toLowerCase() === prefix + 'ping') {
        msg.channel.send("Pong!")
    }
    if (args[0].toLowerCase() === prefix + 'play') {
        const channel = msg.member.voiceChannel
        if (!channel) {
            msg.channel.send(":x: | Tu dois rejoindre un canal vocal pour exécuter cette commande !")
            return undefined
        }
        const permissions = channel.permissionsFor(msg.client.user)
        if (!args[1]) {
            msg.channel.send(":x: | Merci de saisir un URL YouTube !")
            return undefined
        }
        if (!permissions.has('CONNECT')) {
            return msg.channel.send(":information_source: | Je n'ai pas les permissions de me connecter à ce canal")
        }
        if (!permissions.has('SPEAK')) {
            return msg.channel.send(":information_source: | Je ne peux pas parler dans ce canal")
        }
        try {
            await ytdl(args[1])
        } catch(error) {
            return msg.channel.send(":x: | Je ne peux pas lire cette vidéo")
        }
        const songInfo = await ytdl.getInfo(args[1])
        const song = {
            title: songInfo.title,
            url: songInfo.video_url
        }
        if (!serverPrevious) {
            const previousContruct = {
                songs: [],
                status: false
            }
            previous.set(msg.guild.id, previousContruct)
        }
        if (!serverQueue) {
            const queueConstruct = {
                textChannel: msg.channel,
                voiceChannel: channel,
                connection: null,
                songs: [],
                volume: 5,
                playing: true
            }
            queue.set(msg.guild.id, queueConstruct)
            queueConstruct.songs.push(song)
            try {
                var connection = await channel.join()
                queueConstruct.connection = connection
                play(msg.guild, queueConstruct.songs[0])
            } catch(error) {
                return msg.channel.send(":x: | Je ne peux pas me connecter à ce canal")
            }
        } else {
            serverQueue.songs.push(song)
            return msg.channel.send(`:white_check_mark: | **${song.title}** a été ajouté à la liste d'attente`)
        }
    }
    if (args[0].toLowerCase() === prefix + 'stop') {
        const client = msg.guild.voiceConnection
        const channel = msg.member.voiceChannel
        if (!client) {
            msg.channel.send("Je ne suis pas dans un canal vocal")
        } else {
            channel.leave()
            msg.react('👋')
            return undefined
        }
    }
    if (args[0].toLowerCase() === prefix + 'skip') {
        if (!msg.member.voiceChannel) return msg.channel.send(":x: | Tu dois rejoindre un canal vocal pour exécuter cette commande !")
        skip(msg.guild)
    }
    if (args[0].toLowerCase() === prefix + 'volume') {
        if (!msg.member.voiceChannel) return msg.channel.send(":x: | Tu dois rejoindre un canal vocal pour exécuter cette commande !")
        if (!serverQueue) return msg.channel.send(":x: | Aucune musique en cours de lecture")
        if (!args[1]) return msg.channel.send(`🔊 | Le volume actuel est: **${serverQueue.volume}**`)
        serverQueue.volume = args[1]
        serverQueue.connection.dispatcher.setVolumeLogarithmic(args[1] / 5)
        return msg.channel.send(`🔊 | Volume réglé à: **${args[1]}**`)
    }
    return undefined
})


function play(guild, song) {
    const serverQueue = queue.get(guild.id)
    const serverPrevious = previous.get(guild.id)
    serverPrevious.songs.push(song)
	if (!song) {
        serverQueue.textChannel.send(":information_source: | Plus aucune musique en liste d'attente, déconnexion !")
        serverQueue.voiceChannel.leave()
        queue.delete(guild.id)
        previous.delete(guild.id)
		return
	}
    console.log(serverQueue.songs)
    console.log(serverPrevious.songs)

	const dispatcher = serverQueue.connection.playStream(ytdl(song.url))
		.on('end', reason => {
			if (reason === 'Stream is not generating quickly enough.') console.log('Fin chanson')
            else console.log(reason)
            if (serverPrevious.status === true) {
                play(guild, serverPrevious.songs[0])
                serverPrevious.songs.shift()
                serverPrevious.status = false
            } else {
                serverQueue.songs.shift()
			    play(guild, serverQueue.songs[0])
            }
		})
		.on('error', error => console.error(error))
	dispatcher.setVolumeLogarithmic(serverQueue.volume / 5)

	serverQueue.textChannel.send(`:musical_note: | Joue: **${song.title}**`).then(async function(message) {
        playpause(message,guild)
    })
}

function skip(guild) {
    const serverQueue = queue.get(guild.id)
    serverQueue.connection.dispatcher.end()
}

async function playpause(message, guild) {
    const serverQueue = queue.get(guild.id)
    const serverPrevious = previous.get(guild.id)
    await message.react('⏮')
    await message.react('⏯')
    await message.react('⏭')
    const filter = function(reaction, user) {
        return ['⏮','⏯','⏭'].includes(reaction.emoji.name) && user.id != 554693806256029707
    }
    await message.awaitReactions(filter, { max: 1, time: 6000000, errors: ['time'] }).then(async function(collected) {
        const reaction = collected.first()
        if (reaction.emoji.name === '⏮') {
            serverPrevious.status = true
            skip(guild)
            return undefined
        }
        if (reaction.emoji.name === '⏯') {
            if (serverQueue.playing === true) {
                serverQueue.playing = false
                serverQueue.connection.dispatcher.pause()
                message.channel.send(":pause_button: | Musique en pause ! ").then(async function(message) {
                    playpause(message,guild)
                })
            }
            else if (serverQueue.playing ===false) {
                serverQueue.playing = true
                serverQueue.connection.dispatcher.resume()
                message.channel.send(':arrow_forward: | Play!').then(async function(message) {
                    playpause(message,guild)
                })
            }
            return undefined
        }
        if (reaction.emoji.name === '⏭') {
            message.channel.send(":fast_forward: | Musique suivante")
            skip(guild)
            return undefined
        }
    })
}