index.js 3.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
  1. require('tls').DEFAULT_MIN_VERSION = 'TLSv1';
  2. const fs = require('fs-extra');
  3. const path = require('path');
  4. const argv = require('minimist')(process.argv.slice(2));
  5. const express = require('express');
  6. const compression = require('compression');
  7. const http = require('http');
  8. const WebSocket = require ('ws');
  9. async function init() {
  10. //config
  11. const configManager = new (require('./config'))();//singleton
  12. await configManager.init();
  13. configManager.userConfigFile = argv.config;
  14. await configManager.load();
  15. const config = configManager.config;
  16. //logger
  17. const appLogger = new (require('./core/AppLogger'))();//singleton
  18. await appLogger.init(config);
  19. const log = appLogger.log;
  20. //dirs
  21. log(`${config.name} v${config.version}, Node.js ${process.version}`);
  22. log('Initializing');
  23. await fs.ensureDir(config.dataDir);
  24. await fs.ensureDir(config.uploadDir);
  25. await fs.ensureDir(config.sharedDir);
  26. await fs.ensureDir(config.tempDir);
  27. await fs.emptyDir(config.tempDir);
  28. const appDir = `${config.publicDir}/app`;
  29. const appNewDir = `${config.publicDir}/app_new`;
  30. if (await fs.pathExists(appNewDir)) {
  31. await fs.remove(appDir);
  32. await fs.move(appNewDir, appDir);
  33. }
  34. //connections
  35. const connManager = new (require('./db/ConnManager'))();//singleton
  36. await connManager.init(config);
  37. }
  38. async function main() {
  39. const log = new (require('./core/AppLogger'))().log;//singleton
  40. const config = new (require('./config'))().config;//singleton
  41. //servers
  42. for (let serverCfg of config.servers) {
  43. if (serverCfg.mode !== 'none') {
  44. const app = express();
  45. const server = http.createServer(app);
  46. const wss = new WebSocket.Server({ server, maxPayload: 10*1024*1024 });
  47. const serverConfig = Object.assign({}, config, serverCfg);
  48. let devModule = undefined;
  49. if (serverConfig.branch == 'development') {
  50. const devFileName = './dev.js'; //require ignored by pkg -50Mb executable size
  51. devModule = require(devFileName);
  52. devModule.webpackDevMiddleware(app);
  53. }
  54. app.use(compression({ level: 1 }));
  55. app.use(express.json({limit: '10mb'}));
  56. if (devModule)
  57. devModule.logQueries(app);
  58. app.use(express.static(serverConfig.publicDir, {
  59. maxAge: '30d',
  60. setHeaders: (res, filePath) => {
  61. if (path.basename(path.dirname(filePath)) == 'tmp') {
  62. res.set('Content-Type', 'text/xml');
  63. res.set('Content-Encoding', 'gzip');
  64. }
  65. }
  66. }));
  67. require('./routes').initRoutes(app, wss, serverConfig);
  68. if (devModule) {
  69. devModule.logErrors(app);
  70. } else {
  71. app.use(function(err, req, res, next) {// eslint-disable-line no-unused-vars
  72. log(LM_ERR, err.stack);
  73. res.sendStatus(500);
  74. });
  75. }
  76. server.listen(serverConfig.port, serverConfig.ip, function() {
  77. log(`Server-${serverConfig.serverName} is ready on ${serverConfig.ip}:${serverConfig.port}, mode: ${serverConfig.mode}`);
  78. });
  79. }
  80. }
  81. }
  82. (async() => {
  83. try {
  84. await init();
  85. await main();
  86. } catch (e) {
  87. console.error(e);
  88. process.exit(1);
  89. }
  90. })();