tronnet/ProxmoxAAS-API
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix formatting

Browse Source
This commit is contained in:
Arthur Lu 2023-06-09 02:05:26 +00:00
parent c110330154
commit 0043e3e783
3 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
db.js
View File

@ -4,7 +4,7 @@ class localdb {
#template = "localdb.json.template"; #template = "localdb.json.template";
#filename = "localdb.json"; #filename = "localdb.json";
#data = null; #data = null;
constructor () { constructor() {
try { try {
this.load(this.#filename); this.load(this.#filename);
} }
@ -15,14 +15,14 @@ class localdb {
} }
load(path) { load(path) {
this.#data = JSON.parse(readFileSync(path)); this.#data = JSON.parse(readFileSync(path));
} }
save(path) { save(path) {
writeFileSync(path, JSON.stringify(this.#data)); writeFileSync(path, JSON.stringify(this.#data));
} }
getResourceConfig () { getResourceConfig() {
return this.#data.resources; return this.#data.resources;
} }
getUserConfig (username) { getUserConfig(username) {
if (this.#data.users[username]) { if (this.#data.users[username]) {
return this.#data.users[username]; return this.#data.users[username];
} }

4
pve.js
View File

@ -35,7 +35,7 @@ export async function requestPVE(path, method, cookies, body = null, token = nul
export async function handleResponse(node, result, res) { export async function handleResponse(node, result, res) {
const waitFor = delay => new Promise(resolve => setTimeout(resolve, delay)); const waitFor = delay => new Promise(resolve => setTimeout(resolve, delay));
if (result.data.data && typeof(result.data.data) === "string" && result.data.data.startsWith("UPID:")) { if (result.data.data && typeof (result.data.data) === "string" && result.data.data.startsWith("UPID:")) {
let upid = result.data.data; let upid = result.data.data;
while (true) { while (true) {
let taskStatus = await requestPVE(`/nodes/${node}/tasks/${upid}/status`, "GET", null, null, pveAPIToken); let taskStatus = await requestPVE(`/nodes/${node}/tasks/${upid}/status`, "GET", null, null, pveAPIToken);
@ -62,7 +62,7 @@ export async function handleResponse(node, result, res) {
} }
else { else {
res.status(result.status).send(result.data); res.status(result.status).send(result.data);
res.end(); res.end();
} }
} }

4
utils.js
View File

@ -27,7 +27,7 @@ export async function checkAuth(cookies, res, vmpath = null) {
return auth; return auth;
} }
export async function getUserResources (req, username) { export async function getUserResources(req, username) {
let dbResources = db.getResourceConfig(); let dbResources = db.getResourceConfig();
let used = await getUsedResources(req, dbResources); let used = await getUsedResources(req, dbResources);
let max = db.getUserConfig(username).resources.max; let max = db.getUserConfig(username).resources.max;
@ -50,7 +50,7 @@ export async function approveResources(req, username, request) {
} }
else if (avail[key] - request[key] < 0) { // if the avail resources is less than the requested resources, block else if (avail[key] - request[key] < 0) { // if the avail resources is less than the requested resources, block
approved = false; approved = false;
} }
}); });
return approved; // if all requested resources pass, allow return approved; // if all requested resources pass, allow
} }