From 357d1aab21c6bd36c438a6a14e7ee3014b71763d Mon Sep 17 00:00:00 2001 From: shamoon <4887959+shamoon@users.noreply.github.com> Date: Sun, 4 Jan 2026 00:16:53 -0800 Subject: [PATCH] Update proxy.js --- src/widgets/truenas/proxy.js | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/src/widgets/truenas/proxy.js b/src/widgets/truenas/proxy.js index 2f5bde9e0..920923511 100644 --- a/src/widgets/truenas/proxy.js +++ b/src/widgets/truenas/proxy.js @@ -19,24 +19,24 @@ function buildWebsocketUrl(baseUrl) { return url.toString(); } -function waitForEvent(ws, matcher, { event = "message", parseJson = true, timeoutMs = 10000 } = {}) { +function waitForEvent(ws, handler, { event = "message", parseJson = true } = {}) { return new Promise((resolve, reject) => { const timeout = setTimeout(() => { cleanup(); reject(new Error("TrueNAS websocket wait timed out")); - }, timeoutMs); + }, 10000); const handleEvent = (payload) => { try { const parsed = parseJson ? JSON.parse(payload.toString()) : payload; if (parseJson) logger.info("Received TrueNAS websocket message: %o", parsed); - const matchResult = matcher(parsed); - if (matchResult !== undefined) { + const handlerResult = handler(parsed); + if (handlerResult !== undefined) { cleanup(); - if (matchResult instanceof Error) { - reject(matchResult); + if (handlerResult instanceof Error) { + reject(handlerResult); } else { - resolve(matchResult); + resolve(handlerResult); } } } catch (err) {