[FEATURE] Basic System with file manager (#4)

Co-authored-by: dunemask <dunemask@gmail.com>
Co-authored-by: Dunemask <dunemask@gmail.com>
Reviewed-on: https://gitea.dunemask.dev/elysium/minecluster/pulls/4

lib/controllers/file-controller.js

@@ -0,0 +1,70 @@
+import {
+  createServerFolder,
+  getServerItem,
+  listServerFiles,
+  removeServerItem,
+  uploadServerItem,
+} from "../k8s/server-files.js";
+import { sendError } from "../util/ExpressClientError.js";
+
+export async function listFiles(req, res) {
+  const serverSpec = req.body;
+  if (!serverSpec) return res.sendStatus(400);
+  if (!serverSpec.name) return res.status(400).send("Server name required!");
+  listServerFiles(serverSpec)
+    .then((f) => {
+      const fileData = f.map((fi, i) => ({
+        name: fi.name,
+        isDir: fi.type === 2,
+        id: `${fi.name}-${i}`,
+        isHidden: fi.name.startsWith("."),
+        isSymLink: !!fi.link,
+        size: fi.size,
+      }));
+      res.json(fileData);
+    })
+    .catch(sendError(res));
+}
+
+export async function createFolder(req, res) {
+  const serverSpec = req.body;
+  if (!serverSpec) return res.sendStatus(400);
+  if (!serverSpec.name) return res.status(400).send("Server name required!");
+  if (!serverSpec.path) return res.status(400).send("Path required!");
+  createServerFolder(serverSpec)
+    .then(() => res.sendStatus(200))
+    .catch(sendError(res));
+}
+
+export async function deleteItem(req, res) {
+  const serverSpec = req.body;
+  if (!serverSpec) return res.sendStatus(400);
+  if (!serverSpec.name) return res.status(400).send("Server name required!");
+  if (!serverSpec.path) return res.status(400).send("Path required!");
+  if (serverSpec.isDir === undefined || serverSpec.isDir === null)
+    return res.status(400).send("IsDIr required!");
+  removeServerItem(serverSpec)
+    .then(() => res.sendStatus(200))
+    .catch(sendError(res));
+}
+
+export async function uploadItem(req, res) {
+  const serverSpec = req.body;
+  if (!serverSpec.name) return res.status(400).send("Server name required!");
+  if (!serverSpec.path) return res.status(400).send("Path required!");
+  uploadServerItem(serverSpec, req.file)
+    .then(() => res.sendStatus(200))
+    .catch(sendError(res));
+}
+
+export async function getItem(req, res) {
+  const serverSpec = req.body;
+  if (!serverSpec.name) return res.status(400).send("Server name required!");
+  if (!serverSpec.path) return res.status(400).send("Path required!");
+  getServerItem(serverSpec, res)
+    .then(({ ds, ftpTransfer }) => {
+      ds.pipe(res).on("error", sendError(res));
+      return ftpTransfer;
+    })
+    .catch(sendError(res));
+}

lib/controllers/lifecycle-controller.js

@@ -0,0 +1,93 @@
+import createServerResources from "../k8s/server-create.js";
+import deleteServerResources from "../k8s/server-delete.js";
+import {
+  createServerEntry,
+  deleteServerEntry,
+  getServerEntry,
+} from "../database/queries/server-queries.js";
+import { sendError } from "../util/ExpressClientError.js";
+import {
+  startServerContainer,
+  stopServerContainer,
+} from "../k8s/server-control.js";
+import { toggleServer } from "../k8s/k8s-server-control.js";
+
+function payloadFilter(req, res) {
+  const serverSpec = req.body;
+  if (!serverSpec) return res.sendStatus(400);
+  const { name, host, version, serverType, difficulty, gamemode, memory } =
+    serverSpec;
+  if (!name) return res.status(400).send("Server name is required!");
+  if (!host) return res.status(400).send("Server host is required!");
+  if (!version) return res.status(400).send("Server version is required!");
+  if (!difficulty)
+    return res.status(400).send("Server difficulty is required!");
+  if (!serverType) return res.status(400).send("Server type is required!");
+  if (!gamemode) return res.status(400).send("Server Gamemode is required!");
+  if (!memory) return res.status(400).send("Memory is required!");
+  req.body.name = req.body.name.toLowerCase();
+  return "filtered";
+}
+
+function checkServerName(serverSpec) {
+  if (!serverSpec) throw new ExpressClientError({ c: 400 });
+  if (!serverSpec.name)
+    throw new ExpressClientError({ c: 400, m: "Server name required!" });
+}
+
+export async function createServer(req, res) {
+  if (payloadFilter(req, res) !== "filtered") return;
+  const serverSpec = req.body;
+  try {
+    const serverSpecs = await getServerEntry(serverSpec.name);
+    if (serverSpecs.length !== 0) throw Error("Server already exists in DB!");
+    await createServerResources(serverSpec);
+    await createServerEntry(serverSpec);
+    res.sendStatus(200);
+  } catch (e) {
+    sendError(res)(e);
+  }
+}
+
+export async function deleteServer(req, res) {
+  // Ensure spec is safe
+  const serverSpec = req.body;
+  try {
+    checkServerName(serverSpec);
+  } catch (e) {
+    return sendError(res)(e);
+  }
+  const deleteEntry = deleteServerEntry(serverSpec.name);
+  const deleteResources = deleteServerResources(serverSpec);
+  Promise.all([deleteEntry, deleteResources])
+    .then(() => res.sendStatus(200))
+    .catch(sendError(res));
+}
+
+export async function startServer(req, res) {
+  // Ensure spec is safe
+  const serverSpec = req.body;
+  try {
+    checkServerName(serverSpec);
+  } catch (e) {
+    return sendError(res)(e);
+  }
+  const { name } = serverSpec;
+  toggleServer(name, true)
+    .then(() => res.sendStatus(200))
+    .catch(sendError(res));
+}
+
+export async function stopServer(req, res) {
+  // Ensure spec is safe
+  const serverSpec = req.body;
+  try {
+    checkServerName(serverSpec);
+  } catch (e) {
+    return sendError(res)(e);
+  }
+  const { name } = serverSpec;
+  toggleServer(name, false)
+    .then(() => res.sendStatus(200))
+    .catch(sendError(res));
+}

lib/controllers/status-controller.js

@@ -0,0 +1,18 @@
+import { getDeployments } from "../k8s/k8s-server-control.js";
+import { getInstances } from "../k8s/server-control.js";
+import { sendError } from "../util/ExpressClientError.js";
+
+export function serverList(req, res) {
+  getDeployments()
+    .then((sd) => res.json(sd.map((s) => s.metadata.name.substring(4))))
+    .catch((e) => {
+      ERR("SERVER CONTROL", e);
+      res.status(500).send("Couldn't get server list");
+    });
+}
+
+export function serverInstances(req, res) {
+  getInstances()
+    .then((i) => res.json(i))
+    .catch(sendError(res));
+}

lib/controllers/sub-controllers/console-controller.js

@@ -0,0 +1,65 @@
+// Imports
+import k8s from "@kubernetes/client-node";
+import { Rcon as RconClient } from "rcon-client";
+import stream from "stream";
+import { ERR, WARN } from "../../util/logging.js";
+
+// Kubernetes Configuration
+const kc = new k8s.KubeConfig();
+kc.loadFromDefault();
+const k8sCore = kc.makeApiClient(k8s.CoreV1Api);
+const namespace = process.env.MCL_SERVER_NAMESPACE;
+
+// Retrieves logs from the minecraft server container
+export async function webConsoleLogs(socket) {
+  const { serverName } = socket.mcs;
+  const podName = `mcl-${serverName}`;
+  const containerName = `${podName}-server`;
+  const podResponse = await k8sCore.listNamespacedPod(namespace);
+  const pods = podResponse.body.items.map((vp1) => vp1.metadata.name);
+  const mcsPods = pods.filter((p) => p.startsWith(podName));
+  if (mcsPods.length === 0)
+    throw Error(`Could not find a pod that starts with ${podName}`);
+  if (mcsPods.length > 1)
+    throw Error(`Multiple pods match the name ${podName}`);
+
+  const log = new k8s.Log(kc);
+  const logStream = new stream.PassThrough();
+  logStream.on("data", (chunk) =>
+    socket.emit("push", Buffer.from(chunk).toString()),
+  );
+  log
+    .log(namespace, mcsPods[0], containerName, logStream, {
+      follow: true,
+      pretty: false,
+      timestamps: false,
+    })
+    .catch((e) => ERR("CONSOLE CONTROLLER", "Error streaming logs", e));
+}
+
+// Creates an RCON connection to the minecraft container
+export async function webConsoleRcon(socket) {
+  if (socket.rconClient)
+    return VERB("RCON", "Socket already connected to RCON");
+  const rconSecret = `mcl-${socket.mcs.serverName}-rcon-secret`;
+  const rconRes = await k8sCore.readNamespacedSecret(rconSecret, namespace);
+  const rconPassword = Buffer.from(
+    rconRes.body.data["rcon-password"],
+    "base64",
+  ).toString("utf8");
+  const { serverName } = socket.mcs;
+  const rconHost = `mcl-${serverName}-rcon.${namespace}.svc.cluster.local`;
+  const rcon = new RconClient({
+    host: rconHost,
+    port: 25575,
+    password: rconPassword,
+  });
+  rcon.on("error", (error) => socket.emit("push", error));
+  try {
+    await rcon.connect();
+  } catch (error) {
+    socket.emit("push", "Could not connect RCON Input to server!");
+    WARN("RCON", `Could not connect to '${rconHost}'`);
+  }
+  socket.rconClient = rcon;
+}