Chorehancement: add fileflows widget v2 for 26.10 breaking changes (#7239)

src/utils/config/service-helpers.js

@@ -619,6 +619,7 @@ export function cleanServiceGroups(groups) {
           [
             "authentik",
             "beszel",
+            "fileflows",
             "glances",
             "immich",
             "jellyfin",

src/utils/proxy/handlers/credentialed.js

@@ -130,6 +130,10 @@ export default async function credentialedProxyHandler(req, res, map) {
         headers.Authorization = widget.key;
       } else if (widget.type === "gitlab") {
         headers["PRIVATE-TOKEN"] = widget.key;
+      } else if (widget.type === "fileflows") {
+        if (widget.key) {
+          headers["X-Webhook-Token"] = `${widget.key}`;
+        }
       } else if (widget.type === "speedtest") {
         if (widget.key) {
           // v1 does not require a key

src/utils/proxy/handlers/credentialed.test.js

@@ -40,6 +40,7 @@ vi.mock("widgets/widgets", () => ({
     checkmk: { api: "{url}/{endpoint}" },
     stocks: { api: "{url}/{endpoint}" },
     speedtest: { api: "{url}/{endpoint}" },
+    fileflows: { api: "{url}/{endpoint}" },
     tubearchivist: { api: "{url}/{endpoint}" },
     autobrr: { api: "{url}/{endpoint}" },
     jellystat: { api: "{url}/{endpoint}" },
@@ -328,6 +329,7 @@ describe("utils/proxy/handlers/credentialed", () => {
       [{ type: "trilium", url: "http://x", key: "k" }, { Authorization: "k" }],
       [{ type: "gitlab", url: "http://x", key: "k" }, { "PRIVATE-TOKEN": "k" }],
       [{ type: "speedtest", url: "http://x", key: "k" }, { Authorization: "Bearer k" }],
+      [{ type: "fileflows", url: "http://x", key: "k" }, { "X-Webhook-Token": "k" }],
       [
         { type: "azuredevops", url: "http://x", key: "k" },
         { Authorization: `Basic ${Buffer.from("$:k").toString("base64")}` },

src/widgets/fileflows/component.jsx

@@ -8,8 +8,9 @@ export default function Component({ service }) {
   const { t } = useTranslation();
 
   const { widget } = service;
+  const version = widget.version ?? 1;
 
-  const { data: fileflowsData, error: fileflowsError } = useWidgetAPI(widget, "status");
+  const { data: fileflowsData, error: fileflowsError } = useWidgetAPI(widget, version === 2 ? "status_v2" : "status");
 
   if (fileflowsError) {
     return <Container service={service} error={fileflowsError} />;
@@ -21,7 +22,18 @@ export default function Component({ service }) {
         <Block label="fileflows.queue" />
         <Block label="fileflows.processing" />
         <Block label="fileflows.processed" />
-        <Block label="fileflows.time" />
+        {version === 2 ? <Block label="fileflows.failed" /> : <Block label="fileflows.time" />}
+      </Container>
+    );
+  }
+
+  if (version === 2) {
+    return (
+      <Container service={service}>
+        <Block label="fileflows.queue" value={t("common.number", { value: fileflowsData.Unprocessed })} />
+        <Block label="fileflows.processing" value={t("common.number", { value: fileflowsData.Processing })} />
+        <Block label="fileflows.processed" value={t("common.number", { value: fileflowsData.Processed })} />
+        <Block label="fileflows.failed" value={t("common.number", { value: fileflowsData.Failed })} />
       </Container>
     );
   }

src/widgets/fileflows/component.test.jsx

@@ -62,4 +62,23 @@ describe("widgets/fileflows/component", () => {
     expectBlockValue(container, "fileflows.processed", 3);
     expectBlockValue(container, "fileflows.time", "0:00");
   });
+
+  it("uses the webhook endpoint and fields for version 2", () => {
+    useWidgetAPI.mockReturnValue({
+      data: { Unprocessed: 4, Processing: 1, Processed: 10, Failed: 2 },
+      error: undefined,
+    });
+
+    const widget = { type: "fileflows", url: "http://x", version: 2 };
+    const { container } = renderWithProviders(<Component service={{ widget }} />, {
+      settings: { hideErrors: false },
+    });
+
+    expect(useWidgetAPI).toHaveBeenCalledWith(widget, "status_v2");
+    expectBlockValue(container, "fileflows.queue", 4);
+    expectBlockValue(container, "fileflows.processing", 1);
+    expectBlockValue(container, "fileflows.processed", 10);
+    expectBlockValue(container, "fileflows.failed", 2);
+    expect(screen.queryByText("fileflows.time")).not.toBeInTheDocument();
+  });
 });

src/widgets/fileflows/widget.js

@@ -1,12 +1,15 @@
-import genericProxyHandler from "utils/proxy/handlers/generic";
+import credentialedProxyHandler from "utils/proxy/handlers/credentialed";
 
 const widget = {
-  api: "{url}/api/{endpoint}",
-  proxyHandler: genericProxyHandler,
+  api: "{url}/{endpoint}",
+  proxyHandler: credentialedProxyHandler,
 
   mappings: {
     status: {
-      endpoint: "status",
+      endpoint: "api/status",
+    },
+    status_v2: {
+      endpoint: "webhook/fenrus",
     },
   },
 };