85 lines
2.6 KiB
JavaScript
85 lines
2.6 KiB
JavaScript
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 { 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, 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 (!serverType) return res.status(400).send("Server type is required!");
|
|
if (!memory) return res.status(400).send("Memory is required!");
|
|
return "filtered";
|
|
}
|
|
|
|
function checkServerHost(serverSpec) {
|
|
if (!serverSpec) throw new ExpressClientError({ c: 400 });
|
|
if (!serverSpec.host)
|
|
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.id);
|
|
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 {
|
|
checkServerHost(serverSpec);
|
|
} catch (e) {
|
|
return sendError(res)(e);
|
|
}
|
|
const deleteEntry = deleteServerEntry(serverSpec.id);
|
|
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 {
|
|
checkServerHost(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 {
|
|
checkServerHost(serverSpec);
|
|
} catch (e) {
|
|
return sendError(res)(e);
|
|
}
|
|
const { name } = serverSpec;
|
|
toggleServer(name, false)
|
|
.then(() => res.sendStatus(200))
|
|
.catch(sendError(res));
|
|
}
|