var mysql = require('mysql');
var WebSocketClient = require('websocket').client

var dbConn = mysql.createConnection({
	host     : 'localhost',
	user     : 'root',
	password : 'rootpassowordlolthisisnotreal',
	database : 'test'
});

dbConn.connect(function(err){
	if(!err) {
		console.log("Database is connected");
	}
	else{
		console.log("Error connecting database");
	}
});

var ws = new WebSocketClient();
var url = "wss://push.planetside2.com/streaming?environment=ps2&service-id=s:Consortium";
ws.connect(url);

// Set event handlers.
ws.on('connectFailed', function(error) {
    console.log('Connect Error: ' + error.toString());
});

ws.on('connect', function(connection) {
    console.log('WebSocket Client Connected');
    connection.on('error', function(error) {
        console.log("Connection Error: " + error.toString());
    });
    connection.on('close', function() {
        console.log('echo-protocol Connection Closed');
    });
    connection.on('message', function(data) {
        if (data.type === 'utf8'){
            onMessage(data.utf8Data);
        }
    });

    if(connection.connected)
	{
		connection.sendUTF('{"service":"event","action":"subscribe","worlds":["all"],"eventNames":["PlayerLogin","PlayerLogout"]}');
	}
});



function onMessage(data){
	data = JSON.parse(data);
	if(data.type == "serviceMessage"){
		var logType = (data.payload.event_name);
		outputLogData(data);
		//getPlayerInfo(data.payload.character_id, logType);
	}
	else if(data.type == "heartbeat"){
		console.log("Heartbeat");
		console.log("");
	}
}

function outputLogData(data){
	console.log("LogType: " + data.payload.event_name);
	console.log("Character ID: " + data.payload.character_id);
	console.log("World ID: " + returnWorldName(data.payload.world_id));
	console.log("Timestamp: " + data.payload.timestamp);
	console.log("");
}




function appendNewPlayer(){

}

var queryString = 'SELECT * FROM testTable';

dbConn.query(queryString, function(err, rows, fields) {
	dbConn.end();
	if (!err){
		console.log('The solution is: ', rows);
	}
	else{
		console.log('Error while performing Query');
	}
});
console.log(" ");

function returnWorldName(id){
	switch(id){
		case "1":
			return "Connery";
			break;
		case "10":
			return "Miller";
			break;
		case "13":
			return "Cobalt";
			break;
		case "17":
			return "Emerald";
			break;
		case "19":
			return "Jaeger";
			break;
		case "25":
			return "Briggs";
			break;

	}
}