server.js

"use strict";
var logger = require('./common/logger')(process.env.NODE_ENV || 'development');
var express = require('express.io');
var http = require('http');
var swig = require('swig');
var fs = require('fs');
var db = require('./models');
var controllers_path = __dirname + '/controllers';
var config = require('./config.json')[process.env.NODE_ENV || 'development'];
var passport = require('passport');
var flash = require('connect-flash');
var bcrypt = require('bcrypt');
var RedisStore = require('connect-redis')(express.session);
var _ = require('lodash');
var querystring = require('querystring');

var GitHubStrategy = require('passport-github').Strategy;
var LocalStrategy = require('passport-local').Strategy;
var GITHUB_CLIENT_ID = process.env.GITHUB_CLIENT_ID || "bd50fa6daf6a89fbf00e";
var GITHUB_CLIENT_SECRET = process.env.GITHUB_CLIENT_SECRET || "45fa3e239b03d97c1624adf908dd1e6dfd895404";
var GITHUB_REDIRECT =  process.env.GITHUB_REDIRECT || "http://localhost/auth/github/callback";


var app = express();


app.http().io();
app.set('env', process.env.NODE_ENV || 'development');
app.configure('development', function () {
    app.engine('html', swig.renderFile);
    app.set('port', config.app.port);
    app.set('redisPort', config.redis.port);
    app.set('redisHost', config.redis.host);
    app.set('view cache',false);
    swig.setDefaults({ cache: false });
});
app.configure('production', function () {
    app.engine('html', swig.renderFile);
    app.set('port', config.app.port);
    app.set('redisPort', config.redis.port);
    app.set('redisHost', config.redis.host);
});
app.set('view engine', 'html');
app.set('logger', logger);
app.set('views', __dirname + '/views');
app.use('/app/partials', express.static(__dirname + '/views/angular'));
app.use('/app', express.static(__dirname + '/assets/dist'));
app.use('/app', express.static(__dirname + '/assets/src'));
app.use('/app', express.static(__dirname + '/assets/src/bower_components'));

app.use(express.cookieParser());
app.use(express.bodyParser());
app.use(express.methodOverride());
app.use(express.session({
    store: new RedisStore({
        host : app.get('redisHost'),
        port : app.get('redisPort')
    }),
    secret: 'keyboard cat'
}));
app.use(passport.initialize());
app.use(passport.session());
app.use(flash());


app.use(function(req, res, next) {
    app.set('error', req.flash('error'));
    app.set('success', req.flash('success'));
    app.set('notifications', req.flash('notifications'));
    app.set('req', req);
    next();
});

swig.setFilter('substring', function (input, count) {
    return input && input.toString().substr(0, count);
});

swig.setFilter('map', function(input,key){
    console.log("MAP:",_.map(_.map(input, key), function(item){
        return item;
    }));
    return _.map(_.map(input, key), function(item){
        return item;
    });
});

swig.setFilter('in', function(val,array){
    console.log("VAL:",val);
    console.log("ARR:",array);
    console.log("RES:",_.contains(array,val));
    return _.contains(array,val);
});

app.locals.buildPages = function(total,perpage,current,req){
    var pages = [];
    var q = req.query || {};
    for(var i = 1; i <= total / perpage; ++i){
        q.page = i;
        pages.push({
            num : i,
            current : i == current,
            path : querystring.stringify(q)
        });
    }
    console.log("PAGES",pages);
    return pages;
};
app.locals.req = function(){
    if(app.get('req')){
        return app.get('req');
    }
    return null;
};
app.locals.getNotifications = function(){
    if(app.get('notifications') && app.get('notifications').length > 0){
        return app.get('notifications')[0];
    }
    if(app.get('error') && app.get('error').length > 0){
        return {
            status : "error",
            message : app.get('error')
        };
    }
    if(app.get('success') && app.get('success').length > 0){
        return {
            status : "success",
            message : app.get('success')
        };
    }
    return null;
};

var repos_path = __dirname + '/repository';
var repos = {};
fs.readdirSync(repos_path).forEach(function (file) {
    var name = file.replace('.js', '');
    repos[name] = require(repos_path + '/' + file);
});
app.set("repos", repos);

var Accounts = app.get("repos").AccountsRepo;

passport.serializeUser(function (user, done) {
    done(null, user.id);
});
passport.deserializeUser(function (id, done) {
    Accounts.get(id).then(function(user){
        done(null, user);
    })
});
passport.use(new GitHubStrategy({
        clientID: GITHUB_CLIENT_ID,
        clientSecret: GITHUB_CLIENT_SECRET,
        callbackURL: GITHUB_REDIRECT
    },
    function (accessToken, refreshToken, profile, done) {
        if(profile._json.email){
            Accounts.getByEmail(profile._json.email).then(function (account) {
                if(account){
                    Accounts.update(account.username, {
                        token : accessToken
                    },true).then(function(account){
                        done(null, account, { message: 'Logged in' });    
                    });
                }else{
                    Accounts.create({
                        username : profile._json.login,
                        email: profile._json.email,
                        password: null,
                        token : accessToken
                    },true).then(function (account) {
                        done(null, account, { message: 'Logged in' });  
                    }).finally(function () {
                        console.log("ACCOUNT DONE");
                    });
                }
            });
        }else{
            done(null,null);
        }
    }
));
passport.use(new LocalStrategy(
    function (email, password, done) {
        var user;
        Accounts.getByEmail(email).then(function (account) {
            if(!account){
                this.reject();
                return this.promise;
            }
            user = account;
            return Accounts.checkPassword(password || "", account.password);
        }).then(function(valid){
            if (valid) {
                done(null, user, { message: 'Logged in' });
            }else {
                done(null,null, { message: 'Incorrect email or password' });
            }
        }).catch(function(){
            done(null,null, { message: 'Incorrect email or password' });
        });
    }
));

fs.readdirSync(controllers_path).forEach(function (file) {
    require(controllers_path + '/' + file)(app);
});

app.listen(app.get('port'),function () {
    logger.info("Express server listening on port " + app.get('port'));
});

app.on('error',function(){
    logger.error("Uncaught exception: " + err);
});

return app;