var express = require('express');
var app = express();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var fs = require('fs');
var sharp = require('sharp');



var userCounter = 0;

var usersOnline = new Object();
var usersOnlineSendable = new Object();

app.get('/', function(req, res){
	console.log(new Date().getTime() + ":[get: /]");
	res.sendFile(__dirname + '/public/index.html');
});

app.use(express.static('public'));

function addToOnlineUsers(user, name, socket){
	usersOnline[user] = {"user": user, "name": name, "socket": socket};
	usersOnlineSendable[user] = {"user": user, "name": name};
}
function remFromOnlineUsers(user, name){
	delete usersOnline[user];
	delete usersOnline[""+user];
	delete usersOnlineSendable[user];
	delete usersOnlineSendable[""+user];
}
function changeUserName(user, newuser){
	var index = user;
	if (index === 0 || (index && index !== -1)){
		usersOnline[index] = {"user": user, "name": newuser, "socket": usersOnline[index].socket};
		usersOnlineSendable[index] = {"user": user, "name": newuser};
	}
}
function userExists(userName){
	var toReturn = false;
	for (elem in usersOnline){
		if (usersOnline[elem].name == userName){
			toReturn = true;
		}
	}
	return toReturn;
}
function isLegalUserName(wantedUser){
	var toReturn = true;
	if (wantedUser.indexOf("/") > -1 || wantedUser.indexOf("@") > -1 || wantedUser.indexOf(":") > -1){
		toReturn = false;
	}
	if (userExists(wantedUser)){
		toReturn = false;
	}
	return toReturn;
}

function getUserSocketBy(field, val){
	var toReturn = undefined;
	for (elem in usersOnline){
		if (usersOnline[elem][field] == val){
			toReturn = usersOnline[elem].socket;
			break;
		}
	}
	return toReturn;
}

function loopFun(){
	for (elem in usersOnline){
		io.emit("nxt-online-users", JSON.stringify(usersOnlineSendable));
		break;
	}
}
var loopInterval = setInterval(loopFun, 1000);

function sendChatMessage(type, msg){
	// /@Pipoo:
	
	if (msg.content.indexOf("/@") == 0 && msg.content.indexOf(":")>-1){
		//private message
		privDest = msg.content.substring(2, msg.content.indexOf(":"));
		privMess = msg.content.substring(msg.content.indexOf(":")+1);
		console.log("i have to send " + privMess + " only to " + privDest);
		var targetSocket = getUserSocketBy("name", privDest);
		msg.content = privMess;
		msg.messageType = "private message";
		targetSocket.emit('private message', JSON.stringify(msg));
	}else{
		//public message
		io.emit(type, JSON.stringify(msg));
	}
	
	
}

io.on('connection', function(socket){
	var userId = userCounter++;
	var userName = "Anonymous"+userId;
	console.log(new Date().getTime() + ":[new connection] user " + userName);
	var jsonConnected = {
		content: "connected",
		contentType: "System",
		messageType: 'nxt-broadcast',
		ts: new Date().getTime(),
		user: userName
	}
	//io.emit("nxt-broadcast", "connected user: " + userName);
	io.emit("nxt-broadcast", JSON.stringify(jsonConnected));
	addToOnlineUsers(userId, userName, socket);
	
	socket.on('disconnect', function(){
		console.log(new Date().getTime() + ":[disconnected] user " + userName);
		//io.emit('nxt-broadcast', "disconnected user: " + userName);
		var jsonConnected = {
			content: "disconnected",
			contentType: "System",
			messageType: 'nxt-broadcast',
			ts: new Date().getTime(),
			user: userName
		}
		io.emit("nxt-broadcast", JSON.stringify(jsonConnected));
		remFromOnlineUsers(userId, userName);
	});
	socket.on('chat message1', function(msg){
		console.log('user ' + userName + ' chat message 1: ' + msg);
		var parsedMsg = JSON.parse(msg);
		parsedMsg.user = userName;
		sendChatMessage('chat message1', parsedMsg);
		//io.emit('chat message1', JSON.stringify(parsedMsg));
	});
	socket.on('chat message2', function(msg){
		console.log('user ' + userName + ' chat message 2: ' + msg);
		var parsedMsg = JSON.parse(msg);
		parsedMsg.user = userName;
		//io.emit('chat message1', JSON.stringify(parsedMsg));
		sendChatMessage('chat message2', parsedMsg);
	});
	socket.on('chat message3', function(msg){
		console.log('user ' + userName + ' chat message 3: ' + msg);
		var parsedMsg = JSON.parse(msg);
		parsedMsg.user = userName;
		//io.emit('chat message1', JSON.stringify(parsedMsg));
		sendChatMessage('chat message3', parsedMsg);
	});
	socket.on('change name', function(msg){
		console.log('user ' + userName + ' changed name with: ' + msg);
		var json = JSON.parse(msg);
		
		var wantedUser = json.content;
		json.user = userName;
		if (isLegalUserName(wantedUser)){
			io.emit('change name', JSON.stringify(json));
			userName = json.content;
			changeUserName(userId, userName);
		}else{
			json.messageType = 'invalid change name';
			io.emit('invalid change name', JSON.stringify(json));
		}
		
		
	});
	
	socket.on('image-base64', function(msg){
		//console.log('user ' + userName + ' sent image in base64: ' + msg);
		console.log('user ' + userName + ' sent an image');
		var json = JSON.parse(msg);
		//data:image/jpeg;base64,
		//socket.emit('image', { image: true, buffer: buf.toString('base64') });
		
		var nomeFile = json.contentName;
		var extension = "";
		var extension = json.content.indexOf("/png") || json.content.indexOf("/apng") ? ".png" : extension;
		var extension = json.content.indexOf("/jpg") || json.content.indexOf("/jpeg") ? ".jpg" : extension;
		
		nomeFile = userName + "_" + json.ts + extension;
		
		console.log('user ' + userName + ' saving file name: ' + nomeFile);
		
		
		var fs = require('fs');
		var dir = "./public/imagesFull/"+userName;
		var dir2 = "./public/imagesThumb/"+userName;
		if (!fs.existsSync(dir)){
			fs.mkdirSync(dir);
		}
		if (!fs.existsSync(dir2)){
			fs.mkdirSync(dir2);
		}
		
		var base64Data = json.content.replace(/^data:image\/png;base64,/, "");
		base64Data = base64Data.replace(/^data:image\/jpeg;base64,/, "");
		base64Data = base64Data.replace(/^data:image\/jpg;base64,/, "");
		base64Data = base64Data.replace(/^data:image\/apng;base64,/, "");
		
		fs.writeFile(dir +"/"+nomeFile, base64Data, 'base64', function(err) {
			console.log(err);
		});
		
		let imgBuffer =  Buffer.from(base64Data, 'base64');
   	
		sharp(imgBuffer)
			.resize(160, 120)
			.toFile(dir2 + "/" + nomeFile, function(err, info) {
				console.log(err);
				json.content = dir2.replace("./public/", "/") +"/"+nomeFile;
				json.contentFull = dir.replace("./public/", "/") +"/"+nomeFile;
				json.user = userName;
				json.messageType = "image-link";
				
				console.log("To return: " + JSON.stringify(json));
				
				io.emit('image-link', JSON.stringify(json));
			});
			
		return false;
	});
});

http.listen(3001, function(){
  console.log('listening on *:3001');
});