cleanup typescript build output structure
This commit is contained in:
@@ -1,25 +0,0 @@
|
||||
"use strict";
|
||||
var __importDefault = (this && this.__importDefault) || function (mod) {
|
||||
return (mod && mod.__esModule) ? mod : { "default": mod };
|
||||
};
|
||||
Object.defineProperty(exports, "__esModule", { value: true });
|
||||
exports.SERVER_WORKING_DIRECTORY = exports.SERVER_SCRIPT_PATH = exports.WRAPPER_QUERY_INTERVAL = exports.WRAPPER_STATUS_INTERVAL = exports.WRAPPER_HEARTBEAT_INTERVAL = exports.RABBITMQ_URL = void 0;
|
||||
exports.loadConfig = loadConfig;
|
||||
exports.saveConfig = saveConfig;
|
||||
const fs_1 = __importDefault(require("fs"));
|
||||
const FILE = "./config.json";
|
||||
exports.RABBITMQ_URL = "amqp://manager:gigi1337@192.168.1.74";
|
||||
exports.WRAPPER_HEARTBEAT_INTERVAL = 10000;
|
||||
exports.WRAPPER_STATUS_INTERVAL = 10000;
|
||||
exports.WRAPPER_QUERY_INTERVAL = 5000;
|
||||
exports.SERVER_SCRIPT_PATH = "/home/heroes/HeroesOfValorServer.sh";
|
||||
exports.SERVER_WORKING_DIRECTORY = "/home/heroes";
|
||||
function loadConfig() {
|
||||
if (!fs_1.default.existsSync(FILE)) {
|
||||
return {};
|
||||
}
|
||||
return JSON.parse(fs_1.default.readFileSync(FILE, "utf-8"));
|
||||
}
|
||||
function saveConfig(config) {
|
||||
fs_1.default.writeFileSync(FILE, JSON.stringify(config, null, 4));
|
||||
}
|
||||
@@ -1,155 +0,0 @@
|
||||
"use strict";
|
||||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
|
||||
if (k2 === undefined) k2 = k;
|
||||
var desc = Object.getOwnPropertyDescriptor(m, k);
|
||||
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
|
||||
desc = { enumerable: true, get: function() { return m[k]; } };
|
||||
}
|
||||
Object.defineProperty(o, k2, desc);
|
||||
}) : (function(o, m, k, k2) {
|
||||
if (k2 === undefined) k2 = k;
|
||||
o[k2] = m[k];
|
||||
}));
|
||||
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
|
||||
Object.defineProperty(o, "default", { enumerable: true, value: v });
|
||||
}) : function(o, v) {
|
||||
o["default"] = v;
|
||||
});
|
||||
var __importStar = (this && this.__importStar) || (function () {
|
||||
var ownKeys = function(o) {
|
||||
ownKeys = Object.getOwnPropertyNames || function (o) {
|
||||
var ar = [];
|
||||
for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k;
|
||||
return ar;
|
||||
};
|
||||
return ownKeys(o);
|
||||
};
|
||||
return function (mod) {
|
||||
if (mod && mod.__esModule) return mod;
|
||||
var result = {};
|
||||
if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]);
|
||||
__setModuleDefault(result, mod);
|
||||
return result;
|
||||
};
|
||||
})();
|
||||
var __importDefault = (this && this.__importDefault) || function (mod) {
|
||||
return (mod && mod.__esModule) ? mod : { "default": mod };
|
||||
};
|
||||
Object.defineProperty(exports, "__esModule", { value: true });
|
||||
const amqp = __importStar(require("amqplib"));
|
||||
const os_1 = __importDefault(require("os"));
|
||||
const config_1 = require("./config");
|
||||
const processManager_1 = require("./processManager");
|
||||
const statusReporter_1 = require("./statusReporter");
|
||||
const queryManager_1 = require("./queryManager");
|
||||
const logger_1 = require("./logger");
|
||||
const logger = (0, logger_1.getLogger)("Wrapper");
|
||||
class Wrapper {
|
||||
constructor() {
|
||||
this.processManager = new processManager_1.ProcessManager();
|
||||
this.queryManager = new queryManager_1.QueryManager(this.processManager);
|
||||
}
|
||||
async start() {
|
||||
const config = (0, config_1.loadConfig)();
|
||||
logger.info("Konfiguration geladen");
|
||||
if (config.wrapperId) {
|
||||
this.id =
|
||||
config.wrapperId;
|
||||
logger.debug("Starte mit vorhandener ID:", this.id);
|
||||
}
|
||||
else {
|
||||
logger.warn("Keine Wrapper ID vorhanden - neue Registrierung");
|
||||
}
|
||||
this.connection =
|
||||
await amqp.connect(config_1.RABBITMQ_URL);
|
||||
this.channel =
|
||||
await this.connection.createChannel();
|
||||
logger.info("RabbitMQ Verbindung hergestellt");
|
||||
this.queryManager.start();
|
||||
await this.register();
|
||||
}
|
||||
async register() {
|
||||
const reply = await this.channel.assertQueue("", {
|
||||
exclusive: true
|
||||
});
|
||||
const replyQueue = reply.queue;
|
||||
await this.channel.consume(replyQueue, msg => {
|
||||
if (!msg)
|
||||
return;
|
||||
const data = JSON.parse(msg.content.toString());
|
||||
logger.debug("Antwort vom Manager:", data.type);
|
||||
if (data.type === "wrapper.registered") {
|
||||
this.id =
|
||||
data.wrapperId;
|
||||
(0, config_1.saveConfig)({
|
||||
wrapperId: this.id
|
||||
});
|
||||
logger.info("Registrierung beim Manager erfolgreich");
|
||||
logger.debug("Wrapper ID gespeichert:", this.id);
|
||||
if (!this.id) {
|
||||
logger.error("Keine Wrapper ID erhalten!");
|
||||
return;
|
||||
}
|
||||
this.listenCommands(data.commandQueue);
|
||||
const reporter = new statusReporter_1.StatusReporter(this.channel, this.processManager, this.queryManager, this.id);
|
||||
reporter.start();
|
||||
}
|
||||
this.channel.ack(msg);
|
||||
});
|
||||
const message = {
|
||||
type: "wrapper.register",
|
||||
// vorhandene ID mitsenden
|
||||
wrapperId: this.id,
|
||||
hostname: os_1.default.hostname(),
|
||||
cpu: os_1.default.cpus().length,
|
||||
ram: Math.round(os_1.default.totalmem() / 1024 / 1024),
|
||||
replyQueue
|
||||
};
|
||||
await this.channel.sendToQueue("wrapper.register", Buffer.from(JSON.stringify(message)));
|
||||
logger.debug("Registrierung gesendet", this.id ?? "ohne ID");
|
||||
}
|
||||
async listenCommands(queue) {
|
||||
await this.channel.consume(queue, msg => {
|
||||
if (!msg)
|
||||
return;
|
||||
const rawCommand = JSON.parse(msg.content.toString());
|
||||
const commandType = rawCommand.type;
|
||||
switch (commandType) {
|
||||
case "test": {
|
||||
const command = rawCommand;
|
||||
logger.debug("TEST COMMAND:", command.message);
|
||||
break;
|
||||
}
|
||||
case "server.start": {
|
||||
const command = rawCommand;
|
||||
this.processManager.startServer(command);
|
||||
break;
|
||||
}
|
||||
case "server.stop": {
|
||||
const command = rawCommand;
|
||||
this.processManager.stopServer(command.serverId);
|
||||
break;
|
||||
}
|
||||
default:
|
||||
logger.warn("Unbekannter Command:", commandType);
|
||||
}
|
||||
this.channel.ack(msg);
|
||||
});
|
||||
logger.debug("Warte auf Commands:", queue);
|
||||
this.heartbeat();
|
||||
}
|
||||
heartbeat() {
|
||||
logger.debug("Heartbeat gestartet");
|
||||
setInterval(() => {
|
||||
if (!this.id)
|
||||
return;
|
||||
const heartbeat = {
|
||||
type: "wrapper.heartbeat",
|
||||
wrapperId: this.id
|
||||
};
|
||||
this.channel.sendToQueue("wrapper.register", Buffer.from(JSON.stringify(heartbeat)));
|
||||
logger.debug("Heartbeat gesendet");
|
||||
}, config_1.WRAPPER_HEARTBEAT_INTERVAL);
|
||||
}
|
||||
}
|
||||
new Wrapper().start();
|
||||
@@ -1,47 +0,0 @@
|
||||
"use strict";
|
||||
Object.defineProperty(exports, "__esModule", { value: true });
|
||||
exports.getLogger = getLogger;
|
||||
const LEVELS = {
|
||||
DEBUG: 0,
|
||||
INFO: 1,
|
||||
WARN: 2,
|
||||
ERROR: 3,
|
||||
};
|
||||
const DEFAULT_LOG_LEVEL = "INFO";
|
||||
const configuredLevel = (process.env.LOG_LEVEL ?? "").toUpperCase();
|
||||
const currentLogLevel = configuredLevel in LEVELS ? configuredLevel : DEFAULT_LOG_LEVEL;
|
||||
const currentLogLevelValue = LEVELS[currentLogLevel];
|
||||
function shouldLog(level) {
|
||||
return LEVELS[level] >= currentLogLevelValue;
|
||||
}
|
||||
function formatMessage(level, component, message) {
|
||||
return `${new Date().toISOString()} ${level} [${component}] ${message}`;
|
||||
}
|
||||
class Logger {
|
||||
constructor(component) {
|
||||
this.component = component;
|
||||
}
|
||||
debug(message, ...args) {
|
||||
if (!shouldLog("DEBUG"))
|
||||
return;
|
||||
console.log(formatMessage("DEBUG", this.component, message), ...args);
|
||||
}
|
||||
info(message, ...args) {
|
||||
if (!shouldLog("INFO"))
|
||||
return;
|
||||
console.log(formatMessage("INFO", this.component, message), ...args);
|
||||
}
|
||||
warn(message, ...args) {
|
||||
if (!shouldLog("WARN"))
|
||||
return;
|
||||
console.warn(formatMessage("WARN", this.component, message), ...args);
|
||||
}
|
||||
error(message, ...args) {
|
||||
if (!shouldLog("ERROR"))
|
||||
return;
|
||||
console.error(formatMessage("ERROR", this.component, message), ...args);
|
||||
}
|
||||
}
|
||||
function getLogger(component) {
|
||||
return new Logger(component);
|
||||
}
|
||||
@@ -1,79 +0,0 @@
|
||||
"use strict";
|
||||
Object.defineProperty(exports, "__esModule", { value: true });
|
||||
exports.ProcessManager = void 0;
|
||||
const child_process_1 = require("child_process");
|
||||
const config_1 = require("./config");
|
||||
const logger_1 = require("./logger");
|
||||
const logger = (0, logger_1.getLogger)("ProcessManager");
|
||||
class ProcessManager {
|
||||
constructor() {
|
||||
this.processes = new Map();
|
||||
}
|
||||
startServer(data) {
|
||||
logger.debug("Starte Game Server:", data.name);
|
||||
const args = [
|
||||
`-Port=${data.port}`,
|
||||
`-QueryPort=${data.queryPort}`,
|
||||
`-ServerName=${data.name}`
|
||||
];
|
||||
const process = (0, child_process_1.spawn)(config_1.SERVER_SCRIPT_PATH, args, {
|
||||
cwd: config_1.SERVER_WORKING_DIRECTORY,
|
||||
stdio: "pipe",
|
||||
detached: true
|
||||
});
|
||||
process.stdout?.on("data", data => {
|
||||
logger.debug(`[${data.name}]`, data.toString());
|
||||
});
|
||||
process.stderr?.on("data", data => {
|
||||
logger.error("SERVER ERROR:", data.toString());
|
||||
});
|
||||
process.on("exit", code => {
|
||||
const server = this.processes.get(data.serverId);
|
||||
if (server) {
|
||||
logger.info("Server beendet:", server.name, code);
|
||||
this.processes.delete(data.serverId);
|
||||
}
|
||||
});
|
||||
this.processes.set(data.serverId, {
|
||||
id: data.serverId,
|
||||
name: data.name,
|
||||
port: data.port,
|
||||
queryPort: data.queryPort,
|
||||
process,
|
||||
started: Date.now(),
|
||||
alive: true,
|
||||
players: 0,
|
||||
maxPlayers: 0
|
||||
});
|
||||
logger.info("Server gestartet:", {
|
||||
id: data.serverId,
|
||||
pid: process.pid
|
||||
});
|
||||
}
|
||||
stopServer(id) {
|
||||
const server = this.processes.get(id);
|
||||
if (!server) {
|
||||
logger.warn("Server nicht gefunden:", id);
|
||||
return;
|
||||
}
|
||||
logger.debug("Stoppe Server:", server.name);
|
||||
process.kill(-server.process.pid, "SIGTERM");
|
||||
}
|
||||
getServers() {
|
||||
return Array.from(this.processes.values());
|
||||
}
|
||||
getStatus() {
|
||||
return Array.from(this.processes.values()).map(server => ({
|
||||
id: server.id,
|
||||
name: server.name,
|
||||
port: server.port,
|
||||
queryPort: server.queryPort,
|
||||
pid: server.process.pid,
|
||||
alive: server.alive,
|
||||
players: server.players,
|
||||
maxPlayers: server.maxPlayers,
|
||||
started: server.started
|
||||
}));
|
||||
}
|
||||
}
|
||||
exports.ProcessManager = ProcessManager;
|
||||
@@ -1,44 +0,0 @@
|
||||
"use strict";
|
||||
Object.defineProperty(exports, "__esModule", { value: true });
|
||||
exports.QueryManager = void 0;
|
||||
const steam_server_query_1 = require("steam-server-query");
|
||||
const config_1 = require("./config");
|
||||
const logger_1 = require("./logger");
|
||||
const logger = (0, logger_1.getLogger)("QueryManager");
|
||||
class QueryManager {
|
||||
constructor(processManager) {
|
||||
this.processManager = processManager;
|
||||
}
|
||||
start() {
|
||||
logger.debug("Query Manager gestartet");
|
||||
setInterval(() => {
|
||||
this.updateQueries();
|
||||
}, config_1.WRAPPER_QUERY_INTERVAL);
|
||||
}
|
||||
async updateQueries() {
|
||||
const servers = this.processManager.getServers();
|
||||
for (const server of servers) {
|
||||
try {
|
||||
const info = await (0, steam_server_query_1.queryGameServerInfo)(`127.0.0.1:${server.queryPort}`);
|
||||
server.players =
|
||||
info.players;
|
||||
server.maxPlayers =
|
||||
info.maxPlayers;
|
||||
logger.debug("Query erfolgreich:", server.name, `${server.players}/${server.maxPlayers}`);
|
||||
}
|
||||
catch (err) {
|
||||
logger.warn("Query fehlgeschlagen:", server.name);
|
||||
}
|
||||
}
|
||||
}
|
||||
getStatus() {
|
||||
return this.processManager
|
||||
.getServers()
|
||||
.map(server => ({
|
||||
id: server.id,
|
||||
players: server.players,
|
||||
maxPlayers: server.maxPlayers
|
||||
}));
|
||||
}
|
||||
}
|
||||
exports.QueryManager = QueryManager;
|
||||
@@ -1,49 +0,0 @@
|
||||
"use strict";
|
||||
var __importDefault = (this && this.__importDefault) || function (mod) {
|
||||
return (mod && mod.__esModule) ? mod : { "default": mod };
|
||||
};
|
||||
Object.defineProperty(exports, "__esModule", { value: true });
|
||||
exports.StatusReporter = void 0;
|
||||
const os_1 = __importDefault(require("os"));
|
||||
const config_1 = require("./config");
|
||||
const logger_1 = require("./logger");
|
||||
const logger = (0, logger_1.getLogger)("StatusReporter");
|
||||
class StatusReporter {
|
||||
constructor(channel, processManager, queryManager, wrapperId) {
|
||||
this.channel = channel;
|
||||
this.processManager = processManager;
|
||||
this.queryManager = queryManager;
|
||||
this.wrapperId = wrapperId;
|
||||
}
|
||||
start() {
|
||||
logger.debug("Status Reporter gestartet");
|
||||
setInterval(() => {
|
||||
this.sendStatus();
|
||||
}, config_1.WRAPPER_STATUS_INTERVAL);
|
||||
}
|
||||
sendStatus() {
|
||||
const processes = this.processManager.getStatus();
|
||||
const queries = this.queryManager.getStatus();
|
||||
const servers = processes.map(server => {
|
||||
const query = queries.find((q) => q.id === server.id);
|
||||
return {
|
||||
...server,
|
||||
players: query?.players ?? 0,
|
||||
maxPlayers: query?.maxPlayers ?? 0
|
||||
};
|
||||
});
|
||||
const status = {
|
||||
type: "wrapper.status",
|
||||
wrapperId: this.wrapperId,
|
||||
servers,
|
||||
ramFree: Math.round(os_1.default.freemem()
|
||||
/
|
||||
1024
|
||||
/
|
||||
1024)
|
||||
};
|
||||
this.channel.sendToQueue("wrapper.register", Buffer.from(JSON.stringify(status)));
|
||||
logger.debug("Status gesendet:", servers.length, "Server");
|
||||
}
|
||||
}
|
||||
exports.StatusReporter = StatusReporter;
|
||||
Reference in New Issue
Block a user