music.js

const ytdl = require('ytdl-core')
const Handles = new Map()
const yt = require('simple-youtube-api')
const youtube = require('yt-search')
const sf = require('snekfetch')
const Discord = require('discord.js')

process.on('unhandledRejection', function (err) {
    console.log(err)
})

module.exports.create = (identificate, voiceChannel, message) => {
    if (!Handles.get(identificate)) {
        Handles.set(identificate, {
            voiceChannel: voiceChannel,
            queue: [],
            volume: 50,
            channel: message.channel,
            playing: false,
            dispatcher: false
        })
    }
}
module.exports.start = (identificate) => {
    if (!Handles.get(identificate).playing) return this.startStream(identificate)
}

module.exports.next = (identificate) => {
    this.getGuild(identificate).queue.shift()

    if (this.getQueue(identificate)[0]) {
        if (Handles.get(identificate).voiceChannel.members.filter(m => !m.user.bot).size == 0) {
            let embed = new Discord.MessageEmbed()
                .setColor(require('./config').color)
                .addField('채널에 아무도 없습니다.', '저런 노래는 듣지도 않으면서 틀어놨군... 전기를 아껴주라구! \`#p\`커맨드로 대기열을 다시 불러오고 재생할 수 있어!',)
            getGuild(identificate).channel.send(embed)
            Handles.remove(identificate)
        } else if(Handles.get(identificate).voiceChannel.members.filter(m => !m.user.bot).size != 0){
        Handles.get(identificate).playing = false

        this.startStream(identificate)
        }
    } 
    
    else{
        this.endStream(identificate)
    }
}

module.exports.getNP = getNP

function getNP(identificate) {
    const latest = Handles.get(identificate).queue[0]

    return latest
}

module.exports.getQueue = (identificate) => {
    const latest = Handles.get(identificate)

    if (latest) {
        return latest.queue
    } else {
        return false
    }
}

module.exports.getGuild = (identificate) => {
    return Handles.get(identificate)
}

function getGuild(identificate) {
    return Handles.get(identificate)
}

module.exports.addQueue = async (identificate, videoURL, message, info, thumb) => {
    let q = {
        url: videoURL,
        author: message.author.id,
        vote: 0,
        time: new Date(),
        info: info,
        thumbnail : thumb
    }
    Handles.get(identificate).queue.push(q)
}

module.exports.removeQueue = (identificate, index) => {
    if(index == 0) {
        this.next(identificate)
    }
    else Handles.get(identificate).queue.splice(index, 1)

}

module.exports.resetQueue = (identificate) => {
    Handles.get(identificate).queue.splice(0, Handles.get(identificate).queue.length)
    this.endStream(identificate)
}

module.exports.startStream = (identificate) => {
    if (Handles.get(identificate).playing) return

    const stream = ytdl(this.getNP(identificate).url, {
        quality: 'highest',
        filter: 'audioonly'
    }).on('error', error => {
        console.log(error)
    })
    
    Handles.get(identificate).voiceChannel.join().then(connection => {
        const dispatcher = connection.play(stream, { bitrate: 96 })
    
        Handles.get(identificate).dispatcher = dispatcher
        Handles.get(identificate).playing = true

        dispatcher.setVolume(this.getGuild(identificate).volume / 100)

        dispatcher.on('finish', () => {
            if(!Handles.get(identificate)) return
            Handles.get(identificate).playing = false
            this.next(identificate)
        })

        dispatcher.on('start', () => { 
            let info = getNP(identificate).info.title
            getGuild(identificate).channel.send('<a:playforpark:708621715571474482>음악을 재생합니다!' + random(require('./config').playmsg).replace('%song%', '`'+info+'`'))
        })
    })
}

module.exports.endStream = (identificate, message) => {
    Handles.get(identificate).voiceChannel.leave()
    if(!message) {
        Handles.get(identificate).channel.send("더이상 플레이할 노래가 없어, 대기열을 초기화됬어! 그럼 난 이만👋")
    }
    else if(message){
        message.channel.send("더이상 플레이할 노래가 없어 : 대기열을 초기화했어! 그럼 난 이만👋")
    }
    Handles.delete(identificate)
}

module.exports.pauseStream = (identificate) => {
    Handles.get(identificate).dispatcher.pause()
}

module.exports.resumeStream = (identificate) => {
    Handles.get(identificate).dispatcher.resume()
}

module.exports.changeStatus = (identificate, status) => {
    Handles.get(identificate).playing = status
}

function random(items) {
    return items[Math.floor(Math.random() * items.length)]
}