apimap.js

var qs = require('querystring');
var users = require("./api/users.js");
var companies = require("./api/companies.js");
var matches = require("./api/matches.js");
var registrations = require("./api/registrations.js");
var init = require("./api/init.js");
var customapi = require("./api/customapi.js");
var merge = require('merge');

init.init();

exports.afterReady = function(callback) { init.afterReady(callback); }

var map = {
	getPlayers:users.getUsers,
	addPlayer:users.addUser,
	editPlayer:users.editUser,
	getPlayersByIds:users.getPlayersByIds,
	getExpectedScores:users.getExpectedScores,
	getRatingChange:users.getRatingChange,
	getMatchUps:users.getMatchUps,
	getMatches:matches.getMatches,
	getMatchesRaw:matches.getMatchesRaw,
	addMatch:matches.addMatch,
	updateMatch:matches.updateMatch,
	matchStatus:matches.getMatchStatus,
	assignCardId:users.assignCardId,
	rebuiltMatchStats:matches.rebuiltMatchStats,
	repeatMatchStats:matches.repeatMatchStats,
	getCompanies:companies.getCompanies,
	getRecentGainers:customapi.getRecentGainers,
	addCompany:companies.addCompany,
	addRegistration:registrations.addRegistration,
	getRegistrations:registrations.getRegistrations,
	activateRegistration:registrations.activeRegistration,
	assignTeam:users.assignTeam,
	leaderboard:customapi.getCustomLeaderboard,
	submitleaderboard:customapi.submitCustomLeaderboard
	};

exports.runAPI = function(request, response)
{
	var OK;
    if (request.method == 'POST') {
        var bodystring = '';
        request.on('data', function (data) {
            bodystring += data;
        });
        request.on('end', function () {
			var body;
			var contentType = request.headers["content-type"];
			if (contentType == "application/json"){
				body = JSON.parse(bodystring);
				var queryParams = require('url').parse(request.url, true).query;
				body = merge(body,queryParams);
			}else{
				body = qs.parse(bodystring);
			}

			console.log("body: "+JSON.stringify(body));

			runAPIBody(body, response);
        });
    }
	else
	{
		var body = require('url').parse(request.url, true).query;
		console.log("body: "+JSON.stringify(body));

		runAPIBody(body, response);
	}
};

function runAPIBody(body, response)
{
	var requestkey = body.request;
	//console.log("runAPI: " + requestkey);
	var apifunction = map[requestkey];
	if(apifunction)
	{
		try
		{
			apifunction(body, onApiFunctionCallback);
		}
		catch (err)
		{
			console.log("Error:", err);
			respondError(response, "Internal error");
		}

		function onApiFunctionCallback(data)
		{
			try
			{
				response.writeHeader(200, {"Content-Type": "text/plain", "Cache-control": "no-cache"});
				response.write(JSON.stringify(data));
				response.end();
			}
			catch (err)
			{
				console.log("Error:", data, err);
				respondError(response, "Internal error");
			}
		}
	}
	else
	{
		respondError(response, "undefined request");
	}
}

function respondError(response, message)
{
	console.log("Erorr with request. "+message);
	response.writeHeader(500, {"Content-Type": "text/plain"});
	response.write('{"status":"error", "message":"'+message+'"}');
	response.end();
}

getFunctionForAPIString = function(apistring)
{
  return map[apistring];
};