diff --git a/src/widgets/uptimekuma/component.jsx b/src/widgets/uptimekuma/component.jsx
index dd112db4..7e62244b 100644
--- a/src/widgets/uptimekuma/component.jsx
+++ b/src/widgets/uptimekuma/component.jsx
@@ -4,25 +4,43 @@ import Container from "components/services/widget/container";
import useWidgetAPI from "utils/proxy/use-widget-api";
import Block from "components/services/widget/block";
-const Status = {
- good: "uptimekuma.good",
- warn: "uptimekuma.warn",
- bad: "uptimekuma.bad",
- unknown: "uptimekuma.unknown",
-};
+// Adapted from https://github.com/bastienwirtz/homer/blob/b7cd8f9482e6836a96b354b11595b03b9c3d67cd/src/components/services/UptimeKuma.vue#L59
+function getMessage(heartbeatData) {
+ let message = "good";
+ if (Object.keys(heartbeatData.heartbeatList) === 0) {
+ message = "unknown";
+ }
+
+ let hasUp = false;
+ Object.values(heartbeatData.heartbeatList).forEach((siteList) => {
+ const lastHeartbeat = siteList[siteList.length - 1];
+ if (lastHeartbeat?.status === 1) {
+ hasUp = true;
+ } else {
+ message = "warn";
+ }
+ });
+
+ if (!hasUp) {
+ message = "bad";
+ }
+
+ return message;
+}
export default function Component({ service }) {
const { t } = useTranslation();
const { widget } = service;
- const { data: statusData, error: statusError } = useWidgetAPI(widget);
+ const { data: statusData, error: statusError } = useWidgetAPI(widget, "status_page");
+ const { data: heartbeatData, error: heartbeatError } = useWidgetAPI(widget, "heartbeat");
- if (statusError) {
- return ;
+ if (statusError || heartbeatError) {
+ return ;
}
- if (!statusData) {
+ if (!statusData || !heartbeatData) {
return (
@@ -31,15 +49,16 @@ export default function Component({ service }) {
);
}
- if (statusData.icon) {
- // eslint-disable-next-line no-param-reassign
- service.icon = statusData.icon;
- }
+ const message = getMessage(heartbeatData);
+ // Adapted from https://github.com/bastienwirtz/homer/blob/b7cd8f9482e6836a96b354b11595b03b9c3d67cd/src/components/services/UptimeKuma.vue#L105
+ const uptimeList = Object.values(heartbeatData.uptimeList);
+ const percent = uptimeList.reduce((a, b) => a + b, 0) / uptimeList.length || 0;
+ const uptime = (percent * 100).toFixed(1);
return (
-
-
+
+
);
}
diff --git a/src/widgets/uptimekuma/proxy.js b/src/widgets/uptimekuma/proxy.js
deleted file mode 100644
index 6722de85..00000000
--- a/src/widgets/uptimekuma/proxy.js
+++ /dev/null
@@ -1,95 +0,0 @@
-import { httpProxy } from "utils/proxy/http";
-import getServiceWidget from "utils/config/service-helpers";
-import createLogger from "utils/logger";
-
-const logger = createLogger("uptimeKumaProxyHandler");
-
-async function getStatus(widget) {
- const url = new URL(`${widget.url}/api/status-page/${widget.slug}`).toString();
- logger.debug("get status %s", url);
- const params = { method: "GET", headers: {} };
- const [status, , data] = await httpProxy(url, params);
- try {
- return [status, JSON.parse(data)];
- } catch (e) {
- logger.error("Error decoding status data. Data: %s", data.toString());
- return [status, null];
- }
-}
-
-async function getHeartbeat(widget) {
- const url = new URL(`${widget.url}/api/status-page/heartbeat/${widget.slug}`).toString();
- logger.debug("get heartbeat %s", url);
- const params = { method: "GET", headers: {} };
- const [status, , data] = await httpProxy(url, params);
- try {
- return [status, JSON.parse(data)];
- } catch (e) {
- logger.error("Error decoding heartbeat data. Data: %s", data.toString());
- return [status, null];
- }
-}
-
-function statusMessage(data) {
- if (!data || Object.keys(data.heartbeatList) === 0) {
- return "unknown";
- }
-
- let result = "good";
- let hasUp = false;
- Object.values(data.heartbeatList).forEach((el) => {
- const index = el.length - 1;
- if (el[index].status === 1) {
- hasUp = true;
- } else {
- result = "warn";
- }
- });
-
- if (!hasUp) {
- result = "bad";
- }
- return result;
-}
-
-function uptime(data) {
- if (!data) {
- return 0;
- }
-
- const uptimeList = Object.values(data.uptimeList);
- const percent = uptimeList.reduce((a, b) => a + b, 0) / uptimeList.length || 0;
- return (percent * 100).toFixed(1);
-}
-
-export default async function uptimeKumaProxyHandler(req, res) {
- const { group, service } = req.query;
- const widget = await getServiceWidget(group, service);
- if (!widget) {
- logger.debug("Invalid or missing widget for service '%s' in group '%s'", service, group);
- return res.status(400).json({ error: "Invalid proxy service type" });
- }
-
- const [[statusCode, statusData], [heartbeatCode, heartbeatData]] = await Promise.all([
- getStatus(widget),
- getHeartbeat(widget),
- ]);
-
- if (statusCode !== 200) {
- logger.error("HTTP %d getting status data error. Data: %s", statusCode, statusData);
- return res.status(statusCode).send(statusData);
- }
-
- if (heartbeatCode !== 200) {
- logger.error("HTTP %d getting heartbeat data error. Data: %s", heartbeatCode, heartbeatData);
- return res.status(heartbeatCode).send(heartbeatData);
- }
-
- const icon = statusData?.config ? statusData.config.icon : null;
- return res.status(200).send({
- uptime: uptime(heartbeatData),
- message: statusMessage(heartbeatData),
- incident: statusData?.incident ? statusData.incident.title : "",
- icon: `${widget.url}${icon}`,
- });
-}
diff --git a/src/widgets/uptimekuma/widget.js b/src/widgets/uptimekuma/widget.js
index 9687e1a4..928534b3 100644
--- a/src/widgets/uptimekuma/widget.js
+++ b/src/widgets/uptimekuma/widget.js
@@ -1,8 +1,18 @@
// import credentialedProxyHandler from "utils/proxy/handlers/credentialed";
-import uptimeKumaProxyHandler from "./proxy";
+import genericProxyHandler from "utils/proxy/handlers/generic";
const widget = {
- proxyHandler: uptimeKumaProxyHandler,
+ api: "{url}/api/{endpoint}/{slug}",
+ proxyHandler: genericProxyHandler,
+
+ mappings: {
+ status_page: {
+ endpoint: "status-page",
+ },
+ heartbeat: {
+ endpoint: "status-page/heartbeat",
+ },
+ }
};
export default widget;