main.js

/*
    This file is part of Ironbane MMO.

    Ironbane MMO is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    Ironbane MMO is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with Ironbane MMO.  If not, see <http://www.gnu.org/licenses/>.
*/

var path = require('path'),
    config = require('./nconf'),
    pkg = require('./package.json'),
    log = require('util').log,
    Q = require('q');

// track root path of this file, so no matter where the game is launched from we have the base for require
global.APP_ROOT_PATH = __dirname;

var isProduction = config.get('isProduction');
var cryptSalt = config.get('cryptSalt');

// profiling...
if (!isProduction && config.get('use_nodetime')) {
    require('nodetime').profile(config.get('nodetime'));
}

var clientDir = config.get('buildTarget') + 'game/';
var assetDir = config.get('assetDir');

if (!cryptSalt) {
    var warn = function() {
        console.log("Warning: no password hash set! Your server works, but is very insecure. Edit config.json and set the cryptSalt variable.");
    };
    if (isProduction) {
        setInterval(warn, 1000);
    } else {
        setTimeout(warn, 3000);
    }
}

// System start
var SERVER = true;

var fs = require('fs');
var spawn = require('child_process').spawn;
var window = {};

// Custom
var NameGen = require('./External/namegen.js');
var wrench = require('wrench');
var crypto = require('crypto');

var util = require('./Engine/ibutil.js');
var fsi = require('./External/fsi.js');

// https://github.com/chriso/node-validator
var check = require('validator').check,
    sanitize = require('validator').sanitize;

var _ = require('underscore');

var THREE = require('./src/client/game/lib/three/three.js');

// Everything runs on one database, since the db is not hurt that bad by performance
// We cut the middle man and only use mysql occasionally to save/load data
// Start MySQL - has to be here for global access below...
var mysql = require('./src/server/db');

var GameEngine = require('./src/server/game/engine');

// create game server, do it first so that the other 2 "servers" can query it
var engine;

// create express.io server
var HttpServer,
    httpServer;

// for the global access coming...todo: refactor
var io,
    ioApp;

// setup REPL for console server mgmt
var startREPL = function() {
    if(config.get('use_repl') === true){
        var repl = require('repl');

        // Not game stuff, this is for the server executable
        process.stdin.setEncoding('utf8');

        // startup a full node repl for javascript awesomeness
        var serverREPL = repl.start({
           prompt: "ironbane> ",
           input: process.stdin,
           output: process.stdout
        });

        serverREPL.on('exit', function() {
           // todo: other shutdown stuff, like stop db, etc.


           process.exit();

        });

        // context variables get attached to "global" of this instance
        serverREPL.context.version = pkg.version;
        serverREPL.context.httpServer = httpServer;
    }
    if(config.get('use_netrepl') === true){
    	// Add UNIX socket to REPL for awesome realtime debugging
    	// We take the sweetest auto-complete with colors available module
    	var repl = require('net-repl');

    	var options = {
    	    prompt: 'ironbane> ',
    	    deleteSocketOnStart: true,
    	    useGlobal: true,
    	    useColors: true
    	}

    	var socketPath = "/tmp/ibs-" + config.get('mysql_database');
    	var srv = repl.createServer(options).listen(socketPath);
    }
};

// Necessary to prevent 'Mysql has gone away' errors
// Use it check for restarting on git push
var shuttingDown = false;

function keepAlive() {
    //mysql.query('SELECT 1');
    if (shuttingDown) {
        return;
    }

    mysql.query('SELECT value FROM ib_config WHERE name = ?', ["restart"], function(err, results, fields) {
        if (err) {
            throw err;
        }

        if (results.length) {
            shuttingDown = true;

            global.chatHandler.announce("&lt;Server&gt; New update available!", "red");
            global.chatHandler.announce("&lt;Server&gt; Auto-restarting in 10 seconds...", "red");

            // Disconnect all clients first
            io.sockets.emit("disconnect");

            setTimeout(function() {
                mysql.query('DELETE FROM ib_config WHERE name = ?', ["restart"], function(err, results, fields) {
                    if (err) {
                        throw err;
                    }

                    process.exit();
                });
            }, 20000);
        }

    });
    return;
}

var LoadActorScripts = function() {
    var scriptPath = assetDir + 'scripts',
        fs = require('q-io/fs'),
        path = require('path'),
        actorScripts = {};

    return fs.listTree(scriptPath, function(file) {
        return path.extname(file) === '.js';
    }).then(function(files) {
        console.log('loading actor scripts...' + files.length);
        _.each(files, function(file) {
            console.log("loading... " + path.basename(file));

            try {
                var script = require(path.resolve(file, '.')); // does this fix both nix & windows?

                // script should be an object to add
                _.each(_.keys(script), function(key) {
                    global.actorScripts[key] = script[key];
                });
            } catch(e) {
                console.error("error loading script!!" + e);
            }
        });

        return actorScripts;
    }, function(err) {
        console.log('error loading asset scripts! ', err);
        return {};
    });
};

function start(scripts) {

    // create express.io server
    HttpServer = require('./src/server/http/server').Server;
    httpServer = new HttpServer({
        db: mysql
    });

    // for the global access coming...todo: refactor
    io = httpServer.server.io;
    ioApp = httpServer.server;

    // load constants (was Shared.js)
    var IB = require('./src/common/constants');
    // inject into global until rest is modular
    _.extend(global, IB);

    // temporarily global services
    global.itemTemplateService = require('./src/server/services/itemTemplate');
    global.itemService = require('./src/server/services/item');

    // temporarily global entities
    global.ItemTemplate = require('./src/server/entity/itemTemplate');
    global.Item = require('./src/server/entity/item');

    // Load DataHandler global for now (holds memory DB of item and unit templates)
    global.dataHandler = require('./src/server/game/dataHandler');

    // load AI as a module
    var AI = require('./src/server/game/ai');
    // temp pass them on to global for access below
    global.StateMachine = AI.StateMachine;
    global.State = AI.State;
    _.extend(global, AI.States);

    // READ REST OF OLD GLOBAL APP HERE
    for (var f = 0; f < includes.length; f++) {
        log("Loading: " + includes[f]);
        eval(fs.readFileSync(includes[f]) + '');
    }

    // temp hack
    global.worldHandler = worldHandler;

    global.actorScripts = {};
    LoadActorScripts()
        .then(function(scripts) {

            _.extend(global.actorScripts, scripts);

            // Load Chat module - after worldHandler, there is a dep
            global.chatHandler = require('./src/server/game/chat')(io, global.dataHandler.units, global.worldHandler);

            // All set! Tell WorldHandler to load
            return worldHandler.loadWorld();

        }).then(function() {

            return worldHandler.Awake(); // Awaken units after loading

        }).then(function() {

            // create game server, do it first so that the other 2 "servers" can query it
            engine = new GameEngine();

            engine.on('start', function() {
                engine.tick();
            });


            engine.on('tick', function(elapsed) {
                server.tick(elapsed);
                setTimeout(function() {
                    engine.tick.bind(engine);
                }, 100 );
            });

            engine.start();

            // start it up, todo: only per config?
            startREPL();

            setInterval(keepAlive, 10000);

            setInterval(function() {
                worldHandler.autoSave();
            }, 60 * 1 * 1000);

            // Schedule an auto-restart to prevent EM readfile errors
            // We can only prevent this by upgrading to a real dedicated server, which we will do
            // when we have more people. Currently IB runs on a VPS.
            setTimeout(function() {
                global.chatHandler.announce("This server needs to restart in order to keep it running smoothly. The restart will happen in 1 minute. Your progress will be saved.", "red");
                setTimeout(function() {
                    process.exit();
                }, 60000);
            }, 60 * 60 * 24 * 1000);

        });
}

// These are all to be converted to modules
var includes = [
    '/Shared/seedrandom.js',
    '/Shared/Buffs.js',
    '/Shared/Util.js',
    '/Engine/worldhandler/snapshots.js',
    '/Engine/worldhandler/zones.js',
    '/Engine/ConsoleCommand.js',
    '/Engine/ConsoleHandler.js',
    '/Engine/Switch.js',
    '/Engine/SocketHandler.js',
    '/Engine/worldhandler/index.js',
    '/Game/SteeringBehaviour.js',
    '/Game/Unit.js',
    '/Game/MovingUnit.js',
    '/Game/Actor.js',
    '/Game/Fighter.js',
    '/Game/NPC.js',
    '/Game/Lootable.js',
    '/Game/Player.js',
    '/Game/Special/MovingObstacle.js',
    '/Game/Special/ToggleableObstacle.js',
    '/Game/Special/Train.js',
    '/Game/Special/Lever.js',
    '/Game/Special/TeleportEntrance.js',
    '/Game/Special/TeleportExit.js',
    '/Game/Special/Sign.js',
    '/Game/Special/Waypoint.js',
    '/Game/Special/trigger.js',
    '/Game/bank.js', // subclass of trigger
    '/Game/Special/HeartPiece.js',
    '/Game/Special/MusicPlayer.js',
    '/Server.js'
];

includes = _.map(includes, function(include) {
    return APP_ROOT_PATH + include;
});

start(includes);