im.doctor/src/server/app.js

/**
 * 应用程序入口。
 */
"use strict";

let express = require('express');
let path = require('path');
let favicon = require('serve-favicon');
let logger = require('morgan');
let cookieParser = require('cookie-parser');
let bodyParser = require('body-parser');
let log = require('./util/log');
let redis = require('redis');

// server configurations
let APIv1 = require('./include/endpoints').APIv1;
let PAGES = require('./include/endpoints').PAGES;
let configFile = require('./include/commons').CONFIG_FILE;
let config = require('./resources/config/' + configFile);

// pages
let index = require('./controllers/index');
let socket = require('./controllers/socket');

// endpoints
let application = require('./endpoints/application.endpoint');
let users = require('./endpoints/users.endpoint');
let groups = require('./endpoints/groups.endpoint');
let chats = require('./endpoints/chats.endpoint');
let sessions = require('./endpoints/session.endpoint');
let management = require('./endpoints/management.endpoint');

// handlers
let SocketHandler = require('./handlers/socket.handler');

// schedule
let PushJobLoader = require('./models/schedule/push.job.loader')

// initialize express application
let app = express();
app.set('port', config.serverPort);

// view engine
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'jade');

// logger, body parser, cookie parser and view path
app.use(favicon(__dirname + '/public/favicon.ico', null));
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended: true}));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));

// pages
app.use(PAGES.Home.Index, index);
app.use(PAGES.Socket.Index, socket);

// setup rest endpoints
app.use(APIv1.Application.Base, application);
app.use(APIv1.Chats.Base, chats);
app.use(APIv1.Users.Base, users);
app.use(APIv1.Groups.Base, groups);
app.use(APIv1.Management.Base, management);
app.use(APIv1.Sessions.Base,sessions);
// error handler, only handle the sync call exception
app.use(function (err, req, res, next) {
    if (err) {
        res
            .status(err.httpStatus || 500)
            .send({message: err.message});
    }

    next(err);
});

// In development mode, error handler will print stacktrace, only handle the sync call exception
if (app.get('env') === 'development') {
    app.use(function (err, req, res, next) {
        log.error(err);

        next(err);
    });
}

// only handle the sync call exception
process.on('uncaughtException', function (err) {
    console.error(err);
});

// now enable http server and socket.io
let server = require('http').createServer(app);
let io = require('socket.io').listen(server);

server.listen(config.serverPort);

// event listener for HTTP server "error" event
server.on('error', function (error) {
    if (error.syscall !== 'listen') throw error;

    let bind = typeof port === 'string' ? 'Pipe ' + port : 'Port ' + port;

    // handle specific listen errors with friendly messages
    switch (error.code) {
        case 'EACCES':
            console.error(bind + ' requires elevated privileges');
            process.exit(1);
            break;
        case 'EADDRINUSE':
            console.error(bind + ' is already in use');
            process.exit(1);
            break;
        default:
            throw error;
    }
});

// event listener for HTTP server "listening" event
server.on('listening', function onListening() {
    let addr = server.address();
    let bind = typeof addr === 'string' ? 'pipe ' + addr : 'port ' + addr.port;
});

let socketHandler = new SocketHandler(io);
socketHandler.start();

log.info('Starting IM server, version ' + config.version + ', running on port ' + server.address().port + ', ' + new Date().toLocaleString());
log.info('Configuration profile: ' + configFile.split('.')[1]);