feat: add Globalping support (#6163)

Co-authored-by: Frank Elsinga <frank@elsinga.de>
Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>

Author: 3 people

db/knex_migrations/2025-12-17-0000-add-globalping-monitor.js

@@ -0,0 +1,17 @@
+exports.up = function (knex) {
+    // Add new columns
+    return knex.schema.alterTable("monitor", function (table) {
+        table.string("subtype", 10).nullable();
+        table.string("location", 255).nullable();
+        table.string("protocol", 20).nullable();
+    });
+};
+
+exports.down = function (knex) {
+    // Drop columns
+    return knex.schema.alterTable("monitor", function (table) {
+        table.dropColumn("subtype");
+        table.dropColumn("location");
+        table.dropColumn("protocol");
+    });
+};

package-lock.json

@@ -96,6 +96,7 @@
         "express-static-gzip": "~2.1.7",
         "feed": "^4.2.2",
         "form-data": "~4.0.0",
+        "globalping": "^0.2.0",
         "gamedig": "^5.0.1",
         "html-escaper": "^3.0.3",
         "http-cookie-agent": "~5.0.4",

package.json

@@ -33,14 +33,15 @@ const {
     checkStatusCode,
     getTotalClientInRoom,
     setting,
-    setSetting,
     httpNtlm,
     radius,
     kafkaProducerAsync,
     getOidcTokenClientCredentials,
     rootCertificatesFingerprints,
     axiosAbortSignal,
     checkCertificateHostname,
+    encodeBase64,
+    checkCertExpiryNotifications,
 } = require("../util-server");
 const { R } = require("redbean-node");
 const { BeanModel } = require("redbean-node/dist/bean-model");
@@ -141,11 +142,14 @@ class Monitor extends BeanModel {
             method: this.method,
             hostname: this.hostname,
             port: this.port,
+            location: this.location,
+            protocol: this.protocol,
             maxretries: this.maxretries,
             weight: this.weight,
             active: preloadData.activeStatus.get(this.id),
             forceInactive: preloadData.forceInactive.get(this.id),
             type: this.type,
+            subtype: this.subtype,
             timeout: this.timeout,
             interval: this.interval,
             retryInterval: this.retryInterval,
@@ -289,17 +293,6 @@ class Monitor extends BeanModel {
         };
     }
 
-    /**
-     * Encode user and password to Base64 encoding
-     * for HTTP "basic" auth, as per RFC-7617
-     * @param {string|null} user - The username (nullable if not changed by a user)
-     * @param {string|null} pass - The password (nullable if not changed by a user)
-     * @returns {string} Encoded Base64 string
-     */
-    encodeBase64(user, pass) {
-        return Buffer.from(`${user || ""}:${pass || ""}`).toString("base64");
-    }
-
     /**
      * Is the TLS expiry notification enabled?
      * @returns {boolean} Enabled?
@@ -421,6 +414,8 @@ class Monitor extends BeanModel {
         let previousBeat = null;
         let retries = 0;
 
+        this.rootCertificates = rootCertificates;
+
         try {
             this.prometheus = new Prometheus(this, await this.getTags());
         } catch (e) {
@@ -482,7 +477,7 @@ class Monitor extends BeanModel {
                     let basicAuthHeader = {};
                     if (this.auth_method === "basic") {
                         basicAuthHeader = {
-                            Authorization: "Basic " + this.encodeBase64(this.basic_auth_user, this.basic_auth_pass),
+                            Authorization: "Basic " + encodeBase64(this.basic_auth_user, this.basic_auth_pass),
                         };
                     }
 
@@ -922,7 +917,7 @@ class Monitor extends BeanModel {
                         );
                     }
 
-                    if (!bean.ping) {
+                    if (bean.ping === undefined || bean.ping === null) {
                         bean.ping = dayjs().valueOf() - startTime;
                     }
                 } else if (this.type === "kafka-producer") {
@@ -1572,64 +1567,6 @@ class Monitor extends BeanModel {
         return notificationList;
     }
 
-    /**
-     * checks certificate chain for expiring certificates
-     * @param {object} tlsInfoObject Information about certificate
-     * @returns {Promise<void>}
-     */
-    async checkCertExpiryNotifications(tlsInfoObject) {
-        if (tlsInfoObject && tlsInfoObject.certInfo && tlsInfoObject.certInfo.daysRemaining) {
-            const notificationList = await Monitor.getNotificationList(this);
-
-            if (!notificationList.length > 0) {
-                // fail fast. If no notification is set, all the following checks can be skipped.
-                log.debug("monitor", "No notification, no need to send cert notification");
-                return;
-            }
-
-            let notifyDays = await setting("tlsExpiryNotifyDays");
-            if (notifyDays == null || !Array.isArray(notifyDays)) {
-                // Reset Default
-                await setSetting("tlsExpiryNotifyDays", [7, 14, 21], "general");
-                notifyDays = [7, 14, 21];
-            }
-
-            if (Array.isArray(notifyDays)) {
-                for (const targetDays of notifyDays) {
-                    let certInfo = tlsInfoObject.certInfo;
-                    while (certInfo) {
-                        let subjectCN = certInfo.subject["CN"];
-                        if (rootCertificates.has(certInfo.fingerprint256)) {
-                            log.debug(
-                                "monitor",
-                                `Known root cert: ${certInfo.certType} certificate "${subjectCN}" (${certInfo.daysRemaining} days valid) on ${targetDays} deadline.`
-                            );
-                            break;
-                        } else if (certInfo.daysRemaining > targetDays) {
-                            log.debug(
-                                "monitor",
-                                `No need to send cert notification for ${certInfo.certType} certificate "${subjectCN}" (${certInfo.daysRemaining} days valid) on ${targetDays} deadline.`
-                            );
-                        } else {
-                            log.debug(
-                                "monitor",
-                                `call sendCertNotificationByTargetDays for ${targetDays} deadline on certificate ${subjectCN}.`
-                            );
-                            await this.sendCertNotificationByTargetDays(
-                                subjectCN,
-                                certInfo.certType,
-                                certInfo.daysRemaining,
-                                targetDays,
-                                notificationList
-                            );
-                        }
-                        certInfo = certInfo.issuerCertificate;
-                    }
-                }
-            }
-        }
-    }
-
     /**
      * Send a certificate notification when certificate expires in less
      * than target days
@@ -2164,7 +2101,7 @@ class Monitor extends BeanModel {
 
         if (!this.getIgnoreTls() && this.isEnabledExpiryNotification()) {
             log.debug("monitor", `[${this.name}] call checkCertExpiryNotifications`);
-            await this.checkCertExpiryNotifications(tlsInfo);
+            await checkCertExpiryNotifications(this, tlsInfo);
         }
     }
 }