var readline = require('readline');
var fs = require('fs');
var color = require("ansi-color").set;
var mc = require('minecraft-protocol');
var states = mc.states;
var util = require('util');


var colors = {
  "black": 'black+white_bg',
  "dark_blue": 'blue',
  "dark_green": 'green',
  "dark_aqua": 'cyan',
  "dark_red": 'red',
  "dark_purple": 'magenta',
  "gold": 'yellow',
  "gray": 'black+white_bg',
  "dark_gray": 'black+white_bg',
  "blue": 'blue',
  "green": 'green',
  "aqua": 'cyan',
  "red": 'red',
  "light_purple": 'magenta',
  "yellow": 'yellow',
  "white": 'white',
  "obfuscated": 'blink',
  "bold": 'bold',
  "strikethrough": '',
  "underlined": 'underlined',
  "italic": '',
  "reset": 'white+black_bg'
};

var dictionary = {
  "chat.stream.emote": "(%s) * %s %s",
  "chat.stream.text": "(%s) <%s> %s",
  "chat.type.achievement": "%s has just earned the achievement %s",
  "chat.type.admin": "[%s: %s]",
  "chat.type.announcement": "[%s] %s",
  "chat.type.emote": "* %s %s",
  "chat.type.text": "<%s> %s"
};

var rl = readline.createInterface({
  input: process.stdin,
  output: process.stdout,
  terminal: false
});
var users = JSON.parse(fs.readFileSync('users.txt', 'utf8'));
var userIndex = -1;



function indexOfUser(email){

}
var user = ""
var passwd = ""

function print_help() {
  console.log("usage: node client_chat.js <hostname> <port> <user> [<password>]");
}

if(process.argv.length < 3) {
  if (users.users.length > 0){
	console.log("Too few arguments! setting user to user with email -> " + users.users[0].email );
	user = users.users[0].email;
	passwd = users.users[0].passwd;
  }else {
	console.log("Too few arguments!");
	process.exit(1);
  }
} else {
  user = process.argv[2];
  passwd = process.argv[3];
}

process.argv.forEach(function(val) {
  if(val == "-h") {
    print_help();
    process.exit(0);
  }
});

var host = "mc.freakyville.net"
var port = 25565

users.users.forEach(function iterate(item,index) {
		if (user == item.email){
			 userIndex = index;
			 console.log(userIndex);
		}
	});

if(host.indexOf(':') != -1) {
  port = host.substring(host.indexOf(':') + 1);
  host = host.substring(0, host.indexOf(':'));
}


console.log("connecting to " + host + ":" + port);
console.log("user: " + user);



var client = mc.createClient({
  host: host,
  port: port,
  username: user,
  password: passwd,
  version: '1.10'
});

client.on('kick_disconnect', function(packet) {
  console.info(color('Kicked for ' + packet.reason, "blink+red"));
  //process.exit(1);
});

var chats = [];

client.on('connect', function() {
  console.info(color('Successfully connected to ' + host + ':' + port, "blink+green"));
  setTimeout(function(){
    //do what you need here
	client.write('chat', {message:"/skyblock"});
	setTimeout(function(){
		getAllKits();
		setTimeout(function(){
			client.end();
		},30000)
	}, 2000);
}, 2000);


});

client.on('disconnect', function(packet) {
  console.log('disconnected: '+ packet.reason);
});

client.on('end', function() {
  console.log("Connection lost");
  console.log(userIndex + ":" + users.users.length);
  if ( users.users.length > userIndex ){
	  userIndex++;
	  require('child_process').exec(__dirname + '\\mybat.bat ' + users.users[userIndex].email + ' ' + users.users[userIndex].passwd,function (err, stdout, stderr) {
		  if(err) {
			console.log(err);
		  }
	  });
  }
});



client.on('error', function(err) {
  console.log("Error occured");
  console.log(err);
  //process.exit(1);
});

client.on('state', function(newState) {
  if(newState === states.PLAY) {
    chats.forEach(function(chat) {
      client.write('chat', {message: chat});
    });
  }
});

rl.on('line', function(line) {
  if(line == '') {
    return;
  } else if(line == '/quit') {
    console.info('Disconnected from ' + host + ':' + port);
    client.end();
    return;
  } else if(line == '/end') {
    console.info('Forcibly ended client');
    //process.exit(0);
    return;
  }
  if(!client.write('chat', {message: line})) {
    chats.push(line);
  }
});

client.on('chat', function(packet) {
  var j = JSON.parse(packet.message);
  var chat = parseChat(j, {});
  var lastMsg = ""
  if (lastMsg != chat){
	lastMsg = chat
	console.info(chat);
  }
});


function sendChat(msg){
	client.write('chat', {message: msg});
}

function getAllKits(){
	getKit('konge');
	getKit('op');
	getKit('titan');
	getKit('treasure');
	getKit('madchemist');
}

function getKit(kit){
	sendChat('/kit ' + kit);
}

function parseChat(chatObj, parentState) {
  function getColorize(parentState) {
    var myColor = "";
    if('color' in parentState) myColor += colors[parentState.color] + "+";
    if(parentState.bold) myColor += "bold+";
    if(parentState.underlined) myColor += "underline+";
    if(parentState.obfuscated) myColor += "obfuscated+";
    if(myColor.length > 0) myColor = myColor.slice(0, -1);
    return myColor;
  }

  if(typeof chatObj === "string") {
    return color(chatObj, getColorize(parentState));
  } else {
    var chat = "";
    if('color' in chatObj) parentState.color = chatObj['color'];
    if('bold' in chatObj) parentState.bold = chatObj['bold'];
    if('italic' in chatObj) parentState.italic = chatObj['italic'];
    if('underlined' in chatObj) parentState.underlined = chatObj['underlined'];
    if('strikethrough' in chatObj) parentState.strikethrough = chatObj['strikethrough'];
    if('obfuscated' in chatObj) parentState.obfuscated = chatObj['obfuscated'];

    if('text' in chatObj) {
      chat += color(chatObj.text, getColorize(parentState));
    } else if('translate' in chatObj && dictionary.hasOwnProperty(chatObj.translate)) {
      var args = [dictionary[chatObj.translate]];
      chatObj['with'].forEach(function(s) {
        args.push(parseChat(s, parentState));
      });

      chat += color(util.format.apply(this, args), getColorize(parentState));
    }
    if (chatObj.extra) {
      chatObj.extra.forEach(function(item) {
        chat += parseChat(item, parentState);
      });
    }
    return chat;
  }
}