New Notification: Slow Response Time w/ Resend Interval

db/knex_migrations/2023-11-09-slow-response-notification.js

@@ -0,0 +1,33 @@
+exports.up = function (knex) {
+    // add various slow_response_notification parameters
+    return knex.schema
+        .alterTable("monitor", function (table) {
+            table.boolean("slow_response_notification").notNullable().defaultTo(false);
+            table.string("slow_response_notification_method").notNullable().defaultTo("average");
+            table.integer("slow_response_notification_range").notNullable().defaultTo(300);
+            table.string("slow_response_notification_threshold_method").notNullable().defaultTo("threshold-relative-24-hour");
+            table.integer("slow_response_notification_threshold").notNullable().defaultTo(2500);
+            table.float("slow_response_notification_threshold_multiplier").notNullable().defaultTo(5.0);
+            table.integer("slow_response_notification_resend_interval").notNullable().defaultTo(0);
+        })
+        .alterTable("heartbeat", function (table) {
+            table.integer("slow_response_count").notNullable().defaultTo(0);
+        });
+};
+
+exports.down = function (knex) {
+    // remove various slow_response_notification parameters
+    return knex.schema
+        .alterTable("monitor", function (table) {
+            table.dropColumn("slow_response_notification");
+            table.dropColumn("slow_response_notification_method");
+            table.dropColumn("slow_response_notification_range");
+            table.dropColumn("slow_response_notification_threshold_method");
+            table.dropColumn("slow_response_notification_threshold");
+            table.dropColumn("slow_response_notification_threshold_multiplier");
+            table.dropColumn("slow_response_notification_resend_interval");
+        })
+        .alterTable("heartbeat", function (table) {
+            table.dropColumn("slow_response_count");
+        });
+};

db/knex_migrations/2023-11-10-slow-response-visual-improvements.js

@@ -0,0 +1,21 @@
+exports.up = function (knex) {
+    // add various slow response parameters
+    return knex.schema
+        .alterTable("heartbeat", function (table) {
+            table.integer("ping_status").nullable().defaultTo(null);
+            table.integer("ping_threshold").nullable().defaultTo(null);
+            table.boolean("ping_important").notNullable().defaultTo(0);
+            table.string("ping_msg").nullable().defaultTo(null);
+        });
+};
+
+exports.down = function (knex) {
+    // remove various slow response parameters
+    return knex.schema
+        .alterTable("heartbeat", function (table) {
+            table.dropColumn("ping_status");
+            table.dropColumn("ping_threshold");
+            table.dropColumn("ping_important");
+            table.dropColumn("ping_msg");
+        });
+};

package.json

@@ -164,6 +164,7 @@
         "bootstrap": "5.1.3",
         "chart.js": "~4.2.1",
         "chartjs-adapter-dayjs-4": "~1.0.4",
+        "chartjs-plugin-annotation": "~3.0.1",
         "concurrently": "^7.1.0",
         "core-js": "~3.26.1",
         "cronstrue": "~2.24.0",

server/client.js

@@ -54,7 +54,7 @@ async function sendHeartbeatList(socket, monitorID, toUser = false, overwrite =
         monitorID,
     ]);
 
-    let result = list.reverse();
+    let result = R.convertToBeans("heartbeat", list.reverse());
 
     if (toUser) {
         io.to(socket.userID).emit("heartbeatList", monitorID, result, overwrite);

server/model/heartbeat.js

@@ -6,6 +6,9 @@ const { BeanModel } = require("redbean-node/dist/bean-model");
  *      1 = UP
  *      2 = PENDING
  *      3 = MAINTENANCE
+ * pingStatus:
+ *      4 = SLOW
+ *      5 = NOMINAL
  */
 class Heartbeat extends BeanModel {
 
@@ -37,6 +40,10 @@ class Heartbeat extends BeanModel {
             important: this._important,
             duration: this._duration,
             retries: this._retries,
+            pingThreshold: this._pingThreshold,
+            pingStatus: this._pingStatus,
+            pingImportant: this._pingImportant,
+            pingMsg: this._pingMsg,
         };
     }