pandorafms/pandora_console/include/functions_servers.php

<?php
/**
 * Auxiliary functions to manage servers.
 *
 * @category   Library
 * @package    Pandora FMS
 * @subpackage Opensource
 * @version    1.0.0
 * @license    See below
 *
 *    ______                 ___                    _______ _______ ________
 * |   __ \.-----.--.--.--|  |.-----.----.-----. |    ___|   |   |     __|
 * |    __/|  _  |     |  _  ||  _  |   _|  _  | |    ___|       |__     |
 * |___|   |___._|__|__|_____||_____|__| |___._| |___|   |__|_|__|_______|
 *
 * ============================================================================
 * Copyright (c) 2005-2023 Pandora FMS
 * Please see https://pandorafms.com/community/ for full contribution list
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation for version 2.
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 * ============================================================================
 */

require_once __DIR__.'/constants.php';


/**
 * Get a server.
 *
 * @param integer $id_server Server id to get.
 * @param array   $filter    Extra filter.
 * @param array   $fields    Fields to get.
 *
 * @return Server with the given id. False if not available.
 */
function servers_get_server($id_server, $filter=false, $fields=false)
{
    if (empty($id_server)) {
        return false;
    }

    if (! is_array($filter)) {
        $filter = [];
    }

    $filter['id_server'] = $id_server;

    return @db_get_row_filter('tserver', $filter, $fields);
}


/**
 * Get all the server availables.
 *
 * @return array the servers available.
 */
function servers_get_names()
{
    $all_servers = db_get_all_rows_sql(
        'SELECT DISTINCT(`name`) as name
        FROM tserver
        WHERE server_type <> 13'
    );

    if ($all_servers === false) {
        return [];
    }

    $servers = [];
    foreach ($all_servers as $server) {
        $servers[$server['name']] = $server['name'];
    }

    return $servers;
}


/**
 * This function forces a recon task to be queued by the server asap.
 *
 * @param integer $id_recon_task Id.
 *
 * @return void
 */
function servers_force_recon_task($id_recon_task)
{
    $values = [
        'utimestamp' => 0,
        'status'     => 1,
    ];
    db_process_sql_update('trecon_task', $values, ['id_rt' => $id_recon_task]);
}


/**
 * Retrieves total number of modules per server.
 *
 * @return array Modules per server (total).
 */
function servers_get_total_modules()
{
    $modules = [];

    $modules_from_monitors = db_get_all_rows_sql(
        'SELECT
          tserver.server_type,
          count(tagente_estado.id_agente_modulo) as modules_assigned
        FROM tserver, tagente_estado, tagente_modulo, tagente
        WHERE tagente.disabled=0
          AND tagente_modulo.id_agente = tagente.id_agente
          AND tagente_modulo.disabled = 0
          AND tagente_modulo.id_agente_modulo = tagente_estado.id_agente_modulo
          AND tagente_estado.running_by = tserver.id_server
        GROUP BY tserver.server_type;'
    );

    if ($modules_from_monitors !== false) {
        $modules = array_reduce(
            $modules_from_monitors,
            function ($carry, $item) {
                $carry[$item['server_type']] = $item['modules_assigned'];
                return $carry;
            }
        );
    }

    $modules[SERVER_TYPE_INVENTORY] = db_get_sql(
        'SELECT COUNT(tagent_module_inventory.id_agent_module_inventory)
        FROM tagente, tagent_module_inventory
        WHERE tagente.disabled=0
          AND tagent_module_inventory.id_agente = tagente.id_agente'
    );

    $modules[SERVER_TYPE_EXPORT] = db_get_sql(
        'SELECT COUNT(tagente_modulo.id_agente_modulo)
        FROM tagente, tagente_modulo
        WHERE tagente.disabled=0
          AND tagente_modulo.id_agente = tagente.id_agente
          AND tagente_modulo.id_export != 0'
    );

    return $modules;

}


/**
 * This function will get several metrics from the database
 * to get info about server performance.
 *
 * @return array with several data.
 */
function servers_get_performance($filter=[])
{
    global $config;

    if (empty($filter) === false && empty($filter['groups']) === false && $filter['groups'] !== 0) {
        $filter_group = 'AND tagente.id_grupo IN ('.$filter['groups'].')';
    } else {
        $filter_group = '';
    }

    $data = [];
    $data['total_modules'] = 0;
    $data['total_remote_modules'] = 0;
    $data['total_local_modules'] = 0;
    $data['avg_interval_total_modules'] = [];
    $data['avg_interval_remote_modules'] = [];
    $data['avg_interval_local_modules'] = 0;
    $data['local_modules_rate'] = 0;
    $data['network_modules_rate'] = 0;

    if ($config['realtimestats'] == 1) {
        if (is_metaconsole() === true) {
            $counts = [];
            $servers = metaconsole_get_servers();

            // Check if the group can be deleted or not.
            if (isset($servers) === true
                && is_array($servers) === true
            ) {
                foreach ($servers as $server) {
                    if (metaconsole_connect($server) == NOERR) {
                        $meta_counts = db_get_all_rows_sql(
                            'SELECT tagente_modulo.id_modulo,
                                COUNT(tagente_modulo.id_agente_modulo) modules
                            FROM tagente_modulo, tagente_estado, tagente
                            WHERE tagente_modulo.id_agente_modulo = tagente_estado.id_agente_modulo
                                AND tagente.id_agente = tagente_estado.id_agente
                                AND tagente_modulo.disabled = 0
                                        AND tagente_modulo.id_modulo <> 0
                                AND delete_pending = 0
                                AND tagente.disabled = 0 
                                '.$filter_group.' 
                                GROUP BY tagente_modulo.id_modulo'
                        );
                        foreach ($meta_counts as $key => $val) {
                            if (array_key_exists($key, $counts)) {
                                if ($meta_counts[$key]['id_modulo'] == $counts[$key]['id_modulo']) {
                                    $counts[$key]['modules'] += $meta_counts[$key]['modules'];
                                }
                            } else {
                                $counts[$key] = $meta_counts[$key];
                            }
                        }
                    }

                    metaconsole_restore_db();
                }
            }
        } else {
            $counts = db_get_all_rows_sql(
                'SELECT tagente_modulo.id_modulo,
                    COUNT(tagente_modulo.id_agente_modulo) modules
                FROM tagente_modulo, tagente_estado, tagente
                WHERE tagente_modulo.id_agente_modulo = tagente_estado.id_agente_modulo
                    AND tagente.id_agente = tagente_estado.id_agente
                    AND tagente_modulo.disabled = 0
                            AND tagente_modulo.id_modulo <> 0
                    AND delete_pending = 0
                    AND tagente.disabled = 0 
                    '.$filter_group.' 
                    GROUP BY tagente_modulo.id_modulo'
            );
        }

        if (empty($counts)) {
            $counts = [];
        }

        foreach ($counts as $c) {
            switch ($c['id_modulo']) {
                case MODULE_DATA:
                    $data['total_local_modules'] = $c['modules'];
                break;

                case MODULE_NETWORK:
                    $data['total_network_modules'] = $c['modules'];
                break;

                case MODULE_PLUGIN:
                    $data['total_plugin_modules'] = $c['modules'];
                break;

                case MODULE_PREDICTION:
                    $data['total_prediction_modules'] = $c['modules'];
                break;

                case MODULE_WMI:
                    $data['total_wmi_modules'] = $c['modules'];
                break;

                case MODULE_WEB:
                    $data['total_web_modules'] = $c['modules'];
                break;

                default:
                    // Not possible.
                break;
            }

            if ($c['id_modulo'] != MODULE_DATA) {
                $data['total_remote_modules'] += $c['modules'];
            }

            $data['total_modules'] += $c['modules'];
        }
    } else {
        $counts = db_get_all_rows_sql(
            '
			SELECT server_type, my_modules modules
			FROM tserver
			GROUP BY server_type'
        );

        if (empty($counts)) {
            $counts = [];
        }

        foreach ($counts as $c) {
            if (empty($c['modules']) === true) {
                continue;
            }

            switch ($c['server_type']) {
                case SERVER_TYPE_DATA:
                    $data['total_local_modules'] = $c['modules'];
                break;

                case SERVER_TYPE_NETWORK:
                case SERVER_TYPE_SNMP:
                case SERVER_TYPE_ENTERPRISE_ICMP:
                case SERVER_TYPE_ENTERPRISE_SNMP:
                    $data['total_network_modules'] += $c['modules'];
                break;

                case SERVER_TYPE_PLUGIN:
                    $data['total_plugin_modules'] = $c['modules'];
                break;

                case SERVER_TYPE_PREDICTION:
                    $data['total_prediction_modules'] = $c['modules'];
                break;

                case SERVER_TYPE_WMI:
                    $data['total_wmi_modules'] = $c['modules'];
                break;

                case SERVER_TYPE_WEB:
                    $data['total_web_modules'] = $c['modules'];
                break;

                case SERVER_TYPE_EXPORT:
                case SERVER_TYPE_INVENTORY:
                case SERVER_TYPE_EVENT:
                case SERVER_TYPE_DISCOVERY:
                case SERVER_TYPE_SYSLOG:
                default:
                    // Nothing.
                break;
            }

            if ($c['server_type'] != SERVER_TYPE_DATA) {
                $data['total_remote_modules'] += $c['modules'];
            }

            $data['total_modules'] += $c['modules'];
        }
    }

    $interval_avgs = [];
    if (is_metaconsole() === true) {
        $interval_avgs_modules = [];
        $servers = metaconsole_get_servers();

        // Check if the group can be deleted or not.
        if (isset($servers) === true
            && is_array($servers) === true
        ) {
            foreach ($servers as $server) {
                if (metaconsole_connect($server) == NOERR) {
                    // Avg of modules interval when modules have module_interval > 0.
                    $meta_interval_avgs_modules = db_get_all_rows_sql(
                        'SELECT count(tagente_modulo.id_modulo) modules ,
                            tagente_modulo.id_modulo,
                            AVG(tagente_modulo.module_interval) avg_interval
                        FROM tagente_modulo, tagente_estado, tagente
                        WHERE tagente_modulo.id_agente_modulo = tagente_estado.id_agente_modulo
                            AND tagente_modulo.disabled = 0
                            AND module_interval > 0
                            AND (utimestamp > 0 OR (
                                    id_tipo_modulo = 100
                                    OR (id_tipo_modulo > 21
                                        AND id_tipo_modulo < 23
                                    )
                                )
                            )
                            AND delete_pending = 0
                            AND tagente.disabled = 0
                            AND tagente.id_agente = tagente_estado.id_agente
                        GROUP BY tagente_modulo.id_modulo'
                    );

                    foreach ($meta_interval_avgs_modules as $key => $val) {
                        if (array_key_exists($key, $interval_avgs_modules)) {
                            if ($meta_interval_avgs_modules[$key]['id_modulo'] == $interval_avgs_modules[$key]['id_modulo']) {
                                $interval_avgs_modules[$key]['modules'] += $meta_interval_avgs_modules[$key]['modules'];
                                $interval_avgs_modules[$key]['avg_interval'] += $meta_interval_avgs_modules[$key]['avg_interval'];
                            }
                        } else {
                            $interval_avgs_modules[$key] = $meta_interval_avgs_modules[$key];
                        }
                    }
                }

                metaconsole_restore_db();
            }
        }
    } else {
        // Avg of modules interval when modules have module_interval > 0.
        $interval_avgs_modules = db_get_all_rows_sql(
            'SELECT count(tagente_modulo.id_modulo) modules ,
                tagente_modulo.id_modulo,
                AVG(tagente_modulo.module_interval) avg_interval
            FROM tagente_modulo, tagente_estado, tagente
            WHERE tagente_modulo.id_agente_modulo = tagente_estado.id_agente_modulo
                AND tagente_modulo.disabled = 0
                AND module_interval > 0
                AND (utimestamp > 0 OR (
                        id_tipo_modulo = 100
                        OR (id_tipo_modulo > 21
                            AND id_tipo_modulo < 23
                        )
                    )
                )
                AND delete_pending = 0
                AND tagente.disabled = 0
                AND tagente.id_agente = tagente_estado.id_agente
            GROUP BY tagente_modulo.id_modulo'
        );
    }

    if (empty($interval_avgs_modules)) {
        $interval_avgs_modules = [];
    }

    // Transform into a easily format.
    foreach ($interval_avgs_modules as $iamodules) {
        $interval_avgs[$iamodules['id_modulo']]['avg_interval'] = $iamodules['avg_interval'];
        $interval_avgs[$iamodules['id_modulo']]['modules'] = $iamodules['modules'];
    }

    // Avg of agents interval when modules have module_interval == 0.
    $interval_avgs_agents = db_get_all_rows_sql(
        'SELECT count(tagente_modulo.id_modulo) modules ,
			tagente_modulo.id_modulo, AVG(tagente.intervalo) avg_interval
		FROM tagente_modulo, tagente_estado, tagente
		WHERE tagente_modulo.id_agente_modulo = tagente_estado.id_agente_modulo
			AND tagente_modulo.disabled = 0
			AND module_interval = 0
			AND (utimestamp > 0 OR (id_tipo_modulo = 100 OR (id_tipo_modulo >= 21 AND id_tipo_modulo <= 23)))
			AND delete_pending = 0
			AND tagente.disabled = 0
			AND tagente.id_agente = tagente_estado.id_agente
		GROUP BY tagente_modulo.id_modulo'
    );

    if (empty($interval_avgs_agents)) {
        $interval_avgs_agents = [];
    }

    // Merge with the previous calculated array.
    foreach ($interval_avgs_agents as $iaagents) {
        if (!isset($interval_avgs[$iaagents['id_modulo']]['modules'])) {
            $interval_avgs[$iaagents['id_modulo']]['avg_interval'] = $iaagents['avg_interval'];
            $interval_avgs[$iaagents['id_modulo']]['modules'] = $iaagents['modules'];
        } else {
            $interval_avgs[$iaagents['id_modulo']]['avg_interval'] = servers_get_avg_interval(
                $interval_avgs[$iaagents['id_modulo']],
                $iaagents
            );
            $interval_avgs[$iaagents['id_modulo']]['modules'] += $iaagents['modules'];
        }
    }

    $info_servers = array_reduce(
        servers_get_info(),
        function ($carry, $item) {
            $carry[$item['server_type']] = $item;
            return $carry;
        }
    );
    foreach ($interval_avgs as $id_modulo => $ia) {
        $module_lag = 0;
        switch ($id_modulo) {
            case MODULE_DATA:
                $module_lag = $info_servers[SERVER_TYPE_DATA]['module_lag'];
                $data['avg_interval_local_modules'] = $ia['avg_interval'];
                $data['local_modules_rate'] = servers_get_rate(
                    $data['avg_interval_local_modules'],
                    ($data['total_local_modules'] - $module_lag)
                );
            break;

            case MODULE_NETWORK:
                $module_lag = $info_servers[SERVER_TYPE_NETWORK]['module_lag'];
                $module_lag += $info_servers[SERVER_TYPE_SNMP]['module_lag'];
                $module_lag += $info_servers[SERVER_TYPE_ENTERPRISE_ICMP]['module_lag'];
                $module_lag += $info_servers[SERVER_TYPE_ENTERPRISE_SNMP]['module_lag'];
                $data['avg_interval_network_modules'] = $ia['avg_interval'];
                $data['network_modules_rate'] = servers_get_rate(
                    $data['avg_interval_network_modules'],
                    ($data['total_network_modules'] - $module_lag)
                );
            break;

            case MODULE_PLUGIN:
                $module_lag = $info_servers[SERVER_TYPE_PLUGIN]['module_lag'];
                $data['avg_interval_plugin_modules'] = $ia['avg_interval'];
                $data['plugin_modules_rate'] = servers_get_rate(
                    $data['avg_interval_plugin_modules'],
                    ($data['total_plugin_modules'] - $module_lag)
                );
            break;

            case MODULE_PREDICTION:
                $module_lag = $info_servers[SERVER_TYPE_PREDICTION]['module_lag'];
                $data['avg_interval_prediction_modules'] = $ia['avg_interval'];
                $data['prediction_modules_rate'] = servers_get_rate(
                    $data['avg_interval_prediction_modules'],
                    ($data['total_prediction_modules'] - $module_lag)
                );
            break;

            case MODULE_WMI:
                $module_lag = $info_servers[SERVER_TYPE_WMI]['module_lag'];
                $data['avg_interval_wmi_modules'] = $ia['avg_interval'];
                $data['wmi_modules_rate'] = servers_get_rate(
                    $data['avg_interval_wmi_modules'],
                    ($data['total_wmi_modules'] - $module_lag)
                );
            break;

            case MODULE_WEB:
                $module_lag = $info_servers[SERVER_TYPE_WEB]['module_lag'];
                $data['avg_interval_web_modules'] = $ia['avg_interval'];
                $data['web_modules_rate'] = servers_get_rate(
                    $data['avg_interval_web_modules'],
                    ($data['total_web_modules'] - $module_lag)
                );
            break;

            default:
                // Not possible.
            break;
        }

        if ($id_modulo != MODULE_DATA) {
            $data['avg_interval_remote_modules'][] = $ia['avg_interval'];
        }

        $data['avg_interval_total_modules'][] = $ia['avg_interval'];
    }

    if (empty($data['avg_interval_remote_modules'])) {
        $data['avg_interval_remote_modules'] = 0;
    } else {
        $data['avg_interval_remote_modules'] = (array_sum($data['avg_interval_remote_modules']) / count($data['avg_interval_remote_modules']));
    }

    if (empty($data['avg_interval_total_modules'])) {
        $data['avg_interval_total_modules'] = 0;
    } else {
        $data['avg_interval_total_modules'] = (array_sum($data['avg_interval_total_modules']) / count($data['avg_interval_total_modules']));
    }

    $total_modules_lag = 0;
    foreach ($info_servers as $key => $value) {
        switch ($key) {
            case SERVER_TYPE_DATA:
            case SERVER_TYPE_NETWORK:
            case SERVER_TYPE_SNMP:
            case SERVER_TYPE_ENTERPRISE_ICMP:
            case SERVER_TYPE_ENTERPRISE_SNMP:
            case SERVER_TYPE_PLUGIN:
            case SERVER_TYPE_PREDICTION:
            case SERVER_TYPE_WMI:
            case SERVER_TYPE_WEB:
                $total_modules_lag += $value['module_lag'];
            break;

            default:
                // Not possible.
            break;
        }
    }

    $data['remote_modules_rate'] = servers_get_rate(
        $data['avg_interval_remote_modules'],
        $data['total_remote_modules']
    );

    $data['total_modules_rate'] = servers_get_rate(
        $data['avg_interval_total_modules'],
        ($data['total_modules'] - $total_modules_lag)
    );

    return ($data);
}


/**
 * Get avg interval.
 *
 * @param array $modules_avg_interval1 Array with avg and count
 * data of first part.
 * @param array $modules_avg_interval2 Array with avg and count
 * data of second part.
 *
 * @return float number of avg modules between two parts.
 */
function servers_get_avg_interval(
    $modules_avg_interval1,
    $modules_avg_interval2
) {
    $total_modules = ($modules_avg_interval1['modules'] + $modules_avg_interval2['modules']);

    $parcial1 = ($modules_avg_interval1['avg_interval'] * $modules_avg_interval1['modules']);
    $parcial2 = ($modules_avg_interval2['avg_interval'] * $modules_avg_interval2['modules']);

    return (($parcial1 + $parcial2) / $total_modules);
}


/**
 * Get server rate
 *
 * @param float   $avg_interval Avg of interval of these modules.
 * @param integer $num_modules  Number of modules.
 *
 * @return float number of modules processed by second
 */
function servers_get_rate($avg_interval, $num_modules)
{
    return ($avg_interval > 0) ? ($num_modules / $avg_interval) : 0;
}


/**
 * This function will get all the server information in an array
 * or a specific server.
 *
 * @param integer|array $id_server An optional integer or array of integers
 * to select specific servers.
 *
 * @return mixed False in case the server doesn't exist or an array with info.
 */
function servers_get_info($id_server=-1, $sql_limit=-1)
{
    global $config;

    $select_id = '';
    if (is_array($id_server) === true) {
        $select_id = ' AND id_server IN ('.implode(',', $id_server).')';
    } else if ($id_server > 0) {
        $select_id = ' AND id_server IN ('.(int) $id_server.')';
    }

    $types_sql = sprintf(
        ' AND (
            `server_type` != %d AND 
            `server_type` != %d
        )',
        SERVER_TYPE_AUTOPROVISION,
        SERVER_TYPE_MIGRATION
    );
    if (is_metaconsole() === true && isset($config['ndbh']) === false) {
        $types_sql = sprintf(
            ' AND (
                `server_type` = %d OR 
                `server_type` = %d OR 
                `server_type` = %d OR 
                `server_type` = %d
            )',
            SERVER_TYPE_AUTOPROVISION,
            SERVER_TYPE_EVENT,
            SERVER_TYPE_MIGRATION,
            SERVER_TYPE_PREDICTION
        );
    }

    $sql = sprintf(
        'SELECT *
		FROM tserver
        WHERE 1=1
        %s
        %s
		ORDER BY server_type',
        $select_id,
        $types_sql
    );

    if ($sql_limit !== -1) {
        $sql = sprintf(
            'SELECT *
		    FROM tserver
            WHERE 1=1
            %s
            %s
		    ORDER BY server_type
            %s',
            $select_id,
            $types_sql,
            $sql_limit
        );
    }

    $result = db_get_all_rows_sql($sql);

    if (empty($result)) {
        return false;
    }

    $return = [];
    foreach ($result as $server) {
        switch ($server['server_type']) {
            case SERVER_TYPE_DATA:
                $server['img'] = html_print_image(
                    'images/data-server@svg.svg',
                    true,
                    [
                        'title' => __('Data server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'data';
                $id_modulo = 1;
                $server['server_name'] = __('Data server');
            break;

            case SERVER_TYPE_NETWORK:
                $server['img'] = html_print_image(
                    'images/network-server@os.svg',
                    true,
                    [
                        'title' => __('Network server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'network';
                $id_modulo = 2;
                $server['server_name'] = __('Network server');
            break;

            case SERVER_TYPE_SNMP:
                $server['img'] = html_print_image(
                    'images/snmp-trap@svg.svg',
                    true,
                    [
                        'title' => __('SNMP Trap server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'snmp';
                $id_modulo = 0;
                $server['server_name'] = __('SNMP Trap server');
            break;

            case SERVER_TYPE_DISCOVERY:
                $server['img'] = html_print_image(
                    'images/rrs@svg.svg',
                    true,
                    [
                        'title' => __('Discovery server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'recon';
                $id_modulo = 0;
                $server['server_name'] = __('Discovery server');
            break;

            case SERVER_TYPE_PLUGIN:
                $server['img'] = html_print_image(
                    'images/plugins@svg.svg',
                    true,
                    [
                        'title' => __('Plugin server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'plugin';
                $id_modulo = 4;
                $server['server_name'] = __('Plugin server');
            break;

            case SERVER_TYPE_PREDICTION:
                $server['img'] = html_print_image(
                    'images/prediction@svg.svg',
                    true,
                    [
                        'title' => __('Prediction server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'prediction';
                $id_modulo = 5;
                $server['server_name'] = __('Prediction server');
            break;

            case SERVER_TYPE_WMI:
                $server['img'] = html_print_image(
                    'images/WMI@svg.svg',
                    true,
                    [
                        'title' => __('WMI server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'wmi';
                $id_modulo = 6;
                $server['server_name'] = __('WMI server');
            break;

            case SERVER_TYPE_EXPORT:
                $server['img'] = html_print_image(
                    'images/server-export@svg.svg',
                    true,
                    [
                        'title' => __('Export server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'export';
                $id_modulo = 0;
                $server['server_name'] = __('Export server');
            break;

            case SERVER_TYPE_INVENTORY:
                $server['img'] = html_print_image(
                    'images/hardware-software-component@svg.svg',
                    true,
                    [
                        'title' => __('Inventory server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'inventory';
                $id_modulo = 0;
                $server['server_name'] = __('Inventory server');
            break;

            case SERVER_TYPE_WEB:
                $server['img'] = html_print_image(
                    'images/server-web@svg.svg',
                    true,
                    [
                        'title' => __('Web server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'web';
                $id_modulo = 0;
                $server['server_name'] = __('Web server');
            break;

            case SERVER_TYPE_EVENT:
                $server['img'] = html_print_image(
                    'images/server-events@svg.svg',
                    true,
                    [
                        'title' => __('Event server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'event';
                $id_modulo = 2;
                $server['server_name'] = __('Event server');
            break;

            case SERVER_TYPE_CORRELATION:
                $server['img'] = html_print_image(
                    'images/server-events@svg.svg',
                    true,
                    [
                        'title' => __('Correlation server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'correlation';
                $id_modulo = 0;
                $server['server_name'] = __('Correlation server');
            break;

            case SERVER_TYPE_ENTERPRISE_ICMP:
                $server['img'] = html_print_image(
                    'images/network@svg.svg',
                    true,
                    [
                        'title' => __('Enterprise ICMP server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'enterprise icmp';
                $id_modulo = 2;
                $server['server_name'] = __('Enterprise ICMP server');
            break;

            case SERVER_TYPE_ENTERPRISE_SNMP:
                $server['img'] = html_print_image(
                    'images/network@svg.svg',
                    true,
                    [
                        'title' => __('Enterprise SNMP server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'enterprise snmp';
                $id_modulo = 2;
                $server['server_name'] = __('Enterprise SNMP server');
            break;

            case SERVER_TYPE_ENTERPRISE_SATELLITE:
                $server['img'] = html_print_image(
                    'images/satellite@os.svg',
                    true,
                    [
                        'title' => __('Enterprise Satellite server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'enterprise satellite';
                $id_modulo = 0;
                $server['server_name'] = __('Enterprise Satellite server');
            break;

            case SERVER_TYPE_ENTERPRISE_TRANSACTIONAL:
                $server['img'] = html_print_image(
                    'images/server-transactions@svg.svg',
                    true,
                    [
                        'title' => __('Enterprise Transactional server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'enterprise transactional';
                $id_modulo = 0;
                $server['server_name'] = __('Enterprise Transactional server');
            break;

            case SERVER_TYPE_MAINFRAME:
                $server['img'] = html_print_image(
                    'images/mainframe@os.svg',
                    true,
                    [
                        'title' => __('Mainframe server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'mainframe';
                $id_modulo = 0;
                $server['server_name'] = __('Mainframe server');
            break;

            case SERVER_TYPE_SYNC:
                $server['img'] = html_print_image(
                    'images/sync.png',
                    true,
                    [
                        'title' => __('Sync server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'sync';
                $id_modulo = 0;
                $server['server_name'] = __('Sync server');
            break;

            case SERVER_TYPE_WUX:
                $server['img'] = html_print_image(
                    'images/wux@svg.svg',
                    true,
                    [
                        'title' => __('Wux server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'wux';
                $id_modulo = 0;
                $server['server_name'] = __('Wux server');
            break;

            case SERVER_TYPE_SYSLOG:
                $server['img'] = html_print_image(
                    'images/logs@svg.svg',
                    true,
                    [
                        'title' => __('Syslog server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'syslog';
                $id_modulo = 0;
                $server['server_name'] = __('Syslog server');
            break;

            case SERVER_TYPE_NCM:
                $server['img'] = html_print_image(
                    'images/custom-input@svg.svg',
                    true,
                    [
                        'title' => __('NCM server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'ncm';
                $id_modulo = 0;
                $server['server_name'] = __('NCM server');
            break;

            case SERVER_TYPE_AUTOPROVISION:
                $server['img'] = html_print_image(
                    'images/autoprovision.png',
                    true,
                    [
                        'title' => __('Autoprovision server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'autoprovision';
                $id_modulo = 0;
                $server['server_name'] = __('Autoprovision server');
            break;

            case SERVER_TYPE_MIGRATION:
                $server['img'] = html_print_image(
                    'images/server-export@svg.svg',
                    true,
                    [
                        'title' => __('Migration server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'migration';
                $id_modulo = 0;
                $server['server_name'] = __('Migration server');
            break;

            case SERVER_TYPE_ALERT:
                $server['img'] = html_print_image(
                    'images/alert@svg.svg',
                    true,
                    [
                        'title' => __('Alert server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'alert';
                $id_modulo = 0;
                $server['server_name'] = __('Alert server');
            break;

            case SERVER_TYPE_NETFLOW:
                $server['img'] = html_print_image(
                    'images/Netflow2@svg.svg',
                    true,
                    [
                        'title' => __('Netflow server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'netflow';
                $id_modulo = 0;
                $server['server_name'] = __('Netflow server');
            break;

            case SERVER_TYPE_LOG:
                $server['img'] = html_print_image(
                    'images/log_server.svg',
                    true,
                    [
                        'title' => __('Log server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'log';
                $id_modulo = 0;
                $server['server_name'] = __('Log server');
            break;

            case SERVER_TYPE_MADE:
                $server['img'] = html_print_image(
                    'images/Anomaly-detection@svg.svg',
                    true,
                    [
                        'title' => __('MADE server'),
                        'class' => 'main_menu_icon invert_filter',
                    ]
                );
                $server['type'] = 'made';
                $id_modulo = 0;
                $server['server_name'] = __('MADE server');
            break;

            default:
                $server['img'] = '';
                $server['type'] = 'unknown';
                $id_modulo = 0;
            break;
        }

        if ($config['realtimestats'] == 0) {
            // Take data from database if not realtime stats.
            $server['lag'] = db_get_sql(
                'SELECT lag_time
                FROM tserver
                WHERE id_server = '.$server['id_server']
            );
            $server['module_lag'] = db_get_sql(
                'SELECT lag_modules
                FROM tserver
                WHERE id_server = '.$server['id_server']
            );
            $server['modules'] = db_get_sql(
                'SELECT my_modules
                FROM tserver
                WHERE id_server = '.$server['id_server']
            );
            $server['modules_total'] = db_get_sql(
                'SELECT total_modules_running
                FROM tserver
                WHERE id_server = '.$server['id_server']
            );
        } else {
            // Take data in realtime.
            $server['module_lag'] = 0;
            $server['lag'] = 0;

            // Inventory server.
            if ($server['server_type'] == SERVER_TYPE_INVENTORY) {
                // Get modules exported by this server.
                $server['modules'] = db_get_sql(
                    "SELECT COUNT(tagent_module_inventory.id_agent_module_inventory)
                    FROM tagente, tagent_module_inventory
                    WHERE tagente.disabled=0
                        AND tagent_module_inventory.id_agente = tagente.id_agente
                        AND tagente.server_name = '".$server['name']."'"
                );

                // Get total exported modules.
                $server['modules_total'] = db_get_sql(
                    'SELECT COUNT(tagent_module_inventory.id_agent_module_inventory)
                    FROM tagente, tagent_module_inventory
                    WHERE tagente.disabled=0
                    AND tagent_module_inventory.id_agente = tagente.id_agente'
                );

                $interval_esc = db_escape_key_identifier('interval');

                // Get the module lag.
                $server['module_lag'] = db_get_sql(
                    'SELECT COUNT(tagent_module_inventory.id_agent_module_inventory) AS module_lag
					FROM tagente, tagent_module_inventory
					WHERE utimestamp > 0
					AND tagent_module_inventory.id_agente = tagente.id_agente
					AND tagent_module_inventory.'.$interval_esc." > 0
					AND tagente.server_name = '".$server['name']."'
					AND (UNIX_TIMESTAMP() - utimestamp) < (tagent_module_inventory.".$interval_esc.' * 10)
					AND (UNIX_TIMESTAMP() - utimestamp) > tagent_module_inventory.'.$interval_esc
                );

                // Get the lag.
                $server['lag'] = db_get_sql(
                    'SELECT AVG(UNIX_TIMESTAMP() - utimestamp - tagent_module_inventory.'.$interval_esc.')
					FROM tagente, tagent_module_inventory
					WHERE utimestamp > 0
					AND tagent_module_inventory.id_agente = tagente.id_agente
					AND tagent_module_inventory.'.$interval_esc." > 0
					AND tagente.server_name = '".$server['name']."'
					AND (UNIX_TIMESTAMP() - utimestamp) < (tagent_module_inventory.".$interval_esc.' * 10)
					AND (UNIX_TIMESTAMP() - utimestamp) > tagent_module_inventory.'.$interval_esc
                );
                // Export server.
            } else if ($server['server_type'] == SERVER_TYPE_EXPORT) {
                // Get modules exported by this server.
                $server['modules'] = db_get_sql(
                    'SELECT COUNT(tagente_modulo.id_agente_modulo)
                    FROM tagente, tagente_modulo, tserver_export
                    WHERE tagente.disabled=0
                        AND tagente_modulo.id_agente = tagente.id_agente
                        AND tagente_modulo.id_export = tserver_export.id
                        AND tserver_export.id_export_server = '.$server['id_server']
                );

                // Get total exported modules.
                $server['modules_total'] = db_get_sql(
                    'SELECT COUNT(tagente_modulo.id_agente_modulo)
                    FROM tagente, tagente_modulo
                    WHERE tagente.disabled=0
                        AND tagente_modulo.id_agente = tagente.id_agente
                        AND tagente_modulo.id_export != 0'
                );

                $server['lag'] = 0;
                $server['module_lag'] = 0;
            } else if ($server['server_type'] == SERVER_TYPE_DISCOVERY) {
                // Discovery server.
                $server['name'] = '<a href="index.php?sec=estado&amp;sec2=operation/servers/recon_view&amp;server_id='.$server['id_server'].'">'.$server['name'].'</a>';

                // Total jobs running on this Discovery server.
                $server['modules'] = db_get_sql(
                    'SELECT COUNT(id_rt)
					FROM trecon_task
					WHERE id_recon_server = '.$server['id_server']
                );

                // Total recon jobs (all servers).
                $server['modules_total'] = db_get_sql(
                    'SELECT COUNT(status) FROM trecon_task'
                );

                // Lag (take average active time of all active tasks).
                $server['module_lag'] = 0;
                $server['lag'] = db_get_sql(
                    'SELECT UNIX_TIMESTAMP() - utimestamp
                    FROM trecon_task
                    WHERE UNIX_TIMESTAMP()  > (utimestamp + interval_sweep)
                    AND interval_sweep > 0
                    AND id_recon_server = '.$server['id_server']
                );
                $server['module_lag'] = db_get_sql(
                    'SELECT COUNT(id_rt)
                    FROM trecon_task
                    WHERE UNIX_TIMESTAMP()  > (utimestamp + interval_sweep)
                    AND interval_sweep > 0
                    AND id_recon_server = '.$server['id_server']
                );
            } else {
                // Data, Plugin, WMI, Network and Others.
                $server['modules'] = db_get_sql(
                    'SELECT count(tagente_estado.id_agente_modulo)
                    FROM tagente_estado, tagente_modulo, tagente
                    WHERE tagente.disabled=0
                        AND tagente_modulo.id_agente = tagente.id_agente
                        AND tagente_modulo.disabled = 0
                        AND tagente_modulo.id_agente_modulo = tagente_estado.id_agente_modulo
                        AND tagente_estado.running_by = '.$server['id_server']
                );

                $server['modules_total'] = db_get_sql(
                    'SELECT count(tagente_estado.id_agente_modulo)
                    FROM tserver, tagente_estado, tagente_modulo, tagente
                    WHERE tagente.disabled=0
                    AND tagente_modulo.id_agente = tagente.id_agente
                    AND tagente_modulo.disabled = 0
                    AND tagente_modulo.id_agente_modulo = tagente_estado.id_agente_modulo
                    AND tagente_estado.running_by = tserver.id_server
                    AND tserver.server_type = '.$server['server_type']
                );

                // Remote servers LAG Calculation (server_type != 0).
                if ($server['server_type'] != 0) {
                    // MySQL 8.0 has function lag(). So, lag must be enclosed in quotations.
                    $sql = sprintf(
                        'SELECT COUNT(tam.id_agente_modulo) AS module_lag,
                        AVG(UNIX_TIMESTAMP() - tae.last_execution_try - tae.current_interval) AS "lag" 
                        FROM (
                            SELECT tagente_estado.last_execution_try, tagente_estado.current_interval, tagente_estado.id_agente_modulo
                            FROM tagente_estado
                            WHERE tagente_estado.current_interval > 0
                            AND tagente_estado.last_execution_try > 0
                            AND tagente_estado.running_by = %d
                        ) tae
                        JOIN (
                            SELECT tagente_modulo.id_agente_modulo
                            FROM tagente_modulo LEFT JOIN tagente
                            ON tagente_modulo.id_agente = tagente.id_agente
                            WHERE tagente.disabled = 0
                            AND tagente_modulo.disabled = 0
                        ) tam
                        ON tae.id_agente_modulo = tam.id_agente_modulo
                        WHERE (UNIX_TIMESTAMP() - tae.last_execution_try) > (tae.current_interval)
                        AND  (UNIX_TIMESTAMP() - tae.last_execution_try) < ( tae.current_interval * 10)',
                        $server['id_server']
                    );
                } else {
                    // Local/Dataserver server LAG calculation.
                    // MySQL 8.0 has function lag(). So, lag must be enclosed in quotations.
                    $sql = sprintf(
                        'SELECT COUNT(tam.id_agente_modulo) AS module_lag,
                        AVG(UNIX_TIMESTAMP() - tae.last_execution_try - tae.current_interval) AS "lag"
                        FROM (
                          SELECT tagente_estado.last_execution_try, tagente_estado.current_interval, tagente_estado.id_agente_modulo
                            FROM tagente_estado
                            WHERE tagente_estado.current_interval > 0
                            AND tagente_estado.last_execution_try > 0
                            AND tagente_estado.running_by = %d
                        ) tae
                        JOIN (
                            SELECT tagente_modulo.id_agente_modulo
                            FROM tagente_modulo LEFT JOIN tagente
                            ON tagente_modulo.id_agente = tagente.id_agente
                            WHERE tagente.disabled = 0
                            AND tagente_modulo.disabled = 0
                            AND tagente_modulo.id_tipo_modulo < 5
                    ) tam
                        ON tae.id_agente_modulo = tam.id_agente_modulo
                        WHERE (UNIX_TIMESTAMP() - tae.last_execution_try) > (tae.current_interval * 1.1)
                        AND  (UNIX_TIMESTAMP() - tae.last_execution_try) < ( tae.current_interval * 10)',
                        $server['id_server']
                    );
                }

                $result = db_get_row_sql($sql);

                // Lag over current_interval * 2 is not lag,
                // it's a timed out module.
                if (!empty($result['lag'])) {
                    $server['lag'] = $result['lag'];
                }

                if (!empty($result['module_lag'])) {
                    $server['module_lag'] = $result['module_lag'];
                }
            }
        }

        if (isset($server['module_lag'])) {
            $server['lag_txt'] = (($server['lag'] == 0) ? '-' : human_time_description_raw($server['lag'])).' / '.$server['module_lag'];
        } else {
            $server['lag_txt'] = '';
        }

        if ($server['modules_total'] > 0) {
            $server['load'] = round(
                ($server['modules'] / $server['modules_total'] * 100)
            );
        } else {
            $server['load'] = 0;
        }

        // Push the raw data on the return stack.
        $return[$server['id_server']] = $server;
    }

    return $return;
}


/**
 * Get server type
 *
 * @param integer $type Type.
 *
 * @return array Result.
 */
function servers_get_servers_type($type)
{
    return db_get_all_rows_filter('tserver', ['server_type' => $type]);
}


/**
 * Get the server name.
 *
 * @param integer $id_server Server id.
 *
 * @return string Name of the given server
 */
function servers_get_name($id_server)
{
    return (string) db_get_value(
        'name',
        'tserver',
        'id_server',
        (int) $id_server
    );
}


/**
 * Get the presence of .conf and .md5 into remote_config dir.
 *
 * @param string $server_name Agent name.
 *
 * @return true If files exist and are writable.
 */
function servers_check_remote_config($server_name)
{
    global $config;

    $server_md5 = md5($server_name, false);

    $filenames = [];
    $filenames['md5'] = io_safe_output(
        $config['remote_config']
    ).'/md5/'.$server_md5.'.srv.md5';
    $filenames['conf'] = io_safe_output(
        $config['remote_config']
    ).'/conf/'.$server_md5.'.srv.conf';

    if (! isset($filenames['conf'])) {
        return false;
    }

    if (! isset($filenames['md5'])) {
        return false;
    }

    return (file_exists($filenames['conf'])
        && is_writable($filenames['conf'])
        && file_exists($filenames['md5'])
        && is_writable($filenames['md5']));
}


/**
 * Get the numbers of servers up.
 *
 * This check assumes that server_keepalive should be at least 15 minutes.
 *
 * @return integer The number of servers alive.
 */
function servers_check_status()
{
    global $config;

    $sql = 'SELECT COUNT(id_server)
        FROM tserver
        WHERE status = 1
            AND keepalive > NOW() - INTERVAL server_keepalive*2 SECOND';

    $status = (int) db_get_sql($sql);
    // Cast as int will assure a number value
    // This function should just ack of server down, not set it down.
    return $status;
}


/**
 * Get statistical information for a given server
 *
 * @param integer $id_server Server id to get status.
 *
 * @return array Server info array
 */
function servers_get_status($id_server)
{
    $serverinfo = servers_get_info($id_server);
    return $serverinfo[$id_server];
}


/**
 * Return server name based on identifier.
 *
 * @param integer $server Server identifier.
 *
 * @return string Server name
 */
function servers_get_server_string_name(int $server)
{
    switch ($server) {
        case SERVER_TYPE_DATA:
        return __('Data server');

        case SERVER_TYPE_NETWORK:
        return __('Network server');

        case SERVER_TYPE_SNMP:
        return __('SNMP server');

        case SERVER_TYPE_ENTERPRISE_ICMP:
        return __('Enterprise ICMP server');

        case SERVER_TYPE_ENTERPRISE_SNMP:
        return __('Enterprise SNMP server');

        case SERVER_TYPE_PLUGIN:
        return __('Plugin server');

        case SERVER_TYPE_PREDICTION:
        return __('Prediction Server');

        case SERVER_TYPE_WMI:
        return __('WMI server');

        case SERVER_TYPE_WEB:
        return __('Web server');

        case SERVER_TYPE_EXPORT:
        return __('Export server');

        case SERVER_TYPE_INVENTORY:
        return __('Inventory server');

        case SERVER_TYPE_EVENT:
        return __('Event server');

        case SERVER_TYPE_DISCOVERY:
        return __('Discovery server');

        case SERVER_TYPE_SYSLOG:
        return __('Log server');

        case SERVER_TYPE_WUX:
        return __('WUX server');

        case SERVER_TYPE_ENTERPRISE_SATELLITE:
        return __('Satellite server');

        case SERVER_TYPE_ALERT:
        return __('Alert server');

        case SERVER_TYPE_NCM:
        return __('NCM server');

        case SERVER_TYPE_AUTOPROVISION:
        return __('Autoprovision server');

        case SERVER_TYPE_MIGRATION:
        return __('Migration server');

        default:
        return __('N/A');
    }
}


/**
 * Return server name master where status is activated.
 *
 * @return string
 */
function servers_get_master()
{
    $sql = 'SELECT `name` FROM tserver WHERE `status` = 1 order by `master` desc';

    $result = db_get_value_sql($sql);

    if ($result === false) {
        $result = '';
    }

    return $result;
}


/**
 * Return true if all servers are up.
 *
 * @return boolean
 */
function check_all_servers_up()
{
    $status = true;

    $servers = servers_get_info();

    foreach ($servers as $server) {
        if ($server['status'] !== '1') {
            return false;
        }
    }

    return $status;
}