server.js 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235
  1. "use strict";
  2. // ===========================================
  3. // REQUARKS WIKI
  4. // 1.0.0
  5. // Licensed under AGPLv3
  6. // ===========================================
  7. global.ROOTPATH = __dirname;
  8. global.PROCNAME = 'SERVER';
  9. // ----------------------------------------
  10. // Load Winston
  11. // ----------------------------------------
  12. const _isDebug = process.env.NODE_ENV === 'development';
  13. global.winston = require('./libs/winston')(_isDebug);
  14. winston.info('[SERVER] Requarks Wiki is initializing...');
  15. // ----------------------------------------
  16. // Load global modules
  17. // ----------------------------------------
  18. var appconfig = require('./libs/config')('./config.yml');
  19. global.lcdata = require('./libs/local').init(appconfig);
  20. global.db = require('./libs/mongo').init(appconfig);
  21. global.entries = require('./libs/entries').init(appconfig);
  22. global.git = require('./libs/git').init(appconfig, false);
  23. global.lang = require('i18next');
  24. global.mark = require('./libs/markdown');
  25. global.upl = require('./libs/uploads').init(appconfig);
  26. global.rights = require('./libs/rights');
  27. // ----------------------------------------
  28. // Load modules
  29. // ----------------------------------------
  30. const _ = require('lodash');
  31. const autoload = require('auto-load');
  32. const bodyParser = require('body-parser');
  33. const compression = require('compression');
  34. const cookieParser = require('cookie-parser');
  35. const express = require('express');
  36. const favicon = require('serve-favicon');
  37. const flash = require('connect-flash');
  38. const fork = require('child_process').fork;
  39. const http = require('http');
  40. const i18next_backend = require('i18next-node-fs-backend');
  41. const i18next_mw = require('i18next-express-middleware');
  42. const passport = require('passport');
  43. const passportSocketIo = require('passport.socketio');
  44. const path = require('path');
  45. const session = require('express-session');
  46. const sessionMongoStore = require('connect-mongo')(session);
  47. const socketio = require('socket.io');
  48. var mw = autoload(path.join(ROOTPATH, '/middlewares'));
  49. var ctrl = autoload(path.join(ROOTPATH, '/controllers'));
  50. var libInternalAuth = require('./libs/internalAuth');
  51. global.WSInternalKey = libInternalAuth.generateKey();
  52. // ----------------------------------------
  53. // Define Express App
  54. // ----------------------------------------
  55. global.app = express();
  56. app.use(compression());
  57. // ----------------------------------------
  58. // Security
  59. // ----------------------------------------
  60. app.use(mw.security);
  61. // ----------------------------------------
  62. // Public Assets
  63. // ----------------------------------------
  64. app.use(favicon(path.join(ROOTPATH, 'assets', 'favicon.ico')));
  65. app.use(express.static(path.join(ROOTPATH, 'assets')));
  66. // ----------------------------------------
  67. // Session
  68. // ----------------------------------------
  69. const strategies = require('./libs/auth')(passport, appconfig);
  70. var sessionStore = new sessionMongoStore({
  71. mongooseConnection: db.connection,
  72. touchAfter: 15
  73. });
  74. app.use(cookieParser());
  75. app.use(session({
  76. name: 'requarkswiki.sid',
  77. store: sessionStore,
  78. secret: appconfig.sessionSecret,
  79. resave: false,
  80. saveUninitialized: false
  81. }));
  82. app.use(flash());
  83. app.use(passport.initialize());
  84. app.use(passport.session());
  85. // ----------------------------------------
  86. // Localization Engine
  87. // ----------------------------------------
  88. lang
  89. .use(i18next_backend)
  90. .use(i18next_mw.LanguageDetector)
  91. .init({
  92. load: 'languageOnly',
  93. ns: ['common'],
  94. defaultNS: 'common',
  95. saveMissing: false,
  96. supportedLngs: ['en', 'fr'],
  97. preload: ['en', 'fr'],
  98. fallbackLng : 'en',
  99. backend: {
  100. loadPath: './locales/{{lng}}/{{ns}}.json'
  101. }
  102. });
  103. // ----------------------------------------
  104. // View Engine Setup
  105. // ----------------------------------------
  106. app.use(i18next_mw.handle(lang));
  107. app.set('views', path.join(ROOTPATH, 'views'));
  108. app.set('view engine', 'pug');
  109. app.use(bodyParser.json());
  110. app.use(bodyParser.urlencoded({ extended: false }));
  111. // ----------------------------------------
  112. // View accessible data
  113. // ----------------------------------------
  114. app.locals._ = require('lodash');
  115. app.locals.moment = require('moment');
  116. app.locals.appconfig = appconfig;
  117. app.use(mw.flash);
  118. // ----------------------------------------
  119. // Controllers
  120. // ----------------------------------------
  121. app.use('/', ctrl.auth);
  122. app.use('/uploads', mw.auth, ctrl.uploads);
  123. app.use('/admin', mw.auth, ctrl.admin);
  124. app.use('/', mw.auth, ctrl.pages);
  125. // ----------------------------------------
  126. // Error handling
  127. // ----------------------------------------
  128. app.use(function(req, res, next) {
  129. var err = new Error('Not Found');
  130. err.status = 404;
  131. next(err);
  132. });
  133. app.use(function(err, req, res, next) {
  134. res.status(err.status || 500);
  135. res.render('error', {
  136. message: err.message,
  137. error: _isDebug ? err : {}
  138. });
  139. });
  140. // ----------------------------------------
  141. // Start HTTP server
  142. // ----------------------------------------
  143. winston.info('[SERVER] Starting HTTP/WS server on port ' + appconfig.port + '...');
  144. app.set('port', appconfig.port);
  145. var server = http.createServer(app);
  146. var io = socketio(server);
  147. server.listen(appconfig.port);
  148. server.on('error', (error) => {
  149. if (error.syscall !== 'listen') {
  150. throw error;
  151. }
  152. // handle specific listen errors with friendly messages
  153. switch (error.code) {
  154. case 'EACCES':
  155. console.error('Listening on port ' + appconfig.port + ' requires elevated privileges!');
  156. process.exit(1);
  157. break;
  158. case 'EADDRINUSE':
  159. console.error('Port ' + appconfig.port + ' is already in use!');
  160. process.exit(1);
  161. break;
  162. default:
  163. throw error;
  164. }
  165. });
  166. server.on('listening', () => {
  167. winston.info('[SERVER] HTTP/WS server started successfully! [RUNNING]');
  168. });
  169. // ----------------------------------------
  170. // WebSocket
  171. // ----------------------------------------
  172. io.use(passportSocketIo.authorize({
  173. key: 'requarkswiki.sid',
  174. store: sessionStore,
  175. secret: appconfig.sessionSecret,
  176. passport,
  177. cookieParser,
  178. success: (data, accept) => {
  179. accept();
  180. },
  181. fail: (data, message, error, accept) => {
  182. return accept(new Error(message));
  183. }
  184. }));
  185. io.on('connection', ctrl.ws);
  186. // ----------------------------------------
  187. // Start child processes
  188. // ----------------------------------------
  189. global.bgAgent = fork('agent.js');
  190. process.on('exit', (code) => {
  191. bgAgent.disconnect();
  192. });