habitica/website/src/server.js

require('babel/register');
// Only do the minimal amount of work before forking just in case of a dyno restart
var cluster = require("cluster");
var _ = require('lodash');
var nconf = require('nconf');
var utils = require('./libs/utils');
utils.setupConfig();
var logging = require('./libs/logging');
var isProd = nconf.get('NODE_ENV') === 'production';
var isDev = nconf.get('NODE_ENV') === 'development';
var DISABLE_LOGGING = nconf.get('DISABLE_REQUEST_LOGGING');
var cores = +nconf.get("WEB_CONCURRENCY") || 0;

if (cores!==0 && cluster.isMaster && (isDev || isProd)) {
  // Fork workers. If config.json has CORES=x, use that - otherwise, use all cpus-1 (production)
  _.times(cores, cluster.fork);

  cluster.on('disconnect', function(worker, code, signal) {
    var w = cluster.fork(); // replace the dead worker
    logging.info('[%s] [master:%s] worker:%s disconnect! new worker:%s fork', new Date(), process.pid, worker.process.pid, w.process.pid);
  });

} else {
  var express = require("express");
  var http = require("http");
  var path = require("path");
  var swagger = require("swagger-node-express");
  var autoinc = require('mongoose-id-autoinc');
  var shared = require('../../common');

  // Setup translations
  var i18n = require('./libs/i18n');

  var TWO_WEEKS = 1000 * 60 * 60 * 24 * 14;
  var app = express();
  var server = http.createServer();

  // ------------  MongoDB Configuration ------------
  var mongoose = require('mongoose');
  var mongooseOptions = !isProd ? {} : {
    replset: { socketOptions: { keepAlive: 1, connectTimeoutMS: 30000 } },
    server: { socketOptions: { keepAlive: 1, connectTimeoutMS: 30000 } }
  };
  var db = mongoose.connect(nconf.get('NODE_DB_URI'), mongooseOptions, function(err) {
    if (err) throw err;
    logging.info('Connected with Mongoose');
  });
  autoinc.init(db);

  require('./libs/firebase');

  // load schemas & models
  require('./models/challenge');
  require('./models/group');
  require('./models/user');

  // ------------  Passport Configuration ------------
  var passport = require('passport')
  var util = require('util')
  var FacebookStrategy = require('passport-facebook').Strategy;
  // Passport session setup.
  //   To support persistent login sessions, Passport needs to be able to
  //   serialize users into and deserialize users out of the session.  Typically,
  //   this will be as simple as storing the user ID when serializing, and finding
  //   the user by ID when deserializing.  However, since this example does not
  //   have a database of user records, the complete Facebook profile is serialized
  //   and deserialized.
  passport.serializeUser(function(user, done) {
    done(null, user);
  });

  passport.deserializeUser(function(obj, done) {
    done(null, obj);
  });

  // FIXME
  // This auth strategy is no longer used. It's just kept around for auth.js#loginFacebook() (passport._strategies.facebook.userProfile)
  // The proper fix would be to move to a general OAuth module simply to verify accessTokens
  passport.use(new FacebookStrategy({
    clientID: nconf.get("FACEBOOK_KEY"),
    clientSecret: nconf.get("FACEBOOK_SECRET"),
    //callbackURL: nconf.get("BASE_URL") + "/auth/facebook/callback"
  },
    function(accessToken, refreshToken, profile, done) {
      done(null, profile);
    }
   ));

  // ------------  Server Configuration ------------
  var publicDir = path.join(__dirname, "/../public");

  app.set("port", nconf.get('PORT'));

  // Setup two different Express apps, one that matches everything except '/api/v3'
  // and the other for /api/v3 routes, so we can keep the old an new api versions completely separate
  // not sharing a single middleware if we don't want to
  var oldApp = express(); // api v1 and v2, and not scoped routes
  var newApp = express(); // api v3

  // Route requests to the right app
  app.use(app.router);
  // Matches all request except the ones going to /api/v3/**
  app.all(/^(?!\/api\/v3).+/i, oldApp);
  // Matches all requests going to /api/v3
  app.all('/api/v3', newApp);

  require('./middlewares/apiThrottle')(oldApp);
  oldApp.use(require('./middlewares/domain')(server,mongoose));
  if (!isProd && !DISABLE_LOGGING) oldApp.use(express.logger("dev"));
  oldApp.use(express.compress());
  oldApp.set("views", __dirname + "/../views");
  oldApp.set("view engine", "jade");
  oldApp.use(express.favicon(publicDir + '/favicon.ico'));
  oldApp.use(require('./middlewares/cors'));

  var redirects = require('./middlewares/redirects');
  oldApp.use(redirects.forceHabitica);
  oldApp.use(redirects.forceSSL);
  oldApp.use(express.urlencoded());
  oldApp.use(express.json());
  oldApp.use(require('method-override')());
  //oldApp.use(express.cookieParser(nconf.get('SESSION_SECRET')));
  oldApp.use(express.cookieParser());
  oldApp.use(express.cookieSession({ secret: nconf.get('SESSION_SECRET'), httpOnly: false, cookie: { maxAge: TWO_WEEKS }}));
  //oldApp.use(express.session());

  // Initialize Passport!  Also use passport.session() middleware, to support
  // persistent login sessions (recommended).
  oldApp.use(passport.initialize());
  oldApp.use(passport.session());

  oldApp.use(oldApp.router);

  var maxAge = isProd ? 31536000000 : 0;
  // Cache emojis without copying them to build, they are too many
  oldApp.use(express['static'](path.join(__dirname, "/../build"), { maxAge: maxAge }));
  oldApp.use('/common/dist', express['static'](publicDir + "/../../common/dist", { maxAge: maxAge }));
  oldApp.use('/common/audio', express['static'](publicDir + "/../../common/audio", { maxAge: maxAge }));
  oldApp.use('/common/script/public', express['static'](publicDir + "/../../common/script/public", { maxAge: maxAge }));
  oldApp.use('/common/img', express['static'](publicDir + "/../../common/img", { maxAge: maxAge }));
  oldApp.use(express['static'](publicDir));

  // Custom Directives
  oldApp.use(require('./routes/pages').middleware);
  oldApp.use(require('./routes/payments').middleware);
  oldApp.use(require('./routes/api-v2/auth').middleware);
  oldApp.use(require('./routes/api-v2/coupon').middleware);
  oldApp.use(require('./routes/api-v2/unsubscription').middleware);
  var v2 = express();
  oldApp.use('/api/v2', v2);
  oldApp.use('/api/v1', require('./routes/api-v1').middleware);
  oldApp.use('/export', require('./routes/dataexport').middleware);
  require('./routes/api-v2/swagger')(swagger, v2);
  oldApp.use(require('./middlewares/errorHandler'));

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

  module.exports = server;
}