Cache clearing, default channel bug fix, embedded image clicking bug fix

[KiwiIRC.git] / node / kiwi.js

/*jslint continue: true, forin: true, regexp: true, undef: false, node: true, nomen: true, plusplus: true, maxerr: 50, indent: 4 */
"use strict";
var tls = require('tls'),
    net = require('net'),
    http = require('http'),
    https = require('https'),
    fs = require('fs'),
    url = require('url'),
    dns = require('dns'),
    crypto = require('crypto'),
    ws = require('socket.io'),
    jsp = require("uglify-js").parser,
    pro = require("uglify-js").uglify,
    _ = require('./lib/underscore.min.js'),
    starttls = require('./lib/starttls.js'),
    app = require(__dirname + '/app.js');





// Libraries may need to know kiwi.js path as __dirname
// only gives that librarys path. Set it here for usage later.
this.kiwi_root = __dirname;



/*
 * Configuration and rehashing routines
 */
var config_filename = 'config.json',
    config_dirs = ['/etc/kiwiirc/', this.kiwi_root + '/'];

this.config = {};
this.loadConfig = function () {
    var i, j,
        nconf = {},
        cconf = {},
        found_config = false;
    
    for (i in config_dirs) {
        try {
            if (fs.lstatSync(config_dirs[i] + config_filename).isDirectory() === false) {
                found_config = true;
                nconf = JSON.parse(fs.readFileSync(config_dirs[i] + config_filename, 'ascii'));
                for (j in nconf) {
                    // If this has changed from the previous config, mark it as changed
                    if (!_.isEqual(this.config[j], nconf[j])) {
                        cconf[j] = nconf[j];
                    }

                    this.config[j] = nconf[j];
                }

                console.log('Loaded config file ' + config_dirs[i] + config_filename);
                break;
            }
        } catch (e) {
            switch (e.code) {
            case 'ENOENT':      // No file/dir
                break;
            default:
                console.log('An error occured parsing the config file ' + config_dirs[i] + config_filename + ': ' + e.message);
                return false;
            }
            continue;
        }
    }
    if (Object.keys(this.config).length === 0) {
        if (!found_config) {
            console.log('Couldn\'t find a config file!');
        }
        return false;
    }
    return [nconf, cconf];
};


// Reloads the config during runtime
this.rehash = function () {
    return app.rehash();
}

// Reloads app.js during runtime for any recoding
this.recode = function () {
    if (typeof require.cache[this.kiwi_root + '/app.js'] !== 'undefined'){
        delete require.cache[this.kiwi_root + '/app.js'];
    }

    app = null;
    app = require(__dirname + '/app.js');

    var objs = {tls:tls, net:net, http:http, https:https, fs:fs, url:url, dns:dns, crypto:crypto, ws:ws, jsp:jsp, pro:pro, _:_, starttls:starttls};
    app.init(objs);

    return true;
}






/*
 * Before we continue we need the config loaded
 */
if (!this.loadConfig()) {
    process.exit(0);
}







/*
 * HTTP file serving
 */
if (this.config.handle_http) {
    this.fileServer = new (require('node-static').Server)(__dirname + this.config.public_http);
    this.jade = require('jade');
    this.cache = {alljs: '', html: []};
}
this.httpServer = null;
this.httpHandler = function (request, response) {
    return app.httpHandler(request, response);
}






/*
 * Websocket handling
 */
this.connections = {};
this.io = null;
this.websocketListen = function (port, host, handler, secure, key, cert) {
    return app.websocketListen(port, host, handler, secure, key, cert);
}
this.websocketConnection = function (websocket) {
    return app.websocketConnection(websocket);
}
this.websocketDisconnect = function () {
    return app.websocketDisconnect(this);
}
this.websocketMessage = function (msg, callback) {
    return app.websocketMessage(this, msg, callback);
}
this.websocketIRCConnect = function (nick, host, port, ssl, callback) {
    return app.websocketIRCConnect(this, nick, host, port, ssl, callback);
}




/*
 * IRC handling
 */
this.parseIRCMessage = function (websocket, ircSocket, data) {
    return app.parseIRCMessage(websocket, ircSocket, data);
}
this.ircSocketDataHandler = function (data, websocket, ircSocket) {
    return app.ircSocketDataHandler(data, websocket, ircSocket);
}









/*
 * Load up main application source
 */
if (!this.recode()) {
    process.exit(0);
}



// Set the process title
app.setTitle();



/*
 * Load the modules as set in the config and print them out
 */
this.kiwi_mod = require('./lib/kiwi_mod.js');
this.kiwi_mod.loadModules(this.kiwi_root, this.config);
this.kiwi_mod.printMods();




// Start the server up
this.websocketListen(this.config.port, this.config.bind_address, this.httpHandler, this.config.listen_ssl, this.config.ssl_key, this.config.ssl_cert);

// Now we're listening on the network, set our UID/GIDs if required
app.changeUser();

// Listen for controll messages
app.startControll();