Compare commits

...
Sign in to create a new pull request.

4 commits

19 changed files with 291 additions and 35 deletions

View file

@ -4,34 +4,19 @@ import {
createServerEntry, createServerEntry,
deleteServerEntry, deleteServerEntry,
getServerEntry, getServerEntry,
modifyServerEntry,
} from "../database/queries/server-queries.js"; } from "../database/queries/server-queries.js";
import { sendError } from "../util/ExpressClientError.js"; import ExpressClientError, { sendError } from "../util/ExpressClientError.js";
import { toggleServer } from "../k8s/k8s-server-control.js"; import { toggleServer } from "../k8s/k8s-server-control.js";
const dnsRegex = new RegExp( const dnsRegex = new RegExp(
`^([a-zA-Z0-9]|[a-zA-Z0-9][a-zA-Z0-9\-]{0,61}[a-zA-Z0-9])(\.([a-zA-Z0-9]|[a-zA-Z0-9][a-zA-Z0-9\-]{0,61}[a-zA-Z0-9]))*$`, `^([a-zA-Z0-9]|[a-zA-Z0-9][a-zA-Z0-9\-]{0,61}[a-zA-Z0-9])(\.([a-zA-Z0-9]|[a-zA-Z0-9][a-zA-Z0-9\-]{0,61}[a-zA-Z0-9]))*$`,
); );
function payloadFilter(req, res) { function backupPayloadFilter(req, res) {
const serverSpec = req.body; const serverSpec = req.body;
if (!serverSpec) return res.sendStatus(400);
const { name, host, version, serverType, memory, extraPorts } = serverSpec;
const { backupHost, backupBucket, backupId, backupKey, backupInterval } = const { backupHost, backupBucket, backupId, backupKey, backupInterval } =
serverSpec; serverSpec;
if (!name) return res.status(400).send("Server name is required!");
if (!host) return res.status(400).send("Server host is required!");
if (!dnsRegex.test(host)) return res.status(400).send("Hostname invalid!");
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!");
if (
!!extraPorts &&
(!Array.isArray(extraPorts) ||
extraPorts.find((e) => typeof e !== "string" || e.length > 5))
)
return res
.status(400)
.send("Extra ports must be a list of strings with length of 5!");
// TODO: Impliment non creation time backups // TODO: Impliment non creation time backups
if ( if (
!!backupHost || !!backupHost ||
@ -57,6 +42,27 @@ function payloadFilter(req, res) {
return "filtered"; return "filtered";
} }
function payloadFilter(req, res) {
const serverSpec = req.body;
if (!serverSpec) return res.sendStatus(400);
const { name, host, version, serverType, memory, extraPorts } = serverSpec;
if (!name) return res.status(400).send("Server name is required!");
if (!host) return res.status(400).send("Server host is required!");
if (!dnsRegex.test(host)) return res.status(400).send("Hostname invalid!");
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!");
if (
!!extraPorts &&
(!Array.isArray(extraPorts) ||
extraPorts.find((e) => typeof e !== "string" || e.length > 5))
)
return res
.status(400)
.send("Extra ports must be a list of strings with length of 5!");
return "filtered";
}
function checkServerId(serverSpec) { function checkServerId(serverSpec) {
if (!serverSpec) throw new ExpressClientError({ c: 400 }); if (!serverSpec) throw new ExpressClientError({ c: 400 });
if (!serverSpec.id) if (!serverSpec.id)
@ -65,6 +71,7 @@ function checkServerId(serverSpec) {
export async function createServer(req, res) { export async function createServer(req, res) {
if (payloadFilter(req, res) !== "filtered") return; if (payloadFilter(req, res) !== "filtered") return;
if (backupPayloadFilter(req, res) !== "filtered") return;
const serverSpec = req.body; const serverSpec = req.body;
try { try {
const serverEntry = await createServerEntry(serverSpec); const serverEntry = await createServerEntry(serverSpec);
@ -117,3 +124,34 @@ export async function stopServer(req, res) {
.then(() => res.sendStatus(200)) .then(() => res.sendStatus(200))
.catch(sendError(res)); .catch(sendError(res));
} }
export async function getServer(req, res) {
// Ensure spec is safe
const serverSpec = req.body;
try {
checkServerId(serverSpec);
} catch (e) {
return sendError(res)(e);
}
const { id } = serverSpec;
getServerEntry(id).then((s) => {
delete s.backupKey; // Do not let this ever get to an API client
s.backupBucket = s.backupPath;
delete s.backupPath;
delete s.backupId; // Do not let this ever get to an API client
res.json(s);
});
}
export async function modifyServer(req, res) {
if (payloadFilter(req, res) !== "filtered") return;
const serverSpec = req.body;
try {
checkServerId(serverSpec);
const serverEntry = await modifyServerEntry(serverSpec);
// await createServerResources(serverEntry);
res.sendStatus(200);
} catch (e) {
sendError(res)(e);
}
}

View file

@ -1,5 +1,10 @@
import pg from "../postgres.js"; import pg from "../postgres.js";
import { deleteQuery, insertQuery, selectWhereQuery } from "../pg-query.js"; import {
deleteQuery,
insertQuery,
selectWhereQuery,
updateWhereAllQuery,
} from "../pg-query.js";
import ExpressClientError from "../../util/ExpressClientError.js"; import ExpressClientError from "../../util/ExpressClientError.js";
const table = "servers"; const table = "servers";
@ -30,7 +35,7 @@ export async function createServerEntry(serverSpec) {
server_type, server_type,
memory, memory,
extra_ports, extra_ports,
backup_enabled: !!backup_interval, // We already verified the payload, so any backup key will work backup_enabled: !!backup_interval ? true : null, // We already verified the payload, so any backup key will work
backup_host, backup_host,
backup_bucket_path, backup_bucket_path,
backup_id, backup_id,
@ -128,6 +133,45 @@ export async function getServerEntry(serverId) {
} }
} }
export async function modifyServerEntry(serverSpec) {
const {
id,
name,
host,
version,
serverType: server_type,
memory,
extraPorts: extra_ports,
backupEnabled: backup_enabled,
backupHost: backup_host,
backupBucket: backup_bucket_path,
backupId: backup_id,
backupKey: backup_key,
backupInterval: backup_interval,
} = serverSpec;
const q = updateWhereAllQuery(
table,
{
name,
host,
version,
server_type,
memory,
extra_ports,
backup_enabled,
backup_host,
backup_bucket_path,
backup_id,
backup_key,
backup_interval,
},
{ id },
);
return pg.query(q);
}
export async function getServerEntries() { export async function getServerEntries() {
const q = `SELECT * FROM ${table}`; const q = `SELECT * FROM ${table}`;
return pg.query(q); return pg.query(q);

View file

@ -4,6 +4,8 @@ import {
deleteServer, deleteServer,
startServer, startServer,
stopServer, stopServer,
getServer,
modifyServer,
} from "../controllers/lifecycle-controller.js"; } from "../controllers/lifecycle-controller.js";
import { import {
serverInstances, serverInstances,
@ -18,4 +20,6 @@ router.post("/start", startServer);
router.post("/stop", stopServer); router.post("/stop", stopServer);
router.get("/list", serverList); router.get("/list", serverList);
router.get("/instances", serverInstances); router.get("/instances", serverInstances);
router.post("/blueprint", getServer);
router.post("/modify", modifyServer);
export default router; export default router;

View file

@ -6,7 +6,7 @@ export default function BackupBucketOption(props) {
<TextField <TextField
label="Bucket Path" label="Bucket Path"
onChange={onChange} onChange={onChange}
defaultValue={value} value={value}
helperText="Example: /minecraft-backups/example-backups" helperText="Example: /minecraft-backups/example-backups"
FormHelperTextProps={{ sx: { ml: 0 } }} FormHelperTextProps={{ sx: { ml: 0 } }}
required required

View file

@ -1,11 +1,12 @@
import TextField from "@mui/material/TextField"; import TextField from "@mui/material/TextField";
export default function BackupHostOption(props) { export default function BackupHostOption(props) {
const { onChange } = props; const { value, onChange } = props;
return ( return (
<TextField <TextField
label="Backup Host" label="Backup Host"
onChange={onChange} onChange={onChange}
value={value}
helperText="Example: s3.mydomain.com" helperText="Example: s3.mydomain.com"
FormHelperTextProps={{ sx: { ml: 0 } }} FormHelperTextProps={{ sx: { ml: 0 } }}
required required

View file

@ -1,10 +1,11 @@
import TextField from "@mui/material/TextField"; import TextField from "@mui/material/TextField";
export default function BackupIdOption(props) { export default function BackupIdOption(props) {
const { onChange } = props; const { value, onChange } = props;
return ( return (
<TextField <TextField
label="S3 Access Key ID" label="S3 Access Key ID"
value={value}
onChange={onChange} onChange={onChange}
helperText="Example: s3-access-key-id" helperText="Example: s3-access-key-id"
FormHelperTextProps={{ sx: { ml: 0 } }} FormHelperTextProps={{ sx: { ml: 0 } }}

View file

@ -12,7 +12,7 @@ export default function CpuOption(props) {
<TextField <TextField
label="CPU" label="CPU"
onChange={onChange} onChange={onChange}
value={value} value={value ?? cpuOptions[0]}
select select
required required
SelectProps={{ MenuProps: { sx: { maxHeight: "20rem" } } }} SelectProps={{ MenuProps: { sx: { maxHeight: "20rem" } } }}

View file

@ -6,7 +6,8 @@ import Chip from "@mui/material/Chip";
const validatePort = (p) => p !== "25565" && p !== "25575" && p.length < 6; const validatePort = (p) => p !== "25565" && p !== "25575" && p.length < 6;
export default function ExtraPortsOption(props) { export default function ExtraPortsOption(props) {
const [extraPorts, setExtraPorts] = useState([]); const { extraPorts: initExtraPorts } = props;
const [extraPorts, setExtraPorts] = useState(initExtraPorts ?? []);
const { onChange } = props; const { onChange } = props;
function portChange(e, val, optionType, changedValue) { function portChange(e, val, optionType, changedValue) {

View file

@ -1,10 +1,11 @@
import TextField from "@mui/material/TextField"; import TextField from "@mui/material/TextField";
export default function HostOption(props) { export default function HostOption(props) {
const { onChange } = props; const { value, onChange } = props;
return ( return (
<TextField <TextField
label="Host" label="Host"
value={value ?? ""}
onChange={onChange} onChange={onChange}
helperText="Example: host.mydomain.com" helperText="Example: host.mydomain.com"
FormHelperTextProps={{ sx: { ml: 0 } }} FormHelperTextProps={{ sx: { ml: 0 } }}

View file

@ -11,7 +11,7 @@ export default function Option(props) {
<TextField <TextField
label="Memory" label="Memory"
onChange={onChange} onChange={onChange}
value={value} value={value ?? memoryOptions[1]}
select select
required required
SelectProps={{ MenuProps: { sx: { maxHeight: "20rem" } } }} SelectProps={{ MenuProps: { sx: { maxHeight: "20rem" } } }}

View file

@ -1,10 +1,11 @@
import TextField from "@mui/material/TextField"; import TextField from "@mui/material/TextField";
export default function NameOption(props) { export default function NameOption(props) {
const { onChange } = props; const { value, onChange } = props;
return ( return (
<TextField <TextField
label="Name" label="Name"
value={value ?? ""}
onChange={onChange} onChange={onChange}
helperText="Example: My Survival World" helperText="Example: My Survival World"
FormHelperTextProps={{ sx: { ml: 0 } }} FormHelperTextProps={{ sx: { ml: 0 } }}

View file

@ -10,7 +10,7 @@ export default function ServerTypeOption(props) {
<TextField <TextField
label="Memory" label="Memory"
onChange={onChange} onChange={onChange}
value={value} value={value ?? serverTypeOptions[0]}
select select
required required
SelectProps={{ MenuProps: { sx: { maxHeight: "20rem" } } }} SelectProps={{ MenuProps: { sx: { maxHeight: "20rem" } } }}

View file

@ -22,7 +22,7 @@ export default function VersionOption(props) {
<TextField <TextField
label="Version" label="Version"
onChange={onChange} onChange={onChange}
value={value} value={value ?? "latest"}
select select
required required
SelectProps={{ MenuProps: { sx: { maxHeight: "20rem" } } }} SelectProps={{ MenuProps: { sx: { maxHeight: "20rem" } } }}

View file

@ -113,6 +113,7 @@ export default function ServerCard(props) {
size="large" size="large"
component={Link} component={Link}
to={`/mcl/edit?server=${id}`} to={`/mcl/edit?server=${id}`}
disabled={services.includes("server")}
> >
<EditIcon /> <EditIcon />
</IconButton> </IconButton>

View file

@ -1,6 +1,7 @@
import Home from "@mcl/pages/Home.jsx"; import Home from "@mcl/pages/Home.jsx";
import Create from "@mcl/pages/Create.jsx"; import Create from "@mcl/pages/Create.jsx";
import Files from "@mcl/pages/Files.jsx"; import Files from "@mcl/pages/Files.jsx";
import Edit from "@mcl/pages/Edit.jsx";
// Go To https://mui.com/material-ui/material-icons/ for more! // Go To https://mui.com/material-ui/material-icons/ for more!
import HomeIcon from "@mui/icons-material/Home"; import HomeIcon from "@mui/icons-material/Home";
import AddIcon from "@mui/icons-material/Add"; import AddIcon from "@mui/icons-material/Add";
@ -21,10 +22,17 @@ export default [
visible: true, visible: true,
}, },
{ {
name: "Edit", name: "Files",
path: "/mcl/files", path: "/mcl/files",
icon: <AddIcon />, icon: <AddIcon />,
component: <Files />, component: <Files />,
visible: false, visible: false,
}, },
{
name: "Edit",
path: "/mcl/edit",
icon: <AddIcon />,
component: <Edit />,
visible: false,
},
]; ];

View file

@ -55,8 +55,8 @@ export default function CreateCoreOptions() {
async function upsertSpec() { async function upsertSpec() {
if (validateSpec() !== "validated") return; if (validateSpec() !== "validated") return;
createServer(spec) createServer()
// .then(() => nav("/")) .then(() => nav("/"))
.catch(alert); .catch(alert);
} }
@ -90,8 +90,8 @@ export default function CreateCoreOptions() {
sx={{ width: "100%", maxWidth: "600px", margin: "auto" }} sx={{ width: "100%", maxWidth: "600px", margin: "auto" }}
> >
<FormControl fullWidth sx={{ mt: "2rem", display: "flex", gap: ".5rem" }}> <FormControl fullWidth sx={{ mt: "2rem", display: "flex", gap: ".5rem" }}>
<NameOption onChange={coreUpdate("name")} /> <NameOption value={spec.name} onChange={coreUpdate("name")} />
<HostOption onChange={coreUpdate("host")} /> <HostOption value={spec.host} onChange={coreUpdate("host")} />
<VersionOption value={spec.version} onChange={coreUpdate("version")} /> <VersionOption value={spec.version} onChange={coreUpdate("version")} />
<ServerTypeOption <ServerTypeOption
value={spec.serverType} value={spec.serverType}

14
src/pages/Edit.jsx Normal file
View file

@ -0,0 +1,14 @@
import { useSearchParams, useNavigate } from "react-router-dom";
import Box from "@mui/material/Box";
import EditCoreOptions from "./EditCoreOptions.jsx";
export default function Edit() {
const [searchParams] = useSearchParams();
const currentServer = searchParams.get("server");
return (
<Box className="edit">
<Box className="edit-wrapper" sx={{ display: "flex" }}>
<EditCoreOptions serverId={currentServer} />
</Box>
</Box>
);
}

View file

@ -0,0 +1,134 @@
import { useState, useEffect } from "react";
import { useNavigate } from "react-router-dom";
import Box from "@mui/material/Box";
import Button from "@mui/material/Button";
import FormControl from "@mui/material/FormControl";
import FormControlLabel from "@mui/material/FormControlLabel";
import Switch from "@mui/material/Switch";
import Typography from "@mui/material/Typography";
import { useGetServer, useModifyServer } from "@mcl/queries";
// Core Options
import NameOption from "@mcl/components/server-options/NameOption.jsx";
import HostOption from "@mcl/components/server-options/HostOption.jsx";
import VersionOption from "@mcl/components/server-options/VersionOption.jsx";
import ServerTypeOption, {
serverTypeOptions,
} from "@mcl/components/server-options/ServerTypeOption.jsx";
import CpuOption, {
cpuOptions,
} from "@mcl/components/server-options/CpuOption.jsx";
import MemoryOption, {
memoryOptions,
} from "@mcl/components/server-options/MemoryOption.jsx";
import ExtraPortsOption from "@mcl/components/server-options/ExtraPortsOption.jsx";
import BackupHostOption from "@mcl/components/server-options/BackupHostOption.jsx";
import BackupBucketOption from "@mcl/components/server-options/BackupBucketOption.jsx";
import BackupIdOption from "@mcl/components/server-options/BackupIdOption.jsx";
import BackupKeyOption from "@mcl/components/server-options/BackupKeyOption.jsx";
import BackupIntervalOption, {
backupIntervalDefault,
} from "@mcl/components/server-options/BackupIntervalOption.jsx";
export default function EditCoreOptions(props) {
const { serverId } = props;
const [spec, setSpec] = useState();
const modifyServer = useModifyServer(spec);
const { isLoading, data: serverBlueprint } = useGetServer(serverId);
useEffect(() => setSpec(serverBlueprint), [serverBlueprint]);
const updateSpec = (attr, val) => {
const s = { ...spec };
s[attr] = val;
setSpec(s);
};
const coreUpdate = (attr) => (e) => updateSpec(attr, e.target.value);
const upsertSpec = () => {
modifyServer(spec);
};
const toggleBackupEnabled = () =>
updateSpec("backupEnabled", !spec.backupEnabled);
function validateSpec() {
console.log("TODO CREATE VALIDATION");
if (!spec.host) return alertValidationError("Host cannot be blank");
if (!spec.name) return alertValidationError("Name not included");
if (!spec.version) return alertValidationError("Version cannot be blank");
return "validated";
}
function alertValidationError(reason) {
alert(`Could not validate spec because: ${reason}`);
}
if (!spec) return; // TODO: Add loading for spec
return (
<Box
className="edit-options"
sx={{ width: "100%", maxWidth: "600px", margin: "auto" }}
>
<FormControl fullWidth sx={{ mt: "2rem", display: "flex", gap: ".5rem" }}>
<NameOption value={spec.name} onChange={coreUpdate("name")} />
<HostOption value={spec.host} onChange={coreUpdate("host")} />
<VersionOption value={spec.version} onChange={coreUpdate("version")} />
<ServerTypeOption
value={spec.serverType}
onChange={coreUpdate("serverType")}
/>
<CpuOption value={spec.cpu} onChange={coreUpdate("cpu")} />
<MemoryOption value={spec.memory} onChange={coreUpdate("memory")} />
<ExtraPortsOption extraPorts={spec.extraPorts} onChange={updateSpec} />
{spec.backupEnabled !== null && (
<FormControlLabel
control={
<Switch
checked={spec.backupEnabled}
inputProps={{ "aria-label": "controlled" }}
onClick={toggleBackupEnabled}
/>
}
label="Enable Backups?"
labelPlacement="start"
sx={{ mr: "auto" }}
/>
)}
{/*spec.backupEnabled && ( // TODO: Disabled while secrets are insecure
<FormControl
fullWidth
sx={{ mt: "2rem", display: "flex", gap: ".5rem" }}
>
<Typography variant="h6">Backups</Typography>
<BackupHostOption
value={spec.backupHost}
onChange={coreUpdate("backupHost")}
/>
<BackupBucketOption
value={spec.backupBucket}
onChange={coreUpdate("backupBucket")}
/>
<BackupIdOption
value={spec.backupId}
onChange={coreUpdate("backupId")}
/>
<BackupKeyOption
value={spec.backupKey}
onChange={coreUpdate("backupKey")}
/>
<BackupIntervalOption onChange={coreUpdate("backupInterval")} />
</FormControl>
)*/}
<Button onClick={upsertSpec} variant="contained">
Save Changes
</Button>
</FormControl>
</Box>
);
}

View file

@ -39,6 +39,14 @@ export const useDeleteServer = (serverId) =>
postJsonApi("/server/delete", { id: serverId }, "server-instances", "DELETE"); postJsonApi("/server/delete", { id: serverId }, "server-instances", "DELETE");
export const useCreateServer = (spec) => export const useCreateServer = (spec) =>
postJsonApi("/server/create", spec, "server-list"); postJsonApi("/server/create", spec, "server-list");
export const useModifyServer = (spec) =>
postJsonApi("/server/modify", spec, "server-list");
export const useGetServer = (serverId) =>
useQuery({
queryKey: [`server-blueprint-${serverId}`],
queryFn: fetchApiPost("/server/blueprint", { id: serverId }),
});
export const getServerFiles = async (serverId, path) => export const getServerFiles = async (serverId, path) =>
fetchApiCore("/files/list", { id: serverId, path }, "POST", true); fetchApiCore("/files/list", { id: serverId, path }, "POST", true);