Compare commits
4
Commits
57d63f5bf4
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
 xBeaTz
|
1b96c4f79b | ||
|
xBeaTz
|
aea8eff656 | ||
|
xBeaTz
|
048a869c30 | ||
|
xBeaTz
|
25b2ad1b3f |
@@ -0,0 +1,70 @@
|
|||||||
|
# Server Manager
|
||||||
|
|
||||||
|
Dynamic Dedicated Server Management System.
|
||||||
|
|
||||||
|
## Components
|
||||||
|
|
||||||
|
* Manager
|
||||||
|
* Wrapper
|
||||||
|
* Shared
|
||||||
|
* Dashboard
|
||||||
|
|
||||||
|
## Build
|
||||||
|
|
||||||
|
Build all workspaces:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
npm run build --workspaces
|
||||||
|
```
|
||||||
|
|
||||||
|
## Development
|
||||||
|
|
||||||
|
### Manager
|
||||||
|
|
||||||
|
```bash
|
||||||
|
npm start --workspace manager
|
||||||
|
```
|
||||||
|
|
||||||
|
### Dashboard
|
||||||
|
|
||||||
|
```bash
|
||||||
|
npm run dev --workspace dashboard
|
||||||
|
```
|
||||||
|
|
||||||
|
## Architecture
|
||||||
|
|
||||||
|
### Manager
|
||||||
|
|
||||||
|
Responsible for:
|
||||||
|
|
||||||
|
* Server lifecycle management
|
||||||
|
* Dynamic scaling
|
||||||
|
* Wrapper communication
|
||||||
|
* Server registry
|
||||||
|
|
||||||
|
### Wrapper
|
||||||
|
|
||||||
|
Responsible for:
|
||||||
|
|
||||||
|
* Process management
|
||||||
|
* Dedicated server control
|
||||||
|
* Server monitoring
|
||||||
|
* Status reporting
|
||||||
|
|
||||||
|
### Shared
|
||||||
|
|
||||||
|
Contains:
|
||||||
|
|
||||||
|
* Common types
|
||||||
|
* Shared interfaces
|
||||||
|
* Communication contracts
|
||||||
|
|
||||||
|
## Project Structure
|
||||||
|
|
||||||
|
```text
|
||||||
|
server-manager/
|
||||||
|
├── manager/
|
||||||
|
├── wrapper/
|
||||||
|
├── shared/
|
||||||
|
└── dashboard/
|
||||||
|
```
|
||||||
@@ -1,11 +1,12 @@
|
|||||||
{
|
{
|
||||||
"name": "manager",
|
"name": "manager",
|
||||||
"version": "1.0.0",
|
"version": "1.0.0",
|
||||||
"description": "",
|
"description": "Server Manager for dedicated game servers",
|
||||||
"main": "index.js",
|
"main": "dist/index.js",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"start": "ts-node src/index.ts",
|
"dev": "ts-node src/index.ts",
|
||||||
"build": "tsc -p tsconfig.json"
|
"build": "tsc -p tsconfig.json",
|
||||||
|
"start": "node dist/index.js"
|
||||||
},
|
},
|
||||||
"keywords": [],
|
"keywords": [],
|
||||||
"author": "",
|
"author": "",
|
||||||
|
|||||||
@@ -1,15 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.CommandService = void 0;
|
|
||||||
const logger_1 = require("./logger");
|
|
||||||
const logger = (0, logger_1.getLogger)("CommandService");
|
|
||||||
class CommandService {
|
|
||||||
constructor(channel) {
|
|
||||||
this.channel = channel;
|
|
||||||
}
|
|
||||||
async send(queue, command) {
|
|
||||||
await this.channel.sendToQueue(queue, Buffer.from(JSON.stringify(command)));
|
|
||||||
logger.debug("Command sent", command);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
exports.CommandService = CommandService;
|
|
||||||
@@ -1,21 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.QUERY_PORT_START = exports.GAME_PORT_START = exports.DEFAULT_DESIRED_SERVERS = exports.LIFECYCLE_CRASH_RETENTION = exports.LIFECYCLE_CRASH_TIMEOUT = exports.LIFECYCLE_SCALE_COOLDOWN = exports.LIFECYCLE_STARTUP_GRACE_PERIOD = exports.LIFECYCLE_SCALE_DOWN_THRESHOLD = exports.LIFECYCLE_MIN_UPTIME = exports.LIFECYCLE_EMPTY_TIMEOUT = exports.LIFECYCLE_CHECK_INTERVAL = exports.RABBITMQ_URL = void 0;
|
|
||||||
exports.RABBITMQ_URL = "amqp://manager:gigi1337@192.168.1.74";
|
|
||||||
// Lifecycle
|
|
||||||
exports.LIFECYCLE_CHECK_INTERVAL = 10000; // Alle 10 Sekunden prüfen
|
|
||||||
// Scale Down
|
|
||||||
exports.LIFECYCLE_EMPTY_TIMEOUT = 300000; // 5 Minuten leer
|
|
||||||
exports.LIFECYCLE_MIN_UPTIME = 600000; // 10 Minuten Mindestlaufzeit
|
|
||||||
exports.LIFECYCLE_SCALE_DOWN_THRESHOLD = 0.30; // Unter 30% Gesamtauslastung darf abgebaut werden
|
|
||||||
// Scale Up
|
|
||||||
exports.LIFECYCLE_STARTUP_GRACE_PERIOD = 60000; // 1 Minute Schutz nach Start
|
|
||||||
exports.LIFECYCLE_SCALE_COOLDOWN = 120000; // 2 Minuten zwischen Scale-Up Aktionen
|
|
||||||
// Crash Detection
|
|
||||||
exports.LIFECYCLE_CRASH_TIMEOUT = 120000; // 2 Minuten ohne Status -> Crash
|
|
||||||
exports.LIFECYCLE_CRASH_RETENTION = 300000; // 5 Minuten sichtbar nach Crash
|
|
||||||
// Default
|
|
||||||
exports.DEFAULT_DESIRED_SERVERS = 1;
|
|
||||||
// Ports
|
|
||||||
exports.GAME_PORT_START = 7777;
|
|
||||||
exports.QUERY_PORT_START = 27015;
|
|
||||||
@@ -1,46 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
const rabbit_1 = require("./rabbit");
|
|
||||||
const wrapperManager_1 = require("./wrapperManager");
|
|
||||||
const wrapperRegistry_1 = require("./wrapperRegistry");
|
|
||||||
const serverRegistry_1 = require("./serverRegistry");
|
|
||||||
const serverManager_1 = require("./serverManager");
|
|
||||||
const portManager_1 = require("./portManager");
|
|
||||||
const serverStatusManager_1 = require("./serverStatusManager");
|
|
||||||
const serverLifecycle_1 = require("./serverLifecycle");
|
|
||||||
const logger_1 = require("./logger");
|
|
||||||
const server_1 = require("./web/server");
|
|
||||||
const logger = (0, logger_1.getLogger)("Index");
|
|
||||||
const wrapperRegistry = new wrapperRegistry_1.WrapperRegistry();
|
|
||||||
const serverRegistry = new serverRegistry_1.ServerRegistry();
|
|
||||||
const portManager = new portManager_1.PortManager();
|
|
||||||
async function main() {
|
|
||||||
const rabbit = new rabbit_1.Rabbit();
|
|
||||||
await rabbit.connect();
|
|
||||||
logger.info("RabbitMQ-Verbindung hergestellt");
|
|
||||||
await portManager.init();
|
|
||||||
logger.info("Persistenz initialisiert");
|
|
||||||
await wrapperRegistry.init();
|
|
||||||
logger.debug("WrapperRegistry initialisiert");
|
|
||||||
await serverRegistry.init();
|
|
||||||
logger.debug("ServerRegistry initialisiert");
|
|
||||||
const wrapperManager = new wrapperManager_1.WrapperManager(rabbit, wrapperRegistry, serverRegistry);
|
|
||||||
await wrapperManager.start();
|
|
||||||
logger.info("WrapperManager erfolgreich gestartet");
|
|
||||||
const serverManager = new serverManager_1.ServerManager(rabbit, wrapperRegistry, serverRegistry, portManager);
|
|
||||||
const lifecycle = new serverLifecycle_1.ServerLifecycle(serverRegistry, serverManager);
|
|
||||||
lifecycle.start();
|
|
||||||
logger.debug("ServerLifecycle gestartet");
|
|
||||||
const statusManager = new serverStatusManager_1.ServerStatusManager(rabbit, serverRegistry);
|
|
||||||
await statusManager.start();
|
|
||||||
const webServer = (0, server_1.createWebServer)({
|
|
||||||
wrapperRegistry,
|
|
||||||
serverRegistry,
|
|
||||||
lifecycle,
|
|
||||||
rabbitMqStatus: "connected",
|
|
||||||
managerStatus: "running"
|
|
||||||
}, 3000);
|
|
||||||
logger.info("Manager gestartet");
|
|
||||||
void webServer;
|
|
||||||
}
|
|
||||||
main();
|
|
||||||
@@ -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,40 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.generateServerName = generateServerName;
|
|
||||||
const locations = [
|
|
||||||
"Crimson",
|
|
||||||
"Azure",
|
|
||||||
"Emerald",
|
|
||||||
"Amber",
|
|
||||||
"Sapphire",
|
|
||||||
"Ruby",
|
|
||||||
"Obsidian",
|
|
||||||
"Pearl",
|
|
||||||
"Onyx",
|
|
||||||
"Ivory",
|
|
||||||
"Copper",
|
|
||||||
"Platinum",
|
|
||||||
"Titanium",
|
|
||||||
"Neon",
|
|
||||||
"Shadow",
|
|
||||||
"Frost",
|
|
||||||
"Solar",
|
|
||||||
"Void",
|
|
||||||
"Storm",
|
|
||||||
"Ocean"
|
|
||||||
];
|
|
||||||
function generateServerName(existingNames) {
|
|
||||||
for (const location of locations) {
|
|
||||||
const name = "[EU] druecktieR | " + location;
|
|
||||||
if (!existingNames.includes(name)) {
|
|
||||||
return name;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
/*
|
|
||||||
Falls alle Namen vergeben sind
|
|
||||||
*/
|
|
||||||
return ("[EU] druecktieR | " +
|
|
||||||
Math.random()
|
|
||||||
.toString(36)
|
|
||||||
.substring(2, 6));
|
|
||||||
}
|
|
||||||
@@ -1,35 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.JsonFileStore = void 0;
|
|
||||||
const fs_1 = require("fs");
|
|
||||||
const logger_1 = require("../logger");
|
|
||||||
const logger = (0, logger_1.getLogger)("JsonFileStore");
|
|
||||||
class JsonFileStore {
|
|
||||||
constructor(filePath) {
|
|
||||||
this.filePath = filePath;
|
|
||||||
}
|
|
||||||
async load() {
|
|
||||||
try {
|
|
||||||
const fileContents = await fs_1.promises.readFile(this.filePath, "utf-8");
|
|
||||||
return JSON.parse(fileContents);
|
|
||||||
}
|
|
||||||
catch (error) {
|
|
||||||
if (error.code === "ENOENT") {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
logger.error(`Fehler beim Laden der Persistenzdatei ${this.filePath}:`, error);
|
|
||||||
throw error;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
async save(data) {
|
|
||||||
try {
|
|
||||||
const fileContents = JSON.stringify(data, null, 4);
|
|
||||||
await fs_1.promises.writeFile(this.filePath, fileContents, "utf-8");
|
|
||||||
}
|
|
||||||
catch (error) {
|
|
||||||
logger.error(`Fehler beim Speichern der Persistenzdatei ${this.filePath}:`, error);
|
|
||||||
throw error;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
exports.JsonFileStore = JsonFileStore;
|
|
||||||
@@ -1,2 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
@@ -1,68 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.PortManager = void 0;
|
|
||||||
const config_1 = require("./config");
|
|
||||||
const jsonFileStore_1 = require("./persistence/jsonFileStore");
|
|
||||||
const logger_1 = require("./logger");
|
|
||||||
const logger = (0, logger_1.getLogger)("PortManager");
|
|
||||||
class PortManager {
|
|
||||||
constructor() {
|
|
||||||
this.usedPorts = new Set();
|
|
||||||
this.usedQueryPorts = new Set();
|
|
||||||
this.gamePortStart = config_1.GAME_PORT_START;
|
|
||||||
this.queryPortStart = config_1.QUERY_PORT_START;
|
|
||||||
this.persistence = new jsonFileStore_1.JsonFileStore("portManager-state.json");
|
|
||||||
}
|
|
||||||
async init() {
|
|
||||||
const state = await this.persistence.load();
|
|
||||||
if (!state)
|
|
||||||
return;
|
|
||||||
this.usedPorts =
|
|
||||||
new Set(state.usedPorts);
|
|
||||||
this.usedQueryPorts =
|
|
||||||
new Set(state.usedQueryPorts);
|
|
||||||
}
|
|
||||||
allocate() {
|
|
||||||
let port = this.gamePortStart;
|
|
||||||
while (this.usedPorts.has(port)) {
|
|
||||||
port++;
|
|
||||||
}
|
|
||||||
let queryPort = this.queryPortStart;
|
|
||||||
while (this.usedQueryPorts.has(queryPort)) {
|
|
||||||
queryPort++;
|
|
||||||
}
|
|
||||||
this.usedPorts.add(port);
|
|
||||||
this.usedQueryPorts.add(queryPort);
|
|
||||||
logger.debug(`Port erfolgreich reserviert: ${port}`);
|
|
||||||
logger.debug(`Query-Port erfolgreich reserviert: ${queryPort}`);
|
|
||||||
this.saveState();
|
|
||||||
return {
|
|
||||||
port,
|
|
||||||
queryPort
|
|
||||||
};
|
|
||||||
}
|
|
||||||
release(port, queryPort) {
|
|
||||||
const removedPort = this.usedPorts.delete(port);
|
|
||||||
const removedQueryPort = this.usedQueryPorts.delete(queryPort);
|
|
||||||
if (!removedPort || !removedQueryPort) {
|
|
||||||
logger.warn(`Unerwarteter Port-Zustand während der Freigabe: port=${port}, queryPort=${queryPort}`);
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
logger.debug(`Port wieder freigegeben: ${port}`);
|
|
||||||
logger.debug(`Query-Port wieder freigegeben: ${queryPort}`);
|
|
||||||
}
|
|
||||||
this.saveState();
|
|
||||||
}
|
|
||||||
saveState() {
|
|
||||||
const state = {
|
|
||||||
usedPorts: Array.from(this.usedPorts),
|
|
||||||
usedQueryPorts: Array.from(this.usedQueryPorts)
|
|
||||||
};
|
|
||||||
this.persistence
|
|
||||||
.save(state)
|
|
||||||
.catch(error => {
|
|
||||||
logger.error("Fehler beim Speichern des PortManager-Zustands:", error);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
exports.PortManager = PortManager;
|
|
||||||
@@ -1,50 +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;
|
|
||||||
};
|
|
||||||
})();
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.Rabbit = void 0;
|
|
||||||
const amqp = __importStar(require("amqplib"));
|
|
||||||
const config_1 = require("./config");
|
|
||||||
const logger_1 = require("./logger");
|
|
||||||
const logger = (0, logger_1.getLogger)("Rabbit");
|
|
||||||
class Rabbit {
|
|
||||||
async connect() {
|
|
||||||
this.connection =
|
|
||||||
await amqp.connect(config_1.RABBITMQ_URL);
|
|
||||||
this.channel =
|
|
||||||
await this.connection.createChannel();
|
|
||||||
logger.info("Connected to RabbitMQ");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
exports.Rabbit = Rabbit;
|
|
||||||
@@ -1,225 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.ServerLifecycle = void 0;
|
|
||||||
const logger_1 = require("./logger");
|
|
||||||
const config_1 = require("./config");
|
|
||||||
const logger = (0, logger_1.getLogger)("ServerLifecycle");
|
|
||||||
class ServerLifecycle {
|
|
||||||
constructor(serverRegistry, serverManager, desiredServers = config_1.DEFAULT_DESIRED_SERVERS) {
|
|
||||||
this.serverRegistry = serverRegistry;
|
|
||||||
this.serverManager = serverManager;
|
|
||||||
this.desiredServers = desiredServers;
|
|
||||||
this.creatingServers = 0;
|
|
||||||
this.emptyTimeout = config_1.LIFECYCLE_EMPTY_TIMEOUT;
|
|
||||||
this.lastScaleUp = 0;
|
|
||||||
this.scaleCooldown = config_1.LIFECYCLE_SCALE_COOLDOWN;
|
|
||||||
}
|
|
||||||
start() {
|
|
||||||
logger.info("Server Lifecycle gestartet");
|
|
||||||
setInterval(() => {
|
|
||||||
this.checkServers();
|
|
||||||
}, config_1.LIFECYCLE_CHECK_INTERVAL);
|
|
||||||
}
|
|
||||||
setDesiredServers(count) {
|
|
||||||
logger.debug("Neue Soll Server Anzahl:", count);
|
|
||||||
this.desiredServers =
|
|
||||||
count;
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* Exposes the configured target for monitoring consumers.
|
|
||||||
* It deliberately does not influence lifecycle behaviour.
|
|
||||||
*/
|
|
||||||
getDesiredServers() {
|
|
||||||
return this.desiredServers;
|
|
||||||
}
|
|
||||||
checkServers() {
|
|
||||||
const servers = this.serverRegistry.getAll();
|
|
||||||
/*
|
|
||||||
STATUS AKTUALISIEREN
|
|
||||||
*/
|
|
||||||
for (const server of servers) {
|
|
||||||
switch (server.status) {
|
|
||||||
case "STARTING":
|
|
||||||
if (server.pid) {
|
|
||||||
server.status =
|
|
||||||
"RUNNING";
|
|
||||||
server.startedAt =
|
|
||||||
Date.now();
|
|
||||||
server.emptySince =
|
|
||||||
undefined;
|
|
||||||
this.serverRegistry.update(server);
|
|
||||||
logger.info("Server RUNNING:", server.name, "PID:", server.pid);
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case "RECOVERING":
|
|
||||||
if (Date.now() -
|
|
||||||
server.lastSeen
|
|
||||||
>
|
|
||||||
config_1.LIFECYCLE_CRASH_TIMEOUT) {
|
|
||||||
server.status =
|
|
||||||
"CRASHED";
|
|
||||||
server.crashedAt =
|
|
||||||
Date.now();
|
|
||||||
this.serverRegistry.update(server);
|
|
||||||
logger.error("Server-Recovery fehlgeschlagen:", server.name);
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case "RUNNING":
|
|
||||||
/*
|
|
||||||
Crash Detection
|
|
||||||
*/
|
|
||||||
if (Date.now() -
|
|
||||||
server.lastSeen
|
|
||||||
>
|
|
||||||
config_1.LIFECYCLE_CRASH_TIMEOUT) {
|
|
||||||
server.status =
|
|
||||||
"CRASHED";
|
|
||||||
server.crashedAt =
|
|
||||||
Date.now();
|
|
||||||
this.serverRegistry.update(server);
|
|
||||||
logger.error("Server abgestürzt:", server.name);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
/*
|
|
||||||
Leere Server tracken
|
|
||||||
*/
|
|
||||||
if (server.players === 0) {
|
|
||||||
if (!server.emptySince) {
|
|
||||||
if (server.startedAt &&
|
|
||||||
Date.now() -
|
|
||||||
server.startedAt <
|
|
||||||
config_1.LIFECYCLE_STARTUP_GRACE_PERIOD) {
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
server.emptySince =
|
|
||||||
Date.now();
|
|
||||||
this.serverRegistry.update(server);
|
|
||||||
logger.debug("Server leer:", server.name);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
if (server.emptySince) {
|
|
||||||
logger.debug("Server wieder aktiv:", server.name);
|
|
||||||
}
|
|
||||||
server.emptySince =
|
|
||||||
undefined;
|
|
||||||
this.serverRegistry.update(server);
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case "CRASHED":
|
|
||||||
if (!server.crashedAt) {
|
|
||||||
server.crashedAt =
|
|
||||||
Date.now();
|
|
||||||
this.serverRegistry.update(server);
|
|
||||||
logger.error("Server abgestürzt erkannt:", server.name);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
if (Date.now() -
|
|
||||||
server.crashedAt
|
|
||||||
>
|
|
||||||
config_1.LIFECYCLE_CRASH_RETENTION) {
|
|
||||||
logger.info("Entferne abgestürzten Server nach Grace-Zeit:", server.name);
|
|
||||||
this.serverRegistry.remove(server.id);
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
/*
|
|
||||||
AKTIVE SERVER
|
|
||||||
*/
|
|
||||||
const activeServers = this.serverRegistry
|
|
||||||
.getAll()
|
|
||||||
.filter(server => server.status === "RUNNING" ||
|
|
||||||
server.status === "STARTING" ||
|
|
||||||
server.status === "RECOVERING");
|
|
||||||
/*
|
|
||||||
SLOT AUSLASTUNG
|
|
||||||
*/
|
|
||||||
const runningServers = activeServers.filter(server => server.status === "RUNNING");
|
|
||||||
const totalPlayers = runningServers.reduce((sum, server) => sum + server.players, 0);
|
|
||||||
const totalSlots = runningServers.reduce((sum, server) => sum + server.maxPlayers, 0);
|
|
||||||
const usage = totalSlots > 0
|
|
||||||
?
|
|
||||||
totalPlayers / totalSlots
|
|
||||||
:
|
|
||||||
0;
|
|
||||||
logger.debug("Kapazität:", `${totalPlayers}/${totalSlots}`, `${(usage * 100).toFixed(1)}%`);
|
|
||||||
/*
|
|
||||||
MINDEST SERVER ANZAHL
|
|
||||||
*/
|
|
||||||
const totalActive = activeServers.length +
|
|
||||||
this.creatingServers;
|
|
||||||
if (totalActive <
|
|
||||||
this.desiredServers) {
|
|
||||||
const missing = this.desiredServers -
|
|
||||||
totalActive;
|
|
||||||
this.startServers(missing);
|
|
||||||
}
|
|
||||||
/*
|
|
||||||
SCALE UP BEI 90%
|
|
||||||
*/
|
|
||||||
const shouldScale = runningServers.length > 0 &&
|
|
||||||
this.creatingServers === 0 &&
|
|
||||||
usage >= 0.90 &&
|
|
||||||
Date.now() -
|
|
||||||
this.lastScaleUp
|
|
||||||
>
|
|
||||||
this.scaleCooldown;
|
|
||||||
if (shouldScale) {
|
|
||||||
logger.info("Auslastung hoch - starte zusätzlichen Server");
|
|
||||||
this.lastScaleUp =
|
|
||||||
Date.now();
|
|
||||||
this.startServers(1);
|
|
||||||
}
|
|
||||||
/*
|
|
||||||
LEERE SERVER ENTFERNEN
|
|
||||||
*/
|
|
||||||
const removableServers = activeServers
|
|
||||||
.filter(server => server.status === "RUNNING" &&
|
|
||||||
server.players === 0 &&
|
|
||||||
server.emptySince &&
|
|
||||||
server.startedAt &&
|
|
||||||
Date.now() -
|
|
||||||
server.startedAt
|
|
||||||
>=
|
|
||||||
config_1.LIFECYCLE_MIN_UPTIME &&
|
|
||||||
Date.now() -
|
|
||||||
server.emptySince
|
|
||||||
>
|
|
||||||
this.emptyTimeout &&
|
|
||||||
usage <
|
|
||||||
config_1.LIFECYCLE_SCALE_DOWN_THRESHOLD)
|
|
||||||
.sort((a, b) => (a.emptySince ?? 0) -
|
|
||||||
(b.emptySince ?? 0));
|
|
||||||
for (const server of removableServers) {
|
|
||||||
const activeCount = this.serverRegistry
|
|
||||||
.getAll()
|
|
||||||
.filter(s => s.status === "RUNNING" ||
|
|
||||||
s.status === "STARTING" ||
|
|
||||||
s.status === "RECOVERING")
|
|
||||||
.length;
|
|
||||||
if (activeCount <=
|
|
||||||
this.desiredServers) {
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
logger.info("Stoppe leeren Server:", server.name);
|
|
||||||
this.serverManager.stopServer(server.id);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
startServers(count) {
|
|
||||||
logger.info("Starte Server:", count);
|
|
||||||
for (let i = 0; i < count; i++) {
|
|
||||||
this.creatingServers++;
|
|
||||||
this.serverManager
|
|
||||||
.createServer()
|
|
||||||
.then(() => {
|
|
||||||
this.creatingServers--;
|
|
||||||
})
|
|
||||||
.catch(err => {
|
|
||||||
this.creatingServers--;
|
|
||||||
logger.error("Server Erstellung fehlgeschlagen:", err);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
exports.ServerLifecycle = ServerLifecycle;
|
|
||||||
@@ -1,41 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.ServerLifecycleManager = void 0;
|
|
||||||
class ServerLifecycleManager {
|
|
||||||
constructor(serverRegistry, rabbit) {
|
|
||||||
this.serverRegistry = serverRegistry;
|
|
||||||
this.rabbit = rabbit;
|
|
||||||
}
|
|
||||||
start() {
|
|
||||||
console.log("Server Lifecycle Manager gestartet");
|
|
||||||
setInterval(() => {
|
|
||||||
this.checkServers();
|
|
||||||
}, 5000);
|
|
||||||
}
|
|
||||||
checkServers() {
|
|
||||||
const servers = this.serverRegistry.getAll();
|
|
||||||
for (const server of servers) {
|
|
||||||
switch (server.status) {
|
|
||||||
case "STARTING":
|
|
||||||
this.checkStarting(server);
|
|
||||||
break;
|
|
||||||
case "RUNNING":
|
|
||||||
this.checkRunning(server);
|
|
||||||
break;
|
|
||||||
case "CRASHED":
|
|
||||||
this.checkOffline(server);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
checkStarting(server) {
|
|
||||||
// kommt später
|
|
||||||
}
|
|
||||||
checkRunning(server) {
|
|
||||||
// kommt später
|
|
||||||
}
|
|
||||||
checkOffline(server) {
|
|
||||||
// kommt später
|
|
||||||
}
|
|
||||||
}
|
|
||||||
exports.ServerLifecycleManager = ServerLifecycleManager;
|
|
||||||
@@ -1,102 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.ServerManager = void 0;
|
|
||||||
const logger_1 = require("./logger");
|
|
||||||
const crypto_1 = require("crypto");
|
|
||||||
const nameGenerator_1 = require("./nameGenerator");
|
|
||||||
const logger = (0, logger_1.getLogger)("ServerManager");
|
|
||||||
class ServerManager {
|
|
||||||
constructor(rabbit, wrapperRegistry, serverRegistry, portManager) {
|
|
||||||
this.rabbit = rabbit;
|
|
||||||
this.wrapperRegistry = wrapperRegistry;
|
|
||||||
this.serverRegistry = serverRegistry;
|
|
||||||
this.portManager = portManager;
|
|
||||||
}
|
|
||||||
async createServer() {
|
|
||||||
/*
|
|
||||||
freien Wrapper suchen
|
|
||||||
*/
|
|
||||||
const wrapper = this.findBestWrapper();
|
|
||||||
if (!wrapper) {
|
|
||||||
logger.warn("Kein Wrapper verfügbar");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const serverId = "srv-" +
|
|
||||||
(0, crypto_1.randomUUID)()
|
|
||||||
.slice(0, 8);
|
|
||||||
const serverName = (0, nameGenerator_1.generateServerName)(this.serverRegistry
|
|
||||||
.getAll()
|
|
||||||
.map(server => server.name));
|
|
||||||
/*
|
|
||||||
Ports reservieren
|
|
||||||
*/
|
|
||||||
const ports = this.portManager.allocate();
|
|
||||||
const server = {
|
|
||||||
id: serverId,
|
|
||||||
name: serverName,
|
|
||||||
wrapperId: wrapper.id,
|
|
||||||
status: "STARTING",
|
|
||||||
port: ports.port,
|
|
||||||
queryPort: ports.queryPort,
|
|
||||||
players: 0,
|
|
||||||
maxPlayers: 21,
|
|
||||||
created: Date.now(),
|
|
||||||
lastSeen: Date.now()
|
|
||||||
};
|
|
||||||
/*
|
|
||||||
Registry Eintrag
|
|
||||||
*/
|
|
||||||
this.serverRegistry.add(server);
|
|
||||||
/*
|
|
||||||
Command an Wrapper
|
|
||||||
*/
|
|
||||||
const command = {
|
|
||||||
type: "server.start",
|
|
||||||
serverId,
|
|
||||||
name: serverName,
|
|
||||||
port: ports.port,
|
|
||||||
queryPort: ports.queryPort
|
|
||||||
};
|
|
||||||
const sent = this.rabbit.channel.sendToQueue(wrapper.commandQueue, Buffer.from(JSON.stringify(command)));
|
|
||||||
if (!sent) {
|
|
||||||
throw new Error("Server Start Command konnte nicht gesendet werden");
|
|
||||||
}
|
|
||||||
logger.info("Starting server:", server.id);
|
|
||||||
}
|
|
||||||
async stopServer(serverId) {
|
|
||||||
const server = this.serverRegistry.get(serverId);
|
|
||||||
if (!server) {
|
|
||||||
logger.warn("Server not found:", serverId);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const wrapper = this.wrapperRegistry.get(server.wrapperId);
|
|
||||||
if (!wrapper) {
|
|
||||||
logger.warn("Wrapper not found:", server.wrapperId);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const command = {
|
|
||||||
type: "server.stop",
|
|
||||||
serverId
|
|
||||||
};
|
|
||||||
this.rabbit.channel.sendToQueue(wrapper.commandQueue, Buffer.from(JSON.stringify(command)));
|
|
||||||
server.status =
|
|
||||||
"STOPPING";
|
|
||||||
this.serverRegistry.update(server);
|
|
||||||
logger.info("Stopping server:", serverId);
|
|
||||||
}
|
|
||||||
findBestWrapper() {
|
|
||||||
const wrappers = this.wrapperRegistry.getAll()
|
|
||||||
.filter(w => w.online);
|
|
||||||
if (wrappers.length === 0)
|
|
||||||
return undefined;
|
|
||||||
/*
|
|
||||||
Einfachste Version:
|
|
||||||
|
|
||||||
wenigste Server
|
|
||||||
*/
|
|
||||||
wrappers.sort((a, b) => a.servers.length -
|
|
||||||
b.servers.length);
|
|
||||||
return wrappers[0];
|
|
||||||
}
|
|
||||||
}
|
|
||||||
exports.ServerManager = ServerManager;
|
|
||||||
@@ -1,151 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.ServerRegistry = void 0;
|
|
||||||
const logger_1 = require("./logger");
|
|
||||||
const jsonFileStore_1 = require("./persistence/jsonFileStore");
|
|
||||||
const logger = (0, logger_1.getLogger)("ServerRegistry");
|
|
||||||
class ServerRegistry {
|
|
||||||
constructor() {
|
|
||||||
this.servers = new Map();
|
|
||||||
this.persistence = new jsonFileStore_1.JsonFileStore("serverRegistry-state.json");
|
|
||||||
}
|
|
||||||
async init() {
|
|
||||||
const state = await this.persistence.load();
|
|
||||||
if (!state)
|
|
||||||
return;
|
|
||||||
for (const serverData of state.servers) {
|
|
||||||
this.servers.set(serverData.id, {
|
|
||||||
id: serverData.id,
|
|
||||||
name: serverData.name,
|
|
||||||
wrapperId: serverData.wrapperId,
|
|
||||||
port: serverData.port,
|
|
||||||
queryPort: serverData.queryPort,
|
|
||||||
created: serverData.created,
|
|
||||||
status: "RECOVERING",
|
|
||||||
players: 0,
|
|
||||||
maxPlayers: 0,
|
|
||||||
lastSeen: Date.now()
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
toState() {
|
|
||||||
return {
|
|
||||||
servers: Array.from(this.servers.values()).map(server => ({
|
|
||||||
id: server.id,
|
|
||||||
name: server.name,
|
|
||||||
wrapperId: server.wrapperId,
|
|
||||||
port: server.port,
|
|
||||||
queryPort: server.queryPort,
|
|
||||||
created: server.created
|
|
||||||
}))
|
|
||||||
};
|
|
||||||
}
|
|
||||||
async saveState() {
|
|
||||||
await this.persistence.save(this.toState());
|
|
||||||
}
|
|
||||||
persist() {
|
|
||||||
void this.saveState();
|
|
||||||
}
|
|
||||||
add(server) {
|
|
||||||
this.servers.set(server.id, server);
|
|
||||||
logger.info("Server added:", server.id);
|
|
||||||
this.persist();
|
|
||||||
}
|
|
||||||
get(id) {
|
|
||||||
return this.servers.get(id);
|
|
||||||
}
|
|
||||||
getAll() {
|
|
||||||
return Array.from(this.servers.values());
|
|
||||||
}
|
|
||||||
update(server) {
|
|
||||||
this.servers.set(server.id, server);
|
|
||||||
this.persist();
|
|
||||||
}
|
|
||||||
remove(id) {
|
|
||||||
this.servers.delete(id);
|
|
||||||
logger.info("Server removed:", id);
|
|
||||||
this.persist();
|
|
||||||
}
|
|
||||||
list() {
|
|
||||||
logger.info("Server list output");
|
|
||||||
const servers = this.getAll();
|
|
||||||
if (servers.length === 0) {
|
|
||||||
logger.info("Keine Server vorhanden");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
for (const server of servers) {
|
|
||||||
logger.info({
|
|
||||||
id: server.id,
|
|
||||||
name: server.name,
|
|
||||||
wrapper: server.wrapperId,
|
|
||||||
status: server.status,
|
|
||||||
port: server.port,
|
|
||||||
queryPort: server.queryPort,
|
|
||||||
players: `${server.players}/${server.maxPlayers}`
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
syncWrapperStatus(data) {
|
|
||||||
if (!data.servers)
|
|
||||||
return;
|
|
||||||
const runningServerIds = new Set(data.servers.map(srv => srv.id));
|
|
||||||
for (const server of this.servers.values()) {
|
|
||||||
if (server.wrapperId === data.wrapperId &&
|
|
||||||
!runningServerIds.has(server.id)) {
|
|
||||||
if (server.status === "STOPPING") {
|
|
||||||
logger.debug("Server cleanly stopped:", server.name);
|
|
||||||
this.remove(server.id);
|
|
||||||
}
|
|
||||||
else if (server.status === "RUNNING" ||
|
|
||||||
server.status === "RECOVERING") {
|
|
||||||
server.status =
|
|
||||||
"CRASHED";
|
|
||||||
if (!server.crashedAt) {
|
|
||||||
server.crashedAt =
|
|
||||||
Date.now();
|
|
||||||
}
|
|
||||||
this.servers.set(server.id, server);
|
|
||||||
logger.warn("Server crashed:", server.name);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
for (const srv of data.servers) {
|
|
||||||
const server = this.servers.get(srv.id);
|
|
||||||
if (!server)
|
|
||||||
continue;
|
|
||||||
server.pid =
|
|
||||||
srv.pid;
|
|
||||||
server.players =
|
|
||||||
srv.players ?? 0;
|
|
||||||
server.maxPlayers =
|
|
||||||
srv.maxPlayers ?? 0;
|
|
||||||
server.lastSeen =
|
|
||||||
Date.now();
|
|
||||||
const oldStatus = server.status;
|
|
||||||
if (srv.alive && server.status !== "STOPPING") {
|
|
||||||
server.crashedAt =
|
|
||||||
undefined;
|
|
||||||
if (!server.startedAt) {
|
|
||||||
server.startedAt =
|
|
||||||
srv.started;
|
|
||||||
}
|
|
||||||
server.status =
|
|
||||||
"RUNNING";
|
|
||||||
}
|
|
||||||
else if (server.status === "RUNNING" ||
|
|
||||||
server.status === "RECOVERING") {
|
|
||||||
server.status =
|
|
||||||
"CRASHED";
|
|
||||||
if (!server.crashedAt) {
|
|
||||||
server.crashedAt =
|
|
||||||
Date.now();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (oldStatus !== server.status) {
|
|
||||||
logger.debug("Status change:", server.name, oldStatus, "->", server.status);
|
|
||||||
}
|
|
||||||
this.servers.set(server.id, server);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
exports.ServerRegistry = ServerRegistry;
|
|
||||||
@@ -1,61 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.ServerStatusManager = void 0;
|
|
||||||
const logger_1 = require("./logger");
|
|
||||||
const logger = (0, logger_1.getLogger)("ServerStatusManager");
|
|
||||||
class ServerStatusManager {
|
|
||||||
constructor(rabbit, registry) {
|
|
||||||
this.rabbit = rabbit;
|
|
||||||
this.registry = registry;
|
|
||||||
}
|
|
||||||
async start() {
|
|
||||||
const queue = "server.status";
|
|
||||||
await this.rabbit.channel.assertQueue(queue);
|
|
||||||
logger.info("Warte auf Server Status...");
|
|
||||||
this.rabbit.channel.consume(queue, msg => {
|
|
||||||
if (!msg)
|
|
||||||
return;
|
|
||||||
const data = JSON.parse(msg.content.toString());
|
|
||||||
switch (data.type) {
|
|
||||||
case "server.started":
|
|
||||||
this.serverStarted(data);
|
|
||||||
break;
|
|
||||||
case "server.stopped":
|
|
||||||
this.serverStopped(data);
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
logger.warn("Unbekannter Server Status:", data);
|
|
||||||
}
|
|
||||||
this.rabbit.channel.ack(msg);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
serverStarted(data) {
|
|
||||||
const server = this.registry.get(data.serverId);
|
|
||||||
if (!server)
|
|
||||||
return;
|
|
||||||
server.status =
|
|
||||||
"RUNNING";
|
|
||||||
server.crashedAt =
|
|
||||||
undefined;
|
|
||||||
if (!server.startedAt) {
|
|
||||||
server.startedAt =
|
|
||||||
Date.now();
|
|
||||||
}
|
|
||||||
this.registry.update(server);
|
|
||||||
logger.info("Server started:", data.serverId);
|
|
||||||
}
|
|
||||||
serverStopped(data) {
|
|
||||||
const server = this.registry.get(data.serverId);
|
|
||||||
if (!server)
|
|
||||||
return;
|
|
||||||
server.status =
|
|
||||||
"CRASHED";
|
|
||||||
if (!server.crashedAt) {
|
|
||||||
server.crashedAt =
|
|
||||||
Date.now();
|
|
||||||
}
|
|
||||||
this.registry.update(server);
|
|
||||||
logger.info("Server stopped:", data.serverId);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
exports.ServerStatusManager = ServerStatusManager;
|
|
||||||
@@ -1,2 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
@@ -1,113 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.WebApi = void 0;
|
|
||||||
class WebApi {
|
|
||||||
constructor(deps) {
|
|
||||||
this.deps = deps;
|
|
||||||
}
|
|
||||||
getHealth() {
|
|
||||||
return {
|
|
||||||
status: this.deps.managerStatus ?? "running",
|
|
||||||
timestamp: new Date().toISOString()
|
|
||||||
};
|
|
||||||
}
|
|
||||||
getDashboard() {
|
|
||||||
const wrappers = this.deps.wrapperRegistry.getAll();
|
|
||||||
const servers = this.deps.serverRegistry.getAll();
|
|
||||||
const runningServers = servers.filter(server => server.status === "RUNNING").length;
|
|
||||||
const totalPlayers = servers.reduce((sum, server) => sum + server.players, 0);
|
|
||||||
const totalCapacity = servers.reduce((sum, server) => sum + server.maxPlayers, 0);
|
|
||||||
const utilizationPercent = totalCapacity > 0 ? Math.round((totalPlayers / totalCapacity) * 100) : 0;
|
|
||||||
return {
|
|
||||||
managerStatus: this.deps.managerStatus ?? "running",
|
|
||||||
rabbitMqStatus: this.deps.rabbitMqStatus ?? "connected",
|
|
||||||
wrapperCount: wrappers.length,
|
|
||||||
onlineWrapperCount: wrappers.filter(wrapper => wrapper.online).length,
|
|
||||||
serverCount: servers.length,
|
|
||||||
runningServerCount: runningServers,
|
|
||||||
totalPlayers,
|
|
||||||
totalCapacity,
|
|
||||||
utilizationPercent,
|
|
||||||
desiredServers: this.getDesiredServers(),
|
|
||||||
activeServers: servers.filter(server => server.status === "RUNNING" || server.status === "STARTING").length
|
|
||||||
};
|
|
||||||
}
|
|
||||||
getWrappers() {
|
|
||||||
return this.deps.wrapperRegistry.getAll().map(wrapper => ({
|
|
||||||
id: wrapper.id,
|
|
||||||
hostname: wrapper.hostname,
|
|
||||||
online: wrapper.online,
|
|
||||||
cpu: wrapper.cpu,
|
|
||||||
ram: wrapper.ram,
|
|
||||||
ramFree: wrapper.ramFree,
|
|
||||||
lastHeartbeat: wrapper.lastHeartbeat,
|
|
||||||
serverCount: wrapper.servers.length
|
|
||||||
}));
|
|
||||||
}
|
|
||||||
getWrapper(id) {
|
|
||||||
const wrapper = this.deps.wrapperRegistry.get(id);
|
|
||||||
if (!wrapper) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
return {
|
|
||||||
id: wrapper.id,
|
|
||||||
hostname: wrapper.hostname,
|
|
||||||
online: wrapper.online,
|
|
||||||
cpu: wrapper.cpu,
|
|
||||||
ram: wrapper.ram,
|
|
||||||
ramFree: wrapper.ramFree,
|
|
||||||
lastHeartbeat: wrapper.lastHeartbeat,
|
|
||||||
serverCount: wrapper.servers.length,
|
|
||||||
servers: wrapper.servers.map(server => ({
|
|
||||||
id: server.id,
|
|
||||||
name: server.name,
|
|
||||||
port: server.port,
|
|
||||||
queryPort: server.queryPort,
|
|
||||||
players: server.players,
|
|
||||||
maxPlayers: server.maxPlayers,
|
|
||||||
alive: server.alive,
|
|
||||||
started: server.started
|
|
||||||
}))
|
|
||||||
};
|
|
||||||
}
|
|
||||||
getServers() {
|
|
||||||
return this.deps.serverRegistry.getAll().map(server => ({
|
|
||||||
id: server.id,
|
|
||||||
name: server.name,
|
|
||||||
status: server.status,
|
|
||||||
wrapperId: server.wrapperId,
|
|
||||||
pid: server.pid,
|
|
||||||
port: server.port,
|
|
||||||
queryPort: server.queryPort,
|
|
||||||
players: server.players,
|
|
||||||
maxPlayers: server.maxPlayers,
|
|
||||||
created: server.created,
|
|
||||||
startedAt: server.startedAt,
|
|
||||||
emptySince: server.emptySince
|
|
||||||
}));
|
|
||||||
}
|
|
||||||
getServer(id) {
|
|
||||||
const server = this.deps.serverRegistry.get(id);
|
|
||||||
if (!server) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
return {
|
|
||||||
id: server.id,
|
|
||||||
name: server.name,
|
|
||||||
status: server.status,
|
|
||||||
wrapperId: server.wrapperId,
|
|
||||||
pid: server.pid,
|
|
||||||
port: server.port,
|
|
||||||
queryPort: server.queryPort,
|
|
||||||
players: server.players,
|
|
||||||
maxPlayers: server.maxPlayers,
|
|
||||||
created: server.created,
|
|
||||||
startedAt: server.startedAt,
|
|
||||||
emptySince: server.emptySince
|
|
||||||
};
|
|
||||||
}
|
|
||||||
getDesiredServers() {
|
|
||||||
return this.deps.lifecycle.getDesiredServers();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
exports.WebApi = WebApi;
|
|
||||||
@@ -1,56 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.registerRoutes = registerRoutes;
|
|
||||||
const url_1 = require("url");
|
|
||||||
function registerRoutes(server, api) {
|
|
||||||
server.on("request", (req, res) => {
|
|
||||||
const url = (0, url_1.parse)(req.url ?? "/", true);
|
|
||||||
const pathname = url.pathname ?? "/";
|
|
||||||
if (pathname === "/api/health") {
|
|
||||||
res.writeHead(200, { "Content-Type": "application/json" });
|
|
||||||
res.end(JSON.stringify(api.getHealth()));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (pathname === "/api/dashboard") {
|
|
||||||
res.writeHead(200, { "Content-Type": "application/json" });
|
|
||||||
res.end(JSON.stringify(api.getDashboard()));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (pathname === "/api/wrappers") {
|
|
||||||
res.writeHead(200, { "Content-Type": "application/json" });
|
|
||||||
res.end(JSON.stringify(api.getWrappers()));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (pathname.startsWith("/api/wrappers/")) {
|
|
||||||
const id = decodeURIComponent(pathname.split("/").pop() ?? "");
|
|
||||||
const wrapper = api.getWrapper(id);
|
|
||||||
if (!wrapper) {
|
|
||||||
res.writeHead(404, { "Content-Type": "application/json" });
|
|
||||||
res.end(JSON.stringify({ error: "Wrapper not found" }));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
res.writeHead(200, { "Content-Type": "application/json" });
|
|
||||||
res.end(JSON.stringify(wrapper));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (pathname === "/api/servers") {
|
|
||||||
res.writeHead(200, { "Content-Type": "application/json" });
|
|
||||||
res.end(JSON.stringify(api.getServers()));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (pathname.startsWith("/api/servers/")) {
|
|
||||||
const id = decodeURIComponent(pathname.split("/").pop() ?? "");
|
|
||||||
const server = api.getServer(id);
|
|
||||||
if (!server) {
|
|
||||||
res.writeHead(404, { "Content-Type": "application/json" });
|
|
||||||
res.end(JSON.stringify({ error: "Server not found" }));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
res.writeHead(200, { "Content-Type": "application/json" });
|
|
||||||
res.end(JSON.stringify(server));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
res.writeHead(404, { "Content-Type": "application/json" });
|
|
||||||
res.end(JSON.stringify({ error: "Not found" }));
|
|
||||||
});
|
|
||||||
}
|
|
||||||
@@ -1,15 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.createWebServer = createWebServer;
|
|
||||||
const http_1 = require("http");
|
|
||||||
const routes_1 = require("./routes");
|
|
||||||
const api_1 = require("./api");
|
|
||||||
function createWebServer(deps, port = 3000) {
|
|
||||||
const api = new api_1.WebApi(deps);
|
|
||||||
const server = (0, http_1.createServer)();
|
|
||||||
(0, routes_1.registerRoutes)(server, api);
|
|
||||||
server.listen(port, () => {
|
|
||||||
// no-op: startup is handled by the manager
|
|
||||||
});
|
|
||||||
return server;
|
|
||||||
}
|
|
||||||
@@ -1,2 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
@@ -1,167 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.WrapperManager = void 0;
|
|
||||||
const logger_1 = require("./logger");
|
|
||||||
const crypto_1 = require("crypto");
|
|
||||||
const logger = (0, logger_1.getLogger)("WrapperManager");
|
|
||||||
class WrapperManager {
|
|
||||||
constructor(rabbit, registry, serverRegistry) {
|
|
||||||
this.rabbit = rabbit;
|
|
||||||
this.registry = registry;
|
|
||||||
this.serverRegistry = serverRegistry;
|
|
||||||
}
|
|
||||||
async start() {
|
|
||||||
const queue = "wrapper.register";
|
|
||||||
await this.rabbit.channel.assertQueue(queue);
|
|
||||||
logger.info("Warte auf Wrapper...");
|
|
||||||
this.rabbit.channel.consume(queue, async (msg) => {
|
|
||||||
if (!msg)
|
|
||||||
return;
|
|
||||||
const data = JSON.parse(msg.content.toString());
|
|
||||||
switch (data.type) {
|
|
||||||
case "wrapper.register":
|
|
||||||
await this.register(data);
|
|
||||||
break;
|
|
||||||
case "wrapper.heartbeat":
|
|
||||||
this.heartbeat(data);
|
|
||||||
break;
|
|
||||||
case "wrapper.status":
|
|
||||||
logger.debug("Status update received from wrapper-id", data.wrapperId);
|
|
||||||
this.registry.updateStatus(data);
|
|
||||||
this.serverRegistry.syncWrapperStatus(data);
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
logger.warn("Unbekannte Nachricht:", data);
|
|
||||||
}
|
|
||||||
this.rabbit.channel.ack(msg);
|
|
||||||
});
|
|
||||||
// Offline Check
|
|
||||||
setInterval(() => {
|
|
||||||
this.registry.checkOffline(30000);
|
|
||||||
}, 5000);
|
|
||||||
}
|
|
||||||
async register(data) {
|
|
||||||
let id = data.wrapperId;
|
|
||||||
/*
|
|
||||||
Neue Wrapper bekommen eine ID
|
|
||||||
*/
|
|
||||||
if (!id) {
|
|
||||||
id =
|
|
||||||
"wrp-" +
|
|
||||||
(0, crypto_1.randomUUID)()
|
|
||||||
.slice(0, 8);
|
|
||||||
logger.debug("Neue Wrapper ID:", id);
|
|
||||||
}
|
|
||||||
const existing = this.registry.get(id);
|
|
||||||
/*
|
|
||||||
Wrapper war schon bekannt
|
|
||||||
*/
|
|
||||||
if (existing) {
|
|
||||||
existing.online = true;
|
|
||||||
existing.lastHeartbeat =
|
|
||||||
Date.now();
|
|
||||||
existing.hostname =
|
|
||||||
data.hostname;
|
|
||||||
existing.cpu =
|
|
||||||
data.cpu;
|
|
||||||
existing.ram =
|
|
||||||
data.ram;
|
|
||||||
existing.ramFree =
|
|
||||||
data.ram;
|
|
||||||
// servers are updated via wrapper.status, not wrapper.register
|
|
||||||
this.registry.update(existing);
|
|
||||||
}
|
|
||||||
/*
|
|
||||||
Neuer Wrapper
|
|
||||||
*/
|
|
||||||
else {
|
|
||||||
const commandQueue = `wrapper.${id}.commands`;
|
|
||||||
await this.rabbit.channel.assertQueue(commandQueue);
|
|
||||||
const wrapper = {
|
|
||||||
id,
|
|
||||||
hostname: data.hostname,
|
|
||||||
commandQueue,
|
|
||||||
cpu: data.cpu,
|
|
||||||
ram: data.ram,
|
|
||||||
ramFree: data.ram,
|
|
||||||
servers: [],
|
|
||||||
online: true,
|
|
||||||
lastHeartbeat: Date.now()
|
|
||||||
};
|
|
||||||
this.registry.add(wrapper);
|
|
||||||
}
|
|
||||||
/*
|
|
||||||
Antwort zurück an Wrapper
|
|
||||||
*/
|
|
||||||
const wrapper = this.registry.get(id);
|
|
||||||
if (data.replyQueue) {
|
|
||||||
this.rabbit.channel.sendToQueue(data.replyQueue, Buffer.from(JSON.stringify({
|
|
||||||
type: "wrapper.registered",
|
|
||||||
wrapperId: id,
|
|
||||||
commandQueue: wrapper?.commandQueue
|
|
||||||
})));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
heartbeat(data) {
|
|
||||||
this.registry.updateHeartbeat(data.wrapperId);
|
|
||||||
logger.debug("Heartbeat:", data.wrapperId);
|
|
||||||
}
|
|
||||||
sendCommand(wrapperId, command) {
|
|
||||||
const wrapper = this.registry.get(wrapperId);
|
|
||||||
if (!wrapper) {
|
|
||||||
throw new Error("Wrapper nicht gefunden");
|
|
||||||
}
|
|
||||||
this.rabbit.channel.sendToQueue(wrapper.commandQueue, Buffer.from(JSON.stringify(command)));
|
|
||||||
}
|
|
||||||
getWrappers() {
|
|
||||||
return this.registry.getAll();
|
|
||||||
}
|
|
||||||
listWrappers() {
|
|
||||||
const wrappers = this.registry.getAll();
|
|
||||||
logger.info("Wrapper Übersicht ausgegeben");
|
|
||||||
if (wrappers.length === 0) {
|
|
||||||
logger.info("Keine Wrapper registriert");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
for (const wrapper of wrappers) {
|
|
||||||
logger.info(`
|
|
||||||
|
|
||||||
ID:
|
|
||||||
${wrapper.id}
|
|
||||||
|
|
||||||
|
|
||||||
Host:
|
|
||||||
${wrapper.hostname}
|
|
||||||
|
|
||||||
|
|
||||||
CPU:
|
|
||||||
${wrapper.cpu} Cores
|
|
||||||
|
|
||||||
|
|
||||||
RAM:
|
|
||||||
${wrapper.ram} MB
|
|
||||||
|
|
||||||
|
|
||||||
RAM frei:
|
|
||||||
${wrapper.ramFree} MB
|
|
||||||
|
|
||||||
|
|
||||||
Server:
|
|
||||||
${wrapper.servers.length}
|
|
||||||
|
|
||||||
|
|
||||||
Online:
|
|
||||||
${wrapper.online}
|
|
||||||
|
|
||||||
|
|
||||||
Heartbeat:
|
|
||||||
${new Date(wrapper.lastHeartbeat).toLocaleString()}
|
|
||||||
|
|
||||||
|
|
||||||
----------------------
|
|
||||||
|
|
||||||
`);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
exports.WrapperManager = WrapperManager;
|
|
||||||
@@ -1,92 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
|
||||||
exports.WrapperRegistry = void 0;
|
|
||||||
const logger_1 = require("./logger");
|
|
||||||
const jsonFileStore_1 = require("./persistence/jsonFileStore");
|
|
||||||
const logger = (0, logger_1.getLogger)("WrapperRegistry");
|
|
||||||
class WrapperRegistry {
|
|
||||||
constructor() {
|
|
||||||
this.wrappers = new Map();
|
|
||||||
this.persistence = new jsonFileStore_1.JsonFileStore("wrapperRegistry-state.json");
|
|
||||||
}
|
|
||||||
async init() {
|
|
||||||
const state = await this.persistence.load();
|
|
||||||
if (!state)
|
|
||||||
return;
|
|
||||||
for (const wrapperData of state.wrappers) {
|
|
||||||
this.wrappers.set(wrapperData.id, {
|
|
||||||
id: wrapperData.id,
|
|
||||||
hostname: wrapperData.hostname,
|
|
||||||
commandQueue: wrapperData.commandQueue,
|
|
||||||
cpu: wrapperData.cpu,
|
|
||||||
ram: wrapperData.ram,
|
|
||||||
ramFree: wrapperData.ram,
|
|
||||||
online: false,
|
|
||||||
lastHeartbeat: 0,
|
|
||||||
servers: []
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
toState() {
|
|
||||||
return {
|
|
||||||
wrappers: Array.from(this.wrappers.values()).map(wrapper => ({
|
|
||||||
id: wrapper.id,
|
|
||||||
hostname: wrapper.hostname,
|
|
||||||
commandQueue: wrapper.commandQueue,
|
|
||||||
cpu: wrapper.cpu,
|
|
||||||
ram: wrapper.ram
|
|
||||||
}))
|
|
||||||
};
|
|
||||||
}
|
|
||||||
async saveState() {
|
|
||||||
await this.persistence.save(this.toState());
|
|
||||||
}
|
|
||||||
add(wrapper) {
|
|
||||||
this.wrappers.set(wrapper.id, wrapper);
|
|
||||||
logger.info("Wrapper added:", wrapper.id);
|
|
||||||
void this.saveState();
|
|
||||||
}
|
|
||||||
get(id) {
|
|
||||||
return this.wrappers.get(id);
|
|
||||||
}
|
|
||||||
getAll() {
|
|
||||||
return Array.from(this.wrappers.values());
|
|
||||||
}
|
|
||||||
updateHeartbeat(id) {
|
|
||||||
const wrapper = this.wrappers.get(id);
|
|
||||||
if (!wrapper)
|
|
||||||
return;
|
|
||||||
wrapper.lastHeartbeat =
|
|
||||||
Date.now();
|
|
||||||
wrapper.online =
|
|
||||||
true;
|
|
||||||
}
|
|
||||||
update(wrapper) {
|
|
||||||
this.wrappers.set(wrapper.id, wrapper);
|
|
||||||
void this.saveState();
|
|
||||||
}
|
|
||||||
checkOffline(timeout) {
|
|
||||||
const now = Date.now();
|
|
||||||
for (const wrapper of this.wrappers.values()) {
|
|
||||||
if (wrapper.online &&
|
|
||||||
now - wrapper.lastHeartbeat > timeout) {
|
|
||||||
wrapper.online = false;
|
|
||||||
logger.warn("Wrapper offline:", wrapper.id);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
updateStatus(data) {
|
|
||||||
const wrapper = this.wrappers.get(data.wrapperId);
|
|
||||||
if (!wrapper)
|
|
||||||
return;
|
|
||||||
wrapper.ramFree =
|
|
||||||
data.ramFree;
|
|
||||||
wrapper.servers =
|
|
||||||
data.servers;
|
|
||||||
wrapper.lastHeartbeat =
|
|
||||||
Date.now();
|
|
||||||
wrapper.online =
|
|
||||||
true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
exports.WrapperRegistry = WrapperRegistry;
|
|
||||||
+10
-1
@@ -8,6 +8,15 @@
|
|||||||
"skipLibCheck": true,
|
"skipLibCheck": true,
|
||||||
"types": [
|
"types": [
|
||||||
"node"
|
"node"
|
||||||
|
],
|
||||||
|
"outDir": "./dist",
|
||||||
|
"rootDir": "./src"
|
||||||
|
},
|
||||||
|
"include": [
|
||||||
|
"src/**/*.ts"
|
||||||
|
],
|
||||||
|
"exclude": [
|
||||||
|
"node_modules",
|
||||||
|
"dist"
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
}
|
|
||||||
+7
-2
@@ -4,10 +4,15 @@
|
|||||||
"main": "dist/index.js",
|
"main": "dist/index.js",
|
||||||
"types": "dist/index.d.ts",
|
"types": "dist/index.d.ts",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"build": "tsc -p tsconfig.json"
|
"build": "tsc -p tsconfig.json",
|
||||||
|
"clean": "rimraf dist"
|
||||||
},
|
},
|
||||||
|
"files": [
|
||||||
|
"dist"
|
||||||
|
],
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@types/node": "^26.1.1",
|
"@types/node": "^26.1.1",
|
||||||
"typescript": "^5.7.3"
|
"typescript": "^5.7.3",
|
||||||
|
"rimraf": "^6.0.1"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -4,8 +4,8 @@
|
|||||||
"module": "CommonJS",
|
"module": "CommonJS",
|
||||||
"declaration": true,
|
"declaration": true,
|
||||||
"declarationMap": true,
|
"declarationMap": true,
|
||||||
"outDir": "dist",
|
"outDir": "./dist",
|
||||||
"rootDir": "src",
|
"rootDir": "./src",
|
||||||
"strict": true,
|
"strict": true,
|
||||||
"esModuleInterop": true,
|
"esModuleInterop": true,
|
||||||
"skipLibCheck": true,
|
"skipLibCheck": true,
|
||||||
@@ -14,6 +14,10 @@
|
|||||||
]
|
]
|
||||||
},
|
},
|
||||||
"include": [
|
"include": [
|
||||||
"src"
|
"src/**/*.ts"
|
||||||
|
],
|
||||||
|
"exclude": [
|
||||||
|
"node_modules",
|
||||||
|
"dist"
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
@@ -1,11 +1,12 @@
|
|||||||
{
|
{
|
||||||
"name": "wrapper",
|
"name": "wrapper",
|
||||||
"version": "1.0.0",
|
"version": "1.0.0",
|
||||||
"description": "",
|
"description": "Server Manager Wrapper",
|
||||||
"main": "index.js",
|
"main": "dist/index.js",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"start": "ts-node src/index.ts",
|
"dev": "ts-node src/index.ts",
|
||||||
"build": "tsc -p tsconfig.json"
|
"build": "tsc -p tsconfig.json",
|
||||||
|
"start": "node dist/index.js"
|
||||||
},
|
},
|
||||||
"keywords": [],
|
"keywords": [],
|
||||||
"author": "",
|
"author": "",
|
||||||
|
|||||||
@@ -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;
|
|
||||||
+14
-2
@@ -5,6 +5,18 @@
|
|||||||
"moduleResolution": "node",
|
"moduleResolution": "node",
|
||||||
"esModuleInterop": true,
|
"esModuleInterop": true,
|
||||||
"strict": true,
|
"strict": true,
|
||||||
"skipLibCheck": true
|
"skipLibCheck": true,
|
||||||
}
|
"outDir": "./dist",
|
||||||
|
"rootDir": "./src",
|
||||||
|
"types": [
|
||||||
|
"node"
|
||||||
|
]
|
||||||
|
},
|
||||||
|
"include": [
|
||||||
|
"src/**/*.ts"
|
||||||
|
],
|
||||||
|
"exclude": [
|
||||||
|
"node_modules",
|
||||||
|
"dist"
|
||||||
|
]
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user