express.js

// Simulate config options from your production environment by
// customising the .env file in your project's root folder.
require('dotenv').config();

let express = require('express');

let middleware = require('./routes/middleware');

let bodyParser = require('body-parser');
let passport = require('passport');
let OidcStrategy = require('passport-openidconnect');

const cors = require('cors');
const showdown = require('showdown');
const fs = require('fs');

let app = express();
app.locals.clanInvitations = {};

//Define environment variables with default values
process.env.NODE_ENV = process.env.NODE_ENV || 'production';
process.env.WP_URL = process.env.WP_URL || 'https://direct.faforever.com/wp-json';
process.env.WP_NEWSHUB_CATEGORYID = process.env.WP_NEWSHUB_CATEGORYID || '0';
process.env.WP_NEWSHUBARCHIVE_CATEGORYID = process.env.WP_NEWSHUBARCHIVE_CATEGORYID || '0';
process.env.CHALLONGE_USERNAME = process.env.CHALLONGE_USERNAME || 'joe';
process.env.CHALLONGE_APIKEY = process.env.CHALLONGE_APIKEY || '12345';
process.env.PORT = process.env.PORT || '4000';
process.env.OAUTH_URL = process.env.OAUTH_URL || 'https://hydra.test.faforever.com';
process.env.API_URL = process.env.API_URL || 'https://api.test.faforever.com';
process.env.OAUTH_CLIENT_ID = process.env.OAUTH_CLIENT_ID || '12345';
process.env.OAUTH_CLIENT_SECRET = process.env.OAUTH_CLIENT_SECRET || '12345';
process.env.HOST = process.env.HOST || 'http://localhost';
process.env.SESSION_SECRET_KEY = process.env.SESSION_SECRET_KEY || '12345';
process.env.TWITCH_CLIENT_ID = process.env.TWITCH_CLIENT_ID || '12345';
process.env.TWITCH_LIVESTREAM_URL = process.env.TWITCH_LIVESTREAM_URL || 'https://api.twitch.tv/kraken/streams/?game=Supreme%20Commander:%20Forged%20Alliance';

//Execute middleware before each request...
app.use(middleware.initLocals);
app.use(middleware.getLatestClientRelease);
app.use(middleware.clientChecks);

//Set static public directory path
app.use(express.static('public', {
    immutable: true,
    maxAge: 4 * 60 * 60 * 1000 // 4 hours
}));

app.use(bodyParser.urlencoded({extended: false}));
app.use(require('express-session')({
    secret: process.env.SESSION_SECRET_KEY,
    resave: false,
    saveUninitialized: false,
  cookie: {
    maxAge: process.env.TOKEN_LIFESPAN * 1000
  }
}));

//Authentication on pages
app.use(passport.initialize());
app.use(passport.session());
app.use(middleware.username);

//Initialize values for default configs
app.set('views', 'templates/views');
app.set('view engine', 'pug');
app.set('port', process.env.PORT);

//Variable to hold routing path
let routes = './routes/views/';

//Define routes
app.get('/', require(routes + 'index'));

function loggedIn(req, res, next) {
    let fullUrl = req.protocol + '://' + req.get('host') + req.originalUrl;
    req.session.referral = fullUrl;

    if (req.isAuthenticated()) {
        res.locals.username = req.user.data.attributes.userName;
        next();
    } else {
        res.redirect('/login');
    }
}

// ToS and Privacy Statement
function markdown(template) {
  let html = new showdown.Converter().makeHtml(fs.readFileSync(template, 'utf-8'));
  return (req, res) => {
    res.render('markdown', {content: html});
  }
}

app.get('/privacy', markdown("templates/views/privacy.md"));
app.get('/tos', markdown("templates/views/tos.md"));
app.get('/rules', markdown("templates/views/rules.md"));

/// Account routes
// Registration
app.get('/account/register', require(routes + 'accounts/get/register'));
app.post('/account/register', require(routes + 'accounts/post/register'));

app.get('/account/activate', require(routes + 'accounts/get/activate'));
app.post('/account/activate', require(routes + 'accounts/post/activate'));

// Callback for registration to create the account using a token
app.get('/account/create', require(routes + 'accounts/get/createAccount'));

app.get('/account/link', loggedIn, require(routes + 'accounts/get/linkSteam'));
app.get('/account/resync', loggedIn, require(routes + 'accounts/get/resync'));

app.get('/account/connect', loggedIn, require(routes + 'accounts/get/connectSteam'));

app.get('/account/password/reset', require(routes + 'accounts/get/requestPasswordReset'));
app.post('/account/password/reset', require(routes + 'accounts/post/requestPasswordReset'));

app.get('/account/password/confirmReset', require(routes + 'accounts/get/confirmPasswordReset'));
app.post('/account/password/confirmReset', require(routes + 'accounts/post/confirmPasswordReset'));

app.get('/account/report', loggedIn, require(routes + 'accounts/get/report'));
app.post('/account/report', loggedIn, require(routes + 'accounts/post/report'));

app.get('/account/password/change', loggedIn, require(routes + 'accounts/get/changePassword'));
app.post('/account/password/change', loggedIn, require(routes + 'accounts/post/changePassword'));

app.get('/account/username/change', loggedIn, require(routes + 'accounts/get/changeUsername'));
app.post('/account/username/change', loggedIn, require(routes + 'accounts/post/changeUsername'));

app.get('/account/email/change', loggedIn, require(routes + 'accounts/get/changeEmail'));
app.post('/account/email/change', loggedIn, require(routes + 'accounts/post/changeEmail'));

app.get('/account_activated', require(routes + 'accounts/get/register'));
app.get('/password_resetted', require(routes + 'accounts/get/requestPasswordReset'));
app.get('/report_submitted', require(routes + 'accounts/get/report'));
app.get('/client', require(routes + 'client'));
app.get('/livestream', require(routes + 'livestream'));
app.get('/contribution', require(routes + 'contribution'));
app.get('/newshub', require(routes + 'newshub'));
app.get('/competitive/tournaments', require(routes + 'tournaments'));
app.get('/competitive/leaderboards/1v1', require(routes + '1v1'));
app.get('/competitive/leaderboards/global', require(routes + 'global'));
app.get('/competitive/leaderboards/leagues', (function(){
    let updateLeagues = require("./scripts/updateLeagues");
    let ladderData = {};
    let updateFunction = function(){
        try {
            updateLeagues.run(ladderData).then(function(ladderUpdatedData){
                ladderData = ladderUpdatedData;
            });
        } catch (e) {
            console.error("Error while updating ladder week!", e);
        }
    };
    setInterval( 
      updateFunction
    ,   parseInt(process.env.LEAGUES_UPDATE_INTERVAL) * 1000);
    
    updateFunction();
    
    return function(res, req){ 
        require(routes + 'leagues')(res, req, ladderData);
    }
})()
);
app.get('/lobby_api', cors(), require('./routes/lobby_api'));
app.get('/account/checkUsername', require('./routes/views/checkUsername'));

app.get('/clans', require(routes + 'clans/get/index'));

app.get('/clans/create', loggedIn, require(routes + 'clans/get/create'));
app.get('/clans/manage', loggedIn, require(routes + 'clans/get/manage'));
app.get('/clans/see', require(routes + 'clans/get/see'));
app.get('/clans/browse', require(routes + 'clans/get/browse'));
app.get('/clans/accept', loggedIn, require(routes + 'clans/get/accept'));

app.post('/clans/create', loggedIn, require(routes + 'clans/post/create'));
app.post('/clans/destroy', loggedIn, require(routes + 'clans/post/destroy'));
app.post('/clans/invite', loggedIn, require(routes + 'clans/post/invite'));
app.post('/clans/kick', loggedIn, require(routes + 'clans/post/kick'));
app.post('/clans/transfer', loggedIn, require(routes + 'clans/post/transfer'));
app.post('/clans/update', loggedIn, require(routes + 'clans/post/update'));
app.post('/clans/leave', loggedIn, require(routes + 'clans/post/leave'));

// Compatibility
app.get('/clan/*', function (req, res){
    const id = req.path.split("/").slice(-1)[0];
    res.redirect('/clans/see?id='+id);

});

app.get('/news/', require(routes + 'blog'));
app.get('/category/:category/page/:page', require(routes + 'blog'));
app.get('/news/search/:search/page/:page', require(routes + 'blog'));
app.get('/tag/:tag/page/:page', require(routes + 'blog'));
app.get('/author/:author/page/:page', require(routes + 'blog'));
app.get('/news/page/:page', require(routes + 'blog'));
app.get('/:year/:month/:slug', require(routes + 'post'));

app.get('/logout', function (req, res) {
    req.logout();
    res.redirect('/');
});

app.get('/login', passport.authenticate('faforever', {
    failureRedirect: '/login',
    failureFlash: true
}), function (req, res) {
    req.logout();
    res.redirect('/');
});

passport.use('faforever', new OidcStrategy({
    issuer: process.env.OAUTH_URL + '/',
    tokenURL: process.env.OAUTH_URL + '/oauth2/token',
    authorizationURL: process.env.OAUTH_URL + '/oauth2/auth',
    userInfoURL: process.env.OAUTH_URL + '/userinfo?schema=openid',
    clientID: process.env.OAUTH_CLIENT_ID,
    clientSecret: process.env.OAUTH_CLIENT_SECRET,
    callbackURL: process.env.HOST + '/callback',
    scope: ['openid', 'public_profile', 'write_account_data']
  },
  function (iss, sub, profile, jwtClaims, accessToken, refreshToken, params, verified) {
    let request = require('request');
    request.get(
      {url: process.env.API_URL + '/me', headers: {'Authorization': 'Bearer ' + accessToken}},
      function (e, r, body) {
        if (r.statusCode !== 200) {
          return verified(null);
        }
        let user = JSON.parse(body);
        user.data.attributes.token = accessToken;
        user.data.id = user.data.attributes.userId;
        return verified(null, user);
      }
        );
    }
));

passport.serializeUser(function (user, done) {
    done(null, user);
});

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

app.get('/callback', passport.authenticate('faforever', {
    failureRedirect: '/login',
    failureFlash: true
}), function (req, res, next) {
    res.redirect(req.session.referral ? req.session.referral : '/');
    req.session.referral = null;
});

//404 Error Handler
app.use(function (req, res, next) {
    res.status(404).render('errors/404');
});

//Display 500 Error Handler if in development mode.
if (process.env.NODE_ENV === 'development') {
    app.enable('verbose errors');

    //500 Error Handler
    app.use(function (err, req, res, next) {
        res.status(500).render('errors/500', {error: err});
    });
}

let extractor = require("./scripts/extractor");
let getLatestClientRelease = require("./scripts/getLatestClientRelease");
let getRecentUsers = require("./scripts/getRecentUsers");
let getAllClans = require("./scripts/getAllClans");

// Run scripts initially on startup
try{
    extractor.run();
    getLatestClientRelease.run();
    getRecentUsers.run();
    getAllClans.run();
}
catch(e){
    console.error("Error while running update scripts. Make sure the API is available. Those scripts will run again after some time - no need to restart the website.", e);
}

// Run leaderboard extractor every minute
setInterval(() => {
    try {
        extractor.run();
    } catch (e) {
        console.error("Error while updating leaderboards!", e);
    }
},  parseInt(process.env.LEADERBOARDS_UPDATE_INTERVAL) * 1000);

// Run recent players detection every 15 minutes
setInterval(() => {
    try {
        getRecentUsers.run();
    } catch (e) {
        console.error("Error while updating recent user list!", e);
    }
},  parseInt(process.env.RECENT_USERS_LIST_UPDATE_INTERVAL) * 1000);

// Run recent players detection every 15 minutes
setInterval(() => {
    try {
        getAllClans.run();
    } catch (e) {
        console.error("Error while updating the clan list!", e);
    }
},  parseInt(process.env.CLAN_LIST_UPDATE_INTERVAL) * 1000);

// Run client release fetcher every 15 minutes
setInterval(() => {
    try {
        getLatestClientRelease.run();
    } catch (e) {
        console.error("Error while fetching latest client release!", e);
    }
},  parseInt(process.env.CLIENT_RELEASE_FETCHING_INTERVAL) * 1000);

//Start and listen on port
app.listen(process.env.PORT, function () {
    console.log('Express listening on port ' + process.env.PORT);
});