Daniel Howard
109 linhas
3.1 KiB
JavaScript
Arquivo Executável
109 linhas
3.1 KiB
JavaScript
Arquivo Executável
#!/usr/bin/env node
|
|
var express = require('express'),
|
|
app = express(),
|
|
http = require('http').Server(app),
|
|
io = require('socket.io')(http),
|
|
sys = require('sys'),
|
|
packages = require('./libs/packages'),
|
|
o_ = require('./libs/utils');
|
|
|
|
o_.merge(global, require('./settings'));
|
|
try { o_.merge(global, require('./settings.local')); } catch(e) {}
|
|
|
|
//app.set('env', 'development');
|
|
app.use(require('method-override')());
|
|
app.use(require('cookie-parser')());
|
|
app.use(require('body-parser').json());
|
|
var mw = require('./middleware/im')({
|
|
maxAge: 60 * 1000,
|
|
reapInterval: 60 * 1000,
|
|
authentication: require('./libs/authentication/' + AUTH_LIBRARY)
|
|
});
|
|
app.use(mw.session);
|
|
var hub = mw.hub;
|
|
|
|
app.set('root', __dirname);
|
|
|
|
if ('development' == app.get('env')) {
|
|
app.set('views', __dirname + '/dev/views');
|
|
app.set('view engine', 'jade');
|
|
|
|
app.use(require("morgan")());
|
|
require('./dev/app')('/dev', app);
|
|
app.use(express.static(
|
|
require('path').join(__dirname, '../client')));
|
|
app.use(require('express-error-handler')({dumpExceptions: true, showStack: true}));
|
|
}
|
|
|
|
io.on('connection', function(socket){
|
|
socket.on('server', function(event) {
|
|
if (event.type == 'hello') {
|
|
event.socketio = socket;
|
|
hub.get(event, function(err, sess) {
|
|
sess.touch();
|
|
store.set(event.sessionID, sess);
|
|
});
|
|
} else {
|
|
hub.find(event.from, function(from) {
|
|
from.socketio = socket;
|
|
from.dispatch(hub, event);
|
|
});
|
|
}
|
|
});
|
|
});
|
|
|
|
http.listen(APP_PORT, APP_HOST, function(){
|
|
console.log('Ajax IM server started...');
|
|
});
|
|
|
|
// Listener endpoint; handled in middleware
|
|
app.get('/app/listen', function(){});
|
|
|
|
app.use('/app/message', function(req, res) {
|
|
res.find(req.param('to'), function(to) {
|
|
if(to) {
|
|
res.message(to, req.event);
|
|
} else {
|
|
req.event._status = {sent: false, e: 'not online'};
|
|
res.jsonp(req.event);
|
|
}
|
|
});
|
|
});
|
|
|
|
app.use('/app/message/typing', function(req, res) {
|
|
if(~packages.TYPING_STATES.indexOf('typing' + req.param('state'))) {
|
|
res.find(req.param('to'), function(user) {
|
|
if(user) {
|
|
req.event.status = 'typing' + req.param('state');
|
|
res.message(user, req.event);
|
|
} else {
|
|
// Typing updates do not receive confirmations,
|
|
// as they are not important enough.
|
|
req.event._status = {sent: false, e: 'invalid user'};
|
|
res.jsonp(req.event);
|
|
}
|
|
});
|
|
} else {
|
|
req.event._status = {sent: false, e: 'invalid state'};
|
|
res.jsonp(req.event);
|
|
}
|
|
});
|
|
|
|
app.use('/app/status', function(req, res) {
|
|
if(~packages.STATUSES.indexOf(req.param('status'))) {
|
|
res.status(req.event);
|
|
} else {
|
|
req.event._status = {sent: false, e: 'invalid status'};
|
|
res.jsonp(req.event);
|
|
}
|
|
});
|
|
|
|
app.use('/app/noop', function(req, res) {
|
|
req.event._status = {sent: true};
|
|
res.jsonp(req.event);
|
|
});
|
|
|
|
app.use('/app/signoff', function(req, res) {
|
|
res.signOff(req.event);
|
|
});
|