Add 'zabbix trigger' monitor

db/knex_init_db.js

@@ -124,6 +124,9 @@ async function createTables() {
         table.integer("resend_interval").notNullable().defaultTo(0);
         table.integer("packet_size").notNullable().defaultTo(56);
         table.string("game", 255);
+        table.text("zabbix_instance_url");
+        table.text("zabbix_auth_token");
+        table.integer("zabbix_trigger_id");
     });
 
     // heartbeat

db/knex_migrations/2023-11-01-2149-patch-add-zabbix.js

@@ -0,0 +1,19 @@
+exports.up = function (knex) {
+    // Create Zabbix Columns
+    return knex.schema
+        .alterTable("monitor", function (table) {
+            table.text("zabbix_instance_url");
+            table.text("zabbix_auth_token");
+            table.integer("zabbix_trigger_id");
+        });
+
+};
+
+exports.down = function (knex) {
+    return knex.schema
+        .alterTable("monitor", function (table) {
+            table.dropColumn("zabbix_instance_url");
+            table.dropColumn("zabbix_auth_token");
+            table.dropColumn("zabbix_trigger_id");
+        });
+};

server/model/monitor.js

@@ -154,6 +154,8 @@ class Monitor extends BeanModel {
             kafkaProducerAllowAutoTopicCreation: this.getKafkaProducerAllowAutoTopicCreation(),
             kafkaProducerMessage: this.kafkaProducerMessage,
             screenshot,
+            zabbixInstanceUrl: this.zabbixInstanceUrl,
+            zabbixTriggerId: this.zabbixTriggerId,
             remote_browser: this.remote_browser,
         };
 
@@ -184,6 +186,7 @@ class Monitor extends BeanModel {
                 tlsCert: this.tlsCert,
                 tlsKey: this.tlsKey,
                 kafkaProducerSaslOptions: JSON.parse(this.kafkaProducerSaslOptions),
+                zabbixAuthToken: this.zabbixAuthToken,
             };
         }
 

server/monitor-types/zabbix-trigger.js

@@ -0,0 +1,64 @@
+const { MonitorType } = require("./monitor-type");
+const { UP, DOWN } = require("../../src/util");
+const axios = require("axios");
+
+class ZabbixTriggerMonitorType extends MonitorType {
+
+    name = "zabbix-trigger";
+
+    /**
+     * @inheritdoc
+     */
+    async check(monitor, heartbeat, _server) {
+
+        // Make Request
+        const options = {
+            method: "post",
+            url: monitor.zabbixInstanceUrl,
+            data: {
+                "jsonrpc": "2.0",
+                "method": "trigger.get",
+                "params": {
+                    "triggerids": monitor.zabbixTriggerId,
+                    "output": "extend",
+                    "selectFunctions": "extend",
+                },
+                // Will be deprecated, but Bearer Auth is currently not working
+                "auth": monitor.zabbixAuthToken,
+                "id": 1
+            },
+            headers: {
+                "Content-Type": "application/json-rpc",
+                // In the future Authentication will use Bearer Token
+                "Authorization": `Bearer ${monitor.zabbixAuthToken}`,
+            }
+        };
+
+        // Send Request & Convert Data
+        let res = await axios(options);
+        let data = res.data;
+
+        // convert data to object
+        if (typeof data === "string") {
+            data = JSON.parse(data);
+        }
+        let trigger = data.result[0];
+
+        /*
+            Zabbix Trigger Value Mapping
+            Value 0 - ok
+            value 1 - Firing
+        */
+        if ( trigger.value === "0" ) {
+            heartbeat.status = UP;
+            heartbeat.msg = `OK - ${ trigger.description }`;
+        } else {
+            heartbeat.status = DOWN;
+            heartbeat.msg = trigger.comments;
+        }
+    }
+}
+
+module.exports = {
+    ZabbixTriggerMonitorType,
+};

server/server.js

@@ -828,6 +828,9 @@ let needSetup = false;
                 bean.kafkaProducerAllowAutoTopicCreation =
                     monitor.kafkaProducerAllowAutoTopicCreation;
                 bean.gamedigGivenPortOnly = monitor.gamedigGivenPortOnly;
+                bean.zabbixInstanceUrl = monitor.zabbixInstanceUrl;
+                bean.zabbixAuthToken = monitor.zabbixAuthToken;
+                bean.zabbixTriggerId = monitor.zabbixTriggerId;
                 bean.remote_browser = monitor.remote_browser;
 
                 bean.validate();

server/uptime-kuma-server.js

@@ -118,6 +118,7 @@ class UptimeKumaServer {
         UptimeKumaServer.monitorTypeList["real-browser"] = new RealBrowserMonitorType();
         UptimeKumaServer.monitorTypeList["tailscale-ping"] = new TailscalePing();
         UptimeKumaServer.monitorTypeList["dns"] = new DnsMonitorType();
+        UptimeKumaServer.monitorTypeList["zabbix-trigger"] = new ZabbixTriggerMonitorType();
 
         this.io = new Server(this.httpServer);
     }
@@ -436,3 +437,4 @@ module.exports = {
 const { RealBrowserMonitorType } = require("./monitor-types/real-browser-monitor-type");
 const { TailscalePing } = require("./monitor-types/tailscale-ping");
 const { DnsMonitorType } = require("./monitor-types/dns");
+const { ZabbixTriggerMonitorType } = require("./monitor-types/zabbix-trigger");

src/lang/en.json

@@ -869,5 +869,9 @@
     "useRemoteBrowser": "Use a Remote Browser",
     "deleteRemoteBrowserMessage": "Are you sure want to delete this Remote Browser for all monitors?",
     "GrafanaOncallUrl": "Grafana Oncall URL",
-    "Browser Screenshot": "Browser Screenshot"
+    "Browser Screenshot": "Browser Screenshot",
+    "GrafanaOncallUrl": "Grafana Oncall URL",
+    "zabbixInstanceUrl": "Zabbix Instance URL",
+    "zabbixAuthToken": "Zabbix Authentication Token",
+    "zabbixTriggerId": "Zabbix Trigger ID"
 }

src/pages/EditMonitor.vue

@@ -82,6 +82,9 @@
                                         <option value="redis">
                                             Redis
                                         </option>
+                                        <option value="zabbix-trigger">
+                                            Zabbix Trigger
+                                        </option>
                                         <option v-if="!$root.info.isContainer" value="tailscale-ping">
                                             Tailscale Ping
                                         </option>
@@ -385,6 +388,23 @@
                                 </div>
                             </template>
 
+                            <template v-if="monitor.type === 'zabbix-trigger'">
+                                <div class="my-3">
+                                    <label for="zabbix_instance_url" class="form-label">{{ $t("zabbixInstanceUrl") }}</label>
+                                    <input id="zabbix_instance_url" v-model="monitor.zabbixInstanceUrl" type="text" class="form-control" required />
+                                </div>
+
+                                <div class="my-3">
+                                    <label for="zabbix_trigger_id" class="form-label">{{ $t("zabbixTriggerId") }}</label>
+                                    <input id="zabbix_trigger_id" v-model="monitor.zabbixTriggerId" type="text" class="form-control" required />
+                                </div>
+
+                                <div class="my-3">
+                                    <label for="zabbix_auth_token" class="form-label">{{ $t("zabbixAuthToken") }}</label>
+                                    <input id="zabbix_auth_token" v-model="monitor.zabbixAuthToken" type="password" class="form-control" required />
+                                </div>
+                            </template>
+
                             <!-- SQL Server / PostgreSQL / MySQL / Redis / MongoDB -->
                             <template v-if="monitor.type === 'sqlserver' || monitor.type === 'postgres' || monitor.type === 'mysql' || monitor.type === 'redis' || monitor.type === 'mongodb'">
                                 <div class="my-3">