import { requestPVE, requestAPI, goToPage, setTitleAndHeader, setAppearance, getSearchSettings } from "./utils.js"; import { alert, dialog } from "./dialog.js"; import { setupClientSync } from "./clientsync.js"; import wfAlign from "../modules/wfa.js"; window.addEventListener("DOMContentLoaded", init); let instances = []; async function init () { setAppearance(); setTitleAndHeader(); const cookie = document.cookie; if (cookie === "") { goToPage("login.html"); } document.querySelector("#instance-add").addEventListener("click", handleInstanceAdd); document.querySelector("#vm-search").addEventListener("input", populateInstances); setupClientSync(refreshInstances); } async function refreshInstances () { await getInstances(); await populateInstances(); } async function getInstances () { const resources = await requestPVE("/cluster/resources", "GET"); instances = []; resources.data.forEach((element) => { if (element.type === "lxc" || element.type === "qemu") { const nodeName = element.node; const nodeStatus = resources.data.find(item => item.node === nodeName && item.type === "node").status; element.node = { name: nodeName, status: nodeStatus }; instances.push(element); } }); } async function populateInstances () { const searchCriteria = getSearchSettings(); const searchQuery = document.querySelector("#search").value || null; let criteria; if (!searchQuery) { criteria = (a, b) => { return (a.vmid > b.vmid) ? 1 : -1; }; } else if (searchCriteria === "exact") { criteria = (a, b) => { const aInc = a.name.toLowerCase().includes(searchQuery.toLowerCase()); const bInc = b.name.toLowerCase().includes(searchQuery.toLowerCase()); if (aInc && bInc) { return a.vmid > b.vmid ? 1 : -1; } else if (aInc && !bInc) { return -1; } else if (!aInc && bInc) { return 1; } else { return a.vmid > b.vmid ? 1 : -1; } }; } else if (searchCriteria === "fuzzy") { const penalties = { m: 0, x: 1, o: 1, e: 1 }; criteria = (a, b) => { // lower is better const aAlign = wfAlign(a.name.toLowerCase(), searchQuery.toLowerCase(), penalties); const aScore = aAlign.score / a.name.length; const bAlign = wfAlign(b.name.toLowerCase(), searchQuery.toLowerCase(), penalties); const bScore = bAlign.score / b.name.length; if (aScore === bScore) { return a.vmid > b.vmid ? 1 : -1; } else { return aScore - bScore; } }; } instances.sort(criteria); const instanceContainer = document.querySelector("#instance-container"); instanceContainer.innerHTML = ""; for (let i = 0; i < instances.length; i++) { const newInstance = document.createElement("instance-card"); instances[i].searchQuery = searchQuery; newInstance.data = instances[i]; instanceContainer.append(newInstance); } } async function handleInstanceAdd () { const header = "Create New Instance"; const body = `

Container Options

`; const templates = await requestAPI("/user/ct-templates", "GET"); const d = dialog(header, body, async (result, form) => { if (result === "confirm") { const body = { name: form.get("name"), cores: form.get("cores"), memory: form.get("memory"), pool: form.get("pool") }; if (form.get("type") === "lxc") { body.swap = form.get("swap"); body.password = form.get("password"); body.ostemplate = form.get("template-image"); body.rootfslocation = form.get("rootfs-storage"); body.rootfssize = form.get("rootfs-size"); } const node = form.get("node"); const type = form.get("type"); const vmid = form.get("vmid"); const result = await requestAPI(`/cluster/${node}/${type}/${vmid}/create`, "POST", body); if (result.status === 200) { populateInstances(); } else { alert(result.error); populateInstances(); } } }); const typeSelect = d.querySelector("#type"); typeSelect.selectedIndex = -1; typeSelect.addEventListener("change", () => { if (typeSelect.value === "qemu") { d.querySelectorAll(".container-specific").forEach((element) => { element.classList.add("none"); element.disabled = true; }); } else { d.querySelectorAll(".container-specific").forEach((element) => { element.classList.remove("none"); element.disabled = false; }); } }); const rootfsContent = "rootdir"; const rootfsStorage = d.querySelector("#rootfs-storage"); rootfsStorage.selectedIndex = -1; const userResources = await requestAPI("/user/dynamic/resources", "GET"); const userCluster = await requestAPI("/user/config/cluster", "GET"); const nodeSelect = d.querySelector("#node"); const clusterNodes = await requestPVE("/nodes", "GET"); const allowedNodes = Object.keys(userCluster.nodes); clusterNodes.data.forEach((element) => { if (element.status === "online" && allowedNodes.includes(element.node)) { nodeSelect.add(new Option(element.node)); } }); nodeSelect.selectedIndex = -1; nodeSelect.addEventListener("change", async () => { // change rootfs storage based on node const node = nodeSelect.value; const storage = await requestPVE(`/nodes/${node}/storage`, "GET"); storage.data.forEach((element) => { if (element.content.includes(rootfsContent)) { rootfsStorage.add(new Option(element.storage)); } }); rootfsStorage.selectedIndex = -1; // set core and memory min/max depending on node selected if (node in userResources.cores.nodes) { d.querySelector("#cores").max = userResources.cores.nodes[node].avail; } else { d.querySelector("#cores").max = userResources.cores.global.avail; } if (node in userResources.memory.nodes) { d.querySelector("#memory").max = userResources.memory.nodes[node].avail; } else { d.querySelector("#memory").max = userResources.memory.global.avail; } }); // set vmid min/max d.querySelector("#vmid").min = userCluster.vmid.min; d.querySelector("#vmid").max = userCluster.vmid.max; // add user pools to selector const poolSelect = d.querySelector("#pool"); const userPools = Object.keys(userCluster.pools); userPools.forEach((element) => { poolSelect.add(new Option(element)); }); poolSelect.selectedIndex = -1; // add template images to selector const templateImage = d.querySelector("#template-image"); // populate templateImage depending on selected image storage for (const template of templates) { templateImage.append(new Option(template.name, template.volid)); } templateImage.selectedIndex = -1; }