app.js

'use strict';
/*global global, require, process, module, jsGen, _restConfig*/

var domain = require('domain'),
    http = require('http'),
    fs = require('fs'),
    path = require('path'),
    zlib = require('zlib');
var processPath = path.dirname(process.argv[1]);
var serverDm = domain.create();
global.jsGen = {}; // 注册全局变量jsGen
jsGen.version = '0.5.7';

serverDm.on('error', function (err) {
    delete err.domain;
    jsGen.errlog.error(err);
});
serverDm.run(function () {
    jsGen.conf = module.exports.conf = require('./config/config'); // 注册rrestjs配置文件
    jsGen.module = {};
    jsGen.module.rrestjs = require('rrestjs');
    jsGen.module.marked = require('marked');
    jsGen.module.mongoskin = require('mongoskin');
    jsGen.module.nodemailer = require('nodemailer');
    jsGen.module.xss = require('xss');
    jsGen.errlog = jsGen.module.rrestjs.restlog;
    jsGen.lib = {};
    jsGen.lib.msg = require('./lib/msg.js');
    jsGen.lib.json = require('./lib/json.js');
    jsGen.lib.tools = require('./lib/tools.js');
    jsGen.lib.CacheLRU = require('./lib/cacheLRU.js');
    jsGen.lib.CacheTL = require('./lib/cacheTL.js');
    jsGen.lib.converter = require('./lib/anyBaseConverter.js');
    jsGen.lib.email = require('./lib/email.js');
    jsGen.Err = jsGen.lib.tools.Err;
    jsGen.redis = require('./lib/redis.js');
    jsGen.dao = {};
    jsGen.dao.db = require('./dao/mongoDao.js').db;
    jsGen.dao.article = require('./dao/articleDao.js');
    jsGen.dao.collection = require('./dao/collectionDao.js');
    jsGen.dao.index = require('./dao/indexDao.js');
    jsGen.dao.message = require('./dao/messageDao.js');
    jsGen.dao.tag = require('./dao/tagDao.js');
    jsGen.dao.user = require('./dao/userDao.js');
    jsGen.config = {};
    (function () {
        var that = this;
        this._update = function (obj) {
            jsGen.lib.tools.union(this, obj);
            this._initTime = Date.now();
        };
        jsGen.dao.index.getGlobalConfig(serverDm.intercept(function (doc) {
            if (!doc) {
                var install = require('./api/install.js');
                install(function () {
                    var doc = jsGen.lib.json.GlobalConfig;
                    todo(doc);
                });
            } else {
                todo(doc);
            }

            function todo(doc) {
                var each = jsGen.lib.tools.each,
                    extend = jsGen.lib.tools.extend,
                    api = ['index', 'user', 'article', 'tag', 'collection', 'message'];
                that._update(doc);
                jsGen.cache = {};
                jsGen.cache.pagination = new jsGen.lib.CacheTL(doc.paginationCache[0] * 1000, doc.paginationCache[1]);
                jsGen.cache.timeInterval = new jsGen.lib.CacheTL(doc.TimeInterval * 1000, 0, true);
                jsGen.cache.online = new jsGen.lib.CacheTL(900000, 0, true);
                jsGen.cache.user = new jsGen.lib.CacheLRU(doc.userCache);
                jsGen.cache.article = new jsGen.lib.CacheLRU(doc.articleCache);
                jsGen.cache.comment = new jsGen.lib.CacheLRU(doc.commentCache);
                jsGen.cache.list = new jsGen.lib.CacheLRU(doc.listCache);
                jsGen.cache.tag = new jsGen.lib.CacheLRU(doc.tagCache);
                jsGen.cache.collection = new jsGen.lib.CacheLRU(doc.collectionCache);
                jsGen.cache.message = new jsGen.lib.CacheLRU(doc.messageCache);
                jsGen.cache.updateList = [];
                jsGen.cache.hotsList = [];
                jsGen.cache.hotCommentsList = [];
                jsGen.robot = {};
                jsGen.robot.reg = new RegExp(doc.robots || 'Baiduspider|Googlebot|BingBot|Slurp!', 'i');
                jsGen.api = {};
                each(api, function (x) {
                    jsGen.api[x] = {};
                });
                each(api, function (x) {
                    extend(jsGen.api[x], require('./api/' + x + '.js'));
                });
                fs.readFile(processPath + '/package.json', 'utf8', serverDm.intercept(function (data) {
                    jsGen.config.info = JSON.parse(data);
                    jsGen.config.info.version = jsGen.version;
                    jsGen.config.info.nodejs = process.versions.node;
                    jsGen.config.info.rrestjs = _restConfig._version;
                }));
                createServer();
            }
        }));
    }).call(jsGen.config);
});

function createServer() {
    var server = http.createServer(function (req, res) {
        var dm = domain.create(),
            resJson = jsGen.lib.tools.resJson;
        dm.on('error', function (err) {
            console.log(err);
            delete err.domain;
            err.type = 'error';
            try {
                res.on('finish', function () {
                    //jsGen.dao.db.close();
                    process.nextTick(function () {
                        dm.dispose();
                    });
                });
                if (err.hasOwnProperty('name')) {
                    res.sendjson(resJson(err));
                } else {
                    //console.log('ReqErr:******************');
                    console.log(req.session.Uid + ':' + req.method + ' : ' + req.path);
                    jsGen.errlog.error(err);
                    res.sendjson(resJson(jsGen.Err('对不起，请求出错了！', '请求错误', {
                        type: 'error',
                        url: '/'
                    })));
                }
            } catch (error) {
                delete error.domain;
                //console.log('CatchERR:******************');
                jsGen.errlog.error(error);
                dm.dispose();
            }
        });
        dm.run(function () {
            if (req.path[0] === 'api' && jsGen.api[req.path[1]]) {
                jsGen.api[req.path[1]][req.method.toUpperCase()](req, res, dm);
            } else if (jsGen.robot.reg.test(req.useragent)) {
                jsGen.api.article.robot(req, res, dm);
            } else {
                jsGen.config.visitors += 1;
                jsGen.dao.index.setGlobalConfig({
                    visitors: 1
                });
                res.setHeader("Content-Type", "text/html");
                if (jsGen.indexTpl) {
                    res.send(jsGen.indexTpl);
                } else {
                    fs.readFile(processPath + '/static/index.html', 'utf8', serverDm.intercept(function (data) {
                        jsGen.indexTpl = data.replace(/_jsGenVersion_/g, jsGen.version);
                        res.send(jsGen.indexTpl);
                    }));
                }
            }
        });
    }).listen(jsGen.module.rrestjs.config.listenPort);
}