ranvier

#!/usr/bin/env node
/**
 * Main file, use this to run the server:
 * node ranvier [options]
 *
 * Options:
 *   -v Verbose loggin
 *   --port Port to listen on
 *   --locale Locale to act as the default
 *   --save Minutes between autosave
 *   --respawn Minutes between respawn
 */


    // built-ins
var net = require('net'),
    util = require('util'),
    express = require('express'),

    // local
    Commands = require('./src/commands').Commands,
    Rooms    = require('./src/rooms').Rooms,
    Npcs     = require('./src/npcs').Npcs,
    Items    = require('./src/items').Items,
    Data     = require('./src/data').Data,
    Events   = require('./src/events').Events,
	Plugins  = require('./src/plugins'),
    PlayerManager = require('./src/player_manager').PlayerManager,

    // third party
    Localize  = require('localize'),
    argv = require('optimist').argv,
    telnet = require('./src/3rdparty/telnet.js');

/**
 * These aren't really globals, they're only "global" to this file,
 * we'll pass them around via construction as needed
 */
	// cmdline options
var locale  = argv.locale || 'en',
	port    = argv.port || 6250,
    verbose = !!argv.v,
	save_interval    = isNaN(parseInt(argv.save, 10)) ? 10 : parseInt(argv.save, 10), // number of minutes between autosave ticks
	respawn_interval = isNaN(parseInt(argv.respawn, 10)) ? 20 : parseInt(argv.respawn, 10), // "" between respawn tickets

	//storage of main game entities
	players,
	rooms = new Rooms(),
	items = new Items(),
	npcs  = new Npcs(),
	server,
	
	// Stuff for the server executable
	l10n,
	respawnint,
	saveint;

/**
 * Do the dirty work
 */
var init = function (restart_server)
{
	util.log("START - Loading entities");
	players = new PlayerManager([]);
	restart_server = typeof restart_server === 'undefined' ? true : restart_server;

	Commands.configure({
		rooms: rooms,
		players: players,
		items: items,
		npcs: npcs,
		locale: locale
	});

	Events.configure({
		players: players,
		items: items,
		locale:  locale,
		npcs: npcs,
		rooms: rooms
	});

	if (restart_server) {
		util.log("START - Starting server");

		/**
		* Effectively the 'main' game loop but not really because it's a REPL
		*/
		server = new telnet.Server(function (socket) {
			socket.on('interrupt', function () {
				socket.write("\n*interrupt*\n");
			});

			// Register all of the events
			for (var event in Events.events) {
				socket.on(event, Events.events[event]);
			}

			socket.write("Connecting...\n");
			util.log("User connected...");
			// @see: src/events.js - Events.events.login
			socket.emit('login', socket);

		});

		// start the server
		server.listen(port);


		// save every 10 minutes
		util.log("Setting autosave to " + save_interval + " minutes.");
		clearInterval(saveint);
		var saveint = setInterval(save, save_interval * 60000);

		// respawn every 20 minutes, probably a better way to do this
		util.log("Setting respawn to " + respawn_interval + " minutes.");
		clearInterval(respawnint);
		var respawnint = setInterval(load, respawn_interval * 60000);
		
		clearInterval(loggingint);
		var loggingint = setInterval(logging, 60000);

		Plugins.init(true, {
			players: players,
			items:   items,
			locale:  locale,
			npcs:    npcs,
			rooms:   rooms,
			server:  server
		});

	}

	load(function (success) {
		if (success) {
			util.log("Server started...");
			server.emit('startup');
		} else {
			process.exit(1);
		}
	});
};


// START IT UP!
init();


/**
 * Logging the statistics
 */

// Helper function to create a valid key for JavaScript
function dateToStr(dt) { return 'D' + String(dt.getFullYear()) + '_' + String((dt.getMonth() + 1)) + '_' + String(dt.getDate()); }

function logging() {
	var fs = require('fs'),
		daily = {},
		current = [],
		dailyFile = '',
		currentFile = '';

	try {
		dailyFile = fs.readFileSync('./stats/daily.counts', 'ascii');
		if (dailyFile !== false) daily = JSON.parse(dailyFile);
	} catch (err) { }

	try {
		currentFile = fs.readFileSync('./stats/current.counts', 'ascii');
		if (currentFile !== false) current = JSON.parse(currentFile);
	} catch (err) { }

	if (current.length > 60) { current.shift(); }

	var now = new Date();
	var dateStr = dateToStr(now);
	current.push({dt: now.getTime(), count: players.players.length});

	if (Object.keys(daily).length == 0) {
		daily = JSON.parse('{"' + dateStr + '":{"current":0,"high":0,"hours":[]}}');
	} else if (typeof(daily[dateStr]) == 'undefined') {
		var days30 = now;
		daily[dateStr] = { current: 0, high: 0, hours: [] };
		days30.setDate(days30.getDate() - 30);
		if (Object.keys(daily).length > 30) { delete daily[dateToStr(days30)]; }
		util.log(JSON.stringify(daily));
	}
	
	daily[dateStr].current = players.players.length;
	daily[dateStr].high = ( daily[dateStr].high < daily[dateStr].current ? daily[dateStr].current : daily[dateStr].high );
	if (typeof(daily[dateStr].hours) == 'undefined') { daily[dateStr].hours = []; }
	if (typeof(daily[dateStr].hours[now.getHours()]) == 'undefined') { daily[dateStr].hours[now.getHours()] = 0; }
	daily[dateStr].hours[now.getHours()] = ( daily[dateStr].hours[now.getHours()] < daily[dateStr].current ? daily[dateStr].current : daily[dateStr].hours[now.getHours()] );
	fs.writeFileSync('./stats/daily.counts', JSON.stringify(daily), 'ascii');
	fs.writeFileSync('./stats/current.counts', JSON.stringify(current), 'ascii');
}

/**
 * Save all connected players
 */
function save()
{
	util.log("Saving...");
	players.each(function (p) {
		p.save();
	});
	util.log("Done");
}

/**
 * Load rooms, items, npcs. Register items and npcs to their base locations.
 * Configure the event and command modules after load. Doubles as a "respawn"
 */
function load(callback)
{
	util.log("Loading rooms...");
	rooms.load(verbose, function () {
		util.log("Done.");
		util.log("Loading items...");
		items.load(verbose, function () {
			util.log("Done.");

			util.log("Adding items to rooms...");
			items.each(function (item) {
				if (item.getRoom()) {
					var room = rooms.getAt(item.getRoom());
					if (!room.hasItem(item.getUuid())) {
						room.addItem(item.getUuid());
					}
				}
			});
			util.log("Done.");

			util.log("Loading npcs...")
			npcs.load(verbose, function () {
				util.log("Done.");

				util.log("Adding npcs to rooms...");
				npcs.each(function (npc) {
					if (npc.getRoom()) {
						var room =rooms.getAt(npc.getRoom());
						if (!room.hasNpc(npc.getUuid())) {
							room.addNpc(npc.getUuid());
						}
					}
				});
				util.log("Done.");
				if (callback) {
					callback(true);
				}
			});
		})
	});
}


// Not game stuff, this is for the server executable
process.stdin.setEncoding('utf8');
l10n = new Localize(require('js-yaml').load(require('fs').readFileSync(__dirname + '/l10n/server.yml').toString('utf8')), undefined, 'zz');

/**
 * Commands that the server executable itself accepts
 */
var server_commands = {
	/**
	 * Hotboot, AKA do everything involved with a restart but keep players connected
	 */
	hotboot : function (args)
	{
		args = args ? args.split(' ') : [];
		var warn = args[0] && args[0] === 'warn';
		var time = args[0] ? parseInt(args[warn ? 1 : 0], 10) : 0;

		if (time && time < 20) {
			console.log("Gotta give the players a bit longer than that, might as well do it instantly...");
			return;
		}
		time = time ? time * 1000 : 0;

		if (warn) {
			warn = function (interval) {
				players.broadcastL10n(l10n, 'HOTBOOT_WARN', interval);
				players.each(function(p) {p.prompt();});
			};
			warn(time / 1000 + " seconds");
			setTimeout(function () { warn(Math.floor((time / 4) / 1000) + " seconds"); }, time - Math.floor(time / 4));
		}

		util.log("HOTBOOTING SERVER" + (time ? " IN " + (time / 1000) + " SECONDS " : ''));
		setTimeout(function () {
			util.log("HOTBOOTING...");
			save();
			init(false);
		}, time);
	},
	/**
	 * Hard restart: saves and disconnects all connected players
	 */
	restart: function (args)
	{
		args = args ? args.split(' ') : [];
		var warn = args[0] && args[0] === 'warn';
		var time = args[0] ? parseInt(args[warn ? 1 : 0], 10) : 0;

		if (time && time < 20) {
			console.log("Gotta give the players a bit longer than that, might as well do it instantly...");
			return;
		}
		time = time ? time * 1000 : 0;

		if (warn) {
			warn = function (interval) {
				players.broadcastL10n(l10n, 'RESTART_WARN', interval);
				players.each(function(p) {p.prompt();});
			};
			warn(time / 1000 + " seconds");
			setTimeout(function () { warn(Math.floor((time / 4) / 1000) + " seconds"); }, time - Math.floor(time / 4));
		}

		util.log("RESTARTING SERVER" + (time ? " IN " + (time / 1000) + " SECONDS " : ''));
		setTimeout(function () {
			util.log("RESTARTING...");
			save();
			server.emit('shutdown');
			server.close();
			players.each(function (p) { p.getSocket().end(); });
			init(true);
		}, time);
	}
};
//
//process.on('SIGINT', function ()
//{
//	util.log("Shutting down - not so gracefully...");
//	process.exit(0);
//});
//
process.stdin.resume();
process.stdin.on('data', function (data)
{
	data = data.trim();
	var command = data.split(' ')[0];
	
	if (!(command in server_commands)) {
		console.log("That's not a real command...");
		return;
	}

	server_commands[command](data.split(' ').slice(1).join(' '));
});
// vim: set syn=javascript :