#include "ChatWebApi.h"

#include <cstdint>

#include "dCommonVars.h"
#include "eConnectionType.h"
#include "eChatMessageType.h"
#include "httplib.h"
#include "dServer.h"
#include "PlayerContainer.h"
#include "dConfig.h"
#include "httplib.h"
#include "json.h"

namespace {
	httplib::Server m_APIServer;
}

void ChatWebApi::Listen(const uint32_t port) {
	if (Game::config->GetValue("enable_chat_web_api") != "1") {
		LOG("Chat Web API is disabled");
		return;
	}
	LOG("Chat Web API is enabled, starting web server...");

	m_APIServer.Post("/announce", [](const httplib::Request& req, httplib::Response& res) {
		const json data = json::parse(req.body);
		if (!data.contains("title")) {
			res.set_content("{\"error\":\"Missing paramater: title\"}", "application/json");
			res.status = 400;
			return;
		}
		std::string title = data["title"];
		if (!data.contains("message")) {
			res.set_content("{\"error\":\"Missing paramater: message\"}", "application/json");
			res.status = 400;
			return;
		}
		std::string message = data["message"];
		// build and send the packet to all world servers
		CBITSTREAM;
		BitStreamUtils::WriteHeader(bitStream, eConnectionType::CHAT, eChatMessageType::GM_ANNOUNCE);
		bitStream.Write<uint32_t>(title.size());
		bitStream.Write(title);
		bitStream.Write<uint32_t>(message.size());
		bitStream.Write(message);
		Game::server->Send(bitStream, UNASSIGNED_SYSTEM_ADDRESS, true);
	});

	m_APIServer.Get("/players", [](const httplib::Request& req, httplib::Response& res) {
		auto data = json::array();
		for (auto& [playerID, playerData ]: Game::playerContainer.GetAllPlayers()){
			if (!playerData) continue;
			data.push_back(playerData.to_json());
		}
		res.set_content(data.dump(), "application/json");
		if (data.empty()) res.status = 204;
	});

	m_APIServer.Get("/teams", [](const httplib::Request& req, httplib::Response& res) {
		auto data = json::array();
		for (auto& teamData: Game::playerContainer.GetAllTeams()){
			if (!teamData) continue;
			json toInsert;
			toInsert["id"] = teamData->teamID;
			toInsert["loot_flag"] = teamData->lootFlag;
			toInsert["local"] = teamData->local;

			auto leader = Game::playerContainer.GetPlayerData(teamData->leaderID);
			toInsert["leader"] = leader.to_json();

			json members;
			for (auto& member : teamData->memberIDs){
				auto playerData = Game::playerContainer.GetPlayerData(member);
				if (!playerData) continue;
				members.push_back(playerData.to_json());
			}
			toInsert["members"] = members;
			data.push_back(toInsert);
		}
		res.set_content(data.dump(), "application/json");
		if (data.empty()) res.status = 204;
	});

	m_APIServer.listen(Game::config->GetValue("chat_web_api_listen_address").c_str(), port);
};

void ChatWebApi::Stop(){
	LOG("Stopping Chat Web API server...");
	m_APIServer.stop();
}