8x48/homepage
1
0
Fork 0
mirror of https://github.com/gethomepage/homepage.git synced 2026-01-15 22:02:12 +08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Refactor

Browse Source
This commit is contained in:
shamoon
2026-01-04 10:25:15 -08:00
parent 775c68675e
commit ce74c974fc
1 changed files with 13 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
src/widgets/truenas/proxy.js
View File

@@ -112,22 +112,6 @@ async function authenticate(ws, widget) {
throw new Error("TrueNAS authentication failed"); throw new Error("TrueNAS authentication failed");
} }
async function callWebsocket(widget, method) {
const wsUrl = buildWebsocketUrl(widget);
logger.info("Connecting to TrueNAS websocket at %s", wsUrl);
const ws = new WebSocket(wsUrl, { rejectUnauthorized: false });
await waitForEvent(ws, () => true, { event: "open", parseJson: false });
logger.info("Connected to TrueNAS websocket at %s", wsUrl);
try {
await authenticate(ws, widget);
const result = await sendMethod(ws, method);
return result;
} finally {
ws.close();
}
}
export default async function truenasProxyHandler(req, res, map) { export default async function truenasProxyHandler(req, res, map) {
const { group, service, endpoint, index } = req.query; const { group, service, endpoint, index } = req.query;
@@ -156,7 +140,19 @@ export default async function truenasProxyHandler(req, res, map) {
} }
try { try {
let data = await callWebsocket(widget, wsMethod); let data;
const wsUrl = buildWebsocketUrl(widget);
logger.info("Connecting to TrueNAS websocket at %s", wsUrl);
const ws = new WebSocket(wsUrl, { rejectUnauthorized: false });
await waitForEvent(ws, () => true, { event: "open", parseJson: false });
logger.info("Connected to TrueNAS websocket at %s", wsUrl);
try {
await authenticate(ws, widget);
data = await sendMethod(ws, wsMethod);
} finally {
ws.close();
}
if (!validateWidgetData(widget, endpoint, data)) { if (!validateWidgetData(widget, endpoint, data)) {
return res.status(500).json({ error: { message: "Invalid data", url: sanitizeErrorURL(widget.url), data } }); return res.status(500).json({ error: { message: "Invalid data", url: sanitizeErrorURL(widget.url), data } });