[status page] implement rest api for heartbeat

server/model/group.js

@@ -4,17 +4,7 @@ const { R } = require("redbean-node");
 class Group extends BeanModel {
 
     async toPublicJSON() {
-
-        let monitorBeanList = R.convertToBeans("monitor", await R.getAll(`
-            SELECT * FROM monitor, monitor_group
-            WHERE monitor.id = monitor_group.monitor_id
-            AND group_id = ?
-        `, [
-            this.id,
-        ]));
-
-        console.log(monitorBeanList);
-
+        let monitorBeanList = await this.getMonitorList();
         let monitorList = [];
 
         for (let bean of monitorBeanList) {
@@ -28,6 +18,16 @@ class Group extends BeanModel {
             monitorList,
         };
     }
+
+    async getMonitorList() {
+        return R.convertToBeans("monitor", await R.getAll(`
+            SELECT monitor.* FROM monitor, monitor_group
+            WHERE monitor.id = monitor_group.monitor_id
+            AND group_id = ?
+        `, [
+            this.id,
+        ]));
+    }
 }
 
 module.exports = Group;

server/model/heartbeat.js

@@ -1,8 +1,8 @@
 const dayjs = require("dayjs");
-const utc = require("dayjs/plugin/utc")
-let timezone = require("dayjs/plugin/timezone")
-dayjs.extend(utc)
-dayjs.extend(timezone)
+const utc = require("dayjs/plugin/utc");
+let timezone = require("dayjs/plugin/timezone");
+dayjs.extend(utc);
+dayjs.extend(timezone);
 const { BeanModel } = require("redbean-node/dist/bean-model");
 
 /**
@@ -13,6 +13,15 @@ const { BeanModel } = require("redbean-node/dist/bean-model");
  */
 class Heartbeat extends BeanModel {
 
+    toPublicJSON() {
+        return {
+            status: this.status,
+            time: this.time,
+            msg: "",        // Hide for public
+            ping: this.ping,
+        };
+    }
+
     toJSON() {
         return {
             monitorID: this.monitor_id,

server/routers/api-router.js

@@ -38,9 +38,15 @@ router.get("/api/status-page/incident", async (_, response) => {
     try {
         await checkPublished();
 
+        let incident = await R.findOne("incident", " pin = 1 AND active = 1");
+
+        if (incident) {
+            incident = incident.toPublicJSON();
+        }
+
         response.json({
             ok: true,
-            incident: (await R.findOne("incident", " pin = 1 AND active = 1")).toPublicJSON(),
+            incident,
         });
 
     } catch (error) {
@@ -56,7 +62,7 @@ router.get("/api/status-page/monitor-list", async (_request, response) => {
     try {
         await checkPublished();
         const publicGroupList = [];
-        let list = await R.find("group", " public = 1 ORDER BY weight, name ");
+        let list = await R.find("group", " public = 1 ORDER BY weight ");
 
         for (let groupBean of list) {
             publicGroupList.push(await groupBean.toPublicJSON());
@@ -76,16 +82,30 @@ router.get("/api/status-page/heartbeat", async (_request, response) => {
     try {
         await checkPublished();
 
-        const monitorList = {};
-        let list = await R.find("", "  ", [
-        ]);
+        let heartbeatList = {};
 
-        for (let monitor of list) {
-            monitorList[monitor.id] = await monitor.toJSON();
+        let monitorIDList = await R.getCol(`
+            SELECT monitor_group.monitor_id FROM monitor_group, \`group\`
+            WHERE monitor_group.group_id = \`group\`.id
+            AND public = 1
+        `);
+
+        for (let monitorID of monitorIDList) {
+            let list = await R.getAll(`
+                    SELECT * FROM heartbeat
+                    WHERE monitor_id = ?
+                    ORDER BY time DESC
+                    LIMIT 100
+            `, [
+                monitorID,
+            ]);
+
+            list = R.convertToBeans("heartbeat", list);
+            heartbeatList[monitorID] = list.reverse().map(row => row.toPublicJSON());
         }
 
         response.json({
-            monitorList: monitorList,
+            heartbeatList,
         });
 
     } catch (error) {