/* Copyright: (c) Kayne Ruse 2013
 * 
 * This software is provided 'as-is', without any express or implied
 * warranty. In no event will the authors be held liable for any damages
 * arising from the use of this software.
 * 
 * Permission is granted to anyone to use this software for any purpose,
 * including commercial applications, and to alter it and redistribute it
 * freely, subject to the following restrictions:
 * 
 * 1. The origin of this software must not be misrepresented; you must not
 * claim that you wrote the original software. If you use this software
 * in a product, an acknowledgment in the product documentation would be
 * appreciated but is not required.
 * 
 * 2. Altered source versions must be plainly marked as such, and must not be
 * misrepresented as being the original software.
 * 
 * 3. This notice may not be removed or altered from any source
 * distribution.
*/
#include "server_application.hpp"

#include <stdexcept>
#include <iostream>

using namespace std;

//-------------------------
//Public access members
//-------------------------

ServerApplication::ServerApplication() {
	//
}

ServerApplication::~ServerApplication() {
	//
}

/* ServerApplication::Init()
 * This function initializes the entire program. There are a number of things
 * that could go wrong here, which is why there is such an unusual order of
 * operations.
 * Important things to note:
 *   The APIs are initiated here.
 *   The global objects are initialized here.
 *   The ConfigUtility's call to Load() also ensures that the "rsc\" folder is in the directory. It's easy to forget it.
*/

void ServerApplication::Init() {
	//load the config file
	try {
		configUtil->Load("rsc/config.cfg");
	}
	catch(std::runtime_error& e) {
		std::string s = e.what();
		s += "; Ensure that the \"rsc\" directory is present";
		throw(std::runtime_error(s));
	}

	//check the port is valid
	if (configUtil->Int("server.port") <= 0) {
		throw(runtime_error("Cannot open the server on an invalid port or port 0"));
	}

	//initialize the APIs
	if (SDLNet_Init()) {
		throw(runtime_error("Failed to initialize SDL_net"));
	}

	//initiate the remaining singletons
	netUtil->Open(configUtil->Int("server.port"), sizeof(Packet));

	//create the threads
	beginQueueThread();

	//output the server information
	cout << configUtil->String("server.name") << endl;
	cout << "Open on port " << configUtil->String("server.port") << endl;

	//disable this for debugging
	running = true;
}

void ServerApplication::Proc() {
	Clock::duration delta = Clock::now() - lastTick;
	lastTick = Clock::now();
	while(running) {
		try {
			//process all packets on the network queue
			while(HandlePacket(popNetworkPacket()));
		}
		catch(exception& e) {
			cerr << "Network Error: " << e.what() << endl;
		}
		UpdateWorld(double(delta.count()) / Clock::duration::period::den);
		SDL_Delay(10);
	}
}

void ServerApplication::Quit() {
	//close the threads
	endQueueThread();

	//clean up the singletons
	netUtil->Close();

	//deinitialize the APIs
	SDLNet_Quit();
}

//-------------------------
//Game loop
//-------------------------

void ServerApplication::UpdateWorld(double delta) {
	for (auto it : players) {
		it.second.Update(delta);
	}
}

//-------------------------
//Network loop
//-------------------------

int ServerApplication::HandlePacket(Packet p) {
	switch(p.meta.type) {
		case PacketType::NONE:
			//DO NOTHING
			return 0;
		break;
		case PacketType::PING:
			//quick pong
			p.meta.type = PacketType::PONG;
			netUtil->Send(&p.meta.address, &p, sizeof(Packet));
		break;
		case PacketType::PONG:
			//
		break;
		case PacketType::BROADCAST_REQUEST:
			HandleBroadcast(p.broadcastRequest);
		break;
//		case PacketType::BROADCAST_RESPONSE:
//			//
//		break;
		case PacketType::JOIN_REQUEST:
			HandleConnection(p.joinRequest);
		break;
//		case PacketType::JOIN_RESPONSE:
//			//
//		break;
		case PacketType::DISCONNECT:
			HandleDisconnection(p.disconnect);
		break;
//		case PacketType::SYNCHRONIZE:
//			//
//		break;
//		case PacketType::PLAYER_NEW:
//			//
//		break;
//		case PacketType::PLAYER_DELETE:
//			//
//		break;
//		case PacketType::PLAYER_MOVE:
//			//
//		break;
		default:
			throw(runtime_error("Failed to recognize the packet type: " + itos(int(p.meta.type))));
	}
	return 1;
}

void ServerApplication::HandleBroadcast(BroadcastRequest& bcast) {
	//respond to a broadcast request with the server's data
	Packet p;
	p.meta.type = PacketType::BROADCAST_RESPONSE;
	snprintf(p.broadcastResponse.name, PACKET_STRING_SIZE, "%s", configUtil->CString("server.name"));
	//TODO version information
	netUtil->Send(&bcast.meta.address, &p, sizeof(Packet));
}

void ServerApplication::HandleConnection(JoinRequest& request) {
	if (clients.size() >= SDLNET_MAX_UDPCHANNELS) {
		//ignore the new connection if there's too many clients connected
		return;
	}
	//create the containers
	ClientData client = { uniqueIndex++ };

	//bind the address
	client.channel = netUtil->Bind(&request.meta.address);

	//push this information
	clients[client.index] = client;

	//send the player their information
	Packet p;
	p.meta.type = PacketType::JOIN_RESPONSE;
	p.joinResponse.clientIndex = client.index;
	//TODO: resource list
	netUtil->Send(client.channel, &p, sizeof(Packet));

	//pretty
	cout << "New connection: index " << client.index << endl;
	cout << "number of clients: " << clients.size() << endl;
}

void ServerApplication::HandleDisconnection(Disconnect& disconnect) {
	//disconnect a client (redundant message)
	netUtil->Send(clients[disconnect.clientIndex].channel, &disconnect, sizeof(Packet));
	netUtil->Unbind(clients[disconnect.clientIndex].channel);
	clients.erase(disconnect.clientIndex);

	//remove the player...

	//pretty
	cout << "Lost connection: index " << disconnect.clientIndex << endl;
	cout << "number of clients: " << clients.size() << endl;
}