const Discord = require('discord.js');
const Constants = require('discord.js/src/util/Constants.js');
const fs = require('fs');
Constants.DefaultOptions.ws.properties.$browser='Discord Android';
const auth = require('./auth.json');
var sound;
const {exec} = require("child_process");

// Create bot object
const bot = new Discord.Client({autoReconnect:true});

// Display console message when logged in
bot.once('ready', () => {
    console.log('Connected');
    bot.user.setActivity('Puyo Puyo\u2122Tetris\u00AE',{type: 'PLAYING'});
});

// Reconnecting
bot.on("reconnecting", () => {
	console.log("[" + getTime() + "] Reconnecting!");
	});
	
// Resume
bot.on("resume", () => {
	console.log("[" + getTime() + "] Connection restored!");
	bot.user.setActivity('Puyo Puyo\u2122Tetris\u00AE',{type: 'PLAYING'});
	});
	
//bot.on('debug', console.log);
bot.on('message', message => {
    // Prefix is 'o!'
    if (message.content.substring(0, 2) == 'o!') {
        var args = message.content.substring(2).split(' ');
        var cmd = args[0];
       
        args = args.splice(1);
		
		// Commands
        switch(cmd) {
			
			// o!help
			case 'help':
				message.channel.send("Commands:\n\n**General**\n``o!help``: Display this message\n``o!pi``: Make O speak\n\n**Voice**\n``o!voice``: Make O speak for real\n``o!altvoice``: Make O speak in his alternate voice\n``o!jvoice``: Play one of O's Japanese voice lines\n``o!jaltvoice``: Play one of O's alternate Japanese voice lines\n``o!listen``: O-Bot will record your voice and send it back to you! (These recordings are NOT stored locally.)\n``o!dc``: Make O-Bot leave the voice channel\n\n**Other**\n``o!twitch``: Get link for O-Bot creator's Twitch channel\n``o!donate``: Feed O-Bot");
				break;
			
			// o!pi
			case 'pi':
				message.channel.send('Pipi? Pipi-pipipipipi!');
				break;
				
			// o!voice
			case 'voice':
				play(message, "o_sound/000000" + randomHex() + ".wav");
				break;
				
			// o!altvoice
			case 'altvoice':
				play(message, "o_sound/alt/000000" + randomHex() + ".wav");
				break;
				
			// o!jvoice
			case 'jvoice':
				play(message, "o_sound/j/000000" + randomHex() + ".wav");
				break;
				
			// o!jaltvoice
			case 'jaltvoice':
				play(message, "o_sound/j_alt/000000" + randomHex() + ".wav");
				break;

			// o!twitch
			case 'twitch':
				message.channel.send('Pipi!\nhttps://twitch.tv/notengonombreusario');
				break;
			
			// o!donate
			case 'donate':
				message.channel.send('Pipipiii!!\nhttps://streamlabs.com/notengonombreusario');
				break;
				
			// o!dc	
			case 'dc':
				if(!message.member.voice.channel){
					message.channel.send("``o!dc`` can only be run while you are in a voice channel!");
				}
				else{
					message.channel.send("Disconnecting!");
					message.member.voice.channel.leave();
				}
				
				break;
			// o!randomhex
			case 'randomhex':
				message.channel.send("Your random hexadecimal number is " + randomHex());
				break;
				
			// o!time
			case 'time':
				message.channel.send("The current time is " + getTime());
				break;
				
			// o!listen
			case 'listen':
				listen(message);
				break;
	
			// Invalid command
			default:
				message.channel.send("Pipi...\nInvalid command! Use ``o!help`` to list available commands!");
				break;


            // End of command list
		 }
     }
});

async function play(message, sound){
	try{
		const VC = message.member.voice.channel;
			if(!message.guild){
				message.channel.send("The bot cannot join private voice chats.")
			}
			
			else if(!VC){
				message.channel.send("Join a voice channel and try again!");
			}
			
			else if (!VC.permissionsFor(message.client.user).has('CONNECT') || !VC.permissionsFor(message.client.user).has('SPEAK')) {
				message.channel.send('Missing join/speak permissions!');
			 }
		
			else{
				// Here we try to join the voicechat and save our connection into our object.
				var connection = await VC.join();
				//message.channel.send("Playing!");
				console
				const dispatcher = connection.play(sound);
					dispatcher.on("finish", () => {
						//message.channel.send("Disconnecting!");
						dispatcher.destroy();
						//VC.leave();
					})
					.on('error', error => {
						console.error(error);
					});
					
			}
	
	} catch(error){
		console.log(error);
	}
	
}

function randomHex(){
	let hex="";
	let randNum = 0;
	randNum = (Math.floor(Math.random()*Math.floor(41)));
	if(randNum<16){
		hex = "0" + randNum.toString(16);
	}
	else{
		hex = randNum.toString(16);
	}
	
	return hex;
}

function getTime(){
	var date = new Date();
	var hr = date.getHours();
	var AMPM = hr>=12?"PM":"AM";
	hr=((hr+11)%12+1);
	
	var min = date.getMinutes();
	if(min < 10){
		min = "0" + min;
	}
	var sec = date.getSeconds();
	if(sec < 10){
		sec = "0" + sec;
		}
	var time = hr + ":" + min + ":" + sec + " " + AMPM;
	return time;
	}
	
async function listen(message){
	try{
		var date = new Date();
		const VC = message.member.voice.channel;
			if(!message.guild){
				message.channel.send("The bot cannot join private voice chats.");
			}
			
			else if(!VC){
				message.channel.send("Join a voice channel and try again!");
			}
			
			else if (!VC.permissionsFor(message.client.user).has('CONNECT') || !VC.permissionsFor(message.client.user).has('SPEAK')) {
				message.channel.send('Missing join/speak permissions!');
			 }
		
			else{
				
				// Play silence, then start listening
					var connection = await VC.join();
					var user = message.member.user;
					play(message, "ready.wav");
					setTimeout(async () => {
						message.channel.send("Speak now!");
	
						const audio = connection.receiver.createStream(user,{mode: 'pcm'});
						var filename = message.member.user.username + "_" + date.getTime();
						audio.pipe(fs.createWriteStream(filename));
						var cmd = "sox -t raw -r 48000 -e signed -b 16 -c 2 " + filename + " " + filename + ".wav";
						var delcmd = "rm " + filename + ".wav" + " && rm " + filename;
						var wavfile = filename + ".wav";
						
						audio.on('end', async (filename) => {
							message.channel.send("Finished!");
							audio.destroy();
							
							exec(cmd, (error, stdout, stderr) => {
							if(error){
								console.log(error.message);
								return;
								}
							if(stderr){
								console.log(stderr);
								return;
							}
							console.log(stdout);
							});
							
							setTimeout(() =>{
								message.channel.send({
								files: [wavfile]
								});
								},500);
								
							setTimeout(() => {
								exec(delcmd, (error, stdout, stderr) => {
								if(error){
									console.log(error.message);
									return;
									}
								if(stderr){
									console.log(stderr);
									return;
								}
								console.log(stdout);
								})
							},1000);
							})
								
						.on('error', error => {
							console.error(error);
						});
					}, 200);
					
				}
			}
			
		catch(error){
		console.log(error);
	}
			
		
	
}
	

bot.login(auth.token);