var fs = require('fs'); var path = require('path'); var async = require('async'); var dot = require('dot'); var express = require('express'); var bodyParser = require('body-parser'); var compress = require('compression'); var watch = require('node-watch'); var api = require('./api.js'); module.exports = function(logger){ var portalConfig = JSON.parse(process.env.portalConfig); var poolConfigs = JSON.parse(process.env.pools); var websiteConfig = portalConfig.website; var portalApi = new api(logger, portalConfig, poolConfigs); var portalStats = portalApi.stats; var logSystem = 'Website'; var pageFiles = { 'index.html': 'index', 'home.html': '', 'getting_started.html': 'getting_started', 'stats.html': 'stats', 'api.html': 'api', 'admin.html': 'admin' }; var pageTemplates = {}; var pageProcessed = {}; var indexesProcessed = {}; var processTemplates = function(){ for (var pageName in pageTemplates){ if (pageName === 'index') continue; pageProcessed[pageName] = pageTemplates[pageName]({ poolsConfigs: poolConfigs, stats: portalStats.stats, portalConfig: portalConfig }); indexesProcessed[pageName] = pageTemplates.index({ page: pageProcessed[pageName], selected: pageName, stats: portalStats.stats, poolConfigs: poolConfigs, portalConfig: portalConfig }); } //logger.debug(logSystem, 'Stats', 'Website updated to latest stats'); }; var readPageFiles = function(files){ async.each(files, function(fileName, callback){ var filePath = 'website/' + (fileName === 'index.html' ? '' : 'pages/') + fileName; fs.readFile(filePath, 'utf8', function(err, data){ var pTemp = dot.template(data); pageTemplates[pageFiles[fileName]] = pTemp callback(); }); }, function(err){ if (err){ console.log('error reading files for creating dot templates: '+ JSON.stringify(err)); return; } processTemplates(); }); }; //If an html file was changed reload it watch('website', function(filename){ var basename = path.basename(filename); if (basename in pageFiles){ console.log(filename); readPageFiles([basename]); logger.debug(logSystem, 'Server', 'Reloaded file ' + basename); } }); portalStats.getGlobalStats(function(){ readPageFiles(Object.keys(pageFiles)); }); var buildUpdatedWebsite = function(){ portalStats.getGlobalStats(function(){ processTemplates(); var statData = 'data: ' + JSON.stringify(portalStats.stats) + '\n\n'; for (var uid in portalApi.liveStatConnections){ var res = portalApi.liveStatConnections[uid]; res.write(statData); } }); }; setInterval(buildUpdatedWebsite, websiteConfig.stats.updateInterval * 1000); var getPage = function(pageId){ if (pageId in pageProcessed){ var requestedPage = pageProcessed[pageId]; return requestedPage; } }; var route = function(req, res, next){ var pageId = req.params.page || ''; if (pageId in indexesProcessed){ res.end(indexesProcessed[pageId]); } else next(); }; var app = express(); app.use(bodyParser.json()); app.get('/get_page', function(req, res, next){ var requestedPage = getPage(req.query.id); if (requestedPage){ res.end(requestedPage); return; } next(); }); app.get('/:page', route); app.get('/', route); app.get('/api/:method', function(req, res, next){ portalApi.handleApiRequest(req, res, next); }); app.post('/api/admin/:method', function(req, res, next){ if (portalConfig.website && portalConfig.website.adminCenter && portalConfig.website.adminCenter.enabled){ if (portalConfig.website.adminCenter.password === req.body.password) portalApi.handleAdminApiRequest(req, res, next); else res.send(401, JSON.stringify({error: 'Incorrect Password'})); } else next(); }); app.use(compress()); app.use('/static', express.static('website/static')); app.use(function(err, req, res, next){ console.error(err.stack); res.send(500, 'Something broke!'); }); app.listen(portalConfig.website.port, function(){ logger.debug(logSystem, 'Server', 'Website started on port ' + portalConfig.website.port); }); };