// 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('./utils');
utils.setupConfig();
var logging = require('./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)
  for (var i = 0, n = cores; i < n; i += 1) {
    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 {
  require('coffee-script'); // remove this once we've fully converted over
  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('./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'));
  require('./middlewares/apiThrottle')(app);
  app.use(require('./middlewares/domain')(server,mongoose));
  if (!isProd && !DISABLE_LOGGING) app.use(require('morgan')('dev'));
  app.use(require('compression')());
  app.set('views', __dirname + '/../views');
  app.set('view engine', 'jade');
  app.use(require('serve-favicon')(publicDir + '/favicon.ico'));
  app.use(require('./middlewares/cors'));

  var redirects = require('./middlewares/redirects');
  app.use(redirects.forceHabitica);
  app.use(redirects.forceSSL);

  var bodyParser = require('body-parser');
  // Default limit is 100kb, need that because we actually send whole groups to the server
  // FIXME as soon as possible (need to move on the client from $resource -> $http)    
  app.use(bodyParser.urlencoded({
    limit: '1mb',
    parameterLimit: 10000, // Upped for safety from 1k, FIXME as above
    extended: true // Uses 'qs' library as old connect middleware
  }));
  app.use(bodyParser.json({
    limit: '1mb'
  }));

  app.use(require('method-override')());
  //app.use(express.cookieParser(nconf.get('SESSION_SECRET')));
  app.use(require('cookie-parser')());
  app.use(require('cookie-session')({
    name: 'connect:sess', // Used to keep backward compatibility with Express 3 cookies
    secret: nconf.get('SESSION_SECRET'),
    httpOnly: false,
    maxAge: TWO_WEEKS
  }));

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

  // Custom Directives
  app.use(require('./routes/pages'));
  app.use(require('./routes/payments'));
  app.use(require('./routes/auth'));
  app.use(require('./routes/coupon'));
  app.use(require('./routes/unsubscription'));
  var v2 = express();
  app.use('/api/v2', v2);
  app.use('/api/v1', require('./routes/apiv1'));
  app.use('/export', require('./routes/dataexport'));
  require('./routes/apiv2.coffee')(swagger, v2);

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

  app.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;
}