widget refactoring and cleanup

src/widgets/nzbget/component.jsx

@@ -0,0 +1,42 @@
+import useSWR from "swr";
+import { useTranslation } from "next-i18next";
+
+import Widget from "components/services/widgets/widget";
+import Block from "components/services/widgets/block";
+import { formatProxyUrl } from "utils/api-helpers";
+
+export default function Component({ service }) {
+  const { t } = useTranslation("common");
+
+  const config = service.widget;
+
+  const { data: statusData, error: statusError } = useSWR(formatProxyUrl(config, "status"));
+
+  if (statusError) {
+    return <Widget error={t("widget.api_error")} />;
+  }
+
+  if (!statusData) {
+    return (
+      <Widget>
+        <Block label={t("nzbget.rate")} />
+        <Block label={t("nzbget.remaining")} />
+        <Block label={t("nzbget.downloaded")} />
+      </Widget>
+    );
+  }
+
+  return (
+    <Widget>
+      <Block label={t("nzbget.rate")} value={t("common.bitrate", { value: statusData.DownloadRate })} />
+      <Block
+        label={t("nzbget.remaining")}
+        value={t("common.bytes", { value: statusData.RemainingSizeMB * 1024 * 1024 })}
+      />
+      <Block
+        label={t("nzbget.downloaded")}
+        value={t("common.bytes", { value: statusData.DownloadedSizeMB * 1024 * 1024 })}
+      />
+    </Widget>
+  );
+}

src/widgets/nzbget/proxy.js

@@ -0,0 +1,40 @@
+import { JSONRPCClient } from "json-rpc-2.0";
+
+import getServiceWidget from "utils/service-helpers";
+
+export default async function nzbgetProxyHandler(req, res) {
+  const { group, service, endpoint } = req.query;
+
+  if (group && service) {
+    const widget = await getServiceWidget(group, service);
+
+    if (widget) {
+      const constructedUrl = new URL(widget.url);
+      constructedUrl.pathname = "jsonrpc";
+
+      const authorization = Buffer.from(`${widget.username}:${widget.password}`).toString("base64");
+
+      const client = new JSONRPCClient((jsonRPCRequest) =>
+        fetch(constructedUrl.toString(), {
+          method: "POST",
+          headers: {
+            "content-type": "application/json",
+            authorization: `Basic ${authorization}`,
+          },
+          body: JSON.stringify(jsonRPCRequest),
+        }).then(async (response) => {
+          if (response.status === 200) {
+            const jsonRPCResponse = await response.json();
+            return client.receive(jsonRPCResponse);
+          }
+
+          return Promise.reject(new Error(response.statusText));
+        })
+      );
+
+      return res.send(await client.request(endpoint));
+    }
+  }
+
+  return res.status(400).json({ error: "Invalid proxy service type" });
+}

src/widgets/nzbget/widget.js

@@ -0,0 +1,7 @@
+import nzbgetProxyHandler from "./proxy";
+
+const widget = {
+  proxyHandler: nzbgetProxyHandler,
+};
+
+export default widget;