#!/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...');