90 linhas
2.6 KiB
JavaScript
Arquivo Executável
90 linhas
2.6 KiB
JavaScript
Arquivo Executável
#!/usr/bin/env node
|
|
var sys = require('util'),
|
|
express = require('express'),
|
|
packages = require('./libs/packages'),
|
|
o_ = require('./libs/utils');
|
|
|
|
o_.merge(global, require('./settings'));
|
|
try { o_.merge(global, require('./settings.local')); } catch(e) {}
|
|
|
|
var app = express();
|
|
//app.set('env', 'development');
|
|
app.use( require('request-param')() )
|
|
|
|
app.use(require('method-override')());
|
|
app.use(require('cookie-parser')());;
|
|
//app.use(require('body-parser')());;
|
|
app.use(require('body-parser').urlencoded({extended: true}));;
|
|
app.use(require('body-parser').json());;
|
|
app.use(require('./middleware/im')({
|
|
maxAge: 15 * 60 * 1000,
|
|
reapInterval: 60 * 1000,
|
|
authentication: require('./libs/authentication/' + AUTH_LIBRARY)
|
|
}));
|
|
|
|
app.set('root', __dirname);
|
|
|
|
if ('development' == app.get('env')) {
|
|
app.set('views', __dirname + '/dev/views');
|
|
app.set('view engine', 'jade');
|
|
|
|
app.use(require("morgan")("dev"));
|
|
require('./dev/app')('/dev', app);
|
|
app.use(express.static(
|
|
require('path').join(__dirname, '../client')));
|
|
app.use(require('express-error-handler')({dumpExceptions: true, showStack: true}));
|
|
}
|
|
|
|
app.listen(APP_PORT, APP_HOST);
|
|
|
|
// Listener endpoint; handled in middleware
|
|
app.get('/app/listen', function(){});
|
|
|
|
app.use('/app/message', function(req, res) {
|
|
|
|
res.find(req.param('to'), function(user) {
|
|
if(!user)
|
|
return res.send(new packages.Error('not online'));
|
|
|
|
res.message(user, new packages.Message(
|
|
req.session.data('username'),
|
|
req.param('body')
|
|
));
|
|
});
|
|
});
|
|
|
|
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) {
|
|
res.message(user, new packages.Status(
|
|
req.session.data('username'),
|
|
'typing' + req.param('state')
|
|
));
|
|
}
|
|
|
|
// Typing updates do not receive confirmations,
|
|
// as they are not important enough.
|
|
res.send('');
|
|
});
|
|
} else {
|
|
res.send(new packages.Error('invalid state'));
|
|
}
|
|
});
|
|
|
|
app.use('/app/status', function(req, res) {
|
|
if(~packages.STATUSES.indexOf(req.param('status'))) {
|
|
res.status(req.param('status'), req.param('message'));
|
|
res.send(new packages.Success('status updated'));
|
|
} else {
|
|
res.send(new packages.Error('invalid status'));
|
|
}
|
|
});
|
|
|
|
app.use('/app/signoff', function(req, res) {
|
|
res.signOff();
|
|
res.send(new packages.Success('goodbye'));
|
|
});
|
|
|
|
console.log('Ajax IM server started...');
|