From c526fa5c6cb1631fb282bb1e0445bddde7a3722a Mon Sep 17 00:00:00 2001 From: Benoit Date: Sat, 24 Dec 2022 16:04:34 +0100 Subject: [PATCH 01/29] OPNSense widget : initial version, memory usage is inaccurate. --- public/locales/en/common.json | 7 ++++ src/widgets/components.js | 1 + src/widgets/opnsense/component.jsx | 53 ++++++++++++++++++++++++++++++ src/widgets/opnsense/widget.js | 21 ++++++++++++ src/widgets/widgets.js | 2 ++ 5 files changed, 84 insertions(+) create mode 100644 src/widgets/opnsense/component.jsx create mode 100644 src/widgets/opnsense/widget.js diff --git a/public/locales/en/common.json b/public/locales/en/common.json index a1f9df9c..62c1724d 100644 --- a/public/locales/en/common.json +++ b/public/locales/en/common.json @@ -401,5 +401,12 @@ "memoryUsed": "Memory Used", "uptime": "Uptime", "numberOfLeases": "Leases" + }, + "opnsense": { + "cpu": "CPU Load", + "memory": "Memory Used", + "uptime": "Uptime", + "wanUpload": "WAN Upload", + "wanDownload": "WAN Download" } } diff --git a/src/widgets/components.js b/src/widgets/components.js index a2a26332..4d8a3454 100644 --- a/src/widgets/components.js +++ b/src/widgets/components.js @@ -29,6 +29,7 @@ const components = { nzbget: dynamic(() => import("./nzbget/component")), omada: dynamic(() => import("./omada/component")), ombi: dynamic(() => import("./ombi/component")), + opnsense: dynamic(() => import("./opnsense/component")), overseerr: dynamic(() => import("./overseerr/component")), paperlessngx: dynamic(() => import("./paperlessngx/component")), pihole: dynamic(() => import("./pihole/component")), diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx new file mode 100644 index 00000000..1757d68f --- /dev/null +++ b/src/widgets/opnsense/component.jsx @@ -0,0 +1,53 @@ +import { useTranslation } from "next-i18next"; + +import Container from "components/services/widget/container"; +import Block from "components/services/widget/block"; +import useWidgetAPI from "utils/proxy/use-widget-api"; + +export default function Component({ service }) { + const { t } = useTranslation(); + + const { widget } = service; + + const { data: activityData, error: activityError } = useWidgetAPI(widget, "activity"); + const { data: interfaceData, error: interfaceError } = useWidgetAPI(widget, "interface"); + + if (activityError || interfaceError) { + const finalError = activityError ?? interfaceError; + return ; + } + + if (!activityData || !interfaceData) { + return ( + + + + + + + + ); + } + + const cpuInfos = activityData.headers[2].split(" "); + const cpu = parseFloat(cpuInfos[2]) + parseFloat(cpuInfos[5]) + parseFloat(cpuInfos[8]) + parseFloat(cpuInfos[11]); + const uptimeInfos = activityData.headers[0].match(/.* up ([0-9+:]*) .*/); + const uptime = uptimeInfos[1]; + const memoryInfos = activityData.headers[3].split(" "); + const totalMemory = parseFloat(memoryInfos[1]) + parseFloat(memoryInfos[3]) + parseFloat(memoryInfos[5]) + parseFloat(memoryInfos[7]) + parseFloat(memoryInfos[9])/1024 + parseFloat(memoryInfos[11]); + const memory = ( 1 - parseFloat(memoryInfos[11]) / totalMemory) * 100; + + const wanUpload = interfaceData.interfaces.wan['bytes transmitted']; + const wanDownload = interfaceData.interfaces.wan['bytes received']; + + return ( + + + + + + + + + ); +} diff --git a/src/widgets/opnsense/widget.js b/src/widgets/opnsense/widget.js new file mode 100644 index 00000000..2f2d7951 --- /dev/null +++ b/src/widgets/opnsense/widget.js @@ -0,0 +1,21 @@ + +import genericProxyHandler from "utils/proxy/handlers/generic"; + +const widget = { + api: "{url}/api/{endpoint}", + proxyHandler: genericProxyHandler, + + mappings: { + version: { + endpoint: "core/firmware/status", + }, + activity: { + endpoint: "diagnostics/activity/getActivity", + }, + interface: { + endpoint: "diagnostics/traffic/interface", + } + }, +}; + +export default widget; diff --git a/src/widgets/widgets.js b/src/widgets/widgets.js index 523ba9c2..b4a90378 100644 --- a/src/widgets/widgets.js +++ b/src/widgets/widgets.js @@ -24,6 +24,7 @@ import npm from "./npm/widget"; import nzbget from "./nzbget/widget"; import omada from "./omada/widget"; import ombi from "./ombi/widget"; +import opnsense from "./opnsense/widget"; import overseerr from "./overseerr/widget"; import paperlessngx from "./paperlessngx/widget"; import pihole from "./pihole/widget"; @@ -79,6 +80,7 @@ const widgets = { nzbget, omada, ombi, + opnsense, overseerr, paperlessngx, pihole, From 84affae10d6de149a1f21d5207ed020ae0ecdd04 Mon Sep 17 00:00:00 2001 From: Benoit Date: Sun, 25 Dec 2022 20:13:55 +0100 Subject: [PATCH 02/29] OPNSense widget : code cleanup in widget.js. Firewall is no longer displayed, so it did not need to be queried. --- src/widgets/opnsense/widget.js | 3 --- 1 file changed, 3 deletions(-) diff --git a/src/widgets/opnsense/widget.js b/src/widgets/opnsense/widget.js index 2f2d7951..56ad0733 100644 --- a/src/widgets/opnsense/widget.js +++ b/src/widgets/opnsense/widget.js @@ -6,9 +6,6 @@ const widget = { proxyHandler: genericProxyHandler, mappings: { - version: { - endpoint: "core/firmware/status", - }, activity: { endpoint: "diagnostics/activity/getActivity", }, From f4ceb74f72635798f233a41290172a133f5bfa70 Mon Sep 17 00:00:00 2001 From: Benoit SERRA Date: Sun, 25 Dec 2022 20:15:18 +0100 Subject: [PATCH 03/29] Opnsense widget (#2) * OPNSense widget : initial version, memory usage is inaccurate. * OPNSense widget : code cleanup in widget.js. Firewall is no longer displayed, so it did not need to be queried. --- public/locales/en/common.json | 7 ++++ src/widgets/components.js | 1 + src/widgets/opnsense/component.jsx | 53 ++++++++++++++++++++++++++++++ src/widgets/opnsense/widget.js | 18 ++++++++++ src/widgets/widgets.js | 2 ++ 5 files changed, 81 insertions(+) create mode 100644 src/widgets/opnsense/component.jsx create mode 100644 src/widgets/opnsense/widget.js diff --git a/public/locales/en/common.json b/public/locales/en/common.json index a1f9df9c..62c1724d 100644 --- a/public/locales/en/common.json +++ b/public/locales/en/common.json @@ -401,5 +401,12 @@ "memoryUsed": "Memory Used", "uptime": "Uptime", "numberOfLeases": "Leases" + }, + "opnsense": { + "cpu": "CPU Load", + "memory": "Memory Used", + "uptime": "Uptime", + "wanUpload": "WAN Upload", + "wanDownload": "WAN Download" } } diff --git a/src/widgets/components.js b/src/widgets/components.js index a2a26332..4d8a3454 100644 --- a/src/widgets/components.js +++ b/src/widgets/components.js @@ -29,6 +29,7 @@ const components = { nzbget: dynamic(() => import("./nzbget/component")), omada: dynamic(() => import("./omada/component")), ombi: dynamic(() => import("./ombi/component")), + opnsense: dynamic(() => import("./opnsense/component")), overseerr: dynamic(() => import("./overseerr/component")), paperlessngx: dynamic(() => import("./paperlessngx/component")), pihole: dynamic(() => import("./pihole/component")), diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx new file mode 100644 index 00000000..1757d68f --- /dev/null +++ b/src/widgets/opnsense/component.jsx @@ -0,0 +1,53 @@ +import { useTranslation } from "next-i18next"; + +import Container from "components/services/widget/container"; +import Block from "components/services/widget/block"; +import useWidgetAPI from "utils/proxy/use-widget-api"; + +export default function Component({ service }) { + const { t } = useTranslation(); + + const { widget } = service; + + const { data: activityData, error: activityError } = useWidgetAPI(widget, "activity"); + const { data: interfaceData, error: interfaceError } = useWidgetAPI(widget, "interface"); + + if (activityError || interfaceError) { + const finalError = activityError ?? interfaceError; + return ; + } + + if (!activityData || !interfaceData) { + return ( + + + + + + + + ); + } + + const cpuInfos = activityData.headers[2].split(" "); + const cpu = parseFloat(cpuInfos[2]) + parseFloat(cpuInfos[5]) + parseFloat(cpuInfos[8]) + parseFloat(cpuInfos[11]); + const uptimeInfos = activityData.headers[0].match(/.* up ([0-9+:]*) .*/); + const uptime = uptimeInfos[1]; + const memoryInfos = activityData.headers[3].split(" "); + const totalMemory = parseFloat(memoryInfos[1]) + parseFloat(memoryInfos[3]) + parseFloat(memoryInfos[5]) + parseFloat(memoryInfos[7]) + parseFloat(memoryInfos[9])/1024 + parseFloat(memoryInfos[11]); + const memory = ( 1 - parseFloat(memoryInfos[11]) / totalMemory) * 100; + + const wanUpload = interfaceData.interfaces.wan['bytes transmitted']; + const wanDownload = interfaceData.interfaces.wan['bytes received']; + + return ( + + + + + + + + + ); +} diff --git a/src/widgets/opnsense/widget.js b/src/widgets/opnsense/widget.js new file mode 100644 index 00000000..56ad0733 --- /dev/null +++ b/src/widgets/opnsense/widget.js @@ -0,0 +1,18 @@ + +import genericProxyHandler from "utils/proxy/handlers/generic"; + +const widget = { + api: "{url}/api/{endpoint}", + proxyHandler: genericProxyHandler, + + mappings: { + activity: { + endpoint: "diagnostics/activity/getActivity", + }, + interface: { + endpoint: "diagnostics/traffic/interface", + } + }, +}; + +export default widget; diff --git a/src/widgets/widgets.js b/src/widgets/widgets.js index 523ba9c2..b4a90378 100644 --- a/src/widgets/widgets.js +++ b/src/widgets/widgets.js @@ -24,6 +24,7 @@ import npm from "./npm/widget"; import nzbget from "./nzbget/widget"; import omada from "./omada/widget"; import ombi from "./ombi/widget"; +import opnsense from "./opnsense/widget"; import overseerr from "./overseerr/widget"; import paperlessngx from "./paperlessngx/widget"; import pihole from "./pihole/widget"; @@ -79,6 +80,7 @@ const widgets = { nzbget, omada, ombi, + opnsense, overseerr, paperlessngx, pihole, From e056298f4479cd039b9e0068fb8806cd7e3ca1e7 Mon Sep 17 00:00:00 2001 From: Benoit Date: Sun, 25 Dec 2022 21:09:42 +0100 Subject: [PATCH 04/29] OPNSense widget : fixing the CPU code to make it more reliable. --- src/widgets/opnsense/component.jsx | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index 1757d68f..ebac928a 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -29,8 +29,10 @@ export default function Component({ service }) { ); } - const cpuInfos = activityData.headers[2].split(" "); - const cpu = parseFloat(cpuInfos[2]) + parseFloat(cpuInfos[5]) + parseFloat(cpuInfos[8]) + parseFloat(cpuInfos[11]); + const cpuidle = activityData.headers[2].substring(60,64); + + const cpu = 100 - parseFloat(cpuidle); + const uptimeInfos = activityData.headers[0].match(/.* up ([0-9+:]*) .*/); const uptime = uptimeInfos[1]; const memoryInfos = activityData.headers[3].split(" "); @@ -43,7 +45,7 @@ export default function Component({ service }) { return ( - + From aeca42db118465564970976105492101c5575a8a Mon Sep 17 00:00:00 2001 From: Benoit Date: Mon, 26 Dec 2022 07:28:04 +0100 Subject: [PATCH 05/29] OPNSense widget : fixing the CPU code to make it more reliable. Removing uptime info --- src/widgets/opnsense/component.jsx | 9 +++------ src/widgets/opnsense/widget.js | 6 ++++++ 2 files changed, 9 insertions(+), 6 deletions(-) diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index ebac928a..d53e31fb 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -20,7 +20,7 @@ export default function Component({ service }) { if (!activityData || !interfaceData) { return ( - + @@ -30,11 +30,8 @@ export default function Component({ service }) { } const cpuidle = activityData.headers[2].substring(60,64); - const cpu = 100 - parseFloat(cpuidle); - const uptimeInfos = activityData.headers[0].match(/.* up ([0-9+:]*) .*/); - const uptime = uptimeInfos[1]; const memoryInfos = activityData.headers[3].split(" "); const totalMemory = parseFloat(memoryInfos[1]) + parseFloat(memoryInfos[3]) + parseFloat(memoryInfos[5]) + parseFloat(memoryInfos[7]) + parseFloat(memoryInfos[9])/1024 + parseFloat(memoryInfos[11]); const memory = ( 1 - parseFloat(memoryInfos[11]) / totalMemory) * 100; @@ -44,8 +41,8 @@ export default function Component({ service }) { return ( - - + + diff --git a/src/widgets/opnsense/widget.js b/src/widgets/opnsense/widget.js index 56ad0733..a144ee4c 100644 --- a/src/widgets/opnsense/widget.js +++ b/src/widgets/opnsense/widget.js @@ -8,9 +8,15 @@ const widget = { mappings: { activity: { endpoint: "diagnostics/activity/getActivity", + validate: [ + "headers" + ] }, interface: { endpoint: "diagnostics/traffic/interface", + validate: [ + "interfaces" + ] } }, }; From b4d64e5e80417ccf28fd13766190e29a29697224 Mon Sep 17 00:00:00 2001 From: Benoit SERRA Date: Sun, 25 Dec 2022 20:15:18 +0100 Subject: [PATCH 06/29] Opnsense widget (#2) * OPNSense widget : initial version, memory usage is inaccurate. * OPNSense widget : code cleanup in widget.js. Firewall is no longer displayed, so it did not need to be queried. --- public/locales/en/common.json | 6 ++++ src/widgets/components.js | 1 + src/widgets/opnsense/component.jsx | 53 ++++++++++++++++++++++++++++++ src/widgets/opnsense/widget.js | 18 ++++++++++ src/widgets/widgets.js | 2 ++ 5 files changed, 80 insertions(+) create mode 100644 src/widgets/opnsense/component.jsx create mode 100644 src/widgets/opnsense/widget.js diff --git a/public/locales/en/common.json b/public/locales/en/common.json index 8436d28b..2a968c17 100644 --- a/public/locales/en/common.json +++ b/public/locales/en/common.json @@ -406,5 +406,11 @@ "streams_all": "All Streams", "streams_active": "Active Streams", "streams_xepg": "XEPG Channels" + }, + "opnsense": { + "cpu": "CPU Load", + "memory": "Memory Used", + "wanUpload": "WAN Upload", + "wanDownload": "WAN Download" } } diff --git a/src/widgets/components.js b/src/widgets/components.js index 4ee443ac..10277732 100644 --- a/src/widgets/components.js +++ b/src/widgets/components.js @@ -29,6 +29,7 @@ const components = { nzbget: dynamic(() => import("./nzbget/component")), omada: dynamic(() => import("./omada/component")), ombi: dynamic(() => import("./ombi/component")), + opnsense: dynamic(() => import("./opnsense/component")), overseerr: dynamic(() => import("./overseerr/component")), paperlessngx: dynamic(() => import("./paperlessngx/component")), pihole: dynamic(() => import("./pihole/component")), diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx new file mode 100644 index 00000000..1757d68f --- /dev/null +++ b/src/widgets/opnsense/component.jsx @@ -0,0 +1,53 @@ +import { useTranslation } from "next-i18next"; + +import Container from "components/services/widget/container"; +import Block from "components/services/widget/block"; +import useWidgetAPI from "utils/proxy/use-widget-api"; + +export default function Component({ service }) { + const { t } = useTranslation(); + + const { widget } = service; + + const { data: activityData, error: activityError } = useWidgetAPI(widget, "activity"); + const { data: interfaceData, error: interfaceError } = useWidgetAPI(widget, "interface"); + + if (activityError || interfaceError) { + const finalError = activityError ?? interfaceError; + return ; + } + + if (!activityData || !interfaceData) { + return ( + + + + + + + + ); + } + + const cpuInfos = activityData.headers[2].split(" "); + const cpu = parseFloat(cpuInfos[2]) + parseFloat(cpuInfos[5]) + parseFloat(cpuInfos[8]) + parseFloat(cpuInfos[11]); + const uptimeInfos = activityData.headers[0].match(/.* up ([0-9+:]*) .*/); + const uptime = uptimeInfos[1]; + const memoryInfos = activityData.headers[3].split(" "); + const totalMemory = parseFloat(memoryInfos[1]) + parseFloat(memoryInfos[3]) + parseFloat(memoryInfos[5]) + parseFloat(memoryInfos[7]) + parseFloat(memoryInfos[9])/1024 + parseFloat(memoryInfos[11]); + const memory = ( 1 - parseFloat(memoryInfos[11]) / totalMemory) * 100; + + const wanUpload = interfaceData.interfaces.wan['bytes transmitted']; + const wanDownload = interfaceData.interfaces.wan['bytes received']; + + return ( + + + + + + + + + ); +} diff --git a/src/widgets/opnsense/widget.js b/src/widgets/opnsense/widget.js new file mode 100644 index 00000000..56ad0733 --- /dev/null +++ b/src/widgets/opnsense/widget.js @@ -0,0 +1,18 @@ + +import genericProxyHandler from "utils/proxy/handlers/generic"; + +const widget = { + api: "{url}/api/{endpoint}", + proxyHandler: genericProxyHandler, + + mappings: { + activity: { + endpoint: "diagnostics/activity/getActivity", + }, + interface: { + endpoint: "diagnostics/traffic/interface", + } + }, +}; + +export default widget; diff --git a/src/widgets/widgets.js b/src/widgets/widgets.js index 0c53b388..3e73e55f 100644 --- a/src/widgets/widgets.js +++ b/src/widgets/widgets.js @@ -24,6 +24,7 @@ import npm from "./npm/widget"; import nzbget from "./nzbget/widget"; import omada from "./omada/widget"; import ombi from "./ombi/widget"; +import opnsense from "./opnsense/widget"; import overseerr from "./overseerr/widget"; import paperlessngx from "./paperlessngx/widget"; import pihole from "./pihole/widget"; @@ -80,6 +81,7 @@ const widgets = { nzbget, omada, ombi, + opnsense, overseerr, paperlessngx, pihole, From 8926e2f194a70f5061c41e337767da87b2866aa6 Mon Sep 17 00:00:00 2001 From: Benoit SERRA Date: Mon, 26 Dec 2022 07:36:36 +0100 Subject: [PATCH 07/29] Opnsense widget (#3) * OPNSense widget : initial version, memory usage is inaccurate. * OPNSense widget : code cleanup in widget.js. Firewall is no longer displayed, so it did not need to be queried. * OPNSense widget : fixing the CPU code to make it more reliable. * OPNSense widget : fixing the CPU code to make it more reliable. Removing uptime info --- src/widgets/opnsense/component.jsx | 9 +++------ src/widgets/opnsense/widget.js | 6 ++++++ 2 files changed, 9 insertions(+), 6 deletions(-) diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index 1757d68f..d9e64929 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -20,7 +20,6 @@ export default function Component({ service }) { if (!activityData || !interfaceData) { return ( - @@ -29,10 +28,9 @@ export default function Component({ service }) { ); } - const cpuInfos = activityData.headers[2].split(" "); - const cpu = parseFloat(cpuInfos[2]) + parseFloat(cpuInfos[5]) + parseFloat(cpuInfos[8]) + parseFloat(cpuInfos[11]); - const uptimeInfos = activityData.headers[0].match(/.* up ([0-9+:]*) .*/); - const uptime = uptimeInfos[1]; + + const cpuidle = activityData.headers[2].substring(60,64); + const cpu = 100 - parseFloat(cpuidle); const memoryInfos = activityData.headers[3].split(" "); const totalMemory = parseFloat(memoryInfos[1]) + parseFloat(memoryInfos[3]) + parseFloat(memoryInfos[5]) + parseFloat(memoryInfos[7]) + parseFloat(memoryInfos[9])/1024 + parseFloat(memoryInfos[11]); const memory = ( 1 - parseFloat(memoryInfos[11]) / totalMemory) * 100; @@ -42,7 +40,6 @@ export default function Component({ service }) { return ( - diff --git a/src/widgets/opnsense/widget.js b/src/widgets/opnsense/widget.js index 56ad0733..a144ee4c 100644 --- a/src/widgets/opnsense/widget.js +++ b/src/widgets/opnsense/widget.js @@ -8,9 +8,15 @@ const widget = { mappings: { activity: { endpoint: "diagnostics/activity/getActivity", + validate: [ + "headers" + ] }, interface: { endpoint: "diagnostics/traffic/interface", + validate: [ + "interfaces" + ] } }, }; From 8c64f24cb6424b0f85f6f3372e29c6a991b26c9e Mon Sep 17 00:00:00 2001 From: Benoit SERRA Date: Mon, 26 Dec 2022 08:31:41 +0100 Subject: [PATCH 08/29] Update src/widgets/opnsense/component.jsx Co-authored-by: shamoon <4887959+shamoon@users.noreply.github.com> --- src/widgets/opnsense/component.jsx | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index d9e64929..c17a389f 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -29,8 +29,8 @@ export default function Component({ service }) { } - const cpuidle = activityData.headers[2].substring(60,64); - const cpu = 100 - parseFloat(cpuidle); + const cpuIdle = activityData.headers[2].match(/ ([0-9.]+)% idle/)[1]; + const cpu = 100 - parseFloat(cpuIdle); const memoryInfos = activityData.headers[3].split(" "); const totalMemory = parseFloat(memoryInfos[1]) + parseFloat(memoryInfos[3]) + parseFloat(memoryInfos[5]) + parseFloat(memoryInfos[7]) + parseFloat(memoryInfos[9])/1024 + parseFloat(memoryInfos[11]); const memory = ( 1 - parseFloat(memoryInfos[11]) / totalMemory) * 100; From f2bc5869bfa3312dc1657f6aa53a42b63f5473e6 Mon Sep 17 00:00:00 2001 From: Benoit SERRA Date: Mon, 26 Dec 2022 09:27:39 +0100 Subject: [PATCH 09/29] Update public/locales/en/common.json Co-authored-by: shamoon <4887959+shamoon@users.noreply.github.com> --- public/locales/en/common.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/public/locales/en/common.json b/public/locales/en/common.json index 2a968c17..032c1dfe 100644 --- a/public/locales/en/common.json +++ b/public/locales/en/common.json @@ -409,7 +409,7 @@ }, "opnsense": { "cpu": "CPU Load", - "memory": "Memory Used", + "memory": "Active Memory", "wanUpload": "WAN Upload", "wanDownload": "WAN Download" } From 04dcfd2ef2b1b675c117c9ba7a7b2e3702617bce Mon Sep 17 00:00:00 2001 From: Benoit SERRA Date: Mon, 26 Dec 2022 09:27:49 +0100 Subject: [PATCH 10/29] Update src/widgets/opnsense/component.jsx Co-authored-by: shamoon <4887959+shamoon@users.noreply.github.com> --- src/widgets/opnsense/component.jsx | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index c17a389f..f835ce09 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -31,9 +31,7 @@ export default function Component({ service }) { const cpuIdle = activityData.headers[2].match(/ ([0-9.]+)% idle/)[1]; const cpu = 100 - parseFloat(cpuIdle); - const memoryInfos = activityData.headers[3].split(" "); - const totalMemory = parseFloat(memoryInfos[1]) + parseFloat(memoryInfos[3]) + parseFloat(memoryInfos[5]) + parseFloat(memoryInfos[7]) + parseFloat(memoryInfos[9])/1024 + parseFloat(memoryInfos[11]); - const memory = ( 1 - parseFloat(memoryInfos[11]) / totalMemory) * 100; + const memory = activityData.headers[3].match(/Mem: (.+) Active,/)[1]; const wanUpload = interfaceData.interfaces.wan['bytes transmitted']; const wanDownload = interfaceData.interfaces.wan['bytes received']; From e3bccd6dbdb69afea566b6114bbcbf94bb5d116a Mon Sep 17 00:00:00 2001 From: shamoon <4887959+shamoon@users.noreply.github.com> Date: Mon, 26 Dec 2022 00:29:51 -0800 Subject: [PATCH 11/29] Update src/widgets/opnsense/component.jsx --- src/widgets/opnsense/component.jsx | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index f835ce09..53396b31 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -39,7 +39,7 @@ export default function Component({ service }) { return ( - + From b44a5ac54e07163e263a70e8886f0b1fef3c029a Mon Sep 17 00:00:00 2001 From: Benoit Date: Tue, 27 Dec 2022 17:05:16 +0100 Subject: [PATCH 12/29] OPNsense widget : reporting a correct value for memory usage --- src/widgets/opnsense/component.jsx | 55 ++++++++++++++++++++++++++---- 1 file changed, 49 insertions(+), 6 deletions(-) diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index d9e64929..9afd5f7c 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -5,6 +5,51 @@ import Block from "components/services/widget/block"; import useWidgetAPI from "utils/proxy/use-widget-api"; export default function Component({ service }) { + function toKb(value, unit) { + console.log("toKB : value: ", value, " Unit:", unit); + switch (unit) { + case "K": + return parseInt(value, 10); + case "M": + return parseInt(value, 10) * 1024; + case "G": + return parseInt(value, 10) * 1024 * 1024; + default: + return parseInt(value, 10); + } + } + + function sumMemory(meminfos) { + let result; + let sumused=0; + let sumfree=0; + + const idused = ["Active", "Wired", "Laundry", "Buf"]; + const idfree = ["Inact", "Free"]; + const size = "([0-9]+)([KMG])"; + + for (let id = 0; id < idused.length;id+=1 ) { + const re = new RegExp(`${size } ${ idused[id] }`); + result = re.exec(meminfos); + + if (result) { + sumused += toKb(result[1], result[2]); + } + } + + for (let id = 0; id < idfree.length; id+=1 ) { + const re = new RegExp(`${size } ${ idfree[id] }`); + result = re.exec(meminfos); + + if (result) { + sumfree += toKb(result[1], result[2]); + } + } + + return 100*(sumused / (sumused + sumfree)); + + } + const { t } = useTranslation(); const { widget } = service; @@ -29,11 +74,9 @@ export default function Component({ service }) { } - const cpuidle = activityData.headers[2].substring(60,64); - const cpu = 100 - parseFloat(cpuidle); - const memoryInfos = activityData.headers[3].split(" "); - const totalMemory = parseFloat(memoryInfos[1]) + parseFloat(memoryInfos[3]) + parseFloat(memoryInfos[5]) + parseFloat(memoryInfos[7]) + parseFloat(memoryInfos[9])/1024 + parseFloat(memoryInfos[11]); - const memory = ( 1 - parseFloat(memoryInfos[11]) / totalMemory) * 100; + const cpuIdle = activityData.headers[2].match(/ ([0-9.]+)% idle/)[1]; + const cpu = 100 - parseFloat(cpuIdle); + const memory = sumMemory(activityData.headers[3]); const wanUpload = interfaceData.interfaces.wan['bytes transmitted']; const wanDownload = interfaceData.interfaces.wan['bytes received']; @@ -41,7 +84,7 @@ export default function Component({ service }) { return ( - + From 5bdcc342990f0ddb0b7cc75c5ef1e594cb5e38f4 Mon Sep 17 00:00:00 2001 From: Benoit Date: Thu, 29 Dec 2022 13:47:11 +0100 Subject: [PATCH 13/29] OPNsense widget : reporting a correct value for memory usage, added two fields for wan upload & download rate. Still working on those, code is not ready to use. --- public/locales/en/common.json | 5 +++- src/widgets/opnsense/component.jsx | 46 ++++++++++++++++++++++++++++-- 2 files changed, 48 insertions(+), 3 deletions(-) diff --git a/public/locales/en/common.json b/public/locales/en/common.json index 62c1724d..40854c60 100644 --- a/public/locales/en/common.json +++ b/public/locales/en/common.json @@ -407,6 +407,9 @@ "memory": "Memory Used", "uptime": "Uptime", "wanUpload": "WAN Upload", - "wanDownload": "WAN Download" + "wanDownload": "WAN Download", + "wanUploadRate": "WAN Upload Rate", + "wanDownloadRate": "WAN Download Rate" + } } diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index 9afd5f7c..cb0fad60 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -6,7 +6,6 @@ import useWidgetAPI from "utils/proxy/use-widget-api"; export default function Component({ service }) { function toKb(value, unit) { - console.log("toKB : value: ", value, " Unit:", unit); switch (unit) { case "K": return parseInt(value, 10); @@ -80,14 +79,57 @@ export default function Component({ service }) { const wanUpload = interfaceData.interfaces.wan['bytes transmitted']; const wanDownload = interfaceData.interfaces.wan['bytes received']; + const datas = localStorage.getItem('opnsensewidgetdatas'); + + let wanUploadRate = 0; + let wanDownloadRate = 0; + if (datas !== null) { + const datasObj = JSON.parse(datas); + console.log("Dataobj:", datasObj); + const wanUploadDiff = wanUpload - datasObj.wanUpload; + const wanDownloadDiff = wanDownload - datasObj.wanDownload; + + if (wanUploadDiff > 0 || wanDownloadDiff > 0) { + const specialTimeValue = new Date().getTime(); + console.log("Special time: ", specialTimeValue); + const specialTime = localStorage.getItem('opnsensewidgettime'); + if (specialTime !== null) { + const specialTimeObj = JSON.parse(specialTime); + const timeDif = specialTimeValue - specialTimeObj.specialtime; + wanUploadRate = 8 * wanUploadDiff / (timeDif / 1000); + wanDownloadRate = 8 * wanDownloadDiff / (timeDif / 1000); + localStorage.setItem('opnsensewidgetrate', JSON.stringify({ + wanUploadRate, + wanDownloadRate + })); + console.log("Time diff: ", timeDif, "wanUploadRate: ", wanUploadRate, "wanDownloadRate: ", wanDownloadRate); + } + localStorage.setItem('opnsensewidgettime', JSON.stringify({specialtime: specialTimeValue})); + } else { + const rate = localStorage.getItem('opnsensewidgetrate'); + if (rate !== null) { + const rateObj = JSON.parse(rate); + wanUploadRate = rateObj.wanUploadRate; + wanDownloadRate = rateObj.wanDownloadRate; + } + } + console.log("wanUploadDiff:", wanUploadDiff); + console.log("wanDownloadDiff:", wanDownloadDiff); + } + localStorage.setItem('opnsensewidgetdatas', JSON.stringify({ + wanUpload, + wanDownload, + time: Date.now()})); return ( - + + + ); } From fc263be8ad03cd9f59cee8d568b8115b97ce023a Mon Sep 17 00:00:00 2001 From: Benoit Date: Thu, 29 Dec 2022 15:38:01 +0100 Subject: [PATCH 14/29] OPNsense widget : wan upload & download rate now work when multiple widgets are in use. Still working on those fields, code is not ready to use. Refactor needed for localStorage use. --- src/widgets/opnsense/component.jsx | 21 ++++++++++++--------- 1 file changed, 12 insertions(+), 9 deletions(-) diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index cb0fad60..8cb29838 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -52,7 +52,11 @@ export default function Component({ service }) { const { t } = useTranslation(); const { widget } = service; - + const wid = widget.service_name + "." + widget.service_group; + const rateStorage = `${wid}rate`; + const dataStorage = `${wid}data`; + const timeStorage = `${wid}time`; + console.log("service: ", service, " wid: ", wid); const { data: activityData, error: activityError } = useWidgetAPI(widget, "activity"); const { data: interfaceData, error: interfaceError } = useWidgetAPI(widget, "interface"); @@ -79,7 +83,7 @@ export default function Component({ service }) { const wanUpload = interfaceData.interfaces.wan['bytes transmitted']; const wanDownload = interfaceData.interfaces.wan['bytes received']; - const datas = localStorage.getItem('opnsensewidgetdatas'); + const datas = localStorage.getItem(dataStorage); let wanUploadRate = 0; let wanDownloadRate = 0; @@ -92,21 +96,21 @@ export default function Component({ service }) { if (wanUploadDiff > 0 || wanDownloadDiff > 0) { const specialTimeValue = new Date().getTime(); console.log("Special time: ", specialTimeValue); - const specialTime = localStorage.getItem('opnsensewidgettime'); + const specialTime = localStorage.getItem(timeStorage); if (specialTime !== null) { const specialTimeObj = JSON.parse(specialTime); const timeDif = specialTimeValue - specialTimeObj.specialtime; wanUploadRate = 8 * wanUploadDiff / (timeDif / 1000); wanDownloadRate = 8 * wanDownloadDiff / (timeDif / 1000); - localStorage.setItem('opnsensewidgetrate', JSON.stringify({ + localStorage.setItem(rateStorage, JSON.stringify({ wanUploadRate, wanDownloadRate })); console.log("Time diff: ", timeDif, "wanUploadRate: ", wanUploadRate, "wanDownloadRate: ", wanDownloadRate); } - localStorage.setItem('opnsensewidgettime', JSON.stringify({specialtime: specialTimeValue})); + localStorage.setItem(timeStorage, JSON.stringify({specialtime: specialTimeValue})); } else { - const rate = localStorage.getItem('opnsensewidgetrate'); + const rate = localStorage.getItem(rateStorage); if (rate !== null) { const rateObj = JSON.parse(rate); wanUploadRate = rateObj.wanUploadRate; @@ -116,18 +120,17 @@ export default function Component({ service }) { console.log("wanUploadDiff:", wanUploadDiff); console.log("wanDownloadDiff:", wanDownloadDiff); } - localStorage.setItem('opnsensewidgetdatas', JSON.stringify({ + localStorage.setItem(dataStorage, JSON.stringify({ wanUpload, wanDownload, time: Date.now()})); return ( - + - From 86f21afe1ed471a2e81dbebca3a7c237d94312b1 Mon Sep 17 00:00:00 2001 From: Benoit Date: Thu, 29 Dec 2022 16:29:02 +0100 Subject: [PATCH 15/29] OPNsense widget : all datas are locally stored in a single localStorage object. --- src/widgets/opnsense/component.jsx | 81 ++++++++++++------------------ 1 file changed, 31 insertions(+), 50 deletions(-) diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index 8cb29838..3f1ea951 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -52,11 +52,8 @@ export default function Component({ service }) { const { t } = useTranslation(); const { widget } = service; - const wid = widget.service_name + "." + widget.service_group; - const rateStorage = `${wid}rate`; - const dataStorage = `${wid}data`; - const timeStorage = `${wid}time`; - console.log("service: ", service, " wid: ", wid); + const wid = `${widget.service_name}.${widget.service_group}`; + const dataStorage = `${wid}datas`; const { data: activityData, error: activityError } = useWidgetAPI(widget, "activity"); const { data: interfaceData, error: interfaceError } = useWidgetAPI(widget, "interface"); @@ -81,58 +78,42 @@ export default function Component({ service }) { const cpu = 100 - parseFloat(cpuIdle); const memory = sumMemory(activityData.headers[3]); - const wanUpload = interfaceData.interfaces.wan['bytes transmitted']; - const wanDownload = interfaceData.interfaces.wan['bytes received']; - const datas = localStorage.getItem(dataStorage); + const wanUpload = parseFloat(interfaceData.interfaces.wan['bytes transmitted']); + const wanDownload = parseFloat(interfaceData.interfaces.wan['bytes received']); + const dataStored = localStorage.getItem(dataStorage); + let datas; - let wanUploadRate = 0; - let wanDownloadRate = 0; - if (datas !== null) { - const datasObj = JSON.parse(datas); - console.log("Dataobj:", datasObj); - const wanUploadDiff = wanUpload - datasObj.wanUpload; - const wanDownloadDiff = wanDownload - datasObj.wanDownload; - - if (wanUploadDiff > 0 || wanDownloadDiff > 0) { - const specialTimeValue = new Date().getTime(); - console.log("Special time: ", specialTimeValue); - const specialTime = localStorage.getItem(timeStorage); - if (specialTime !== null) { - const specialTimeObj = JSON.parse(specialTime); - const timeDif = specialTimeValue - specialTimeObj.specialtime; - wanUploadRate = 8 * wanUploadDiff / (timeDif / 1000); - wanDownloadRate = 8 * wanDownloadDiff / (timeDif / 1000); - localStorage.setItem(rateStorage, JSON.stringify({ - wanUploadRate, - wanDownloadRate - })); - console.log("Time diff: ", timeDif, "wanUploadRate: ", wanUploadRate, "wanDownloadRate: ", wanDownloadRate); - } - localStorage.setItem(timeStorage, JSON.stringify({specialtime: specialTimeValue})); - } else { - const rate = localStorage.getItem(rateStorage); - if (rate !== null) { - const rateObj = JSON.parse(rate); - wanUploadRate = rateObj.wanUploadRate; - wanDownloadRate = rateObj.wanDownloadRate; - } + if (dataStored === null) { + datas = { + wanUpload : 0, + wanDownload : 0, + updateTime : 0, + wanUploadRate : 0, + wanDownloadRate : 0 } - console.log("wanUploadDiff:", wanUploadDiff); - console.log("wanDownloadDiff:", wanDownloadDiff); + } else { + datas = JSON.parse(dataStored); } - localStorage.setItem(dataStorage, JSON.stringify({ - wanUpload, - wanDownload, - time: Date.now()})); - + const wanUploadDiff = wanUpload - datas.wanUpload; + const wanDownloadDiff = wanDownload - datas.wanDownload; + if (wanUploadDiff > 0 || wanDownloadDiff > 0) { + const specialTimeValue = new Date().getTime(); + const timeDif = specialTimeValue - datas.updateTime; + datas.wanUploadRate = 8 * wanUploadDiff / (timeDif / 1000); + datas.wanDownloadRate = 8 * wanDownloadDiff / (timeDif / 1000); + datas.updateTime = specialTimeValue; + } + datas.wanUpload = wanUpload; + datas.wanDownload = wanDownload; + localStorage.setItem(dataStorage, JSON.stringify(datas)); return ( - - - - + + + + ); } From 1bdc10bda5691fbe7fc8c2bcb4478bee325775e0 Mon Sep 17 00:00:00 2001 From: Benoit Date: Tue, 3 Jan 2023 13:22:52 +0100 Subject: [PATCH 16/29] Synology diskstation widget: initial commit. Two fields : uptime and volume usage in percent. --- public/locales/en/common.json | 4 ++ src/widgets/components.js | 1 + src/widgets/synology/component.jsx | 36 +++++++++++ src/widgets/synology/proxy.js | 100 +++++++++++++++++++++++++++++ src/widgets/synology/widget.js | 7 ++ src/widgets/widgets.js | 2 + 6 files changed, 150 insertions(+) create mode 100644 src/widgets/synology/component.jsx create mode 100644 src/widgets/synology/proxy.js create mode 100644 src/widgets/synology/widget.js diff --git a/public/locales/en/common.json b/public/locales/en/common.json index 032c1dfe..63ecdd7d 100644 --- a/public/locales/en/common.json +++ b/public/locales/en/common.json @@ -412,5 +412,9 @@ "memory": "Active Memory", "wanUpload": "WAN Upload", "wanDownload": "WAN Download" + }, + "synology": { + "uptime": "Uptime", + "volumeUsage": "Volume Usage" } } diff --git a/src/widgets/components.js b/src/widgets/components.js index 10277732..b25ecd31 100644 --- a/src/widgets/components.js +++ b/src/widgets/components.js @@ -47,6 +47,7 @@ const components = { sonarr: dynamic(() => import("./sonarr/component")), speedtest: dynamic(() => import("./speedtest/component")), strelaysrv: dynamic(() => import("./strelaysrv/component")), + synology: dynamic(() => import("./synology/component")), tautulli: dynamic(() => import("./tautulli/component")), tdarr: dynamic(() => import("./tdarr/component")), traefik: dynamic(() => import("./traefik/component")), diff --git a/src/widgets/synology/component.jsx b/src/widgets/synology/component.jsx new file mode 100644 index 00000000..f2d662a1 --- /dev/null +++ b/src/widgets/synology/component.jsx @@ -0,0 +1,36 @@ +import { useTranslation } from "next-i18next"; + +import Container from "components/services/widget/container"; +import Block from "components/services/widget/block"; +import useWidgetAPI from "utils/proxy/use-widget-api"; + +export default function Component({ service }) { + const { t } = useTranslation(); + + const { widget } = service; + + const { data: dsData, error: dsError } = useWidgetAPI(widget); + + if (dsError) { + return ; + } + + if (!dsData) { + return ( + + + + + + ); + } + + + return ( + + + + + + ); +} diff --git a/src/widgets/synology/proxy.js b/src/widgets/synology/proxy.js new file mode 100644 index 00000000..8681b522 --- /dev/null +++ b/src/widgets/synology/proxy.js @@ -0,0 +1,100 @@ +import { formatApiCall } from "utils/proxy/api-helpers"; +import { httpProxy } from "utils/proxy/http"; +import createLogger from "utils/logger"; +import getServiceWidget from "utils/config/service-helpers"; + +const proxyName = "synologyProxyHandler"; + +const logger = createLogger(proxyName); + +const authApi = "{url}/webapi/entry.cgi?api=SYNO.API.Auth&version=7&method=login&account={username}&passwd={password}&format=cookie" + +async function getApiInfo(api, widget) { + const infoAPI = "{url}/webapi/entry.cgi?api=SYNO.API.Info&version=1&method=query" + const infoUrl = formatApiCall(infoAPI, widget); + const [status, contentType, data] = await httpProxy(infoUrl); + console.log("GetApiInfo API ", api, " Status: ", status); + let path = "Method unavailable"; + let minVersion = 0; + let maxVersion = 0; + if (status === 200) { + const json = JSON.parse(data.toString()); + if (json.data[api]) { + path = json.data[api].path; + minVersion = json.data[api].minVersion; + maxVersion = json.data[api].maxVersion; + } + } + console.log("GetApiInfo Path: ", path, " MinVersion: ", minVersion, " MaxVersion: ", maxVersion); + return [path, minVersion, maxVersion]; +} + +async function login(widget) { + const loginUrl = formatApiCall(authApi, widget); + const [status, contentType, data] = await httpProxy(loginUrl); + if (status !== 200) { + return [status, contentType, data]; + } + + const json = JSON.parse(data.toString()); + + if (json?.success !== true) { + let message = "Authentication failed."; + if (json?.error?.code >= 403) message += " 2FA enabled."; + logger.warn("Unable to login. Code: %d", json?.error?.code); + return [401, "application/json", JSON.stringify({ code: json?.error?.code, message })]; + } + + return [status, contentType, data]; +} + +export default async function synologyProxyHandler(req, res) { + const { group, service } = req.query; + + if (!group || !service) { + return res.status(400).json({ error: "Invalid proxy service type" }); + } + + const widget = await getServiceWidget(group, service); + + let [status, contentType, data] = await login(widget); + + const { sid }=JSON.parse(data.toString()).data; + let api = "SYNO.Core.System"; + let [ path, minVersion, maxVersion] = await getApiInfo(api, widget); + const storageUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=info&type="storage"&_sid=${sid}`; + [status, contentType, data] = await httpProxy(storageUrl ); + let usedVolume = 0; + if (status !== 200) { + return res.status(status).set("Content-Type", contentType).send(data); + } else { + const json=JSON.parse(data.toString()); + if (json?.success !== true) { + + return res.status(401).json({ error: "Error getting volume stats" }); + } else { + usedVolume = 100 * parseFloat(json.data.vol_info[0].used_size) / parseFloat(json.data.vol_info[0].total_size); + } + } + let uptime = "Unknown"; + + const healthUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=info&_sid=${sid}`; + [status, contentType, data] = await httpProxy(healthUrl); + if (status !== 200) { + return res.status(status).set("Content-Type", contentType).send(data); + } else { + const json=JSON.parse(data.toString()); + if (json?.success !== true) { + return res.status(401).json({ error: "Error getting uptime" }); + } else { + uptime = json.data.up_time; + } + } + + const resdata = { + uptime, + usedVolume + } + if (contentType) res.setHeader("Content-Type", contentType); + return res.status(status).send(JSON.stringify(resdata)); +} diff --git a/src/widgets/synology/widget.js b/src/widgets/synology/widget.js new file mode 100644 index 00000000..65a58586 --- /dev/null +++ b/src/widgets/synology/widget.js @@ -0,0 +1,7 @@ +import synologyProxyHandler from "./proxy"; + +const widget = { + proxyHandler: synologyProxyHandler, +}; + +export default widget; diff --git a/src/widgets/widgets.js b/src/widgets/widgets.js index 3e73e55f..93bb2aaa 100644 --- a/src/widgets/widgets.js +++ b/src/widgets/widgets.js @@ -42,6 +42,7 @@ import scrutiny from "./scrutiny/widget"; import sonarr from "./sonarr/widget"; import speedtest from "./speedtest/widget"; import strelaysrv from "./strelaysrv/widget"; +import synology from "./synology/widget"; import tautulli from "./tautulli/widget"; import tdarr from "./tdarr/widget"; import traefik from "./traefik/widget"; @@ -99,6 +100,7 @@ const widgets = { sonarr, speedtest, strelaysrv, + synology, tautulli, tdarr, traefik, From 46b98dbe67e041c9a82f927700351810fc3d0e84 Mon Sep 17 00:00:00 2001 From: Benoit Date: Tue, 3 Jan 2023 14:01:53 +0100 Subject: [PATCH 17/29] Synology diskstation widget: better uptime formatting --- src/widgets/synology/proxy.js | 23 ++++++++++++++++------- 1 file changed, 16 insertions(+), 7 deletions(-) diff --git a/src/widgets/synology/proxy.js b/src/widgets/synology/proxy.js index 8681b522..037316eb 100644 --- a/src/widgets/synology/proxy.js +++ b/src/widgets/synology/proxy.js @@ -9,11 +9,20 @@ const logger = createLogger(proxyName); const authApi = "{url}/webapi/entry.cgi?api=SYNO.API.Auth&version=7&method=login&account={username}&passwd={password}&format=cookie" +function formatUptime(uptime) { + const [hour, minutes, seconds] = uptime.split(":"); + const days = Math.floor(hour/24); + const hours = hour % 24; + + return `${days} days ${hours}:${minutes}:${seconds}` +} + async function getApiInfo(api, widget) { const infoAPI = "{url}/webapi/entry.cgi?api=SYNO.API.Info&version=1&method=query" const infoUrl = formatApiCall(infoAPI, widget); + // eslint-disable-next-line no-unused-vars const [status, contentType, data] = await httpProxy(infoUrl); - console.log("GetApiInfo API ", api, " Status: ", status); + let path = "Method unavailable"; let minVersion = 0; let maxVersion = 0; @@ -25,7 +34,7 @@ async function getApiInfo(api, widget) { maxVersion = json.data[api].maxVersion; } } - console.log("GetApiInfo Path: ", path, " MinVersion: ", minVersion, " MaxVersion: ", maxVersion); + return [path, minVersion, maxVersion]; } @@ -56,12 +65,13 @@ export default async function synologyProxyHandler(req, res) { } const widget = await getServiceWidget(group, service); - + // eslint-disable-next-line no-unused-vars let [status, contentType, data] = await login(widget); const { sid }=JSON.parse(data.toString()).data; - let api = "SYNO.Core.System"; - let [ path, minVersion, maxVersion] = await getApiInfo(api, widget); + const api = "SYNO.Core.System"; + // eslint-disable-next-line no-unused-vars + const [ path, minVersion, maxVersion] = await getApiInfo(api, widget); const storageUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=info&type="storage"&_sid=${sid}`; [status, contentType, data] = await httpProxy(storageUrl ); let usedVolume = 0; @@ -70,7 +80,6 @@ export default async function synologyProxyHandler(req, res) { } else { const json=JSON.parse(data.toString()); if (json?.success !== true) { - return res.status(401).json({ error: "Error getting volume stats" }); } else { usedVolume = 100 * parseFloat(json.data.vol_info[0].used_size) / parseFloat(json.data.vol_info[0].total_size); @@ -87,7 +96,7 @@ export default async function synologyProxyHandler(req, res) { if (json?.success !== true) { return res.status(401).json({ error: "Error getting uptime" }); } else { - uptime = json.data.up_time; + uptime = formatUptime(json.data.up_time); } } From 2401312869ff7f9ab7ebb0ae9657bc186360182f Mon Sep 17 00:00:00 2001 From: Benoit Date: Tue, 3 Jan 2023 14:20:53 +0100 Subject: [PATCH 18/29] Synology diskstation widget: code cleanup --- src/widgets/synology/proxy.js | 25 ++++++++++--------------- 1 file changed, 10 insertions(+), 15 deletions(-) diff --git a/src/widgets/synology/proxy.js b/src/widgets/synology/proxy.js index 037316eb..39dbf8c1 100644 --- a/src/widgets/synology/proxy.js +++ b/src/widgets/synology/proxy.js @@ -77,28 +77,23 @@ export default async function synologyProxyHandler(req, res) { let usedVolume = 0; if (status !== 200) { return res.status(status).set("Content-Type", contentType).send(data); - } else { - const json=JSON.parse(data.toString()); - if (json?.success !== true) { - return res.status(401).json({ error: "Error getting volume stats" }); - } else { - usedVolume = 100 * parseFloat(json.data.vol_info[0].used_size) / parseFloat(json.data.vol_info[0].total_size); - } } - let uptime = "Unknown"; + let json=JSON.parse(data.toString()); + if (json?.success !== true) { + return res.status(401).json({ error: "Error getting volume stats" }); + } + usedVolume = 100 * parseFloat(json.data.vol_info[0].used_size) / parseFloat(json.data.vol_info[0].total_size); const healthUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=info&_sid=${sid}`; [status, contentType, data] = await httpProxy(healthUrl); if (status !== 200) { return res.status(status).set("Content-Type", contentType).send(data); - } else { - const json=JSON.parse(data.toString()); - if (json?.success !== true) { - return res.status(401).json({ error: "Error getting uptime" }); - } else { - uptime = formatUptime(json.data.up_time); - } } + json=JSON.parse(data.toString()); + if (json?.success !== true) { + return res.status(401).json({ error: "Error getting uptime" }); + } + const uptime = formatUptime(json.data.up_time); const resdata = { uptime, From a08d0c6e60792d54d152880254b15dfcb2a12931 Mon Sep 17 00:00:00 2001 From: Benoit Date: Thu, 5 Jan 2023 18:57:23 +0100 Subject: [PATCH 19/29] Synology widget : working on code stability --- public/locales/en/common.json | 5 +++- src/widgets/opnsense/component.jsx | 5 ++-- src/widgets/synology/component.jsx | 6 ++-- src/widgets/synology/proxy.js | 45 ++++++++++++++++++++---------- 4 files changed, 42 insertions(+), 19 deletions(-) diff --git a/public/locales/en/common.json b/public/locales/en/common.json index a6622533..b1481caa 100644 --- a/public/locales/en/common.json +++ b/public/locales/en/common.json @@ -415,7 +415,10 @@ }, "synology": { "uptime": "Uptime", - "volumeUsage": "Volume Usage" + "volumeUsage": "Volume Usage", + "cpuLoad": "CPU Load", + "memoryUsage": "Memory Usage", + "status": "Status" }, "opnsense": { "cpu": "CPU Load", diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index 3f1ea951..698d2d30 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -52,8 +52,7 @@ export default function Component({ service }) { const { t } = useTranslation(); const { widget } = service; - const wid = `${widget.service_name}.${widget.service_group}`; - const dataStorage = `${wid}datas`; + const dataStorage = `${widget.service_name}.${widget.service_group}datas`; const { data: activityData, error: activityError } = useWidgetAPI(widget, "activity"); const { data: interfaceData, error: interfaceError } = useWidgetAPI(widget, "interface"); @@ -69,6 +68,8 @@ export default function Component({ service }) { + + ); } diff --git a/src/widgets/synology/component.jsx b/src/widgets/synology/component.jsx index f2d662a1..fd832c8e 100644 --- a/src/widgets/synology/component.jsx +++ b/src/widgets/synology/component.jsx @@ -20,7 +20,8 @@ export default function Component({ service }) { - + + ); } @@ -30,7 +31,8 @@ export default function Component({ service }) { - + + ); } diff --git a/src/widgets/synology/proxy.js b/src/widgets/synology/proxy.js index 39dbf8c1..9e42d355 100644 --- a/src/widgets/synology/proxy.js +++ b/src/widgets/synology/proxy.js @@ -2,43 +2,42 @@ import { formatApiCall } from "utils/proxy/api-helpers"; import { httpProxy } from "utils/proxy/http"; import createLogger from "utils/logger"; import getServiceWidget from "utils/config/service-helpers"; +import {console} from "next/dist/compiled/@edge-runtime/primitives/console"; const proxyName = "synologyProxyHandler"; const logger = createLogger(proxyName); -const authApi = "{url}/webapi/entry.cgi?api=SYNO.API.Auth&version=7&method=login&account={username}&passwd={password}&format=cookie" function formatUptime(uptime) { const [hour, minutes, seconds] = uptime.split(":"); const days = Math.floor(hour/24); const hours = hour % 24; - return `${days} days ${hours}:${minutes}:${seconds}` + return `${days} d ${hours}h${minutes}m${seconds}s` } async function getApiInfo(api, widget) { - const infoAPI = "{url}/webapi/entry.cgi?api=SYNO.API.Info&version=1&method=query" + const infoAPI = "{url}/webapi/query.cgi?api=SYNO.API.Info&version=1&method=query" + const infoUrl = formatApiCall(infoAPI, widget); // eslint-disable-next-line no-unused-vars const [status, contentType, data] = await httpProxy(infoUrl); - let path = "Method unavailable"; - let minVersion = 0; - let maxVersion = 0; if (status === 200) { const json = JSON.parse(data.toString()); if (json.data[api]) { - path = json.data[api].path; - minVersion = json.data[api].minVersion; - maxVersion = json.data[api].maxVersion; + const { path, minVersion, maxVersion } = json.data[api]; + return [ path, minVersion, maxVersion ]; } } - - return [path, minVersion, maxVersion]; + return [null, null, null]; } async function login(widget) { + // eslint-disable-next-line no-unused-vars + const [path, minVersion, maxVersion] = await getApiInfo("SYNO.API.Auth", widget); + const authApi = `{url}/webapi/${path}?api=SYNO.API.Auth&version=${maxVersion}&method=login&account={username}&passwd={password}&format=cookie` const loginUrl = formatApiCall(authApi, widget); const [status, contentType, data] = await httpProxy(loginUrl); if (status !== 200) { @@ -69,11 +68,15 @@ export default async function synologyProxyHandler(req, res) { let [status, contentType, data] = await login(widget); const { sid }=JSON.parse(data.toString()).data; - const api = "SYNO.Core.System"; + let api = "SYNO.Core.System"; // eslint-disable-next-line no-unused-vars - const [ path, minVersion, maxVersion] = await getApiInfo(api, widget); + let [ path, minVersion, maxVersion] = await getApiInfo(api, widget); + const storageUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=info&type="storage"&_sid=${sid}`; + [status, contentType, data] = await httpProxy(storageUrl ); + + let usedVolume = 0; if (status !== 200) { return res.status(status).set("Content-Type", contentType).send(data); @@ -86,6 +89,7 @@ export default async function synologyProxyHandler(req, res) { const healthUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=info&_sid=${sid}`; [status, contentType, data] = await httpProxy(healthUrl); + if (status !== 200) { return res.status(status).set("Content-Type", contentType).send(data); } @@ -94,11 +98,24 @@ export default async function synologyProxyHandler(req, res) { return res.status(401).json({ error: "Error getting uptime" }); } const uptime = formatUptime(json.data.up_time); + api = "SYNO.Core.System.Utilization"; + // eslint-disable-next-line no-unused-vars + [ path, minVersion, maxVersion] = await getApiInfo(api, widget); + const sysUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=get&_sid=${sid}`; + [status, contentType, data] = await httpProxy(sysUrl ); + + const memoryUsage = 100 - (100 * (parseFloat(JSON.parse(data.toString()).data.memory.avail_real) + parseFloat(JSON.parse(data.toString()).data.memory.cached)) / parseFloat(JSON.parse(data.toString()).data.memory.total_real)); + const cpuLoad = parseFloat(JSON.parse(data.toString()).data.cpu.user_load) + parseFloat(JSON.parse(data.toString()).data.cpu.system_load); + + const resdata = { uptime, - usedVolume + usedVolume, + memoryUsage, + cpuLoad, } if (contentType) res.setHeader("Content-Type", contentType); + console.log("Response Data: ", resdata); return res.status(status).send(JSON.stringify(resdata)); } From 96080eaaeb64ef87998f0da10757af9b893da46e Mon Sep 17 00:00:00 2001 From: Benoit Date: Sat, 7 Jan 2023 12:20:38 +0100 Subject: [PATCH 20/29] Synology widget: code cleanup --- src/widgets/synology/proxy.js | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/widgets/synology/proxy.js b/src/widgets/synology/proxy.js index 9e42d355..b0590ca7 100644 --- a/src/widgets/synology/proxy.js +++ b/src/widgets/synology/proxy.js @@ -1,8 +1,8 @@ + import { formatApiCall } from "utils/proxy/api-helpers"; import { httpProxy } from "utils/proxy/http"; import createLogger from "utils/logger"; import getServiceWidget from "utils/config/service-helpers"; -import {console} from "next/dist/compiled/@edge-runtime/primitives/console"; const proxyName = "synologyProxyHandler"; @@ -116,6 +116,5 @@ export default async function synologyProxyHandler(req, res) { cpuLoad, } if (contentType) res.setHeader("Content-Type", contentType); - console.log("Response Data: ", resdata); return res.status(status).send(JSON.stringify(resdata)); } From 0ea1362462c75af8ea5e4ff44b212ee51fdb75e8 Mon Sep 17 00:00:00 2001 From: Benoit Date: Sat, 7 Jan 2023 17:28:33 +0100 Subject: [PATCH 21/29] Synology widget: code cleanup --- src/widgets/synology/proxy.js | 2 -- 1 file changed, 2 deletions(-) diff --git a/src/widgets/synology/proxy.js b/src/widgets/synology/proxy.js index b0590ca7..4c4d600a 100644 --- a/src/widgets/synology/proxy.js +++ b/src/widgets/synology/proxy.js @@ -107,8 +107,6 @@ export default async function synologyProxyHandler(req, res) { const memoryUsage = 100 - (100 * (parseFloat(JSON.parse(data.toString()).data.memory.avail_real) + parseFloat(JSON.parse(data.toString()).data.memory.cached)) / parseFloat(JSON.parse(data.toString()).data.memory.total_real)); const cpuLoad = parseFloat(JSON.parse(data.toString()).data.cpu.user_load) + parseFloat(JSON.parse(data.toString()).data.cpu.system_load); - - const resdata = { uptime, usedVolume, From a86f832be9c02bbfad32d2854f7ba249eb3e1da2 Mon Sep 17 00:00:00 2001 From: Benoit Date: Thu, 5 Jan 2023 18:57:23 +0100 Subject: [PATCH 22/29] Synology widget : working on code stability --- public/locales/en/common.json | 5 +++- src/widgets/opnsense/component.jsx | 5 ++-- src/widgets/synology/component.jsx | 6 +++-- src/widgets/synology/proxy.js | 42 ++++++++++++++++++++---------- 4 files changed, 39 insertions(+), 19 deletions(-) diff --git a/public/locales/en/common.json b/public/locales/en/common.json index a6622533..b1481caa 100644 --- a/public/locales/en/common.json +++ b/public/locales/en/common.json @@ -415,7 +415,10 @@ }, "synology": { "uptime": "Uptime", - "volumeUsage": "Volume Usage" + "volumeUsage": "Volume Usage", + "cpuLoad": "CPU Load", + "memoryUsage": "Memory Usage", + "status": "Status" }, "opnsense": { "cpu": "CPU Load", diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index 3f1ea951..698d2d30 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -52,8 +52,7 @@ export default function Component({ service }) { const { t } = useTranslation(); const { widget } = service; - const wid = `${widget.service_name}.${widget.service_group}`; - const dataStorage = `${wid}datas`; + const dataStorage = `${widget.service_name}.${widget.service_group}datas`; const { data: activityData, error: activityError } = useWidgetAPI(widget, "activity"); const { data: interfaceData, error: interfaceError } = useWidgetAPI(widget, "interface"); @@ -69,6 +68,8 @@ export default function Component({ service }) { + + ); } diff --git a/src/widgets/synology/component.jsx b/src/widgets/synology/component.jsx index f2d662a1..fd832c8e 100644 --- a/src/widgets/synology/component.jsx +++ b/src/widgets/synology/component.jsx @@ -20,7 +20,8 @@ export default function Component({ service }) { - + + ); } @@ -30,7 +31,8 @@ export default function Component({ service }) { - + + ); } diff --git a/src/widgets/synology/proxy.js b/src/widgets/synology/proxy.js index 39dbf8c1..4c4d600a 100644 --- a/src/widgets/synology/proxy.js +++ b/src/widgets/synology/proxy.js @@ -1,3 +1,4 @@ + import { formatApiCall } from "utils/proxy/api-helpers"; import { httpProxy } from "utils/proxy/http"; import createLogger from "utils/logger"; @@ -7,38 +8,36 @@ const proxyName = "synologyProxyHandler"; const logger = createLogger(proxyName); -const authApi = "{url}/webapi/entry.cgi?api=SYNO.API.Auth&version=7&method=login&account={username}&passwd={password}&format=cookie" function formatUptime(uptime) { const [hour, minutes, seconds] = uptime.split(":"); const days = Math.floor(hour/24); const hours = hour % 24; - return `${days} days ${hours}:${minutes}:${seconds}` + return `${days} d ${hours}h${minutes}m${seconds}s` } async function getApiInfo(api, widget) { - const infoAPI = "{url}/webapi/entry.cgi?api=SYNO.API.Info&version=1&method=query" + const infoAPI = "{url}/webapi/query.cgi?api=SYNO.API.Info&version=1&method=query" + const infoUrl = formatApiCall(infoAPI, widget); // eslint-disable-next-line no-unused-vars const [status, contentType, data] = await httpProxy(infoUrl); - let path = "Method unavailable"; - let minVersion = 0; - let maxVersion = 0; if (status === 200) { const json = JSON.parse(data.toString()); if (json.data[api]) { - path = json.data[api].path; - minVersion = json.data[api].minVersion; - maxVersion = json.data[api].maxVersion; + const { path, minVersion, maxVersion } = json.data[api]; + return [ path, minVersion, maxVersion ]; } } - - return [path, minVersion, maxVersion]; + return [null, null, null]; } async function login(widget) { + // eslint-disable-next-line no-unused-vars + const [path, minVersion, maxVersion] = await getApiInfo("SYNO.API.Auth", widget); + const authApi = `{url}/webapi/${path}?api=SYNO.API.Auth&version=${maxVersion}&method=login&account={username}&passwd={password}&format=cookie` const loginUrl = formatApiCall(authApi, widget); const [status, contentType, data] = await httpProxy(loginUrl); if (status !== 200) { @@ -69,11 +68,15 @@ export default async function synologyProxyHandler(req, res) { let [status, contentType, data] = await login(widget); const { sid }=JSON.parse(data.toString()).data; - const api = "SYNO.Core.System"; + let api = "SYNO.Core.System"; // eslint-disable-next-line no-unused-vars - const [ path, minVersion, maxVersion] = await getApiInfo(api, widget); + let [ path, minVersion, maxVersion] = await getApiInfo(api, widget); + const storageUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=info&type="storage"&_sid=${sid}`; + [status, contentType, data] = await httpProxy(storageUrl ); + + let usedVolume = 0; if (status !== 200) { return res.status(status).set("Content-Type", contentType).send(data); @@ -86,6 +89,7 @@ export default async function synologyProxyHandler(req, res) { const healthUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=info&_sid=${sid}`; [status, contentType, data] = await httpProxy(healthUrl); + if (status !== 200) { return res.status(status).set("Content-Type", contentType).send(data); } @@ -94,10 +98,20 @@ export default async function synologyProxyHandler(req, res) { return res.status(401).json({ error: "Error getting uptime" }); } const uptime = formatUptime(json.data.up_time); + api = "SYNO.Core.System.Utilization"; + // eslint-disable-next-line no-unused-vars + [ path, minVersion, maxVersion] = await getApiInfo(api, widget); + const sysUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=get&_sid=${sid}`; + [status, contentType, data] = await httpProxy(sysUrl ); + + const memoryUsage = 100 - (100 * (parseFloat(JSON.parse(data.toString()).data.memory.avail_real) + parseFloat(JSON.parse(data.toString()).data.memory.cached)) / parseFloat(JSON.parse(data.toString()).data.memory.total_real)); + const cpuLoad = parseFloat(JSON.parse(data.toString()).data.cpu.user_load) + parseFloat(JSON.parse(data.toString()).data.cpu.system_load); const resdata = { uptime, - usedVolume + usedVolume, + memoryUsage, + cpuLoad, } if (contentType) res.setHeader("Content-Type", contentType); return res.status(status).send(JSON.stringify(resdata)); From a57ec06a30265e7fbbe0391d85df4b5926aafe54 Mon Sep 17 00:00:00 2001 From: Benoit Date: Wed, 11 Jan 2023 10:54:28 +0100 Subject: [PATCH 23/29] Synology widget : working on code stability --- src/widgets/synology/proxy.js | 42 +++++++++++++++++++++++------------ 1 file changed, 28 insertions(+), 14 deletions(-) diff --git a/src/widgets/synology/proxy.js b/src/widgets/synology/proxy.js index 39dbf8c1..4c4d600a 100644 --- a/src/widgets/synology/proxy.js +++ b/src/widgets/synology/proxy.js @@ -1,3 +1,4 @@ + import { formatApiCall } from "utils/proxy/api-helpers"; import { httpProxy } from "utils/proxy/http"; import createLogger from "utils/logger"; @@ -7,38 +8,36 @@ const proxyName = "synologyProxyHandler"; const logger = createLogger(proxyName); -const authApi = "{url}/webapi/entry.cgi?api=SYNO.API.Auth&version=7&method=login&account={username}&passwd={password}&format=cookie" function formatUptime(uptime) { const [hour, minutes, seconds] = uptime.split(":"); const days = Math.floor(hour/24); const hours = hour % 24; - return `${days} days ${hours}:${minutes}:${seconds}` + return `${days} d ${hours}h${minutes}m${seconds}s` } async function getApiInfo(api, widget) { - const infoAPI = "{url}/webapi/entry.cgi?api=SYNO.API.Info&version=1&method=query" + const infoAPI = "{url}/webapi/query.cgi?api=SYNO.API.Info&version=1&method=query" + const infoUrl = formatApiCall(infoAPI, widget); // eslint-disable-next-line no-unused-vars const [status, contentType, data] = await httpProxy(infoUrl); - let path = "Method unavailable"; - let minVersion = 0; - let maxVersion = 0; if (status === 200) { const json = JSON.parse(data.toString()); if (json.data[api]) { - path = json.data[api].path; - minVersion = json.data[api].minVersion; - maxVersion = json.data[api].maxVersion; + const { path, minVersion, maxVersion } = json.data[api]; + return [ path, minVersion, maxVersion ]; } } - - return [path, minVersion, maxVersion]; + return [null, null, null]; } async function login(widget) { + // eslint-disable-next-line no-unused-vars + const [path, minVersion, maxVersion] = await getApiInfo("SYNO.API.Auth", widget); + const authApi = `{url}/webapi/${path}?api=SYNO.API.Auth&version=${maxVersion}&method=login&account={username}&passwd={password}&format=cookie` const loginUrl = formatApiCall(authApi, widget); const [status, contentType, data] = await httpProxy(loginUrl); if (status !== 200) { @@ -69,11 +68,15 @@ export default async function synologyProxyHandler(req, res) { let [status, contentType, data] = await login(widget); const { sid }=JSON.parse(data.toString()).data; - const api = "SYNO.Core.System"; + let api = "SYNO.Core.System"; // eslint-disable-next-line no-unused-vars - const [ path, minVersion, maxVersion] = await getApiInfo(api, widget); + let [ path, minVersion, maxVersion] = await getApiInfo(api, widget); + const storageUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=info&type="storage"&_sid=${sid}`; + [status, contentType, data] = await httpProxy(storageUrl ); + + let usedVolume = 0; if (status !== 200) { return res.status(status).set("Content-Type", contentType).send(data); @@ -86,6 +89,7 @@ export default async function synologyProxyHandler(req, res) { const healthUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=info&_sid=${sid}`; [status, contentType, data] = await httpProxy(healthUrl); + if (status !== 200) { return res.status(status).set("Content-Type", contentType).send(data); } @@ -94,10 +98,20 @@ export default async function synologyProxyHandler(req, res) { return res.status(401).json({ error: "Error getting uptime" }); } const uptime = formatUptime(json.data.up_time); + api = "SYNO.Core.System.Utilization"; + // eslint-disable-next-line no-unused-vars + [ path, minVersion, maxVersion] = await getApiInfo(api, widget); + const sysUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=get&_sid=${sid}`; + [status, contentType, data] = await httpProxy(sysUrl ); + + const memoryUsage = 100 - (100 * (parseFloat(JSON.parse(data.toString()).data.memory.avail_real) + parseFloat(JSON.parse(data.toString()).data.memory.cached)) / parseFloat(JSON.parse(data.toString()).data.memory.total_real)); + const cpuLoad = parseFloat(JSON.parse(data.toString()).data.cpu.user_load) + parseFloat(JSON.parse(data.toString()).data.cpu.system_load); const resdata = { uptime, - usedVolume + usedVolume, + memoryUsage, + cpuLoad, } if (contentType) res.setHeader("Content-Type", contentType); return res.status(status).send(JSON.stringify(resdata)); From 977965babb68963c798e81f33f8714fff7ea2812 Mon Sep 17 00:00:00 2001 From: Benoit Date: Wed, 11 Jan 2023 21:59:46 +0100 Subject: [PATCH 24/29] Synology widget : adding volume size --- public/locales/en/common.json | 3 ++- src/widgets/synology/component.jsx | 2 ++ src/widgets/synology/proxy.js | 6 +++--- 3 files changed, 7 insertions(+), 4 deletions(-) diff --git a/public/locales/en/common.json b/public/locales/en/common.json index b1481caa..ad77cbb2 100644 --- a/public/locales/en/common.json +++ b/public/locales/en/common.json @@ -418,7 +418,8 @@ "volumeUsage": "Volume Usage", "cpuLoad": "CPU Load", "memoryUsage": "Memory Usage", - "status": "Status" + "status": "Status", + "volumeTotal": "Total space" }, "opnsense": { "cpu": "CPU Load", diff --git a/src/widgets/synology/component.jsx b/src/widgets/synology/component.jsx index fd832c8e..95405e84 100644 --- a/src/widgets/synology/component.jsx +++ b/src/widgets/synology/component.jsx @@ -20,6 +20,7 @@ export default function Component({ service }) { + @@ -31,6 +32,7 @@ export default function Component({ service }) { + diff --git a/src/widgets/synology/proxy.js b/src/widgets/synology/proxy.js index 4c4d600a..aa1023bc 100644 --- a/src/widgets/synology/proxy.js +++ b/src/widgets/synology/proxy.js @@ -76,8 +76,6 @@ export default async function synologyProxyHandler(req, res) { [status, contentType, data] = await httpProxy(storageUrl ); - - let usedVolume = 0; if (status !== 200) { return res.status(status).set("Content-Type", contentType).send(data); } @@ -85,7 +83,8 @@ export default async function synologyProxyHandler(req, res) { if (json?.success !== true) { return res.status(401).json({ error: "Error getting volume stats" }); } - usedVolume = 100 * parseFloat(json.data.vol_info[0].used_size) / parseFloat(json.data.vol_info[0].total_size); + const totalSize = parseFloat(json.data.vol_info[0].total_size); + const usedVolume = 100 * parseFloat(json.data.vol_info[0].used_size) / parseFloat(json.data.vol_info[0].total_size); const healthUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=info&_sid=${sid}`; [status, contentType, data] = await httpProxy(healthUrl); @@ -110,6 +109,7 @@ export default async function synologyProxyHandler(req, res) { const resdata = { uptime, usedVolume, + totalSize, memoryUsage, cpuLoad, } From b341320f9a4b1e9f61c3d0cb59f62dd06111cdfe Mon Sep 17 00:00:00 2001 From: Benoit Date: Thu, 12 Jan 2023 09:55:21 +0100 Subject: [PATCH 25/29] Synology widget : undoing a merge error with opnsense widget branch --- src/widgets/opnsense/component.jsx | 90 +++--------------------------- 1 file changed, 9 insertions(+), 81 deletions(-) diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index 698d2d30..53396b31 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -5,54 +5,10 @@ import Block from "components/services/widget/block"; import useWidgetAPI from "utils/proxy/use-widget-api"; export default function Component({ service }) { - function toKb(value, unit) { - switch (unit) { - case "K": - return parseInt(value, 10); - case "M": - return parseInt(value, 10) * 1024; - case "G": - return parseInt(value, 10) * 1024 * 1024; - default: - return parseInt(value, 10); - } - } - - function sumMemory(meminfos) { - let result; - let sumused=0; - let sumfree=0; - - const idused = ["Active", "Wired", "Laundry", "Buf"]; - const idfree = ["Inact", "Free"]; - const size = "([0-9]+)([KMG])"; - - for (let id = 0; id < idused.length;id+=1 ) { - const re = new RegExp(`${size } ${ idused[id] }`); - result = re.exec(meminfos); - - if (result) { - sumused += toKb(result[1], result[2]); - } - } - - for (let id = 0; id < idfree.length; id+=1 ) { - const re = new RegExp(`${size } ${ idfree[id] }`); - result = re.exec(meminfos); - - if (result) { - sumfree += toKb(result[1], result[2]); - } - } - - return 100*(sumused / (sumused + sumfree)); - - } - const { t } = useTranslation(); const { widget } = service; - const dataStorage = `${widget.service_name}.${widget.service_group}datas`; + const { data: activityData, error: activityError } = useWidgetAPI(widget, "activity"); const { data: interfaceData, error: interfaceError } = useWidgetAPI(widget, "interface"); @@ -68,8 +24,6 @@ export default function Component({ service }) { - - ); } @@ -77,44 +31,18 @@ export default function Component({ service }) { const cpuIdle = activityData.headers[2].match(/ ([0-9.]+)% idle/)[1]; const cpu = 100 - parseFloat(cpuIdle); - const memory = sumMemory(activityData.headers[3]); + const memory = activityData.headers[3].match(/Mem: (.+) Active,/)[1]; - const wanUpload = parseFloat(interfaceData.interfaces.wan['bytes transmitted']); - const wanDownload = parseFloat(interfaceData.interfaces.wan['bytes received']); - const dataStored = localStorage.getItem(dataStorage); - let datas; + const wanUpload = interfaceData.interfaces.wan['bytes transmitted']; + const wanDownload = interfaceData.interfaces.wan['bytes received']; - if (dataStored === null) { - datas = { - wanUpload : 0, - wanDownload : 0, - updateTime : 0, - wanUploadRate : 0, - wanDownloadRate : 0 - } - } else { - datas = JSON.parse(dataStored); - } - const wanUploadDiff = wanUpload - datas.wanUpload; - const wanDownloadDiff = wanDownload - datas.wanDownload; - if (wanUploadDiff > 0 || wanDownloadDiff > 0) { - const specialTimeValue = new Date().getTime(); - const timeDif = specialTimeValue - datas.updateTime; - datas.wanUploadRate = 8 * wanUploadDiff / (timeDif / 1000); - datas.wanDownloadRate = 8 * wanDownloadDiff / (timeDif / 1000); - datas.updateTime = specialTimeValue; - } - datas.wanUpload = wanUpload; - datas.wanDownload = wanDownload; - localStorage.setItem(dataStorage, JSON.stringify(datas)); return ( - - - - - - + + + + + ); } From 172ade4454fc391c4dc12dae6b8aa3fcd9eddbb0 Mon Sep 17 00:00:00 2001 From: Benoit Date: Wed, 11 Jan 2023 21:59:46 +0100 Subject: [PATCH 26/29] Synology widget : adding volume size --- public/locales/en/common.json | 3 +- src/widgets/opnsense/component.jsx | 90 +++--------------------------- src/widgets/synology/component.jsx | 2 + src/widgets/synology/proxy.js | 6 +- 4 files changed, 16 insertions(+), 85 deletions(-) diff --git a/public/locales/en/common.json b/public/locales/en/common.json index b1481caa..ad77cbb2 100644 --- a/public/locales/en/common.json +++ b/public/locales/en/common.json @@ -418,7 +418,8 @@ "volumeUsage": "Volume Usage", "cpuLoad": "CPU Load", "memoryUsage": "Memory Usage", - "status": "Status" + "status": "Status", + "volumeTotal": "Total space" }, "opnsense": { "cpu": "CPU Load", diff --git a/src/widgets/opnsense/component.jsx b/src/widgets/opnsense/component.jsx index 698d2d30..53396b31 100644 --- a/src/widgets/opnsense/component.jsx +++ b/src/widgets/opnsense/component.jsx @@ -5,54 +5,10 @@ import Block from "components/services/widget/block"; import useWidgetAPI from "utils/proxy/use-widget-api"; export default function Component({ service }) { - function toKb(value, unit) { - switch (unit) { - case "K": - return parseInt(value, 10); - case "M": - return parseInt(value, 10) * 1024; - case "G": - return parseInt(value, 10) * 1024 * 1024; - default: - return parseInt(value, 10); - } - } - - function sumMemory(meminfos) { - let result; - let sumused=0; - let sumfree=0; - - const idused = ["Active", "Wired", "Laundry", "Buf"]; - const idfree = ["Inact", "Free"]; - const size = "([0-9]+)([KMG])"; - - for (let id = 0; id < idused.length;id+=1 ) { - const re = new RegExp(`${size } ${ idused[id] }`); - result = re.exec(meminfos); - - if (result) { - sumused += toKb(result[1], result[2]); - } - } - - for (let id = 0; id < idfree.length; id+=1 ) { - const re = new RegExp(`${size } ${ idfree[id] }`); - result = re.exec(meminfos); - - if (result) { - sumfree += toKb(result[1], result[2]); - } - } - - return 100*(sumused / (sumused + sumfree)); - - } - const { t } = useTranslation(); const { widget } = service; - const dataStorage = `${widget.service_name}.${widget.service_group}datas`; + const { data: activityData, error: activityError } = useWidgetAPI(widget, "activity"); const { data: interfaceData, error: interfaceError } = useWidgetAPI(widget, "interface"); @@ -68,8 +24,6 @@ export default function Component({ service }) { - - ); } @@ -77,44 +31,18 @@ export default function Component({ service }) { const cpuIdle = activityData.headers[2].match(/ ([0-9.]+)% idle/)[1]; const cpu = 100 - parseFloat(cpuIdle); - const memory = sumMemory(activityData.headers[3]); + const memory = activityData.headers[3].match(/Mem: (.+) Active,/)[1]; - const wanUpload = parseFloat(interfaceData.interfaces.wan['bytes transmitted']); - const wanDownload = parseFloat(interfaceData.interfaces.wan['bytes received']); - const dataStored = localStorage.getItem(dataStorage); - let datas; + const wanUpload = interfaceData.interfaces.wan['bytes transmitted']; + const wanDownload = interfaceData.interfaces.wan['bytes received']; - if (dataStored === null) { - datas = { - wanUpload : 0, - wanDownload : 0, - updateTime : 0, - wanUploadRate : 0, - wanDownloadRate : 0 - } - } else { - datas = JSON.parse(dataStored); - } - const wanUploadDiff = wanUpload - datas.wanUpload; - const wanDownloadDiff = wanDownload - datas.wanDownload; - if (wanUploadDiff > 0 || wanDownloadDiff > 0) { - const specialTimeValue = new Date().getTime(); - const timeDif = specialTimeValue - datas.updateTime; - datas.wanUploadRate = 8 * wanUploadDiff / (timeDif / 1000); - datas.wanDownloadRate = 8 * wanDownloadDiff / (timeDif / 1000); - datas.updateTime = specialTimeValue; - } - datas.wanUpload = wanUpload; - datas.wanDownload = wanDownload; - localStorage.setItem(dataStorage, JSON.stringify(datas)); return ( - - - - - - + + + + + ); } diff --git a/src/widgets/synology/component.jsx b/src/widgets/synology/component.jsx index fd832c8e..95405e84 100644 --- a/src/widgets/synology/component.jsx +++ b/src/widgets/synology/component.jsx @@ -20,6 +20,7 @@ export default function Component({ service }) { + @@ -31,6 +32,7 @@ export default function Component({ service }) { + diff --git a/src/widgets/synology/proxy.js b/src/widgets/synology/proxy.js index 4c4d600a..aa1023bc 100644 --- a/src/widgets/synology/proxy.js +++ b/src/widgets/synology/proxy.js @@ -76,8 +76,6 @@ export default async function synologyProxyHandler(req, res) { [status, contentType, data] = await httpProxy(storageUrl ); - - let usedVolume = 0; if (status !== 200) { return res.status(status).set("Content-Type", contentType).send(data); } @@ -85,7 +83,8 @@ export default async function synologyProxyHandler(req, res) { if (json?.success !== true) { return res.status(401).json({ error: "Error getting volume stats" }); } - usedVolume = 100 * parseFloat(json.data.vol_info[0].used_size) / parseFloat(json.data.vol_info[0].total_size); + const totalSize = parseFloat(json.data.vol_info[0].total_size); + const usedVolume = 100 * parseFloat(json.data.vol_info[0].used_size) / parseFloat(json.data.vol_info[0].total_size); const healthUrl = `${widget.url}/webapi/${path}?api=${api}&version=${maxVersion}&method=info&_sid=${sid}`; [status, contentType, data] = await httpProxy(healthUrl); @@ -110,6 +109,7 @@ export default async function synologyProxyHandler(req, res) { const resdata = { uptime, usedVolume, + totalSize, memoryUsage, cpuLoad, } From 879079a0cd3ed9f8b8a01fe39952e88a01efe01f Mon Sep 17 00:00:00 2001 From: Benoit Date: Thu, 12 Jan 2023 13:32:43 +0100 Subject: [PATCH 27/29] Synology widget : renaming widget to diskstation --- src/widgets/components.js | 2 +- src/widgets/{synology => diskstation}/component.jsx | 0 src/widgets/{synology => diskstation}/proxy.js | 0 src/widgets/{synology => diskstation}/widget.js | 0 src/widgets/widgets.js | 5 ++--- 5 files changed, 3 insertions(+), 4 deletions(-) rename src/widgets/{synology => diskstation}/component.jsx (100%) rename src/widgets/{synology => diskstation}/proxy.js (100%) rename src/widgets/{synology => diskstation}/widget.js (100%) diff --git a/src/widgets/components.js b/src/widgets/components.js index b25ecd31..70dbf6c5 100644 --- a/src/widgets/components.js +++ b/src/widgets/components.js @@ -47,7 +47,7 @@ const components = { sonarr: dynamic(() => import("./sonarr/component")), speedtest: dynamic(() => import("./speedtest/component")), strelaysrv: dynamic(() => import("./strelaysrv/component")), - synology: dynamic(() => import("./synology/component")), + diskstation: dynamic(() => import("./diskstation/component")), tautulli: dynamic(() => import("./tautulli/component")), tdarr: dynamic(() => import("./tdarr/component")), traefik: dynamic(() => import("./traefik/component")), diff --git a/src/widgets/synology/component.jsx b/src/widgets/diskstation/component.jsx similarity index 100% rename from src/widgets/synology/component.jsx rename to src/widgets/diskstation/component.jsx diff --git a/src/widgets/synology/proxy.js b/src/widgets/diskstation/proxy.js similarity index 100% rename from src/widgets/synology/proxy.js rename to src/widgets/diskstation/proxy.js diff --git a/src/widgets/synology/widget.js b/src/widgets/diskstation/widget.js similarity index 100% rename from src/widgets/synology/widget.js rename to src/widgets/diskstation/widget.js diff --git a/src/widgets/widgets.js b/src/widgets/widgets.js index 93bb2aaa..7a96a128 100644 --- a/src/widgets/widgets.js +++ b/src/widgets/widgets.js @@ -42,7 +42,7 @@ import scrutiny from "./scrutiny/widget"; import sonarr from "./sonarr/widget"; import speedtest from "./speedtest/widget"; import strelaysrv from "./strelaysrv/widget"; -import synology from "./synology/widget"; +import diskstation from "./diskstation/widget"; import tautulli from "./tautulli/widget"; import tdarr from "./tdarr/widget"; import traefik from "./traefik/widget"; @@ -61,7 +61,7 @@ const widgets = { changedetectionio, coinmarketcap, deluge, - diskstation: downloadstation, + diskstation, downloadstation, emby, flood, @@ -100,7 +100,6 @@ const widgets = { sonarr, speedtest, strelaysrv, - synology, tautulli, tdarr, traefik, From b1143398668f07ed2cbcb243ef0dc968079709f8 Mon Sep 17 00:00:00 2001 From: Benoit Date: Fri, 13 Jan 2023 17:03:29 +0100 Subject: [PATCH 28/29] Diskstation widget : code cleanup --- public/locales/en/common.json | 12 +----------- src/widgets/diskstation/component.jsx | 20 ++++++++++---------- src/widgets/diskstation/proxy.js | 7 +++---- 3 files changed, 14 insertions(+), 25 deletions(-) diff --git a/public/locales/en/common.json b/public/locales/en/common.json index ad77cbb2..9b4a30de 100644 --- a/public/locales/en/common.json +++ b/public/locales/en/common.json @@ -413,22 +413,12 @@ "wanUpload": "WAN Upload", "wanDownload": "WAN Download" }, - "synology": { + "diskstation": { "uptime": "Uptime", "volumeUsage": "Volume Usage", "cpuLoad": "CPU Load", "memoryUsage": "Memory Usage", "status": "Status", "volumeTotal": "Total space" - }, - "opnsense": { - "cpu": "CPU Load", - "memory": "Memory Used", - "uptime": "Uptime", - "wanUpload": "WAN Upload", - "wanDownload": "WAN Download", - "wanUploadRate": "WAN Upload Rate", - "wanDownloadRate": "WAN Download Rate" - } } diff --git a/src/widgets/diskstation/component.jsx b/src/widgets/diskstation/component.jsx index 95405e84..aaf69d31 100644 --- a/src/widgets/diskstation/component.jsx +++ b/src/widgets/diskstation/component.jsx @@ -18,11 +18,11 @@ export default function Component({ service }) { if (!dsData) { return ( - - - - - + + + + + ); } @@ -30,11 +30,11 @@ export default function Component({ service }) { return ( - - - - - + + + + + ); } diff --git a/src/widgets/diskstation/proxy.js b/src/widgets/diskstation/proxy.js index aa1023bc..55d22e31 100644 --- a/src/widgets/diskstation/proxy.js +++ b/src/widgets/diskstation/proxy.js @@ -106,13 +106,12 @@ export default async function synologyProxyHandler(req, res) { const memoryUsage = 100 - (100 * (parseFloat(JSON.parse(data.toString()).data.memory.avail_real) + parseFloat(JSON.parse(data.toString()).data.memory.cached)) / parseFloat(JSON.parse(data.toString()).data.memory.total_real)); const cpuLoad = parseFloat(JSON.parse(data.toString()).data.cpu.user_load) + parseFloat(JSON.parse(data.toString()).data.cpu.system_load); - const resdata = { + if (contentType) res.setHeader("Content-Type", contentType); + return res.status(status).send(JSON.stringify({ uptime, usedVolume, totalSize, memoryUsage, cpuLoad, - } - if (contentType) res.setHeader("Content-Type", contentType); - return res.status(status).send(JSON.stringify(resdata)); + })); } From 2f9861b64d1e2d5046096ed9dfbeaf0d7b8241f6 Mon Sep 17 00:00:00 2001 From: Benoit Date: Thu, 12 Jan 2023 13:32:43 +0100 Subject: [PATCH 29/29] Synology widget : renaming widget to diskstation --- public/locales/en/common.json | 12 +----- src/widgets/components.js | 2 +- src/widgets/diskstation/component.jsx | 40 +++++++++++++++++++ .../{synology => diskstation}/proxy.js | 7 ++-- .../{synology => diskstation}/widget.js | 0 src/widgets/synology/component.jsx | 40 ------------------- src/widgets/widgets.js | 5 +-- 7 files changed, 47 insertions(+), 59 deletions(-) create mode 100644 src/widgets/diskstation/component.jsx rename src/widgets/{synology => diskstation}/proxy.js (98%) rename src/widgets/{synology => diskstation}/widget.js (100%) delete mode 100644 src/widgets/synology/component.jsx diff --git a/public/locales/en/common.json b/public/locales/en/common.json index ad77cbb2..9b4a30de 100644 --- a/public/locales/en/common.json +++ b/public/locales/en/common.json @@ -413,22 +413,12 @@ "wanUpload": "WAN Upload", "wanDownload": "WAN Download" }, - "synology": { + "diskstation": { "uptime": "Uptime", "volumeUsage": "Volume Usage", "cpuLoad": "CPU Load", "memoryUsage": "Memory Usage", "status": "Status", "volumeTotal": "Total space" - }, - "opnsense": { - "cpu": "CPU Load", - "memory": "Memory Used", - "uptime": "Uptime", - "wanUpload": "WAN Upload", - "wanDownload": "WAN Download", - "wanUploadRate": "WAN Upload Rate", - "wanDownloadRate": "WAN Download Rate" - } } diff --git a/src/widgets/components.js b/src/widgets/components.js index b25ecd31..70dbf6c5 100644 --- a/src/widgets/components.js +++ b/src/widgets/components.js @@ -47,7 +47,7 @@ const components = { sonarr: dynamic(() => import("./sonarr/component")), speedtest: dynamic(() => import("./speedtest/component")), strelaysrv: dynamic(() => import("./strelaysrv/component")), - synology: dynamic(() => import("./synology/component")), + diskstation: dynamic(() => import("./diskstation/component")), tautulli: dynamic(() => import("./tautulli/component")), tdarr: dynamic(() => import("./tdarr/component")), traefik: dynamic(() => import("./traefik/component")), diff --git a/src/widgets/diskstation/component.jsx b/src/widgets/diskstation/component.jsx new file mode 100644 index 00000000..aaf69d31 --- /dev/null +++ b/src/widgets/diskstation/component.jsx @@ -0,0 +1,40 @@ +import { useTranslation } from "next-i18next"; + +import Container from "components/services/widget/container"; +import Block from "components/services/widget/block"; +import useWidgetAPI from "utils/proxy/use-widget-api"; + +export default function Component({ service }) { + const { t } = useTranslation(); + + const { widget } = service; + + const { data: dsData, error: dsError } = useWidgetAPI(widget); + + if (dsError) { + return ; + } + + if (!dsData) { + return ( + + + + + + + + ); + } + + + return ( + + + + + + + + ); +} diff --git a/src/widgets/synology/proxy.js b/src/widgets/diskstation/proxy.js similarity index 98% rename from src/widgets/synology/proxy.js rename to src/widgets/diskstation/proxy.js index aa1023bc..55d22e31 100644 --- a/src/widgets/synology/proxy.js +++ b/src/widgets/diskstation/proxy.js @@ -106,13 +106,12 @@ export default async function synologyProxyHandler(req, res) { const memoryUsage = 100 - (100 * (parseFloat(JSON.parse(data.toString()).data.memory.avail_real) + parseFloat(JSON.parse(data.toString()).data.memory.cached)) / parseFloat(JSON.parse(data.toString()).data.memory.total_real)); const cpuLoad = parseFloat(JSON.parse(data.toString()).data.cpu.user_load) + parseFloat(JSON.parse(data.toString()).data.cpu.system_load); - const resdata = { + if (contentType) res.setHeader("Content-Type", contentType); + return res.status(status).send(JSON.stringify({ uptime, usedVolume, totalSize, memoryUsage, cpuLoad, - } - if (contentType) res.setHeader("Content-Type", contentType); - return res.status(status).send(JSON.stringify(resdata)); + })); } diff --git a/src/widgets/synology/widget.js b/src/widgets/diskstation/widget.js similarity index 100% rename from src/widgets/synology/widget.js rename to src/widgets/diskstation/widget.js diff --git a/src/widgets/synology/component.jsx b/src/widgets/synology/component.jsx deleted file mode 100644 index 95405e84..00000000 --- a/src/widgets/synology/component.jsx +++ /dev/null @@ -1,40 +0,0 @@ -import { useTranslation } from "next-i18next"; - -import Container from "components/services/widget/container"; -import Block from "components/services/widget/block"; -import useWidgetAPI from "utils/proxy/use-widget-api"; - -export default function Component({ service }) { - const { t } = useTranslation(); - - const { widget } = service; - - const { data: dsData, error: dsError } = useWidgetAPI(widget); - - if (dsError) { - return ; - } - - if (!dsData) { - return ( - - - - - - - - ); - } - - - return ( - - - - - - - - ); -} diff --git a/src/widgets/widgets.js b/src/widgets/widgets.js index 93bb2aaa..7a96a128 100644 --- a/src/widgets/widgets.js +++ b/src/widgets/widgets.js @@ -42,7 +42,7 @@ import scrutiny from "./scrutiny/widget"; import sonarr from "./sonarr/widget"; import speedtest from "./speedtest/widget"; import strelaysrv from "./strelaysrv/widget"; -import synology from "./synology/widget"; +import diskstation from "./diskstation/widget"; import tautulli from "./tautulli/widget"; import tdarr from "./tdarr/widget"; import traefik from "./traefik/widget"; @@ -61,7 +61,7 @@ const widgets = { changedetectionio, coinmarketcap, deluge, - diskstation: downloadstation, + diskstation, downloadstation, emby, flood, @@ -100,7 +100,6 @@ const widgets = { sonarr, speedtest, strelaysrv, - synology, tautulli, tdarr, traefik,