app.js

//运行时环境检测
try {
  let versionNum = parseInt(process.version.replace(/v/gim, "").split(".")[0]);
  //尽管我们建议最低版本为 v10 版本
  if (versionNum < 10) {
    console.log("[ WARN ] 您的 Node 运行环境版本似乎低于我们要求的版本.");
    console.log("[ WARN ] 可能会出现未知情况,建议您更新 Node 版本 (>=10.0.0)");
  }
} catch (err) {
  //忽略任何版本检测导致的错误
}

//全局变量 SQSERVER
global.SQSERVER = {};

//测试时检测
SQSERVER.allError = 0;
//自动化部署测试
setTimeout(() => {
  let arg2 = process.argv[2] || "";
  if (arg2 === "--test") {
    SQSERVER.infoLog("Test", "测试过程结束...");
    if (SQSERVER.allError > 0) {
      SQSERVER.infoLog("Test", "测试未通过!");
      process.exit(500);
    }
    SQSERVER.infoLog("Test", "测试通过!");
    process.exit(0);
  }
}, 10000);

const fs = require("fs");
const fsex = require("fs-extra");

//全局仅限本地配置
SQSERVER.localProperty = {};

const tools = require("./core/tools");

//生成第一次配置文件
const INIT_CONFIG_PATH = "./model/init_config/";
const PRO_CONFIG = "./property.js";
if (!fs.existsSync(PRO_CONFIG)) tools.mCopyFileSync(INIT_CONFIG_PATH + "property.js", PRO_CONFIG);

//加载配置
require("./property");

const express = require("express");
const session = require("express-session");
const cookieParser = require("cookie-parser");
const bodyParser = require("body-parser");
const querystring = require("querystring");
//gzip压缩
const compression = require("compression");

//各类层装载 与 初始化
const ServerModel = require("./model/ServerModel");
const UserModel = require("./model/UserModel");
const permission = require("./helper/Permission");
const response = require("./helper/Response");
const { randomString } = require("./core/User/CryptoMine");
const counter = require("./core/counter");
const DataModel = require("./core/DataModel");
const tokenManger = require("./helper/TokenManager");
const nodeSchedule = require("node-schedule");
const Schedule = require("./helper/Schedule");
const NewsCenter = require("./model/NewsCenter");
const ControlServer = require("./model/ControlServer");

//控制台颜色
const colors = require("colors");
colors.setTheme({
  silly: "rainbow",
  input: "grey",
  verbose: "cyan",
  prompt: "red",
  info: "green",
  data: "blue",
  help: "cyan",
  warn: "yellow",
  debug: "magenta",
  error: "red"
});

//logo输出
const LOGO_FILE_PATH = "./core/logo.txt";
let data = fs.readFileSync(LOGO_FILE_PATH, "utf-8");
console.log(data);

//全局数据中心 记录 CPU 内存
SQSERVER.dataCenter = {};

//装载log记录器
require("./core/log");
SQSERVER.info("控制面板正在启动中...");

//全局登陆记录器
SQSERVER.login = {};
//全局 在线用户监视器
SQSERVER.onlineUser = {};
//全局 在线 Websocket 监视器
SQSERVER.allSockets = {};
//全局 数据内存记录器
SQSERVER.logCenter = {};
//PAGE 页面数据储存器
SQSERVER.PAGE = {};

//init
SQSERVER.logCenter.initLogData = (objStr, len, def = null) => {
  let tmp = [];
  for (let i = 0; i < len; i++) tmp.push(def);
  SQSERVER.logCenter[objStr] = tmp;
};

//压入方法
SQSERVER.logCenter.pushLogData = (objStr, k, v) => {
  SQSERVER.logCenter[objStr] = SQSERVER.logCenter[objStr].slice(1);
  SQSERVER.logCenter[objStr].push({
    key: k,
    val: v
  });
};

//exp 框架
var app = express();
//web Socket 框架
var expressWs = require("express-ws")(app);

//Cookie and Session 的基础功能
app.use(cookieParser());
app.use(
  bodyParser.urlencoded({
    extended: false
  })
);
app.use(bodyParser.json());

var UUID = require("uuid");
app.use(
  session({
    secret: UUID.v4(),
    name: "MCSM_SESSION_ID",
    cookie: {
      maxAge: SQSERVER.localProperty.session_max_age * 1000 * 60
    },
    resave: false,
    saveUninitialized: false
  })
);

//使用 gzip 静态文本压缩，但是如果你使用反向代理或某 HTTP 服务自带的gzip，请关闭它
if (SQSERVER.localProperty.is_gzip) app.use(compression());

//基础根目录
app.use("/public", express.static("./public"));

// console 中间件挂载
app.use((req, res, next) => {
  // 部分请求不必显示
  if (req.originalUrl.indexOf("/api/") == -1 && req.originalUrl.indexOf("/fs/") == -1 && req.originalUrl.indexOf("/fs_auth/") == -1 && req.originalUrl.indexOf("/fs_auth/") == -1) {
    // SQSERVER.log('[', req.method.cyan, ']', '[', req.ip, ']', req.originalUrl);
  }
  if (SQSERVER.localProperty.is_allow_csrf) {
    res.header("Access-Control-Allow-Origin", "*");
    res.header("Access-Control-Allow-Methods", "GET, POST");
    res.header("Access-Control-Allow-Headers", "X-Requested-With");
    res.header("Access-Control-Allow-Headers", "Content-Type");
  }
  res.header("X-Frame-Options", "DENY");
  next();
});

//基础的根目录路由
app.get(["/login", "/l", "/", "/logined"], function (req, res) {
  permission.needLogin(
    req,
    res,
    () => {
      res.redirect("/public/#welcome");
    },
    () => {
      res.redirect(SQSERVER.localProperty.login_url);
    }
  );
});

//自动装载所有路由
let routeList = fs.readdirSync("./route/");
for (let key in routeList) {
  let name = routeList[key].replace(".js", "");
  app.use("/" + name, require("./route/" + name));
}

process.on("uncaughtException", function (err) {
  //是否出过错误,本变量用于自动化测试
  SQSERVER.allError++;
  //打印出错误
  SQSERVER.error("错误报告:", err);
});

process.on("unhandledRejection", (reason, p) => {
  SQSERVER.error("错误报告:", reason);
});

//初始化目录结构环境
(function initializationRun() {
  const USERS_PATH = "./users/";
  const SERVER_PATH = "./server/";
  const SERVER_PATH_CORE = "./server/server_core/";
  const SERVER_PATH_SCH = "./server/schedule/";
  const CENTEN_LOG_JSON_PATH = "./core/info.json";
  const PUBLIC_URL_PATH = "./public/common/URL.js";
  const RECORD_PARH = "./server/record_tmp/";

  try {
    if (!fs.existsSync(USERS_PATH)) fs.mkdirSync(USERS_PATH);
    if (!fs.existsSync(SERVER_PATH)) fs.mkdirSync(SERVER_PATH);
    if (!fs.existsSync(SERVER_PATH_CORE)) fs.mkdirSync(SERVER_PATH_CORE);
    if (!fs.existsSync(SERVER_PATH_SCH)) fs.mkdirSync(SERVER_PATH_SCH);
    if (!fs.existsSync(RECORD_PARH)) fs.mkdirSync(RECORD_PARH);

    // 生成不 git 同步的文件
    if (!fs.existsSync(CENTEN_LOG_JSON_PATH)) tools.mCopyFileSync(INIT_CONFIG_PATH + "info_reset.json", CENTEN_LOG_JSON_PATH);
    if (!fs.existsSync(PUBLIC_URL_PATH)) tools.mCopyFileSync(INIT_CONFIG_PATH + "INIT_URL.js", PUBLIC_URL_PATH);
  } catch (err) {
    SQSERVER.error("初始化文件环境失败,建议重启,请检查以下报错:", err);
  }
})();

//初始化各个模块
(function initializationProm() {
  SQSERVER.infoLog("Module", "正在初始化用户管理模块");
  counter.init();
  UserModel.userCenter().initUser();

  SQSERVER.infoLog("Module", "正在初始化服务端管理模块");
  ServerModel.ServerManager().loadALLSquadServer();

  SQSERVER.infoLog("Module", "正在初始化计划任务模块");
  Schedule.init();

  var host = SQSERVER.localProperty.http_ip;
  var port = SQSERVER.localProperty.http_port;

  if (host == "::") host = "127.0.0.1";

  //App Http listen
  app.listen(SQSERVER.localProperty.http_port, SQSERVER.localProperty.http_ip, () => {
    SQSERVER.infoLog("HTTP", "模块监听: [ http://" + (host || "127.0.0.1".yellow) + ":" + port + " ]");

    // SQSERVER.infoLog("INFO", "配置文件: property.js");
    // SQSERVER.infoLog("INFO", "文档参阅: https://github.com/suwings/mcsmanager");

    if (SQSERVER.allError <= 0) {
      SQSERVER.infoLog("INFO", "控制面板已经启动");
      let cmd = process.argv.splice(2);
      if(cmd[0]==='StartAll') {
        ControlServer.StartAll()
      }
    } else {
      SQSERVER.infoLog("INFO", "控制面板启动异常");
    }
  });
})();

//用于捕捉前方所有路由都未经过的请求，则可为 404 页面
app.get("*", function (req, res) {
  //404 页面
  res.redirect("/public/template/404_page.html");
  res.end();
});

/*
//设置定时获取最新新闻动态
nodeSchedule.scheduleJob("59 59 23 * * *", function () {
  SQSERVER.infoLog("INFO", "自动更新新闻动态与最新消息");
  NewsCenter.requestNews();
});
//重启自动获取一次
NewsCenter.requestNews();
*/

//程序退出信号处理
require("./core/procexit");