";
+}
+
+/**
+ * Render wrapper header for names view table.
+ *
+ * @return string
+ */
+function renderHeaderNames(): string {
+ return "
";
+}
+
+/**
+ * Render wrapper header for icon tile view.
+ *
+ * @return string
+ */
+function renderHeaderTiles(): string {
+ return renderHeaderDefault();
+}
+
+/**
+ * Render wrapper header for advanced tile view.
+ *
+ * @return string
+ */
+function renderHeaderTilesadt(): string {
+ return renderHeaderDefault();
+}
+
+/**
+ * Render header and sortable column bar for list view.
+ *
+ * @param int $total_rows Total rows matching active filters.
+ * @param int $rows Page row limit.
+ *
+ * @return string
+ */
+function renderHeaderList(int $total_rows = 0, int $rows = 0): string {
+ $display_text = [
+ 'hostname' => [
+ 'display' => __('Hostname', 'monitor'),
+ 'sort' => 'ASC',
+ 'align' => 'left', 'tip' => __('Hostname of device', 'monitor')
+ ],
+ 'id' => [
+ 'display' => __('ID', 'monitor'),
+ 'sort' => 'ASC',
+ 'align' => 'left'
+ ],
+ 'description' => [
+ 'display' => __('Description', 'monitor'),
+ 'sort' => 'ASC',
+ 'align' => 'left'
+ ],
+ 'site_name' => [
+ 'display' => __('Site', 'monitor'),
+ 'sort' => 'ASC',
+ 'align' => 'left'
+ ],
+ 'monitor_criticality' => [
+ 'display' => __('Criticality', 'monitor'),
+ 'sort' => 'ASC',
+ 'align' => 'left'
+ ],
+ 'status' => [
+ 'display' => __('Status', 'monitor'),
+ 'sort' => 'DESC',
+ 'align' => 'center'
+ ],
+ 'instate' => [
+ 'display' => __('Length in Status', 'monitor'),
+ 'sort' => 'ASC',
+ 'align' => 'center'
+ ],
+ 'avg_time' => [
+ 'display' => __('Averages', 'monitor'),
+ 'sort' => 'DESC',
+ 'align' => 'left'
+ ],
+ 'monitor_warn' => [
+ 'display' => __('Warning', 'monitor'),
+ 'sort' => 'DESC',
+ 'align' => 'left'
+ ],
+ 'monitor_text' => [
+ 'display' => __('Admin', 'monitor'),
+ 'sort' => 'ASC',
+ 'tip' => __('Monitor Text Column represents \'Admin\'', 'monitor'),
+ 'align' => 'left'
+ ],
+ 'notes' => [
+ 'display' => __('Notes', 'monitor'),
+ 'sort' => 'ASC',
+ 'align' => 'left'
+ ],
+ 'availability' => [
+ 'display' => __('Availability', 'monitor'),
+ 'sort' => 'DESC',
+ 'align' => 'right'
+ ],
+ 'status_fail_date' => [
+ 'display' => __('Last Fail', 'monitor'),
+ 'sort' => 'DESC',
+ 'align' => 'right'
+ ],
+ ];
+
+ ob_start();
+
+ $nav = html_nav_bar('monitor.php?rfilter=' . get_request_var('rfilter'), MAX_DISPLAY_PAGES, get_request_var('page'), $rows, $total_rows, 12, __('Devices'), 'page', 'main');
+
+ html_start_box(__('Monitored Devices', 'monitor'), '100%', false, '3', 'center', '');
+
+ print $nav;
+
+ html_header_sort($display_text, get_request_var('sort_column'), get_request_var('sort_direction'), false);
+
+ $output = ob_get_contents();
+
+ ob_end_clean();
+
+ return $output;
+}
+
+/**
+ * Indicate whether grouped section headers are suppressed for list view.
+ *
+ * @return bool
+ */
+function renderSuppressgroupsList(): bool {
+ return true;
+}
+
+/**
+ * Render wrapper footer for default/tile monitor views.
+ *
+ * @return string
+ */
+function renderFooterDefault(): string {
+ return '';
+}
+
+/**
+ * Render footer row for names view including trailing empty cells.
+ *
+ * @return string
+ */
+function renderFooterNames(): string {
+ $col = 7 - $_SESSION['names'];
+
+ if ($col == 0) {
+ return '
';
+ } else {
+ return '
| ';
+ }
+}
+
+/**
+ * Render wrapper footer for icon tile view.
+ *
+ * @return string
+ */
+function renderFooterTiles(): string {
+ return renderFooterDefault();
+}
+
+/**
+ * Render wrapper footer for advanced tile view.
+ *
+ * @return string
+ */
+function renderFooterTilesadt(): string {
+ return renderFooterDefault();
+}
+
+/**
+ * Render list view footer and bottom pager.
+ *
+ * @param int $total_rows Total rows matching active filters.
+ * @param int $rows Page row limit.
+ *
+ * @return string
+ */
+function renderFooterList(int $total_rows, int $rows): string {
+ ob_start();
+
+ html_end_box(false);
+
+ if ($total_rows > 0) {
+ $nav = html_nav_bar('monitor.php?rfilter=' . get_request_var('rfilter'), MAX_DISPLAY_PAGES, get_request_var('page'), $rows, $total_rows, 12, __('Devices'), 'page', 'main');
+
+ print $nav;
+ }
+
+ $output = ob_get_contents();
+
+ ob_end_clean();
+
+ return $output;
+}
+
+/**
+ * Render one host row in list view.
+ *
+ * @param array $host Host row data.
+ *
+ * @return string
+ */
+function renderHostList(array $host): string {
+ global $criticalities, $iclasses;
+
+ if ($host['status'] < 2 || $host['status'] == 5) {
+ $dt = get_timeinstate($host);
+ } elseif (strtotime($host['status_rec_date']) > 192800) {
+ $dt = get_timeinstate($host);
+ } else {
+ $dt = __('Never', 'monitor');
+ }
+
+ if ($host['status'] < 3 || $host['status'] == 5) {
+ $host_admin = $host['monitor_text'];
+ } else {
+ $host_admin = '';
+ }
+
+ if (isset($host['monitor_criticality']) && $host['monitor_criticality'] > 0) {
+ $host_crit = $criticalities[$host['monitor_criticality']];
+ } else {
+ $host_crit = '';
+ }
+
+ if ($host['availability_method'] > 0) {
+ $host_avg = __('%d ms', $host['cur_time'], 'monitor') . ' / ' . __('%d ms', $host['avg_time'], 'monitor');
+ } else {
+ $host_avg = __('N/A', 'monitor');
+ }
+
+ if (isset($host['monitor_warn']) && ($host['monitor_warn'] > 0 || $host['monitor_alert'] > 0)) {
+ $host_warn = __('%0.2d ms', $host['monitor_warn'], 'monitor') . ' / ' . __('%0.2d ms', $host['monitor_alert'], 'monitor');
+ } else {
+ $host_warn = '';
+ }
+
+ if (strtotime($host['status_fail_date']) < 86400) {
+ $host['status_fail_date'] = __('Never', 'monitor');
+ }
+
+ $host_datefail = $host['status_fail_date'];
+
+ $iclass = $iclasses[$host['status']];
+ $sdisplay = getHostStatusDescription($host['real_status']);
+
+ $row_class = "{$iclass}Full";
+
+ ob_start();
+
+ print "
";
+
+ $url = $host['anchor'];
+
+ form_selectable_cell(filter_value($host['hostname'], '', $url), $host['id'], '', 'left');
+ form_selectable_cell($host['id'], $host['id'], '', 'left');
+ form_selectable_cell($host['description'], $host['id'], '', 'left');
+ form_selectable_cell($host['site_name'], $host['id'], '', 'left');
+ form_selectable_cell($host_crit, $host['id'], '', 'left');
+ form_selectable_cell($sdisplay, $host['id'], '', 'center');
+ form_selectable_cell($dt, $host['id'], '', 'center');
+ form_selectable_cell($host_avg, $host['id'], '', 'left');
+ form_selectable_cell($host_warn, $host['id'], '', 'left');
+ form_selectable_cell($host_admin, $host['id'], '', 'white-space:pre-wrap;text-align:left');
+ form_selectable_cell(str_replace(["\n", "\r"], [' ', ''], $host['notes']), $host['id'], '', 'white-space:pre-wrap;text-align:left');
+ form_selectable_cell(round($host['availability'], 2) . ' %', $host['id'], '', 'right');
+ form_selectable_cell($host_datefail, $host['id'], '', 'right');
+
+ form_end_row();
+
+ $result = ob_get_contents();
+
+ ob_end_clean();
+
+ return $result;
+}
+
+/**
+ * Render one host cell in names view grid.
+ *
+ * @param array $host Host row data.
+ *
+ * @return string
+ */
+function renderHostNames(array $host): string {
+ $fclass = get_request_var('size');
+
+ $result = '';
+
+ $maxlen = getMonitorTrimLength(100);
+
+ if ($_SESSION['names'] == 0) {
+ $result .= '
';
+ }
+
+ if ($host['status'] <= 2 || $host['status'] == 5) {
+ $result .= "| " . title_trim(html_escape($host['description']), $maxlen) . ' | ';
+ } else {
+ $result .= "" . title_trim(html_escape($host['description']), $maxlen) . ' | ';
+ }
+
+ $_SESSION['names']++;
+
+ if ($_SESSION['names'] > 7) {
+ $result .= '
';
+ $_SESSION['names'] = 0;
+ }
+
+ return $result;
+}
+
+/**
+ * Render one host icon tile.
+ *
+ * @param array $host Host row data.
+ *
+ * @return string
+ */
+function renderHostTiles(array $host): string {
+ $class = getStatusIcon($host['status'], $host['monitor_icon']);
+ $fclass = get_request_var('size');
+
+ return "
";
+}
+
+/**
+ * Render one advanced host tile including time-in-state/uptime text.
+ *
+ * @param array $host Host row data.
+ *
+ * @return string
+ */
+function renderHostTilesadt(array $host): string {
+ $tis = '';
+
+ $class = getStatusIcon($host['status'], $host['monitor_icon']);
+ $fclass = get_request_var('size');
+
+ if ($host['status'] < 2 || $host['status'] == 5) {
+ $tis = get_timeinstate($host);
+
+ return "
";
+ } else {
+ $tis = get_uptime($host);
+
+ return "
";
+ }
+}
+
+/**
+ * Apply monitor trim setting to a computed source field length.
+ *
+ * @param int $fieldlen Initial field length.
+ *
+ * @return int
+ */
+function getMonitorTrimLength(int $fieldlen): int {
+ global $maxchars;
+
+ if (get_request_var('view') == 'default' || get_request_var('view') == 'names') {
+ $maxlen = $maxchars;
+
+ if (get_request_var('trim') < 0) {
+ $maxlen = 4000;
+ } elseif (get_request_var('trim') > 0) {
+ $maxlen = get_request_var('trim');
+ }
+
+ if ($fieldlen > $maxlen) {
+ $fieldlen = $maxlen;
+ }
+ }
+
+ return $fieldlen;
+}
diff --git a/poller_functions.php b/poller_functions.php
new file mode 100644
index 0000000..ddb8568
--- /dev/null
+++ b/poller_functions.php
@@ -0,0 +1,1078 @@
+ 0 && isset($notification_lists[$notify_list])) {
+ $emails = explode(',', $notification_lists[$notify_list]);
+ monitorAddEmails($reboot_emails, $emails, $host_id);
+ }
+}
+
+/**
+ * Fetch the configured global alert email list.
+ *
+ * @return array
+ */
+function getAlertEmails(): array {
+ $alert_email = read_config_option('alert_email');
+
+ return ($alert_email != '') ? explode(',', $alert_email) : [];
+}
+
+/**
+ * Delete monitor table rows that reference missing hosts.
+ *
+ * @param string $table_name Monitor table to purge.
+ *
+ * @return void
+ */
+function purgeOrphanMonitorRows(string $table_name): void {
+ $removed_hosts = db_fetch_assoc("SELECT mu.host_id
+ FROM $table_name AS mu
+ LEFT JOIN host AS h
+ ON h.id = mu.host_id
+ WHERE h.id IS NULL");
+
+ if (cacti_sizeof($removed_hosts)) {
+ db_execute("DELETE mu
+ FROM $table_name AS mu
+ LEFT JOIN host AS h
+ ON h.id = mu.host_id
+ WHERE h.id IS NULL");
+ }
+}
+
+/**
+ * Get monitored hosts whose uptime indicates a reboot.
+ *
+ * @return array
+ */
+function getRebootedHosts(): array {
+ return db_fetch_assoc('SELECT h.id, h.description,
+ h.hostname, h.snmp_sysUpTimeInstance, mu.uptime
+ FROM host AS h
+ LEFT JOIN plugin_monitor_uptime AS mu
+ ON h.id = mu.host_id
+ WHERE h.snmp_version > 0
+ AND status IN (2,3)
+ AND h.deleted = ""
+ AND h.monitor = "on"
+ AND (mu.uptime IS NULL OR mu.uptime > h.snmp_sysUpTimeInstance)
+ AND h.snmp_sysUpTimeInstance > 0');
+}
+
+/**
+ * Fetch notification lists and map id to email string.
+ *
+ * @return array
+ */
+function getNotificationListsMap(): array {
+ return array_rekey(
+ db_fetch_assoc('SELECT id, emails
+ FROM plugin_notification_lists
+ ORDER BY id'),
+ 'id',
+ 'emails'
+ );
+}
+
+/**
+ * Add reboot recipients based on host threshold notification settings.
+ *
+ * @param array $reboot_emails Recipient map keyed by email, then host id.
+ * @param int $host_id Host id being processed.
+ * @param array $alert_emails Global alert email list.
+ * @param array $notification_lists Map of notification list id to emails.
+ *
+ * @return void
+ */
+function addTholdRebootRecipients(array &$reboot_emails, int|string $host_id, array $alert_emails, array $notification_lists): void {
+ $notify = db_fetch_row_prepared(
+ 'SELECT thold_send_email, thold_host_email
+ FROM host
+ WHERE id = ?',
+ [$host_id]
+ );
+
+ if (!cacti_sizeof($notify)) {
+ return;
+ }
+
+ switch ($notify['thold_send_email']) {
+ case '1':
+ monitorAddEmails($reboot_emails, $alert_emails, $host_id);
+
+ break;
+ case '2':
+ monitorAddNotificationList($reboot_emails, $notify['thold_host_email'], $host_id, $notification_lists);
+
+ break;
+ case '3':
+ monitorAddEmails($reboot_emails, $alert_emails, $host_id);
+ monitorAddNotificationList($reboot_emails, $notify['thold_host_email'], $host_id, $notification_lists);
+
+ break;
+ default:
+ break;
+ }
+}
+
+/**
+ * Build reboot recipient map and persist reboot history rows.
+ *
+ * @param array $rebooted_hosts Rebooted host rows.
+ * @param array $alert_emails Global alert email list.
+ *
+ * @return array
+ */
+function buildRebootEmailMap(array $rebooted_hosts, array $alert_emails): array {
+ $reboot_emails = [];
+ $notification_lists = getNotificationListsMap();
+ $monitor_list = read_config_option('monitor_list');
+ $monitor_thold = read_config_option('monitor_reboot_thold');
+
+ foreach ($rebooted_hosts as $host) {
+ db_execute_prepared(
+ 'INSERT INTO plugin_monitor_reboot_history
+ (host_id, reboot_time)
+ VALUES (?, ?)',
+ [$host['id'], date(MONITOR_DATE_TIME_FORMAT, time() - intval($host['snmp_sysUpTimeInstance']))]
+ );
+
+ monitorAddNotificationList($reboot_emails, $monitor_list, $host['id'], $notification_lists);
+
+ if ($monitor_thold == 'on') {
+ addTholdRebootRecipients($reboot_emails, $host['id'], $alert_emails, $notification_lists);
+ }
+ }
+
+ return $reboot_emails;
+}
+
+/**
+ * Dispatch reboot notifications per-recipient or as a single batched email.
+ *
+ * @param array $reboot_emails Recipient map keyed by email, then host id.
+ *
+ * @return void
+ */
+function sendRebootNotifications(array $reboot_emails): void {
+ $monitor_send_one_email = read_config_option('monitor_send_one_email');
+
+ if (!cacti_sizeof($reboot_emails)) {
+ return;
+ }
+
+ $all_hosts = [];
+ $to_email = '';
+
+ foreach ($reboot_emails as $email => $hosts) {
+ if ($email == '') {
+ monitorDebug('Unable to process reboot notification due to empty Email address.');
+
+ continue;
+ }
+
+ $to_email .= ($to_email != '' ? ',' : '') . $email;
+ $all_hosts = array_unique(array_merge($all_hosts, array_values($hosts)));
+
+ if ($monitor_send_one_email !== 'on') {
+ monitorDebug('Processing the Email address: ' . $email);
+ processRebootEmail($email, $hosts);
+ }
+ }
+
+ if ($monitor_send_one_email == 'on' && $to_email !== '') {
+ monitorDebug('Processing the Email address: ' . $to_email);
+ processRebootEmail($to_email, $all_hosts);
+ }
+}
+
+/**
+ * Process reboot detection, uptime refresh, and down-event history logging.
+ *
+ * @return array{int, int} Reboot count and recent down count.
+ */
+function monitorUptimeChecker(): array {
+ monitorDebug('Checking for Uptime of Devices');
+
+ $alert_emails = getAlertEmails();
+
+ purgeOrphanMonitorRows('plugin_monitor_uptime');
+ purgeOrphanMonitorRows('plugin_monitor_reboot_history');
+
+ $rebooted_hosts = getRebootedHosts();
+
+ if (cacti_sizeof($rebooted_hosts)) {
+ $reboot_emails = buildRebootEmailMap($rebooted_hosts, $alert_emails);
+ sendRebootNotifications($reboot_emails);
+ }
+
+ // Freshen the uptimes
+ db_execute('REPLACE INTO plugin_monitor_uptime
+ (host_id, uptime)
+ SELECT id, snmp_sysUpTimeInstance
+ FROM host
+ WHERE snmp_version > 0
+ AND status IN(2,3)
+ AND deleted = ""
+ AND monitor = "on"
+ AND snmp_sysUpTimeInstance > 0');
+
+ // Log Recently Down
+ db_execute('INSERT IGNORE INTO plugin_monitor_notify_history
+ (host_id, notify_type, notification_time, notes)
+ SELECT h.id, "3" AS notify_type, status_fail_date AS notification_time, status_last_error AS notes
+ FROM host AS h
+ WHERE status = 1
+ AND deleted = ""
+ AND monitor = "on"
+ AND status_event_count = 1');
+
+ $recent = db_affected_rows();
+
+ return [cacti_sizeof($rebooted_hosts), $recent];
+}
+
+/**
+ * Build reboot details table/text and capture the last resolved host row.
+ *
+ * @param array $hosts Host ids to include.
+ *
+ * @return array{string, string, array}
+ */
+function buildRebootDetails(array $hosts): array {
+ $body_txt = '';
+ $last_host = [];
+
+ $body = '
' . PHP_EOL;
+ $body .= '' . PHP_EOL;
+
+ foreach ($hosts as $host_id) {
+ $host = db_fetch_row_prepared(
+ 'SELECT description, hostname
+ FROM host
+ WHERE id = ?',
+ [$host_id]
+ );
+
+ if (!cacti_sizeof($host)) {
+ continue;
+ }
+
+ $last_host = $host;
+ $body .= '' .
+ '| ' . $host['description'] . ' | ' .
+ '' . $host['hostname'] . ' | ' .
+ '
' . PHP_EOL;
+
+ $body_txt .=
+ __('Description: ', 'monitor') . $host['description'] . PHP_EOL .
+ __('Hostname: ', 'monitor') . $host['hostname'] . PHP_EOL . PHP_EOL;
+ }
+
+ $body .= '
' . PHP_EOL;
+
+ return [$body, $body_txt, $last_host];
+}
+
+/**
+ * Build reboot notification subject from host count and delivery mode.
+ *
+ * @param array $hosts Host id list.
+ * @param array $last_host Last host row seen while building details.
+ *
+ * @return string
+ */
+function buildRebootSubject(array $hosts, array $last_host): string {
+ $subject = read_config_option('monitor_subject');
+ $monitor_send_one_email = read_config_option('monitor_send_one_email');
+
+ if ($monitor_send_one_email == 'on' && cacti_sizeof($last_host)) {
+ return $subject . ' ' . $last_host['description'] . ' (' . $last_host['hostname'] . ')';
+ }
+
+ if (cacti_sizeof($hosts) == 1 && cacti_sizeof($last_host)) {
+ return $subject . ' 1 device - ' . $last_host['description'] . ' (' . $last_host['hostname'] . ')';
+ }
+
+ return $subject . ' ' . cacti_sizeof($hosts) . ' devices';
+}
+
+/**
+ * Wrap body output with report format template and build mail headers.
+ *
+ * @param string $body HTML body content.
+ * @param string $body_txt Plain text body content.
+ *
+ * @return array{string, string, array}
+ */
+function prepareReportOutput(string $body, string $body_txt): array {
+ $output = '';
+
+ $report_tag = '';
+ $theme = 'modern';
+
+ monitorDebug('Loading Format File');
+
+ $format_ok = reports_load_format_file(read_config_option('monitor_format_file'), $output, $report_tag, $theme);
+
+ monitorDebug('Format File Loaded, Format is ' . ($format_ok ? 'Ok' : 'Not Ok') . ', Report Tag is ' . $report_tag);
+
+ if ($format_ok) {
+ if ($report_tag) {
+ $output = str_replace('
', $body, $output);
+ } else {
+ $output = $output . PHP_EOL . $body;
+ }
+ } else {
+ $output = $body;
+ }
+
+ monitorDebug('HTML Processed');
+
+ if (defined('CACTI_VERSION')) {
+ $version = CACTI_VERSION;
+ } else {
+ $version = get_cacti_version();
+ }
+
+ $headers = ['User-Agent' => 'Cacti-Monitor-v' . $version];
+
+ return [$output, $body_txt, $headers];
+}
+
+/**
+ * Render and send one reboot notification email payload.
+ *
+ * @param string $email Recipient email address string.
+ * @param array $hosts Host ids to include in the message.
+ *
+ * @return void
+ */
+function processRebootEmail(string $email, array $hosts): void {
+ monitorDebug("Reboot Processing for $email starting");
+
+ [$body, $body_txt, $last_host] = buildRebootDetails($hosts);
+ $subject = buildRebootSubject($hosts, $last_host);
+
+ $template_output = read_config_option('monitor_body');
+ $template_output = str_replace('', $body, $template_output) . PHP_EOL;
+
+ if (strpos($template_output, '') !== false) {
+ $toutput = str_replace('', $body_txt, $template_output) . PHP_EOL;
+ } else {
+ $toutput = $body_txt;
+ }
+
+ if (read_config_option('monitor_reboot_notify') != 'on') {
+ return;
+ }
+
+ [$output, $toutput, $headers] = prepareReportOutput($body, $toutput);
+
+ processSendEmail($email, $subject, $output, $toutput, $headers, 'Reboot Notifications');
+}
+
+/**
+ * Resolve alert/warn host ids for requested global/list subscription scopes.
+ *
+ * @param array $lists Requested scopes (`global` or list ids).
+ * @param array $global_list Flattened global notification host ids by severity.
+ * @param array $notify_list Flattened list notification host ids by severity.
+ *
+ * @return array{array, array}
+ */
+function collectNotificationHosts(array $lists, array $global_list, array $notify_list): array {
+ $alert_hosts = [];
+ $warn_hosts = [];
+
+ foreach ($lists as $list) {
+ if ($list === 'global') {
+ if (isset($global_list['alert'])) {
+ $alert_hosts = array_merge($alert_hosts, explode(',', $global_list['alert']));
+ }
+
+ if (isset($global_list['warn'])) {
+ $warn_hosts = array_merge($warn_hosts, explode(',', $global_list['warn']));
+ }
+
+ continue;
+ }
+
+ if (isset($notify_list[$list]['alert'])) {
+ $alert_hosts = array_merge($alert_hosts, explode(',', $notify_list[$list]['alert']));
+ }
+
+ if (isset($notify_list[$list]['warn'])) {
+ $warn_hosts = array_merge($warn_hosts, explode(',', $notify_list[$list]['warn']));
+ }
+ }
+
+ return [$alert_hosts, $warn_hosts];
+}
+
+/**
+ * De-duplicate alert/warn host ids and log notification history entries.
+ *
+ * @param array $alert_hosts Alert host ids; normalized in place.
+ * @param array $warn_hosts Warning host ids; normalized in place.
+ *
+ * @return void
+ */
+function normalizeAndLogNotificationHosts(array &$alert_hosts, array &$warn_hosts): void {
+ if (cacti_sizeof($alert_hosts)) {
+ $alert_hosts = array_unique($alert_hosts, SORT_NUMERIC);
+ logMessages('alert', $alert_hosts);
+ }
+
+ if (cacti_sizeof($warn_hosts)) {
+ $warn_hosts = array_unique($warn_hosts, SORT_NUMERIC);
+ logMessages('warn', $warn_hosts);
+ }
+}
+
+/**
+ * Build shared intro copy for ping threshold email and text output.
+ *
+ * @param int $freq Resend frequency in minutes.
+ *
+ * @return array{string, string}
+ */
+function buildPingNotificationIntro(int|string $freq): array {
+ $body = '' . __(MONITOR_PING_NOTIFICATION_SUBJECT, 'monitor') . '
' . PHP_EOL;
+ $body_txt = __(MONITOR_PING_NOTIFICATION_SUBJECT, 'monitor') . PHP_EOL;
+
+ $message = __('The following report will identify Devices that have eclipsed their ping latency thresholds. You are receiving this report since you are subscribed to a Device associated with the Cacti system located at the following URL below.');
+
+ $body .= '' . $message . '
' . PHP_EOL;
+ $body_txt .= $message . PHP_EOL;
+
+ $body .= '' . PHP_EOL;
+ $body_txt .= __('Cacti Monitoring Site', 'monitor') . PHP_EOL;
+
+ if ($freq > 0) {
+ $body .= '' . __('You will receive notifications every %d minutes if the Device is above its threshold.', $freq, 'monitor') . '
' . PHP_EOL;
+ $body_txt .= __('You will receive notifications every %d minutes if the Device is above its threshold.', $freq, 'monitor') . PHP_EOL;
+ } else {
+ $body .= '' . __('You will receive notifications every time the Device is above its threshold.', 'monitor') . '
' . PHP_EOL;
+ $body_txt .= __('You will receive notifications every time the Device is above its threshold.', 'monitor') . PHP_EOL;
+ }
+
+ return [$body, $body_txt];
+}
+
+/**
+ * Append one severity section for breached host thresholds.
+ *
+ * @param string $body HTML body output buffer.
+ * @param string $body_txt Plain text output buffer.
+ * @param array $host_ids Host ids for the section.
+ * @param array $criticalities Criticality label map.
+ * @param string $section_text Section heading text.
+ * @param string $threshold_field Host threshold field name.
+ *
+ * @return void
+ */
+function appendThresholdSection(string &$body, string &$body_txt, array $host_ids, array $criticalities, string $section_text, string $threshold_field): void {
+ global $config;
+
+ if (!cacti_sizeof($host_ids)) {
+ return;
+ }
+
+ $body .= '' . __($section_text, 'monitor') . '
' . PHP_EOL;
+ $body_txt .= __($section_text, 'monitor') . PHP_EOL;
+
+ $body .= '' . PHP_EOL;
+ $body .= '' . PHP_EOL;
+
+ $body_txt .=
+ __('Hostname', 'monitor') . "\t" .
+ __('Criticality', 'monitor') . "\t" .
+ __(MONITOR_ALERT_PING_LABEL, 'monitor') . "\t" .
+ __(MONITOR_CURRENT_PING_LABEL, 'monitor') . PHP_EOL;
+
+ $hosts = db_fetch_assoc('SELECT *
+ FROM host
+ WHERE id IN(' . implode(',', $host_ids) . ')
+ AND deleted = ""');
+
+ if (cacti_sizeof($hosts)) {
+ foreach ($hosts as $host) {
+ $body .= '' . PHP_EOL;
+ $body .= '| ' . $host['description'] . ' | ' . PHP_EOL;
+ $body .= '' . $criticalities[$host['monitor_criticality']] . ' | ' . PHP_EOL;
+ $body .= '' . number_format_i18n($host[$threshold_field], 2) . ' ms | ' . PHP_EOL;
+ $body .= '' . number_format_i18n($host['cur_time'], 2) . ' ms | ' . PHP_EOL;
+ $body .= '
' . PHP_EOL;
+
+ $body_txt .=
+ $host['description'] . "\t" .
+ $criticalities[$host['monitor_criticality']] . "\t" .
+ number_format_i18n($host[$threshold_field], 2) . " ms\t" .
+ number_format_i18n($host['cur_time'], 2) . ' ms' . PHP_EOL;
+ }
+ }
+
+ $body .= '
' . PHP_EOL;
+}
+
+/**
+ * Build log-friendly summary text for alert/warn delivery counts.
+ *
+ * @param array $alert_hosts Alert host ids.
+ * @param array $warn_hosts Warning host ids.
+ *
+ * @return string
+ */
+function buildNotificationStatus(array $alert_hosts, array $warn_hosts): string {
+ $status = '';
+
+ if (cacti_sizeof($alert_hosts)) {
+ $status = sizeof($alert_hosts) . ' Alert Notifications';
+ }
+
+ if (cacti_sizeof($warn_hosts)) {
+ if ($status !== '') {
+ $status .= ', and ';
+ }
+
+ $status .= sizeof($warn_hosts) . ' Warning Notifications';
+ }
+
+ return $status;
+}
+
+/**
+ * Build and send a ping-threshold notification for one recipient.
+ *
+ * @param string $email Recipient email.
+ * @param array $lists Requested scopes (`global` or list ids).
+ * @param array $global_list Flattened global host ids by severity.
+ * @param array $notify_list Flattened list host ids by severity.
+ *
+ * @return void
+ */
+function processEmail(string $email, array $lists, array $global_list, array $notify_list): void {
+ monitorDebug('Into Processing');
+
+ $criticalities = [
+ 0 => __('Disabled', 'monitor'),
+ 1 => __('Low', 'monitor'),
+ 2 => __('Medium', 'monitor'),
+ 3 => __('High', 'monitor'),
+ 4 => __('Mission Critical', 'monitor')
+ ];
+
+ [$alert_hosts, $warn_hosts] = collectNotificationHosts($lists, $global_list, $notify_list);
+ monitorDebug('Lists Processed');
+
+ normalizeAndLogNotificationHosts($alert_hosts, $warn_hosts);
+ monitorDebug('Found ' . sizeof($alert_hosts) . ' Alert Hosts, and ' . sizeof($warn_hosts) . ' Warn Hosts');
+
+ if (!cacti_sizeof($alert_hosts) && !cacti_sizeof($warn_hosts)) {
+ return;
+ }
+
+ monitorDebug('Formatting Email');
+
+ $freq = read_config_option('monitor_resend_frequency');
+ $subject = __(MONITOR_PING_NOTIFICATION_SUBJECT, 'monitor');
+ [$body, $body_txt] = buildPingNotificationIntro($freq);
+
+ appendThresholdSection(
+ $body,
+ $body_txt,
+ $alert_hosts,
+ $criticalities,
+ 'The following Devices have breached their Alert Notification Threshold.',
+ 'monitor_alert'
+ );
+
+ appendThresholdSection(
+ $body,
+ $body_txt,
+ $warn_hosts,
+ $criticalities,
+ 'The following Devices have breached their Warning Notification Threshold.',
+ 'monitor_warn'
+ );
+
+ [$output, $toutput, $headers] = prepareReportOutput($body, $body_txt);
+ $status = buildNotificationStatus($alert_hosts, $warn_hosts);
+
+ processSendEmail($email, $subject, $output, $toutput, $headers, $status);
+}
+
+/**
+ * Send an email through Cacti mailer with configured sender fallbacks.
+ *
+ * @param string $email Recipient email string.
+ * @param string $subject Message subject.
+ * @param string $output HTML output body.
+ * @param string $toutput Plain text output body.
+ * @param array $headers Extra headers passed to mailer.
+ * @param string $status Status text used in logs.
+ *
+ * @return void
+ */
+function processSendEmail(string $email, string $subject, string $output, string $toutput, array $headers, string $status): void {
+ $from_email = read_config_option('monitor_fromemail');
+
+ if ($from_email == '') {
+ $from_email = read_config_option('settings_from_email');
+
+ if ($from_email == '') {
+ $from_email = 'Cacti@cacti.net';
+ }
+ }
+
+ $from_name = read_config_option('monitor_fromname');
+
+ if ($from_name == '') {
+ $from_name = read_config_option('settings_from_name');
+
+ if ($from_name == '') {
+ $from_name = 'Cacti Reporting';
+ }
+ }
+
+ $html = true;
+
+ if (read_config_option('thold_send_text_only') == 'on') {
+ $output = monitorText($toutput);
+ $html = false;
+ }
+
+ monitorDebug("Sending Email to '$email' for $status");
+
+ $error = mailer(
+ [$from_email, $from_name],
+ $email,
+ '',
+ '',
+ '',
+ $subject,
+ $output,
+ monitorText($toutput),
+ null,
+ $headers,
+ $html
+ );
+
+ monitorDebug("The return from the mailer was '$error'");
+
+ if (strlen($error)) {
+ cacti_log("WARNING: Monitor had problems sending to '$email' for $status. The error was '$error'", false, 'MONITOR');
+ } else {
+ cacti_log("NOTICE: Email Notification Sent to '$email' for $status.", false, 'MONITOR');
+ }
+}
+
+/**
+ * Convert HTML-ish report content into plain text line output.
+ *
+ * @param string $output HTML or mixed output.
+ *
+ * @return string
+ */
+function monitorText(string $output): string {
+ $output = explode(PHP_EOL, $output);
+
+ $new_output = '';
+
+ if (cacti_sizeof($output)) {
+ foreach ($output as $line) {
+ $line = str_replace('
', PHP_EOL, $line);
+ $line = str_replace('
', PHP_EOL, $line);
+ $line = trim(strip_tags($line));
+ $new_output .= $line . PHP_EOL;
+ }
+ }
+
+ return $new_output;
+}
+
+/**
+ * Persist alert or warning notification history rows once per host.
+ *
+ * @param string $type Severity type (`alert` or `warn`).
+ * @param array $alert_hosts Host ids to log for the severity.
+ *
+ * @return void
+ */
+function logMessages(string $type, array $alert_hosts): void {
+ global $start_date;
+
+ static $processed = [];
+
+ if ($type == 'warn') {
+ $type = '0';
+ $column = 'monitor_warn';
+ } elseif ($type == 'alert') {
+ $type = '1';
+ $column = 'monitor_alert';
+ }
+
+ foreach ($alert_hosts as $id) {
+ if (!isset($processed[$id])) {
+ db_execute_prepared(
+ "INSERT INTO plugin_monitor_notify_history
+ (host_id, notify_type, ping_time, ping_threshold, notification_time)
+ SELECT id, '$type' AS notify_type, cur_time, $column, '$start_date' AS notification_time
+ FROM host
+ WHERE deleted = ''
+ AND monitor = 'on'
+ AND id = ?",
+ [$id]
+ );
+ }
+
+ $processed[$id] = true;
+ }
+}
+
+/**
+ * Add grouped host ids to global/list collections by host email mode.
+ *
+ * @param string $type Severity key (`alert` or `warn`).
+ * @param array $entry Grouped SQL row containing mode/list/ids.
+ * @param array $global_list Global grouped bucket, updated in place.
+ * @param array $notify_list Per-list grouped bucket, updated in place.
+ * @param array $lists Set of list ids used for recipient lookups.
+ *
+ * @return void
+ */
+function addGroupedNotificationEntry(string $type, array $entry, array &$global_list, array &$notify_list, array &$lists): void {
+ if ($entry['thold_send_email'] == '1' || $entry['thold_send_email'] == '3') {
+ $global_list[$type][] = $entry;
+ }
+
+ if (($entry['thold_send_email'] == '2' || $entry['thold_send_email'] == '3') && $entry['thold_host_email'] > 0) {
+ $notify_list[$type][$entry['thold_host_email']][] = $entry;
+ $lists[$entry['thold_host_email']] = $entry['thold_host_email'];
+ }
+}
+
+/**
+ * Query and group threshold-breached hosts for one severity type.
+ *
+ * @param string $type Severity key (`alert` or `warn`).
+ * @param int $criticality Minimum criticality threshold.
+ * @param array $global_list Global grouped bucket, updated in place.
+ * @param array $notify_list Per-list grouped bucket, updated in place.
+ * @param array $lists Set of notification list ids, updated in place.
+ *
+ * @return void
+ */
+function getHostsByListType(string $type, int|string $criticality, array &$global_list, array &$notify_list, array &$lists): void {
+ $last_time = date(MONITOR_DATE_TIME_FORMAT, time() - read_config_option('monitor_resend_frequency') * 60);
+
+ $hosts = db_fetch_cell_prepared(
+ "SELECT COUNT(*)
+ FROM host
+ WHERE status = 3
+ AND deleted = ''
+ AND monitor = 'on'
+ AND thold_send_email > 0
+ AND monitor_criticality >= ?
+ AND cur_time > monitor_$type",
+ [$criticality]
+ );
+
+ if ($hosts <= 0) {
+ return;
+ }
+
+ $htype = ($type == 'warn') ? 1 : 0;
+
+ $groups = db_fetch_assoc_prepared(
+ "SELECT
+ thold_send_email, thold_host_email, GROUP_CONCAT(host.id) AS id
+ FROM host
+ LEFT JOIN (
+ SELECT host_id, MAX(notification_time) AS notification_time
+ FROM plugin_monitor_notify_history
+ WHERE notify_type = ?
+ GROUP BY host_id
+ ) AS nh
+ ON host.id=nh.host_id
+ WHERE status = 3
+ AND deleted = ''
+ AND monitor = 'on'
+ AND thold_send_email > 0
+ AND monitor_criticality >= ?
+ AND cur_time > monitor_$type " . ($type == 'warn' ? ' AND cur_time < monitor_alert' : '') . '
+ AND (notification_time < ? OR notification_time IS NULL)
+ AND host.total_polls > 1
+ GROUP BY thold_host_email, thold_send_email
+ ORDER BY thold_host_email, thold_send_email',
+ [$htype, $criticality, $last_time]
+ );
+
+ if (!cacti_sizeof($groups)) {
+ return;
+ }
+
+ foreach ($groups as $entry) {
+ addGroupedNotificationEntry($type, $entry, $global_list, $notify_list, $lists);
+ }
+}
+
+/**
+ * Flatten grouped host id chunks for a single severity bucket.
+ *
+ * @param array $list Grouped rows, each row containing a CSV `id` field.
+ *
+ * @return string
+ */
+function flattenGroupSeverityList(array $list): string {
+ $flattened = '';
+
+ foreach ($list as $item) {
+ $flattened .= ($flattened !== '' ? ',' : '') . $item['id'];
+ }
+
+ return $flattened;
+}
+
+/**
+ * Flatten grouped host ids for each notification list id.
+ *
+ * @param array $lists Grouped entries keyed by notification list id.
+ *
+ * @return array
+ */
+function flattenNotifySeverityLists(array $lists): array {
+ $flattened = [];
+
+ foreach ($lists as $id => $list) {
+ $flattened[$id] = flattenGroupSeverityList($list);
+ }
+
+ return $flattened;
+}
+
+/**
+ * Flatten grouped global and per-list structures into CSV host id strings.
+ *
+ * @param array $global_list Global grouped structure, updated in place.
+ * @param array $notify_list Per-list grouped structure, updated in place.
+ *
+ * @return void
+ */
+function flattenLists(array &$global_list, array &$notify_list): void {
+ if (cacti_sizeof($global_list)) {
+ $new_global = [];
+
+ foreach ($global_list as $severity => $list) {
+ $new_global[$severity] = flattenGroupSeverityList($list);
+ }
+
+ $global_list = $new_global;
+ }
+
+ if (cacti_sizeof($notify_list)) {
+ $new_list = [];
+
+ foreach ($notify_list as $severity => $lists) {
+ $new_list[$severity] = flattenNotifySeverityLists($lists);
+ }
+
+ $notify_list = $new_list;
+ }
+}
+
+/**
+ * Add email addresses into the recipient scope map.
+ *
+ * @param array $notification_emails Recipient map, updated in place.
+ * @param array $emails Raw email values to normalize.
+ * @param string|int $scope_key Scope key (`global` or list id).
+ *
+ * @return void
+ */
+function addEmailsToNotificationMap(array &$notification_emails, array $emails, string|int $scope_key): void {
+ foreach ($emails as $user) {
+ $user = trim($user);
+
+ if ($user !== '') {
+ $notification_emails[$user][$scope_key] = true;
+ }
+ }
+}
+
+/**
+ * Build recipient map for global and notification list subscriptions.
+ *
+ * @param array $lists Notification list ids to resolve.
+ *
+ * @return array
+ */
+function getEmailsAndLists(array $lists): array {
+ $notification_emails = [];
+
+ $alert_email = read_config_option('alert_email');
+ $global_emails = ($alert_email != '') ? explode(',', $alert_email) : [];
+
+ if (cacti_sizeof($global_emails)) {
+ addEmailsToNotificationMap($notification_emails, $global_emails, 'global');
+ }
+
+ if (!cacti_sizeof($lists)) {
+ return $notification_emails;
+ }
+
+ $list_emails = db_fetch_assoc('SELECT id, emails
+ FROM plugin_notification_lists
+ WHERE id IN (' . implode(',', $lists) . ')');
+
+ if (!cacti_sizeof($list_emails)) {
+ return $notification_emails;
+ }
+
+ foreach ($list_emails as $email) {
+ addEmailsToNotificationMap($notification_emails, explode(',', $email['emails']), $email['id']);
+ }
+
+ return $notification_emails;
+}
+
+/**
+ * Purge notification and reboot history records older than configured retention.
+ *
+ * @return array{int, int} Purged notify count and purged reboot count.
+ */
+function purgeEventRecords(): array {
+ // Purge old records
+ $days = read_config_option('monitor_log_storage');
+
+ if (empty($days)) {
+ $days = 120;
+ }
+
+ db_execute_prepared(
+ 'DELETE FROM plugin_monitor_notify_history
+ WHERE notification_time < FROM_UNIXTIME(UNIX_TIMESTAMP() - (? * 86400))',
+ [$days]
+ );
+
+ $purge_n = db_affected_rows();
+
+ db_execute_prepared(
+ 'DELETE FROM plugin_monitor_reboot_history
+ WHERE log_time < FROM_UNIXTIME(UNIX_TIMESTAMP() - (? * 86400))',
+ [$days]
+ );
+
+ $purge_r = db_affected_rows();
+
+ return [$purge_n, $purge_r];
+}
+
+/**
+ * Print a debug line when poller debug mode is enabled.
+ *
+ * @param string $message Debug message.
+ *
+ * @return void
+ */
+function monitorDebug(string $message): void {
+ global $debug;
+
+ if ($debug) {
+ print trim($message) . PHP_EOL;
+ }
+}
+
+/**
+ * Print monitor poller version information.
+ *
+ * @return void
+ */
+function displayVersion(): void {
+ global $config;
+
+ if (!function_exists('plugin_monitor_version')) {
+ include_once $config['base_path'] . '/plugins/monitor/setup.php';
+ }
+
+ $info = plugin_monitor_version();
+
+ print 'Cacti Monitor Poller, Version ' . $info['version'] . ', ' . COPYRIGHT_YEARS . PHP_EOL;
+}
+
+/**
+ * Print CLI help output for this poller entrypoint.
+ *
+ * @return void
+ */
+function displayHelp(): void {
+ displayVersion();
+
+ print PHP_EOL;
+ print 'usage: poller_monitor.php [--debug]' . PHP_EOL . PHP_EOL;
+ print ' --debug - debug execution, e.g. for testing' . PHP_EOL . PHP_EOL;
+}
diff --git a/poller_monitor.php b/poller_monitor.php
index 433da8a..0a7ba3c 100644
--- a/poller_monitor.php
+++ b/poller_monitor.php
@@ -1,4 +1,7 @@
0 || $alert_criticality > 0) {
- monitor_debug('Monitor Notification Enabled for Devices');
+ monitorDebug('Monitor Notification Enabled for Devices');
- // Get hosts that are above threshold. Start with Alert, and then Warning
+ // Get hosts that are above threshold. Start with Alert, and then Warning.
if ($alert_criticality) {
- get_hosts_by_list_type('alert', $alert_criticality, $global_list, $notify_list, $lists);
+ getHostsByListType('alert', $alert_criticality, $global_list, $notify_list, $lists);
}
if ($warning_criticality) {
- get_hosts_by_list_type('warn', $warning_criticality, $global_list, $notify_list, $lists);
+ getHostsByListType('warn', $warning_criticality, $global_list, $notify_list, $lists);
}
- flatten_lists($global_list, $notify_list);
+ flattenLists($global_list, $notify_list);
- monitor_debug('Lists Flattened there are ' . sizeof($global_list) . ' Global Notifications and ' . sizeof($notify_list) . ' Notification List Notifications.');
+ monitorDebug('Lists Flattened there are ' . sizeof($global_list) . ' Global Notifications and ' . sizeof($notify_list) . ' Notification List Notifications.');
if (strlen(read_config_option('alert_email')) == 0) {
- monitor_debug('WARNING: No Global List Defined. Please set under Settings -> Thresholds');
+ monitorDebug('WARNING: No Global List Defined. Please set under Settings -> Thresholds');
cacti_log('WARNING: No Global Notification List defined. Please set under Settings -> Thresholds', false, 'MONITOR');
}
if (cacti_sizeof($global_list) || sizeof($notify_list)) {
// array of email[list|'g'] = true;
- $notification_emails = get_emails_and_lists($lists);
+ $notification_emails = getEmailsAndLists($lists);
// Send out emails to each emails address with all notifications in one
if (cacti_sizeof($notification_emails)) {
foreach ($notification_emails as $email => $lists) {
- monitor_debug('Processing the email address: ' . $email);
- process_email($email, $lists, $global_list, $notify_list);
+ monitorDebug('Processing the email address: ' . $email);
+ processEmail($email, $lists, $global_list, $notify_list);
$notifications++;
}
}
}
} else {
- monitor_debug('Both Warning and Alert Notification are Disabled.');
+ monitorDebug('Both Warning and Alert Notification are Disabled.');
}
-[$purge_n, $purge_r] = purge_event_records();
+[$purge_n, $purge_r] = purgeEventRecords();
$poller_end = microtime(true);
@@ -151,779 +153,3 @@
set_config_option('stats_monitor', $stats);
exit;
-
-function monitor_addemails(&$reboot_emails, $alert_emails, $host_id) {
- if (cacti_sizeof($alert_emails)) {
- foreach ($alert_emails as $email) {
- $reboot_emails[trim(strtolower($email))][$host_id] = $host_id;
- }
- }
-}
-
-function monitor_addnotificationlist(&$reboot_emails, $notify_list, $host_id, $notification_lists) {
- if ($notify_list > 0) {
- if (isset($notification_lists[$notify_list])) {
- $emails = explode(',', $notification_lists[$notify_list]);
- monitor_addemails($reboot_emails, $emails, $host_id);
- }
- }
-}
-
-function monitor_uptime_checker() {
- monitor_debug('Checking for Uptime of Devices');
-
- $start = date('Y-m-d H:i:s');
-
- $reboot_emails = [];
-
- $alert_email = read_config_option('alert_email');
-
- if ($alert_email != '') {
- $alert_emails = explode(',', $alert_email);
- } else {
- $alert_emails = [];
- }
-
- // Remove unneeded device records in associated tables
- $removed_hosts = db_fetch_assoc('SELECT mu.host_id
- FROM plugin_monitor_uptime AS mu
- LEFT JOIN host AS h
- ON h.id = mu.host_id
- WHERE h.id IS NULL');
-
- if (cacti_sizeof($removed_hosts)) {
- db_execute('DELETE mu
- FROM plugin_monitor_uptime AS mu
- LEFT JOIN host AS h
- ON h.id = mu.host_id
- WHERE h.id IS NULL');
- }
-
- $removed_hosts = db_fetch_assoc('SELECT mu.host_id
- FROM plugin_monitor_reboot_history AS mu
- LEFT JOIN host AS h
- ON h.id = mu.host_id
- WHERE h.id IS NULL');
-
- if (cacti_sizeof($removed_hosts)) {
- db_execute('DELETE mu
- FROM plugin_monitor_reboot_history AS mu
- LEFT JOIN host AS h
- ON h.id = mu.host_id
- WHERE h.id IS NULL');
- }
-
- // Get the rebooted devices
- $rebooted_hosts = db_fetch_assoc('SELECT h.id, h.description,
- h.hostname, h.snmp_sysUpTimeInstance, mu.uptime
- FROM host AS h
- LEFT JOIN plugin_monitor_uptime AS mu
- ON h.id = mu.host_id
- WHERE h.snmp_version > 0
- AND status IN (2,3)
- AND h.deleted = ""
- AND h.monitor = "on"
- AND (mu.uptime IS NULL OR mu.uptime > h.snmp_sysUpTimeInstance)
- AND h.snmp_sysUpTimeInstance > 0');
-
- if (cacti_sizeof($rebooted_hosts)) {
- $notification_lists = array_rekey(
- db_fetch_assoc('SELECT id, emails
- FROM plugin_notification_lists
- ORDER BY id'),
- 'id', 'emails'
- );
-
- $monitor_list = read_config_option('monitor_list');
- $monitor_thold = read_config_option('monitor_reboot_thold');
-
- foreach ($rebooted_hosts as $host) {
- db_execute_prepared('INSERT INTO plugin_monitor_reboot_history
- (host_id, reboot_time)
- VALUES (?, ?)',
- [$host['id'], date('Y-m-d H:i:s', time() - intval($host['snmp_sysUpTimeInstance']))]);
-
- monitor_addnotificationlist($reboot_emails, $monitor_list, $host['id'], $notification_lists);
-
- if ($monitor_thold == 'on') {
- $notify = db_fetch_row_prepared('SELECT thold_send_email, thold_host_email
- FROM host
- WHERE id = ?',
- [$host['id']]);
-
- if (cacti_sizeof($notify)) {
- switch($notify['thold_send_email']) {
- case '0': // Disabled
- break;
- case '1': // Global List
- monitor_addemails($reboot_emails, $alert_emails, $host['id']);
-
- break;
- case '2': // Nofitication List
- monitor_addnotificationlist($reboot_emails, $notify['thold_host_email'],
- $host['id'], $notification_lists);
-
- break;
- case '3': // Both Global and Nofication list
- monitor_addemails($reboot_emails, $alert_emails, $host['id']);
- monitor_addnotificationlist($reboot_emails, $notify['thold_host_email'],
- $host['id'], $notification_lists);
-
- break;
- }
- }
- }
- }
-
- $monitor_send_one_email = read_config_option('monitor_send_one_email');
- $to_email = '';
-
- if (cacti_sizeof($reboot_emails)) {
- foreach ($reboot_emails as $email => $hosts) {
- if ($email != '') {
- $to_email .= ($to_email != '' ? ',' : '') . $email;
-
- if ($monitor_send_one_email !== 'on') {
- monitor_debug('Processing the Email address: ' . $email);
- process_reboot_email($email, $hosts);
- }
- } else {
- monitor_debug('Unable to process reboot notification due to empty Email address.');
- }
- }
-
- if ($monitor_send_one_email == 'on') {
- monitor_debug('Processing the Email address: ' . $to_email);
- process_reboot_email($to_email, $hosts);
- }
- }
- }
-
- // Freshen the uptimes
- db_execute('REPLACE INTO plugin_monitor_uptime
- (host_id, uptime)
- SELECT id, snmp_sysUpTimeInstance
- FROM host
- WHERE snmp_version > 0
- AND status IN(2,3)
- AND deleted = ""
- AND monitor = "on"
- AND snmp_sysUpTimeInstance > 0');
-
- // Log Recently Down
- db_execute('INSERT IGNORE INTO plugin_monitor_notify_history
- (host_id, notify_type, notification_time, notes)
- SELECT h.id, "3" AS notify_type, status_fail_date AS notification_time, status_last_error AS notes
- FROM host AS h
- WHERE status = 1
- AND deleted = ""
- AND monitor = "on"
- AND status_event_count = 1');
-
- $recent = db_affected_rows();
-
- return [cacti_sizeof($rebooted_hosts), $recent];
-}
-
-function process_reboot_email($email, $hosts) {
- monitor_debug("Reboot Processing for $email starting");
-
- $body_txt = '';
-
- $body = '' . PHP_EOL;
- $body .= '' . PHP_EOL;
-
- foreach ($hosts as $host) {
- $host = db_fetch_row_prepared('SELECT description, hostname
- FROM host
- WHERE id = ?',
- [$host]);
-
- if (cacti_sizeof($host)) {
- $body .= '' .
- '| ' . $host['description'] . ' | ' .
- '' . $host['hostname'] . ' | ' .
- '
' . PHP_EOL;
-
- $body_txt .=
- __('Description: ', 'monitor') . $host['description'] . PHP_EOL .
- __('Hostname: ', 'monitor') . $host['hostname'] . PHP_EOL . PHP_EOL;
- }
- }
-
- $body .= '
' . PHP_EOL;
-
- $subject = read_config_option('monitor_subject');
- $monitor_send_one_email = read_config_option('monitor_send_one_email');
-
- if ($monitor_send_one_email == 'on') {
- $subject .= ' ' . $host['description'] . ' (' . $host['hostname'] . ')';
- } else {
- if (cacti_sizeof($hosts) == 1) {
- $subject .= ' 1 device - ' . $host['description'] . ' (' . $host['hostname'] . ')';
- } else {
- $subject .= ' ' . cacti_sizeof($hosts) . ' devices';
- }
- }
-
- $output = read_config_option('monitor_body');
- $output = str_replace('', $body, $output) . PHP_EOL;
-
- if (strpos($output, '') !== false) {
- $toutput = str_replace('', $body_txt, $output) . PHP_EOL;
- } else {
- $toutput = $body_txt;
- }
-
- if (read_config_option('monitor_reboot_notify') == 'on') {
- $report_tag = '';
- $theme = 'modern';
-
- monitor_debug('Loading Format File');
-
- $format_ok = reports_load_format_file(read_config_option('monitor_format_file'), $output, $report_tag, $theme);
-
- monitor_debug('Format File Loaded, Format is ' . ($format_ok ? 'Ok' : 'Not Ok') . ', Report Tag is ' . $report_tag);
-
- if ($format_ok) {
- if ($report_tag) {
- $output = str_replace('', $body, $output);
- } else {
- $output = $output . PHP_EOL . $body;
- }
- } else {
- $output = $body;
- }
-
- monitor_debug('HTML Processed');
-
- if (defined('CACTI_VERSION')) {
- $version = CACTI_VERSION;
- } else {
- $version = get_cacti_version();
- }
-
- $headers['User-Agent'] = 'Cacti-Monitor-v' . $version;
-
- $status = 'Reboot Notifications';
-
- process_send_email($email, $subject, $output, $toutput, $headers, $status);
- }
-}
-
-function process_email($email, $lists, $global_list, $notify_list) {
- global $config;
-
- monitor_debug('Into Processing');
-
- $alert_hosts = [];
- $warn_hosts = [];
-
- $criticalities = [
- 0 => __('Disabled', 'monnitor'),
- 1 => __('Low', 'monnitor'),
- 2 => __('Medium', 'monnitor'),
- 3 => __('High', 'monnitor'),
- 4 => __('Mission Critical', 'monnitor')
- ];
-
- foreach ($lists as $list) {
- switch($list) {
- case 'global':
- $hosts = [];
-
- if (isset($global_list['alert'])) {
- $alert_hosts += explode(',', $global_list['alert']);
- }
-
- if (isset($global_list['warn'])) {
- $warn_hosts += explode(',', $global_list['warn']);
- }
-
- break;
- default:
- if (isset($notify_list[$list]['alert'])) {
- $alert_hosts = explode(',', $notify_list[$list]['alert']);
- }
-
- if (isset($notify_list[$list]['warn'])) {
- $warn_hosts = explode(',', $notify_list[$list]['warn']);
- }
-
- break;
- }
- }
-
- monitor_debug('Lists Processed');
-
- if (cacti_sizeof($alert_hosts)) {
- $alert_hosts = array_unique($alert_hosts, SORT_NUMERIC);
-
- log_messages('alert', $alert_hosts);
- }
-
- if (cacti_sizeof($warn_hosts)) {
- $warn_hosts = array_unique($warn_hosts, SORT_NUMERIC);
-
- log_messages('warn', $alert_hosts);
- }
-
- monitor_debug('Found ' . sizeof($alert_hosts) . ' Alert Hosts, and ' . sizeof($warn_hosts) . ' Warn Hosts');
-
- if (cacti_sizeof($alert_hosts) || sizeof($warn_hosts)) {
- monitor_debug('Formatting Email');
-
- $freq = read_config_option('monitor_resend_frequency');
- $subject = __('Cacti Monitor Plugin Ping Threshold Notification', 'monitor');
-
- $body = '' . __('Cacti Monitor Plugin Ping Threshold Notification', 'monitor') . '
' . PHP_EOL;
- $body_txt = __('Cacti Monitor Plugin Ping Threshold Notification', 'monitor') . PHP_EOL;
-
- $body .= '' . __('The following report will identify Devices that have eclipsed their ping latency thresholds. You are receiving this report since you are subscribed to a Device associated with the Cacti system located at the following URL below.') . '
' . PHP_EOL;
-
- $body_txt .= __('The following report will identify Devices that have eclipsed their ping latency thresholds. You are receiving this report since you are subscribed to a Device associated with the Cacti system located at the following URL below.') . PHP_EOL;
-
- $body .= '' . PHP_EOL;
-
- $body_txt .= __('Cacti Monitoring Site', 'monitor') . PHP_EOL;
-
- if ($freq > 0) {
- $body .= '' . __('You will receive notifications every %d minutes if the Device is above its threshold.', $freq, 'monitor') . '
' . PHP_EOL;
-
- $body_txt .= __('You will receive notifications every %d minutes if the Device is above its threshold.', $freq, 'monitor') . PHP_EOL;
- } else {
- $body .= '' . __('You will receive notifications every time the Device is above its threshold.', 'monitor') . '
' . PHP_EOL;
-
- $body_txt .= __('You will receive notifications every time the Device is above its threshold.', 'monitor') . PHP_EOL;
- }
-
- if (cacti_sizeof($alert_hosts)) {
- $body .= '' . __('The following Devices have breached their Alert Notification Threshold.', 'monitor') . '
' . PHP_EOL;
-
- $body_txt .= __('The following Devices have breached their Alert Notification Threshold.', 'monitor') . PHP_EOL;
-
- $body .= '' . PHP_EOL;
- $body .= '' . PHP_EOL;
-
- $hosts = db_fetch_assoc('SELECT *
- FROM host
- WHERE id IN(' . implode(',', $alert_hosts) . ')
- AND deleted = ""');
-
- if (cacti_sizeof($hosts)) {
- foreach ($hosts as $host) {
- $body .= '' . PHP_EOL;
- $body .= '| ' . $host['description'] . ' | ' . PHP_EOL;
-
- $body .= '' . $criticalities[$host['monitor_criticality']] . ' | ' . PHP_EOL;
- $body .= '' . number_format_i18n($host['monitor_alert'],2) . ' ms | ' . PHP_EOL;
- $body .= '' . number_format_i18n($host['cur_time'],2) . ' ms | ' . PHP_EOL;
-
- $body_txt .=
- $host['description'] . "\t" .
- $criticalities[$host['monitor_criticality']] . "\t" .
- number_format_i18n($host['monitor_alert'],2) . " ms\t" .
- number_format_i18n($host['cur_time'],2) . ' ms' . PHP_EOL;
-
- $body .= '
' . PHP_EOL;
- }
- }
-
- $body .= '
' . PHP_EOL;
- }
-
- if (cacti_sizeof($warn_hosts)) {
- $body .= '' . __('The following Devices have breached their Warning Notification Threshold.', 'monitor') . '
' . PHP_EOL;
-
- $body_txt .= __('The following Devices have breached their Warning Notification Threshold.', 'monitor') . PHP_EOL;
-
- $body .= '' . PHP_EOL;
- $body .= '' . PHP_EOL;
-
- $hosts = db_fetch_assoc('SELECT *
- FROM host
- WHERE id IN(' . implode(',', $warn_hosts) . ')
- AND deleted = ""');
-
- if (cacti_sizeof($hosts)) {
- foreach ($hosts as $host) {
- $body .= '' . PHP_EOL;
- $body .= '| ' . $host['description'] . ' | ' . PHP_EOL;
-
- $body .= '' . $criticalities[$host['monitor_criticality']] . ' | ' . PHP_EOL;
- $body .= '' . number_format_i18n($host['monitor_warn'],2) . ' ms | ' . PHP_EOL;
- $body .= '' . number_format_i18n($host['cur_time'],2) . ' ms | ' . PHP_EOL;
-
- $body_txt .=
- $host['description'] . "\t" .
- $criticalities[$host['monitor_criticality']] . "\t" .
- number_format_i18n($host['monitor_alert'],2) . " ms\t" .
- number_format_i18n($host['cur_time'],2) . ' ms' . PHP_EOL;
-
- $body .= '
' . PHP_EOL;
- }
- }
- $body .= '
' . PHP_EOL;
- }
-
- $output = '';
- $toutput = $body_txt;
- $report_tag = '';
- $theme = 'modern';
-
- monitor_debug('Loading Format File');
-
- $format_ok = reports_load_format_file(read_config_option('monitor_format_file'), $output, $report_tag, $theme);
-
- monitor_debug('Format File Loaded, Format is ' . ($format_ok ? 'Ok' : 'Not Ok') . ', Report Tag is ' . $report_tag);
-
- if ($format_ok) {
- if ($report_tag) {
- $output = str_replace('', $body, $output);
- } else {
- $output = $output . PHP_EOL . $body;
- }
- } else {
- $output = $body;
- }
-
- monitor_debug('HTML Processed');
-
- if (defined('CACTI_VERSION')) {
- $version = CACTI_VERSION;
- } else {
- $version = get_cacti_version();
- }
-
- $headers['User-Agent'] = 'Cacti-Monitor-v' . $version;
-
- $status = (cacti_sizeof($alert_hosts) ? sizeof($alert_hosts) . ' Alert Notifications' : '') .
- (cacti_sizeof($warn_hosts) ? (cacti_sizeof($alert_hosts) ? ', and ' : '') .
- sizeof($warn_hosts) . ' Warning Notifications' : '');
-
- process_send_email($email, $subject, $output, $toutput, $headers, $status);
- }
-}
-
-function process_send_email($email, $subject, $output, $toutput, $headers, $status) {
- $from_email = read_config_option('monitor_fromemail');
-
- if ($from_email == '') {
- $from_email = read_config_option('settings_from_email');
-
- if ($from_email == '') {
- $from_email = 'Cacti@cacti.net';
- }
- }
-
- $from_name = read_config_option('monitor_fromname');
-
- if ($from_name != '') {
- $from_name = read_config_option('settings_from_name');
-
- if ($from_name == '') {
- $from_name = 'Cacti Reporting';
- }
- }
-
- $html = true;
-
- if (read_config_option('thold_send_text_only') == 'on') {
- $output = monitor_text($toutput);
- $html = false;
- }
-
- monitor_debug("Sending Email to '$email' for $status");
-
- $error = mailer(
- [$from_email, $from_name],
- $email,
- '',
- '',
- '',
- $subject,
- $output,
- monitor_text($toutput),
- null,
- $headers,
- $html
- );
-
- monitor_debug("The return from the mailer was '$error'");
-
- if (strlen($error)) {
- cacti_log("WARNING: Monitor had problems sending to '$email' for $status. The error was '$error'", false, 'MONITOR');
- } else {
- cacti_log("NOTICE: Email Notification Sent to '$email' for $status.", false, 'MONITOR');
- }
-}
-
-function monitor_text($output) {
- $output = explode(PHP_EOL, $output);
-
- $new_output = '';
-
- if (cacti_sizeof($output)) {
- foreach ($output as $line) {
- $line = str_replace('
', PHP_EOL, $line);
- $line = str_replace('
', PHP_EOL, $line);
- $line = trim(strip_tags($line));
- $new_output .= $line . PHP_EOL;
- }
- }
-
- return $new_output;
-}
-
-function log_messages($type, $alert_hosts) {
- global $start_date;
-
- static $processed = [];
-
- if ($type == 'warn') {
- $type = '0';
- $column = 'monitor_warn';
- } elseif ($type == 'alert') {
- $type = '1';
- $column = 'monitor_alert';
- }
-
- foreach ($alert_hosts as $id) {
- if (!isset($processed[$id])) {
- db_execute_prepared("INSERT INTO plugin_monitor_notify_history
- (host_id, notify_type, ping_time, ping_threshold, notification_time)
- SELECT id, '$type' AS notify_type, cur_time, $column, '$start_date' AS notification_time
- FROM host
- WHERE deleted = ''
- AND monitor = 'on'
- AND id = ?",
- [$id]);
- }
-
- $processed[$id] = true;
- }
-}
-
-function get_hosts_by_list_type($type, $criticality, &$global_list, &$notify_list, &$lists) {
- global $force;
-
- $last_time = date('Y-m-d H:i:s', time() - read_config_option('monitor_resend_frequency') * 60);
-
- $hosts = db_fetch_cell_prepared("SELECT COUNT(*)
- FROM host
- WHERE status = 3
- AND deleted = ''
- AND monitor = 'on'
- AND thold_send_email > 0
- AND monitor_criticality >= ?
- AND cur_time > monitor_$type",
- [$criticality]);
-
- if ($type == 'warn') {
- $htype = 1;
- } else {
- $htype = 0;
- }
-
- if ($hosts > 0) {
- $groups = db_fetch_assoc_prepared("SELECT
- thold_send_email, thold_host_email, GROUP_CONCAT(host.id) AS id
- FROM host
- LEFT JOIN (
- SELECT host_id, MAX(notification_time) AS notification_time
- FROM plugin_monitor_notify_history
- WHERE notify_type = ?
- GROUP BY host_id
- ) AS nh
- ON host.id=nh.host_id
- WHERE status = 3
- AND deleted = ''
- AND monitor = 'on'
- AND thold_send_email > 0
- AND monitor_criticality >= ?
- AND cur_time > monitor_$type " . ($type == 'warn' ? ' AND cur_time < monitor_alert' : '') . '
- AND (notification_time < ? OR notification_time IS NULL)
- AND host.total_polls > 1
- GROUP BY thold_host_email, thold_send_email
- ORDER BY thold_host_email, thold_send_email',
- [$htype, $criticality, $last_time]);
-
- if (cacti_sizeof($groups)) {
- foreach ($groups as $entry) {
- switch($entry['thold_send_email']) {
- case '1': // Global List
- $global_list[$type][] = $entry;
-
- break;
- case '2': // Notification List
- if ($entry['thold_host_email'] > 0) {
- $notify_list[$type][$entry['thold_host_email']][] = $entry;
- $lists[$entry['thold_host_email']] = $entry['thold_host_email'];
- }
-
- break;
- case '3': // Both Notification and Global
- $global_list[$type][] = $entry;
-
- if ($entry['thold_host_email'] > 0) {
- $notify_list[$type][$entry['thold_host_email']][] = $entry;
- $lists[$entry['thold_host_email']] = $entry['thold_host_email'];
- }
-
- break;
- }
- }
- }
- }
-}
-
-function flatten_lists(&$global_list, &$notify_list) {
- if (cacti_sizeof($global_list)) {
- foreach ($global_list as $severity => $list) {
- foreach ($list as $item) {
- $new_global[$severity] = (isset($new_global[$severity]) ? $new_global[$severity] . ',' : '') . $item['id'];
- }
- }
- $global_list = $new_global;
- }
-
- if (cacti_sizeof($notify_list)) {
- foreach ($notify_list as $severity => $lists) {
- foreach ($lists as $id => $list) {
- foreach ($list as $item) {
- $new_list[$severity][$id] = (isset($new_list[$severity][$id]) ? $new_list[$severity][$id] . ',' : '') . $item['id'];
- }
- }
- }
- $notify_list = $new_list;
- }
-}
-
-function get_emails_and_lists($lists) {
- $notification_emails = [];
-
- $alert_email = read_config_option('alert_email');
-
- if ($alert_email != '') {
- $global_emails = explode(',', $alert_email);
- } else {
- $global_emails = [];
- }
-
- if (cacti_sizeof($global_emails)) {
- foreach ($global_emails as $index => $user) {
- if (trim($user) != '') {
- $notification_emails[trim($user)]['global'] = true;
- }
- }
- }
-
- if (cacti_sizeof($lists)) {
- $list_emails = db_fetch_assoc('SELECT id, emails
- FROM plugin_notification_lists
- WHERE id IN (' . implode(',', $lists) . ')');
-
- if (cacti_sizeof($list_emails)) {
- foreach ($list_emails as $email) {
- $emails = explode(',', $email['emails']);
-
- foreach ($emails as $user) {
- if (trim($user) != '') {
- $notification_emails[trim($user)][$email['id']] = true;
- }
- }
- }
- }
- }
-
- return $notification_emails;
-}
-
-function purge_event_records() {
- // Purge old records
- $days = read_config_option('monitor_log_storage');
-
- if (empty($days)) {
- $days = 120;
- }
-
- db_execute_prepared('DELETE FROM plugin_monitor_notify_history
- WHERE notification_time < FROM_UNIXTIME(UNIX_TIMESTAMP() - (? * 86400))',
- [$days]);
-
- $purge_n = db_affected_rows();
-
- db_execute_prepared('DELETE FROM plugin_monitor_reboot_history
- WHERE log_time < FROM_UNIXTIME(UNIX_TIMESTAMP() - (? * 86400))',
- [$days]);
-
- $purge_r = db_affected_rows();
-
- return [$purge_n, $purge_r];
-}
-
-function monitor_debug($message) {
- global $debug;
-
- if ($debug) {
- print trim($message) . PHP_EOL;
- }
-}
-
-function display_version() {
- global $config;
-
- if (!function_exists('plugin_monitor_version')) {
- include_once($config['base_path'] . '/plugins/monitor/setup.php');
- }
-
- $info = plugin_monitor_version();
- print 'Cacti Monitor Poller, Version ' . $info['version'] . ', ' . COPYRIGHT_YEARS . PHP_EOL;
-}
-
-/*
- * display_help
- * displays the usage of the function
- */
-function display_help() {
- display_version();
-
- print PHP_EOL;
- print 'usage: poller_monitor.php [--force] [--debug]' . PHP_EOL . PHP_EOL;
- print ' --force - force execution, e.g. for testing' . PHP_EOL;
- print ' --debug - debug execution, e.g. for testing' . PHP_EOL . PHP_EOL;
-}
diff --git a/setup.php b/setup.php
index 8304a92..283d533 100644
--- a/setup.php
+++ b/setup.php
@@ -215,7 +215,7 @@ function monitor_check_upgrade() {
db_execute('ALTER TABLE plugin_monitor_uptime
MODIFY COLUMN uptime BIGINT unsigned NOT NULL default "0"');
- api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor_icon', 'type' => 'varchar(30)', 'NULL' => false, 'default' => '', 'after' => 'monitor_alert']);
+ api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor_icon', 'type' => 'varchar(30)', 'NULL' => false, 'default' => '']);
if (function_exists('api_plugin_upgrade_register')) {
api_plugin_upgrade_register('monitor');
@@ -1091,12 +1091,27 @@ function monitor_setup_table() {
COMMENT='Stores predefined dashboard information for a user or users'");
}
- api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor', 'type' => 'char(3)', 'NULL' => true, 'default' => 'on', 'after' => 'disabled']);
- api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor_text', 'type' => 'varchar(1024)', 'default' => '', 'NULL' => false, 'after' => 'monitor']);
- api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor_criticality', 'type' => 'tinyint', 'unsigned' => true, 'NULL' => false, 'default' => '0', 'after' => 'monitor_text']);
- api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor_warn', 'type' => 'double', 'NULL' => false, 'default' => '0', 'after' => 'monitor_criticality']);
- api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor_alert', 'type' => 'double', 'NULL' => false, 'default' => '0', 'after' => 'monitor_warn']);
- api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor_icon', 'type' => 'varchar(30)', 'NULL' => false, 'default' => '', 'after' => 'monitor_alert']);
+ if (db_table_exists('host')) {
+ $row_format = db_fetch_cell("SELECT ROW_FORMAT
+ FROM information_schema.tables
+ WHERE TABLE_SCHEMA = DATABASE()
+ AND TABLE_NAME = 'host'");
+
+ if (strtoupper((string) $row_format) !== 'DYNAMIC') {
+ db_execute('ALTER TABLE host ROW_FORMAT=DYNAMIC');
+ }
+ }
+
+ db_execute('SET SESSION innodb_strict_mode=0');
+
+ api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor', 'type' => 'char(3)', 'NULL' => true, 'default' => 'on']);
+ api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor_text', 'type' => 'text', 'NULL' => false]);
+ api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor_criticality', 'type' => 'tinyint', 'unsigned' => true, 'NULL' => false, 'default' => '0']);
+ api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor_warn', 'type' => 'double', 'NULL' => false, 'default' => '0']);
+ api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor_alert', 'type' => 'double', 'NULL' => false, 'default' => '0']);
+ api_plugin_db_add_column('monitor', 'host', ['name' => 'monitor_icon', 'type' => 'varchar(30)', 'NULL' => false, 'default' => '']);
+
+ db_execute('SET SESSION innodb_strict_mode=1');
}
function monitor_poller_bottom() {
diff --git a/sonar-project.properties b/sonar-project.properties
new file mode 100644
index 0000000..5ed8db9
--- /dev/null
+++ b/sonar-project.properties
@@ -0,0 +1,10 @@
+sonar.projectKey=plugin_monitor
+sonar.sources=.
+sonar.exclusions=vendor/**
+
+# php:S4833 - "Use namespaces instead of include/require"
+# This is a Cacti plugin with a required procedural architecture.
+# Namespaces cannot be used; include_once is the correct and only mechanism.
+sonar.issue.ignore.multicriteria=e1
+sonar.issue.ignore.multicriteria.e1.ruleKey=php:S4833
+sonar.issue.ignore.multicriteria.e1.resourceKey=**/*.php
diff --git a/sounds/index.php b/sounds/index.php
index 828ecbe..362957c 100644
--- a/sounds/index.php
+++ b/sounds/index.php
@@ -1,4 +1,5 @@