<?php
/**
 * Observium
 *
 *   This file is part of Observium.
 *
 * @package    observium
 * @subpackage poller
 * @copyright  (C) Adam Armstrong
 *
 */

$table_rows = [];

// Pre-cache all processors oid
$sql = 'SELECT `processor_oid` FROM `processors` WHERE `device_id` = ? AND `processor_oid` REGEXP ? AND `processor_type` != ?';

// wmi excluded, select only valid numeric OIDs like .1.2.3.3 (excluded ucd-old, hr-average)
if ($oid_to_cache = dbFetchColumn($sql, [ $device['device_id'], '^\.?[0-9]+(\.[0-9]+)+$', 'wmi' ])) {
    usort($oid_to_cache, 'compare_numeric_oids'); // correctly sort numeric oids
    print_debug_vars($oid_to_cache);

    $oid_cache = snmp_get_multi_oid($device, $oid_to_cache, $oid_cache, NULL, NULL, OBS_SNMP_ALL_NUMERIC);
    print_debug_vars($oid_cache);
    $cache_polled = snmp_endtime();
}

$sql = "SELECT * FROM `processors` WHERE `device_id` = ?";

foreach (dbFetchRows($sql, [ $device['device_id'] ]) as $processor) {
    // echo("Processor " . $processor['processor_descr'] . " ");

    $processor['processor_oid'] = '.' . ltrim($processor['processor_oid'], '.'); // Fix first dot in oid

    $file = $config['install_dir'] . "/includes/polling/processors/" . $processor['processor_type'] . ".inc.php";
    unset($proc_polled);
    if (is_file($file)) {
        include($file);
        if (!isset($proc_polled)) {
            // prefer more accurate time when required (see ucd-raw)
            $proc_polled = time();
        }
    } elseif (isset($oid_cache[$processor['processor_oid']])) {
        // Use cached OIDs
        $proc = $oid_cache[$processor['processor_oid']];
        $proc_polled = $cache_polled;
    } else {
        // Not should be happening, but keep it as last anyway
        $proc = snmp_get_oid($device, $processor['processor_oid']);
        $proc_polled = snmp_endtime();
    }

    $unit = NULL;

    // Definition-based poller
    if (!empty($processor['processor_mib']) && !empty($processor['processor_object']) &&
        isset($config['mibs'][$processor['processor_mib']]['processor'][$processor['processor_object']])) {

        $def = $config['mibs'][$processor['processor_mib']]['processor'][$processor['processor_object']];
        // Units, see: LANCOM-GS2310PPLUS-MIB
        $unit = $def['unit'] ?? NULL;
    }

    $proc = snmp_fix_numeric($proc, $unit);

    if (is_numeric($proc)) {
        if (!$processor['processor_precision']) {
            $processor['processor_precision'] = 1;
        }
        $proc = round($proc / $processor['processor_precision'], 2);
        if ($processor['processor_returns_idle'] == 1) {
            $proc = 100 - $proc;
        } // The OID returns idle value, so we subtract it from 100.
    } else {
        $proc = 0;
    }
    $processor['processor_usage'] = $proc;

    $graphs['processor'] = TRUE;

    // Update StatsD/Carbon
    if ($config['statsd']['enable'] == TRUE) {
        StatsD ::gauge(str_replace(".", "_", $device['hostname']) . '.' . 'processor' . '.' . $processor['processor_type'] . "-" . $processor['processor_index'], $proc);
    }

    // Update RRD
    rrdtool_update_ng($device, 'processor', [ 'usage' => $proc ], get_processor_rrd($device, $processor, FALSE));

    // Update SQL State
    dbUpdate([ 'processor_usage' => $proc, 'processor_polled' => $proc_polled ], 'processors', '`processor_id` = ?', [ $processor['processor_id'] ]);

    // Check alerts
    check_entity('processor', $processor, [ 'processor_usage' => $proc ]);

    $table_row    = [];
    $table_row[]  = $processor['processor_descr'];
    $table_row[]  = $processor['processor_type'];
    $table_row[]  = $processor['processor_index'];
    $table_row[]  = $processor['processor_usage'] . '%';
    $table_rows[] = $table_row;
    unset($table_row);

}

$headers = ['%WLabel%n', '%WType%n', '%WIndex%n', '%WUsage%n'];
print_cli_table($table_rows, $headers);

// EOF