#!/usr/bin/env node

"use strict";

var app=require("express")(),
    http=require("http").Server(app),
    io=require("socket.io")(http),
    fs=require("fs"),
    spawn=require("child_process").spawn,
    mkdirp=require("mkdirp"),
    C=require("./common.js");


var HTTPPORT=8090;

var uniqid=(function(){
	var id=0;
	return function(){return id++;};
})();

app.get("/",function(req,res){
	res.sendFile(__dirname+"/index.html");
});

["index.html","common.js","dong.ogg","dong.mp3"].forEach(function(fname){
	app.get("/"+fname,function(req,res){
		res.sendFile(__dirname+"/"+fname);
	});
});

function Game(_np){
	if(!(this instanceof Game))return new Game(_np);
	this.bd=C.emptyboard();
	this.np=_np;
	this.onturn=0;
}
Game.prototype.applymove=function(player,pos){
	if(this.onturn!=player)return false;
	var x=pos%C.W,y=~~(pos/C.W);
	if(x<0||y<0||x>=C.W||y>=C.H){
		console.log("applymove asked to apply on pos ("+x+","+y+")");
		return false;
	}
	if(this.bd[y][x].n&&this.bd[y][x].c!=player)return false;
	this.bd[y][x].c=player;
	this.bd[y][x].n++;
	this.bd=C.stabilise(this.bd);
	this.onturn=(this.onturn+1)%this.np;
	if(C.countballs(this.bd)>=this.np){
		while(C.countballs(this.bd,this.onturn)==0){
			this.onturn=(this.onturn+1)%this.np;
		}
	}
	return true;
};
Game.prototype.checkwin=function(){
	if(C.countballs(this.bd)<this.np)return -1;
	return C.checkwin(this.bd);
};

var connlist=[]; //sorted on id, because uniqid is strictly increasing
var rooms={}; //{<roomid>: {ids:[id's], game:Game}}

function findid(id){
	var lo=0,mid,hi=connlist.length-1;
	if(connlist[lo].id==id)return lo;
	if(connlist[hi].id==id)return hi;
	while(lo<hi){
		mid=lo+(hi-lo)/2|0;
		if(connlist[mid].id==id)return mid;
		if(connlist[mid].id<id)lo=mid+1;
		else hi=mid-1;
	}
	if(hi<lo||connlist[lo].id!=id)return -1; //not found
	return lo;
}

function findname(name){
	var i;
	for(i=0;i<connlist.length;i++)if(connlist[i].name==name)return i;
	return -1;
}

io.on("connection",function(conn){
	var obj={
		id:uniqid(),
		name:"user",
		conn:conn,
		rooms:[],
		pending:[]
	};
	obj.name+=obj.id;
	connlist.push(obj);
	conn.emit("me",[obj.id,obj.name]);
	io.emit("userlist",connlist.map(function(o){return [o.id,o.name];}));

	conn.on("disconnect",function(){
		var idx=findid(obj.id);
		if(idx==-1)return; //WAT
		obj.pending.forEach(function(pendid){
			io.to(pendid).emit("roomdestroy",pendid);
			if(rooms[pendid]){
				rooms[pendid].ids.forEach(function(id){
					var o=connlist[findid(id)];
					o.conn.leave(pendid);
					o.rooms.splice(o.rooms.indexOf(pendid),1);
				});
				delete rooms[pendid];
			}
		});
		obj.rooms.forEach(function(roomid){
			io.to(roomid).emit("roomdestroy",roomid);
			rooms[roomid].ids.forEach(function(id){
				var o=connlist[findid(id)];
				o.conn.leave(roomid);
				o.rooms.splice(o.rooms.indexOf(roomid),1);
			});
			delete rooms[roomid];
		});
		connlist.splice(idx,1);
		io.emit("userlist",connlist.map(function(o){return [o.id,o.name];}));
	});
	conn.on("me",function(cb){
		cb([obj.id,obj.name]);
	});
	conn.on("setnick",function(nick){
		var i;
		if(C.validatenick(nick)){
			if(findname(nick)!=-1){
				i=1;
				while(findname(nick+"_"+i)!=-1)i++;
				nick+="_"+i;
			}
			obj.name=nick;
			conn.emit("me",[obj.id,obj.name]);
			io.emit("userlist",connlist.map(function(o){return [o.id,o.name];}));
		} else conn.emit("message","That's an invalid nick!");
	});
	conn.on("userlist",function(cb){
		cb(connlist.map(function(o){return [o.id,o.name];}));
	});
	conn.on("rooms",function(cb){
		cb(obj.rooms);
	});
	conn.on("createroom",function(ids){ //give all id's, except your own
		var myidx=findid(obj.id);
		var indices=ids.map(function(id){return findid(id);}).filter(function(id){return id!=-1;});
		if(indices.length==0){
			conn.emit("message","Room too small; can only create rooms with 2 or more people");
			return;
		}
		var roomid="room_"+uniqid();
		rooms[roomid]={ids:[obj.id],game:null};
		connlist[myidx].rooms.push(roomid);
		conn.emit("room",roomid,[[obj.id,obj.name]]);
		conn.join(roomid);
		indices.forEach(function(idx){
			connlist[idx].conn.emit("roominvite",roomid,[obj.id,obj.name]);
			connlist[idx].pending.push(roomid);
		});
	});
	conn.on("inviteaccept",function(roomid,wellactuallydecline){
		var idx=obj.pending.indexOf(roomid);
		if(idx!=-1)obj.pending.splice(idx,1);
		if(wellactuallydecline)return;
		if(idx==-1||rooms[roomid]==undefined){
			conn.emit("message","Cannot accept non-existent invitation");
			return;
		}
		obj.rooms.push(roomid);
		conn.emit("room",roomid,rooms[roomid].ids.map(function(id){
			return [id,connlist[findid(id)].name];
		}));
		conn.join(roomid);
		io.to(roomid).emit("roomjoin",roomid,[obj.id,obj.name]);
		rooms[roomid].ids.push(obj.id);
	});
	function guardroomid(roomid){
		if(obj.rooms.indexOf(roomid)==-1){
			conn.emit("message","Not a member of that room!");
			return false;
		}
		return true;
	}
	conn.on("roomdestroy",function(roomid){
		if(!guardroomid(roomid))return;
		io.to(roomid).emit("roomdestroy",roomid);
		rooms[roomid].ids.forEach(function(id){
			var o=connlist[findid(id)];
			o.conn.leave(roomid);
			o.rooms.splice(o.rooms.indexOf(roomid),1);
		});
		delete rooms[roomid];
	});
	conn.on("roomusers",function(roomid,cb){
		if(!guardroomid(roomid)){
			cb(false);
			return;
		}
		cb(rooms[roomid].ids.map(function(id){
			return [id,connlist[findid(id)].name];
		}));
	});
	conn.on("roomchat",function(roomid,message){
		if(!guardroomid(roomid))return;
		conn.broadcast.to(roomid).emit("roomchat",roomid,[obj.id,obj.name],message,false); //send to everyone in room EXCEPT this client
		conn.emit("roomchat",roomid,[obj.id,obj.name],message,true);
	});
	conn.on("roomcreategame",function(roomid){
		if(!guardroomid(roomid))return;
		if(rooms[roomid].game!=null){
			conn.emit("message","Room already has a running game");
			return;
		}
		rooms[roomid].game=new Game(rooms[roomid].ids.length);
		io.to(roomid).emit("roomcreategame",roomid);
		connlist[findid(rooms[roomid].ids[0])].conn.emit("roomgameturn",roomid,0);
	});
	conn.on("roomhasgame",function(roomid,cb){
		if(!guardroomid(roomid))return;
		cb(rooms[roomid].game!=null);
	});
	function guardroomgame(roomid){
		if(rooms[roomid].game==null){
			conn.emit("message","No game in that room!");
			return false;
		}
		return true;
	}
	conn.on("roomgameusers",function(roomid,cb){
		if(!guardroomid(roomid)||!guardroomgame(roomid)){
			cb(false);
			return;
		}
		cb(rooms[roomid].ids.map(function(id){
			return [id,connlist[findid(id)].name];
		}));
	});
	conn.on("roomgameboard",function(roomid,cb){
		if(!guardroomid(roomid)||!guardroomgame(roomid)){
			cb(false);
			return;
		}
		cb(rooms[roomid].game.bd);
	});
	conn.on("roomgameplace",function(roomid,pos){
		if(!guardroomid(roomid)||!guardroomgame(roomid))return;
		var playeridx=rooms[roomid].ids.indexOf(obj.id);
		if(playeridx!=rooms[roomid].game.onturn){
			conn.emit("message","Not your turn! (You are player "+(playeridx+1)+", on turn: "+(rooms[roomid].game.onturn+1)+")");
			return;
		}
		if(!rooms[roomid].game.applymove(playeridx,pos)){
			conn.emit("message","Invalid move!");
			return;
		}
		conn.broadcast.to(roomid).emit("roomgameplace",roomid,pos,playeridx,false);
		conn.emit("roomgameplace",roomid,pos,playeridx,true);
		var win=rooms[roomid].game.checkwin();
		if(win!=-1){
			io.to(roomid).emit("roomgamewin",roomid,playeridx);
			rooms[roomid].game=null;
			return;
		}
		connlist[findid(rooms[roomid].ids[rooms[roomid].game.onturn])].conn.emit("roomgameturn",roomid,rooms[roomid].game.onturn);
	});
});

http.listen(HTTPPORT,function(){
	console.log("Listening on http://localhost:"+HTTPPORT);
});