Handle some JSON parsing issues

src/widgets/truenas/proxy.js

@@ -28,9 +28,17 @@ function waitForEvent(ws, handler, { event = "message", parseJson = true } = {})
 
     const handleEvent = (payload) => {
       try {
-        const parsed = parseJson ? JSON.parse(payload.toString()) : payload;
+        let parsed = payload;
-        if (parseJson) logger.info("Received TrueNAS websocket message: %o", parsed);
+        if (parseJson) {
-        else logger.info("Received TrueNAS websocket message: %o", payload);
+          if (Buffer.isBuffer(payload)) {
+            parsed = JSON.parse(payload.toString());
+          } else if (typeof payload === "string") {
+            parsed = JSON.parse(payload);
+          }
+          logger.info("Received TrueNAS websocket message: %o", parsed);
+        } else {
+          logger.info("Received TrueNAS websocket message: %o", payload);
+        }
         const handlerResult = handler(parsed);
         if (handlerResult !== undefined) {
           cleanup();

src/widgets/truenas/widget.js

@@ -10,9 +10,12 @@ const widget = {
     alerts: {
       endpoint: "alert/list",
       wsMethod: "alert.list",
-      map: (data) => ({
+      map: (data) => {
-        pending: jsonArrayFilter(data, (item) => item?.dismissed === false).length,
+        if (Array.isArray(data)) {
-      }),
+          return { pending: data.filter((item) => item?.dismissed === false).length };
+        }
+        return { pending: jsonArrayFilter(data, (item) => item?.dismissed === false).length };
+      },
     },
     status: {
       endpoint: "system/info",
@@ -22,12 +25,14 @@ const widget = {
     pools: {
       endpoint: "pool",
       wsMethod: "pool.query",
-      map: (data) =>
+      map: (data) => {
-        asJson(data).map((entry) => ({
+        const list = Array.isArray(data) ? data : asJson(data);
+        return list.map((entry) => ({
           id: entry.name,
           name: entry.name,
           healthy: entry.healthy,
-        })),
+        }));
+      },
     },
     dataset: {
       endpoint: "pool/dataset",