Merge c4759948ec into dbbc79a05a
Matt Visnovsky
2 weeks ago
committed by
GitHub
commit
806a98be71
@ -0,0 +1,20 @@
|
||||
exports.up = function (knex) {
|
||||
return knex.schema
|
||||
.alterTable("monitor", function (table) {
|
||||
table.string("snmp_community_string", 255).defaultTo("public");
|
||||
table.string("snmp_oid").defaultTo(null);
|
||||
table.enum("snmp_version", [ "1", "2c", "3" ]).defaultTo("2c");
|
||||
table.float("snmp_control_value").defaultTo(null);
|
||||
table.string("snmp_condition").defaultTo(null);
|
||||
});
|
||||
};
|
||||
|
||||
exports.down = function (knex) {
|
||||
return knex.schema.alterTable("monitor", function (table) {
|
||||
table.dropColumn("snmp_community_string");
|
||||
table.dropColumn("snmp_oid");
|
||||
table.dropColumn("snmp_version");
|
||||
table.dropColumn("snmp_control_value");
|
||||
table.dropColumn("snmp_condition");
|
||||
});
|
||||
};
|
||||
@ -0,0 +1,93 @@
|
||||
const { MonitorType } = require("./monitor-type");
|
||||
const { UP, DOWN, log } = require("../../src/util");
|
||||
const snmp = require("net-snmp");
|
||||
|
||||
class SNMPMonitorType extends MonitorType {
|
||||
name = "snmp";
|
||||
|
||||
/**
|
||||
* @inheritdoc
|
||||
*/
|
||||
async check(monitor, heartbeat, _server) {
|
||||
|
||||
const options = {
|
||||
port: monitor.port || "161",
|
||||
retries: monitor.maxretries,
|
||||
timeout: monitor.timeout * 1000,
|
||||
version: snmp.Version[monitor.snmpVersion],
|
||||
};
|
||||
|
||||
let session;
|
||||
try {
|
||||
session = snmp.createSession(monitor.hostname, monitor.radiusPassword, options);
|
||||
|
||||
// Handle errors during session creation
|
||||
session.on("error", (error) => {
|
||||
throw new Error(`Error creating SNMP session: ${error.message}`);
|
||||
});
|
||||
|
||||
const varbinds = await new Promise((resolve, reject) => {
|
||||
session.get([ monitor.snmpOid ], (error, varbinds) => {
|
||||
if (error) {
|
||||
reject(error);
|
||||
} else {
|
||||
resolve(varbinds);
|
||||
}
|
||||
});
|
||||
});
|
||||
log.debug("monitor", `SNMP: Received varbinds (Type: ${snmp.ObjectType[varbinds[0].type]} Value: ${varbinds[0].value}`);
|
||||
|
||||
if (varbinds.length === 0) {
|
||||
throw new Error(`No varbinds returned from SNMP session (OID: ${monitor.snmpOid})`);
|
||||
}
|
||||
|
||||
if (varbinds[0].type === snmp.ObjectType.NoSuchInstance) {
|
||||
throw new Error(`The SNMP query returned that no instance exists for OID ${monitor.snmpOid}`);
|
||||
}
|
||||
|
||||
// We restrict querying to one OID per monitor, therefore `varbinds[0]` will always contain the value we're interested in.
|
||||
const value = varbinds[0].value;
|
||||
|
||||
// Check if inputs are numeric. If not, re-parse as strings. This ensures comparisons are handled correctly.
|
||||
let snmpValue = isNaN(value) ? value.toString() : parseFloat(value);
|
||||
let snmpControlValue = isNaN(monitor.snmpControlValue) ? monitor.snmpControlValue.toString() : parseFloat(monitor.snmpControlValue);
|
||||
|
||||
switch (monitor.snmpCondition) {
|
||||
case ">":
|
||||
heartbeat.status = snmpValue > snmpControlValue ? UP : DOWN;
|
||||
break;
|
||||
case ">=":
|
||||
heartbeat.status = snmpValue >= snmpControlValue ? UP : DOWN;
|
||||
break;
|
||||
case "<":
|
||||
heartbeat.status = snmpValue < snmpControlValue ? UP : DOWN;
|
||||
break;
|
||||
case "<=":
|
||||
heartbeat.status = snmpValue <= snmpControlValue ? UP : DOWN;
|
||||
break;
|
||||
case "==":
|
||||
heartbeat.status = snmpValue.toString() === snmpControlValue.toString() ? UP : DOWN;
|
||||
break;
|
||||
case "contains":
|
||||
heartbeat.status = snmpValue.toString().includes(snmpControlValue.toString()) ? UP : DOWN;
|
||||
break;
|
||||
default:
|
||||
throw new Error(`Invalid condition ${monitor.snmpCondition}`);
|
||||
}
|
||||
heartbeat.msg = "SNMP value " + (heartbeat.status ? "passes" : "does not pass") + ` comparison: ${value.toString()} ${monitor.snmpCondition} ${snmpControlValue}`;
|
||||
|
||||
} catch (err) {
|
||||
heartbeat.status = DOWN;
|
||||
heartbeat.msg = `SNMP Error: ${err.message}`;
|
||||
} finally {
|
||||
if (session) {
|
||||
session.close();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
module.exports = {
|
||||
SNMPMonitorType,
|
||||
};
|
||||
Loading…
Reference in new issue