pandorafms/pandora_console/include/class/Tree.class.php

1535 lines
47 KiB
PHP
Raw Normal View History

2014-12-16 16:39:00 +01:00
<?php
//Pandora FMS- http://pandorafms.com
// ==================================================
// Copyright (c) 2005-2011 Artica Soluciones Tecnologicas
// Please see http://pandorafms.org for full contribution list
// This program is free software; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public License
// as published by the Free Software Foundation; 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.
class Tree {
protected $type = null;
protected $tree = array();
protected $filter = array();
protected $root = null;
protected $childrenMethod = "on_demand";
protected $countModuleStatusMethod = "on_demand";
protected $countAgentStatusMethod = "on_demand";
protected $userGroups;
2014-12-16 16:39:00 +01:00
2015-01-14 17:56:42 +01:00
protected $strictACL = false;
protected $acltags = false;
public function __construct($type, $root = null,
$childrenMethod = "on_demand",
$countModuleStatusMethod = "on_demand",
$countAgentStatusMethod = "on_demand") {
2014-12-16 16:39:00 +01:00
$this->type = $type;
$this->root = $root;
2014-12-17 18:58:34 +01:00
$this->childrenMethod = $childrenMethod;
$this->countModuleStatusMethod = $countModuleStatusMethod;
$this->countAgentStatusMethod = $countAgentStatusMethod;
2015-01-08 16:39:35 +01:00
$userGroups = users_get_groups();
if (empty($userGroups))
$this->userGroups = false;
else
$this->userGroups = $userGroups;
global $config;
include_once($config['homedir']."/include/functions_servers.php");
2014-12-16 16:39:00 +01:00
}
2014-12-17 18:58:34 +01:00
public function setType($type) {
2014-12-16 16:39:00 +01:00
$this->type = $type;
}
2014-12-17 18:58:34 +01:00
public function setFilter($filter) {
2014-12-16 16:39:00 +01:00
$this->filter = $filter;
}
protected function processModule (&$module) {
global $config;
$module['type'] = 'module';
2015-01-02 09:45:53 +01:00
$module['id'] = (int) $module['id_agente_modulo'];
$module['name'] = $module['nombre'];
2015-01-02 09:45:53 +01:00
$module['id_module_type'] = (int) $module['id_tipo_modulo'];
2015-01-08 15:07:01 +01:00
$module['server_type'] = (int) $module['id_modulo'];
// $module['icon'] = modules_get_type_icon($module['id_tipo_modulo']);
2015-01-12 12:47:54 +01:00
if (!isset($module['value']))
$module['value'] = modules_get_last_value($module['id']);
// Status
2015-01-12 12:47:54 +01:00
switch ($module['status']) {
case AGENT_MODULE_STATUS_CRITICAL_ALERT:
2015-01-12 12:47:54 +01:00
$module['alert'] = 1;
case AGENT_MODULE_STATUS_CRITICAL_BAD:
$statusType = STATUS_MODULE_CRITICAL_BALL;
$statusTitle = __('CRITICAL');
$module['statusText'] = "critical";
break;
case AGENT_MODULE_STATUS_WARNING_ALERT:
2015-01-12 12:47:54 +01:00
$module['alert'] = 1;
case AGENT_MODULE_STATUS_WARNING:
$statusType = STATUS_MODULE_WARNING_BALL;
$statusTitle = __('WARNING');
$module['statusText'] = "warning";
break;
case AGENT_MODULE_STATUS_UNKNOWN:
2015-01-12 12:47:54 +01:00
$statusType = STATUS_MODULE_UNKNOWN_BALL;
$statusTitle = __('UNKNOWN');
$module['statusText'] = "unknown";
break;
case AGENT_MODULE_STATUS_NO_DATA:
case AGENT_MODULE_STATUS_NOT_INIT:
2015-01-12 12:47:54 +01:00
$statusType = STATUS_MODULE_NO_DATA_BALL;
$statusTitle = __('NO DATA');
$module['statusText'] = "not_init";
break;
case AGENT_MODULE_STATUS_NORMAL_ALERT:
2015-01-12 12:47:54 +01:00
$module['alert'] = 1;
case AGENT_MODULE_STATUS_NORMAL:
default:
2015-01-12 12:47:54 +01:00
$statusType = STATUS_MODULE_OK_BALL;
$statusTitle = __('NORMAL');
$module['statusText'] = "ok";
break;
}
2015-01-12 12:47:54 +01:00
if ($statusType !== STATUS_MODULE_UNKNOWN_BALL
&& $statusType !== STATUS_MODULE_NO_DATA_BALL) {
if (is_numeric($module["value"])) {
$statusTitle .= " : " . format_for_graph($module["value"]);
}
else {
$statusTitle .= " : " . substr(io_safe_output($module["value"]),0,42);
}
}
$module['statusImageHTML'] = ui_print_status_image($statusType, $statusTitle, true);
// HTML of the server type image
$module['serverTypeHTML'] = servers_show_type($module['server_type']);
// Link to the Module graph
$graphType = return_graphtype($module['id']);
$winHandle = dechex(crc32($module['id'] . $module['name']));
$moduleGraphURL = $config['homeurl'] .
"/operation/agentes/stat_win.php?" .
"type=$graphType&" .
"period=86400&" .
"id=" . $module['id'] . "&" .
"label=" . rawurlencode(urlencode(base64_encode($module['name']))) . "&" .
"refresh=600";
$module['moduleGraph'] = array(
'url' => $moduleGraphURL,
'handle' => $winHandle
);
}
protected function processModules ($modules_aux, &$modules) {
2015-01-12 12:47:54 +01:00
$counters = false;
if (!empty($modules_aux)) {
2015-01-12 12:47:54 +01:00
$counters = array(
'critical' => 0,
'warning' => 0,
'ok' => 0,
'not_init' => 0,
'unknown' => 0,
'alerts' => 0
);
foreach ($modules_aux as $module) {
$this->processModule($module);
$modules[] = $module;
2015-01-12 12:47:54 +01:00
if (isset($counters[$module['statusText']]))
$counters[$module['statusText']]++;
if ($module['alert'])
$counters['alerts']++;
}
}
2015-01-12 12:47:54 +01:00
return $counters;
}
protected function getModules ($parent = 0, $filter = array()) {
$modules = array();
$modules_aux = agents_get_modules($parent,
array('id_agente_modulo', 'nombre', 'id_tipo_modulo', 'id_modulo'), $filter);
2014-12-19 18:13:47 +01:00
if (empty($modules_aux))
$modules_aux = array();
2014-12-19 18:13:47 +01:00
// Process the modules
$this->processModules($modules_aux, $modules);
return $modules;
2014-12-19 18:13:47 +01:00
}
protected function processAgent (&$agent, $modulesFilter = array(), $searchChildren = true) {
$agent['type'] = 'agent';
$agent['id'] = (int) $agent['id_agente'];
$agent['name'] = $agent['nombre'];
// Counters
2015-01-14 17:56:42 +01:00
if (empty($agent['counters'])) {
$agent['counters'] = array();
if (isset($agent['unknown_count']))
$agent['counters']['unknown'] = $agent['unknown_count'];
else
$agent['counters']['unknown'] = agents_monitor_unknown($agent['id']);
if (isset($agent['critical_count']))
$agent['counters']['critical'] = $agent['critical_count'];
else
$agent['counters']['critical'] = agents_monitor_critical($agent['id']);
if (isset($agent['warning_count']))
$agent['counters']['warning'] = $agent['warning_count'];
else
$agent['counters']['warning'] = agents_monitor_warning($agent['id']);
if (isset($agent['notinit_count']))
$agent['counters']['not_init'] = $agent['notinit_count'];
else
$agent['counters']['not_init'] = agents_monitor_notinit($agent['id']);
if (isset($agent['normal_count']))
$agent['counters']['ok'] = $agent['normal_count'];
else
$agent['counters']['ok'] = agents_monitor_ok($agent['id']);
if (isset($agent['total_count']))
$agent['counters']['total'] = $agent['total_count'];
else
$agent['counters']['total'] = agents_monitor_total($agent['id']);
if (isset($agent['fired_count']))
$agent['counters']['alerts'] = $agent['fired_count'];
else
$agent['counters']['alerts'] = agents_get_alerts_fired($agent['id']);
}
// Status image
$agent['statusImageHTML'] = agents_tree_view_status_img_ball(
$agent['counters']['critical'],
$agent['counters']['warning'],
$agent['counters']['unknown'],
$agent['counters']['total'],
$agent['counters']['not_init']);
// Alerts fired image
$agent["alertImageHTML"] = agents_tree_view_alert_img_ball($agent['counters']['alerts']);
// Status
$agent['statusRaw'] = agents_get_status($agent['id']);
switch ($agent['statusRaw']) {
case AGENT_STATUS_NORMAL:
$agent['status'] = "ok";
break;
case AGENT_STATUS_WARNING:
$agent['status'] = "warning";
break;
case AGENT_STATUS_CRITICAL:
$agent['status'] = "critical";
break;
case AGENT_STATUS_UNKNOWN:
$agent['status'] = "unknown";
break;
case AGENT_STATUS_NOT_INIT:
$agent['status'] = "not_init";
break;
default:
$agent['status'] = "none";
break;
}
// Children
2015-01-14 17:56:42 +01:00
if (empty($agent['children'])) {
$agent['children'] = array();
if ($agent['counters']['total'] > 0) {
switch ($this->childrenMethod) {
case 'on_demand':
$agent['searchChildren'] = 1;
break;
case 'live':
$agent['searchChildren'] = 0;
if ($searchChildren)
$agent['children'] = $this->getModules($agent['id'], $modulesFilter);
break;
}
}
2015-01-14 17:56:42 +01:00
else {
switch ($this->childrenMethod) {
case 'on_demand':
$agent['searchChildren'] = 0;
break;
case 'live':
$agent['searchChildren'] = 0;
break;
}
}
}
}
protected function processAgents (&$agents, $modulesFilter = array()) {
if (!empty($agents)) {
foreach ($agents as $iterator => $agent) {
$this->processAgent($agents[$iterator], $modulesFilter);
}
}
}
protected function getAgents ($parent = 0, $parentType = '', $server_id = false) {
2015-01-14 17:56:42 +01:00
// Agent name filter
$agent_search = "";
if (!empty($this->filter['searchAgent'])) {
$agent_search = " AND ta.nombre LIKE '%".$this->filter['searchAgent']."%' ";
}
// Module name filter
$module_search = "";
if (!empty($this->filter['searchModule'])) {
$module_search = " AND tam.nombre LIKE '%".$this->filter['searchModule']."%' ";
}
switch ($parentType) {
2014-12-18 17:51:02 +01:00
case 'group':
// ACL Groups
2015-01-05 17:08:33 +01:00
if (isset($this->userGroups) && $this->userGroups === false)
return array();
if (!empty($this->userGroups) && !empty($parent)) {
if (!isset($this->userGroups[$parent]))
return array();
}
2015-01-14 17:56:42 +01:00
// TODO: Check ACL
2015-01-14 17:56:42 +01:00
// Get the agents. The modules are optional (LEFT JOIN), like their status
$sql = "SELECT ta.id_agente, ta.nombre AS agent_name, ta.fired_count,
ta.normal_count, ta.warning_count, ta.critical_count,
ta.unknown_count, ta.notinit_count, ta.total_count,
tam.id_agente_modulo, tam.nombre AS module_name,
tam.id_tipo_modulo, tam.id_modulo, tae.estado, tae.datos
FROM tagente AS ta
LEFT JOIN tagente_modulo AS tam
LEFT JOIN tagente_estado AS tae
ON tam.id_agente_modulo IS NOT NULL
AND tam.id_agente_modulo = tae.id_agente_modulo
ON tam.disabled = 0
AND ta.id_agente = tam.id_agente
$module_search
WHERE ta.id_grupo = $parent
AND ta.disabled = 0
$agent_search
ORDER BY ta.nombre ASC, ta.id_agente ASC, tam.nombre ASC, tam.id_agente_modulo ASC";
break;
case 'tag':
$groups_clause = "";
if (!empty($this->acltags)) {
$i = 0;
$groups = array();
foreach ($this->acltags as $group_id => $tags) {
if (!empty($tags)) {
$tags_arr = explode(',', $tags);
if (in_array($id_tag, $tags_arr))
$groups[] = $group_id;
}
}
if (!empty($groups)) {
$groups_str = implode(",", $groups);
$groups_clause = " AND ta.id_grupo IN ($groups_str)";
}
2014-12-18 17:51:02 +01:00
}
2015-01-14 17:56:42 +01:00
// Get the agents. The modules are required (INNER JOIN), although their status
$sql = "SELECT ta.id_agente, ta.nombre AS agent_name, ta.fired_count,
ta.normal_count, ta.warning_count, ta.critical_count,
ta.unknown_count, ta.notinit_count, ta.total_count,
tam.id_agente_modulo, tam.nombre AS module_name,
tam.id_tipo_modulo, tam.id_modulo, tae.estado, tae.datos
FROM tagente AS ta
INNER JOIN tagente_modulo AS tam
ON tam.disabled = 0
AND ta.id_agente = tam.id_agente
$module_search
INNER JOIN ttag_module AS ttm
ON ttm.id_tag = $parent
AND tam.id_agente_modulo = ttm.id_agente_modulo
LEFT JOIN tagente_estado AS tae
ON tam.id_agente_modulo = tae.id_agente_modulo
WHERE ta.disabled = 0
$groups_clause
$agent_search
ORDER BY ta.nombre ASC, ta.id_agente ASC, tam.nombre ASC, tam.id_agente_modulo ASC";
2014-12-18 17:51:02 +01:00
break;
default:
return array();
break;
2014-12-18 17:51:02 +01:00
}
if (! defined ('METACONSOLE')) {
$data = db_process_sql($sql);
}
else if ($server_id) {
$server = metaconsole_get_servers($server_id);
if (metaconsole_connect($server) != NOERR) {
$data = db_process_sql($sql);
metaconsole_restore_db();
}
}
2015-01-14 17:56:42 +01:00
if (empty($data))
return array();
2014-12-18 17:51:02 +01:00
2015-01-14 17:56:42 +01:00
$agents = array();
$actual_agent = array();
foreach ($data as $key => $value) {
if (empty($actual_agent) || $actual_agent['id_agente'] != (int)$value['id_agente']) {
if (!empty($actual_agent)) {
2015-01-15 13:23:08 +01:00
$this->processAgent($actual_agent, array(), false);
2015-01-14 17:56:42 +01:00
$agents[] = $actual_agent;
}
$actual_agent = array();
$actual_agent['id_agente'] = (int) $value['id_agente'];
$actual_agent['nombre'] = $value['agent_name'];
$actual_agent['children'] = array();
// Initialize counters
$actual_agent['counters'] = array();
$actual_agent['counters']['total'] = 0;
$actual_agent['counters']['alerts'] = 0;
$actual_agent['counters']['critical'] = 0;
$actual_agent['counters']['warning'] = 0;
$actual_agent['counters']['unknown'] = 0;
$actual_agent['counters']['not_init'] = 0;
$actual_agent['counters']['ok'] = 0;
// $actual_agent['counters'] = array();
// $actual_agent['counters']['total'] = (int) $value['total_count'];
// $actual_agent['counters']['alerts'] = (int) $value['fired_count_count'];
// $actual_agent['counters']['critical'] = (int) $value['critical_count'];
// $actual_agent['counters']['warning'] = (int) $value['warning_count'];
// $actual_agent['counters']['unknown'] = (int) $value['unknown_count'];
// $actual_agent['counters']['not_init'] = (int) $value['notinit_count'];
// $actual_agent['counters']['ok'] = (int) $value['normal_count'];
}
if (empty($value['id_agente_modulo']))
continue;
$module = array();
$module['id_agente_modulo'] = (int) $value['id_agente_modulo'];
$module['nombre'] = $value['module_name'];
$module['id_tipo_modulo'] = (int) $value['id_tipo_modulo'];
$module['server_type'] = (int) $value['id_modulo'];
$module['status'] = (int) $value['estado'];
$module['value'] = $value['data'];
$this->processModule($module);
$actual_agent['children'][] = $module;
$actual_agent['counters']['total']++;
if (isset($actual_agent['counters'][$module['statusText']]))
$actual_agent['counters'][$module['statusText']]++;
if ($module['alert'])
$actual_agent['counters']['alerts']++;
}
if (!empty($actual_agent)) {
2015-01-15 13:23:08 +01:00
$this->processAgent($actual_agent, array(), false);
2015-01-14 17:56:42 +01:00
$agents[] = $actual_agent;
}
2014-12-18 17:51:02 +01:00
return $agents;
}
protected function getGroupsRecursive($parent, $limit = null, $get_agents = true) {
$filter = array();
$filter['parent'] = $parent;
// if (!empty($this->filter['search'])) {
// $filter['nombre'] = "%" . $this->filter['search'] . "%";
// }
// ACL groups
if (isset($this->userGroups) && $this->userGroups === false)
return array();
if (!empty($this->userGroups))
$filter['id_grupo'] = array_keys($this->userGroups);
// First filter by name and father
$groups = db_get_all_rows_filter('tgrupo', $filter, array('id_grupo', 'nombre', 'icon'));
if (empty($groups))
$groups = array();
// Filter by status
// $filter_status = AGENT_STATUS_ALL;
// if (!empty($this->filter['status'])) {
// $filter_status = $this->filter['status'];
// }
foreach ($groups as $iterator => $group) {
// Counters
$group_stats = reporting_get_group_stats($group['id_grupo']);
$groups[$iterator]['counters'] = array();
if (!empty($group_stats)) {
$groups[$iterator]['counters']['unknown'] = $group_stats['agents_unknown'];
$groups[$iterator]['counters']['critical'] = $group_stats['agent_critical'];
$groups[$iterator]['counters']['warning'] = $group_stats['agent_warning'];
$groups[$iterator]['counters']['not_init'] = $group_stats['agent_not_init'];
$groups[$iterator]['counters']['ok'] = $group_stats['agent_ok'];
$groups[$iterator]['counters']['total'] = $group_stats['total_agents'];
}
$groups[$iterator]['status'] = $group_stats['status'];
$groups[$iterator]['icon'] = !empty($group['icon']) ? $group['icon'] . '.png' : 'without_group.png';
// // Filter by status
// if ($filter_status != AGENT_STATUS_ALL) {
// $remove_group = true;
// switch ($filter_status) {
// case AGENT_STATUS_NORMAL:
// if ($groups[$iterator]['status'] === "ok")
// $remove_group = false;
// break;
// case AGENT_STATUS_WARNING:
// if ($groups[$iterator]['status'] === "warning")
// $remove_group = false;
// break;
// case AGENT_STATUS_CRITICAL:
// if ($groups[$iterator]['status'] === "critical")
// $remove_group = false;
// break;
// case AGENT_STATUS_UNKNOWN:
// if ($groups[$iterator]['status'] === "unknown")
// $remove_group = false;
// break;
// case AGENT_STATUS_NOT_INIT:
// if ($groups[$iterator]['status'] === "not_init")
// $remove_group = false;
// break;
// }
// if ($remove_group) {
// unset($groups[$iterator]);
// continue;
// }
// }
if (is_null($limit)) {
$groups[$iterator]['children'] =
$this->getGroupsRecursive($group['id_grupo']);
}
else if ($limit >= 1) {
$groups[$iterator]['children'] =
$this->getGroupsRecursive($group['id_grupo'], ($limit - 1));
}
switch ($this->countAgentStatusMethod) {
case 'on_demand':
$groups[$iterator]['searchCounters'] = 1;
break;
case 'live':
$groups[$iterator]['searchCounters'] = 0;
break;
}
switch ($this->childrenMethod) {
case 'on_demand':
// if (!empty($groups[$iterator]['children'])) {
// $groups[$iterator]['searchChildren'] = 1;
// }
// else {
// $groups[$iterator]['searchChildren'] = 0;
// }
$groups[$iterator]['searchChildren'] = 0;
break;
case 'live':
$groups[$iterator]['searchChildren'] = 0;
break;
}
$groups[$iterator]['type'] = 'group';
$groups[$iterator]['name'] = $groups[$iterator]['nombre'];
$groups[$iterator]['id'] = $groups[$iterator]['id_grupo'];
}
if (!empty($parent) && $get_agents) {
$agents = $this->getAgents($parent, 'group');
if (!empty($agents))
$groups = array_merge($groups, $agents);
}
return $groups;
}
public function getData() {
switch ($this->type) {
case 'os':
$this->getDataOS();
break;
case 'group':
$this->getDataGroup();
break;
case 'module_group':
$this->getDataModuleGroup();
break;
case 'module':
$this->getDataModules();
break;
case 'tag':
$this->getDataTag();
break;
default:
$this->getDataExtended();
}
}
protected function getDataExtended () {
// Override this method to add new types
}
private function getDataGroup() {
2015-01-14 17:56:42 +01:00
global $config;
// Get the parent
if (empty($this->root))
$parent = 0;
else
$parent = $this->root;
2015-01-19 16:52:32 +01:00
function cmpSortNames($a, $b) {
return strcmp($a["name"], $b["name"]);
}
2015-01-14 17:56:42 +01:00
// Get all groups
if (empty($parent)) {
require_once($config['homedir']."/include/functions_groups.php");
// Return all the children groups
function __searchChildren(&$groups, $id, $server_id = false) {
2015-01-14 17:56:42 +01:00
$children = array();
foreach ($groups as $key => $group) {
if (isset($group['_parent_id_']) && $group['_parent_id_'] == $id) {
$children[] = __getProcessedItem($key, $groups, $server_id);
}
}
return $children;
}
2015-01-14 17:56:42 +01:00
2015-01-19 13:12:27 +01:00
function __getProcessedItem($itemKey, &$items, $server_id = false) {
if (!isset($items[$itemKey])) {
return false;
}
else {
$item = $items[$itemKey];
unset($items[$itemKey]);
}
2015-01-14 17:56:42 +01:00
$processed_item = array();
$processed_item['id'] = $item['_id_'];
$processed_item['name'] = $item['_name_'];
$processed_item['searchChildren'] = 1;
2015-01-14 17:56:42 +01:00
2015-01-19 13:12:27 +01:00
if (defined ('METACONSOLE') && $server_id) {
$processed_item['server_id'] = $server_id;
}
if (isset($item['_is_tag_']) && $item['_is_tag_']) {
$processed_item['type'] = 'tag';
}
else {
$processed_item['type'] = 'group';
$processed_item['parentID'] = $item['_parent_id_'];
$processed_item['iconHTML'] = $item['_iconImg_'];
}
2015-01-14 17:56:42 +01:00
$counters = array();
if (isset($item['_agents_unknown_']))
$counters['unknown'] = $item['_agents_unknown_'];
if (isset($item['_agents_critical_']))
$counters['critical'] = $item['_agents_critical_'];
if (isset($item['_agents_warning_']))
$counters['warning'] = $item['_agents_warning_'];
if (isset($item['_agents_not_init_']))
$counters['not_init'] = $item['_agents_not_init_'];
if (isset($item['_agents_ok_']))
$counters['ok'] = $item['_agents_ok_'];
if (isset($item['_total_agents_']))
$counters['total'] = $item['_total_agents_'];
if (isset($item['_monitors_alerts_fired_']))
$counters['alerts'] = $item['_monitors_alerts_fired_'];
$children = __searchChildren($items, $item['_id_'], $server_id);
if (!empty($children)) {
$processed_item['children'] = $children;
foreach ($children as $key => $child) {
if (isset($child['counters'])) {
foreach ($child['counters'] as $type => $value) {
if (isset($counters[$type]))
$counters[$type] += $value;
2015-01-14 17:56:42 +01:00
}
}
}
}
if (!empty($counters))
$processed_item['counters'] = $counters;
return $processed_item;
2015-01-14 17:56:42 +01:00
}
if (! defined ('METACONSOLE')) {
$items = group_get_data($config['id_user'], $this->strictACL, $this->acltags, false, 'tree');
2015-01-14 17:56:42 +01:00
// Build the group hierarchy
$processed_items = array();
foreach ($items as $key => $item) {
if (empty($item['_parent_id_']))
$processed_items[] = __getProcessedItem($key, $items);
}
$items = $processed_items;
2015-01-14 17:56:42 +01:00
}
else {
//enterprise_include_once("include/functions_metaconsole.php");
$servers = metaconsole_get_servers();
2015-01-14 17:56:42 +01:00
$item_list = array();
foreach ($servers as $server) {
if (metaconsole_connect($server) != NOERR)
continue;
2015-01-14 17:56:42 +01:00
$items = group_get_data($config['id_user'], $this->strictACL, $this->acltags, false, 'tree');
2015-01-14 17:56:42 +01:00
// Build the group hierarchy
$processed_items = array();
foreach ($items as $key => $item) {
if (empty($item['_parent_id_']))
2015-01-19 13:31:28 +01:00
$processed_items[] = __getProcessedItem($key, $items, $server['id']);
}
2015-01-19 13:12:27 +01:00
$item_list += $processed_items;
2015-01-14 17:56:42 +01:00
metaconsole_restore_db();
}
2015-01-14 17:56:42 +01:00
function __getMergedItems($items) {
// This variable holds the result
$mergedItems = array();
foreach ($items as $key => $child) {
$childrenAux = array();
// Store the item in a temporary element
$resultItem = $child;
// Remove the item
unset($items[$key]);
// The 'id' parameter will be stored as 'server_id' => 'id'
$resultItem['id'] = array();
$resultItem['id'][$child['server_id']] = $child['id'];
// Initialize counters if any of it don't exist
if (!isset($resultItem['counters']))
$resultItem['counters'] = array();
if (!isset($resultItem['counters']['unknown']))
$resultItem['counters']['unknown'] = 0;
if (!isset($resultItem['counters']['critical']))
$resultItem['counters']['critical'] = 0;
if (!isset($resultItem['counters']['warning']))
$resultItem['counters']['warning'] = 0;
if (!isset($resultItem['counters']['not_init']))
$resultItem['counters']['not_init'] = 0;
if (!isset($resultItem['counters']['ok']))
$resultItem['counters']['ok'] = 0;
if (!isset($resultItem['counters']['total']))
$resultItem['counters']['total'] = 0;
if (!isset($resultItem['counters']['alerts']))
$resultItem['counters']['alerts'] = 0;
// Iterate over the list to search items that match the actual item
foreach ($items as $key2 => $child2) {
// Skip the actual or empty items
if (!isset($key) || !isset($key2) || $key == $key2)
continue;
// Match with the name
if ($child['name'] == $child2['name'] && $child['type'] == $child2['type']) {
// Add the matched ids
$resultItem['id'][$child2['server_id']] = $child2['id'];
// Add the matched counters
if (isset($child2['counters']) && !child2($item['counters'])) {
foreach ($child2['counters'] as $type => $value) {
if (isset($resultItem['counters'][$type]))
$resultItem['counters'][$type] += $value;
}
}
2015-01-14 17:56:42 +01:00
// Add the matched children
if (isset($child2['children']))
$childrenAux += $child2['children'];
2015-01-14 17:56:42 +01:00
// Remove the item
unset($items[$key2]);
2015-01-14 17:56:42 +01:00
}
}
// Get the merged children (recursion)
if (!empty($childrenAux))
$resultItem['children'] = __getMergedItems($childrenAux);
// Add the resulting item
$mergedItems[] = $resultItem;
2015-01-14 17:56:42 +01:00
}
2015-01-19 16:52:32 +01:00
usort($mergedItems, "cmpSortNames");
return $mergedItems;
2015-01-14 17:56:42 +01:00
}
$items = __getMergedItems($item_list);
2015-01-14 17:56:42 +01:00
}
if (empty($items))
$items = array();
$this->tree = $items;
2015-01-14 17:56:42 +01:00
}
// Get the group agents
else {
if (! defined ('METACONSOLE')) {
$this->tree = $this->getAgents($parent, $this->type);
}
else {
$agents = array();
foreach ($parent as $server_id => $group_id) {
$server = metaconsole_get_servers($server_id);
if (!empty($server)) {
if (metaconsole_connect($server) != NOERR)
continue;
$agents += $this->tree = $this->getAgents($group_id, $this->type, $server_id);
metaconsole_restore_db();
}
}
if (!empty($agents))
2015-01-19 16:52:32 +01:00
usort($agents, "cmpSortNames");
$this->tree = $agents;
}
2015-01-14 17:56:42 +01:00
}
}
private function getDataModules() {
// ACL Group
2015-01-05 17:08:33 +01:00
if (isset($this->userGroups) && $this->userGroups === false)
return array();
$group_acl = "";
if (!empty($this->userGroups)) {
$user_groups_str = implode(",", array_keys($this->userGroups));
$group_acl = " AND ta.id_grupo IN ($user_groups_str) ";
}
// Agent name filter
$agent_search = "";
if (!empty($this->filter['searchAgent'])) {
$agent_search = " AND ta.nombre LIKE '%".$this->filter['searchAgent']."%' ";
}
// Module name filter
$module_search = "";
if (!empty($this->filter['searchModule'])) {
$module_search = " AND tam.nombre LIKE '%".$this->filter['searchModule']."%' ";
}
$sql = "SELECT tam.id_agente_modulo, tam.nombre AS module_name,
tam.id_tipo_modulo, tam.id_modulo,
ta.id_agente, ta.nombre AS agent_name, ta.fired_count,
ta.normal_count, ta.warning_count, ta.critical_count,
2015-01-12 12:47:54 +01:00
ta.unknown_count, ta.notinit_count, ta.total_count,
tae.estado, tae.datos
FROM tagente_modulo AS tam
INNER JOIN tagente AS ta
ON ta.id_agente = tam.id_agente
AND ta.disabled = 0
2015-01-14 17:56:42 +01:00
$agent_search
$group_acl
2015-01-12 12:47:54 +01:00
INNER JOIN tagente_estado AS tae
ON tae.id_agente_modulo = tam.id_agente_modulo
WHERE tam.disabled = 0
$module_search
ORDER BY tam.nombre ASC, ta.nombre ASC";
$data = db_process_sql($sql);
if (empty($data)) {
$data = array();
}
$modules = array();
$actual_module_root = array(
'name' => '',
'children' => array(),
'counters' => array()
);
foreach ($data as $key => $value) {
$agent = array();
$agent['id_agente'] = (int) $value['id_agente'];
$agent['nombre'] = $value['agent_name'];
2015-01-14 17:56:42 +01:00
$agent['counters'] = array();
$agent['counters']['total'] = (int) $value['total_count'];
$agent['counters']['alerts'] = (int) $value['fired_count_count'];
$agent['counters']['critical'] = (int) $value['critical_count'];
$agent['counters']['warning'] = (int) $value['warning_count'];
$agent['counters']['unknown'] = (int) $value['unknown_count'];
$agent['counters']['not_init'] = (int) $value['notinit_count'];
$agent['counters']['ok'] = (int) $value['normal_count'];
2015-01-15 13:23:08 +01:00
$this->processAgent($agent, array(), false);
$module = array();
$module['id_agente_modulo'] = (int) $value['id_agente_modulo'];
$module['nombre'] = $value['module_name'];
$module['id_tipo_modulo'] = (int) $value['id_tipo_modulo'];
$module['server_type'] = (int) $value['id_modulo'];
2015-01-12 12:47:54 +01:00
$module['status'] = (int) $value['estado'];
$module['value'] = $value['data'];
$this->processModule($module);
$agent['children'] = array($module);
if ($actual_module_root['name'] == $module['name']) {
$actual_module_root['children'][] = $agent;
// Increase counters
$actual_module_root['counters']['total']++;
if (isset($actual_module_root['counters'][$agent['status']]))
$actual_module_root['counters'][$agent['status']]++;
}
else {
if (!empty($actual_module_root['name']))
$modules[] = $actual_module_root;
$actual_module_root = array();
$actual_module_root['name'] = $module['name'];
$actual_module_root['children'] = array($agent);
// Initialize counters
$actual_module_root['counters'] = array();
$actual_module_root['counters']['total'] = 0;
$actual_module_root['counters']['alerts'] = 0;
$actual_module_root['counters']['critical'] = 0;
$actual_module_root['counters']['warning'] = 0;
$actual_module_root['counters']['unknown'] = 0;
$actual_module_root['counters']['not_init'] = 0;
$actual_module_root['counters']['ok'] = 0;
// Increase counters
$actual_module_root['counters']['total']++;
if (isset($actual_module_root['counters'][$agent['status']]))
$actual_module_root['counters'][$agent['status']]++;
}
}
if (!empty($actual_module_root['name'])) {
$modules[] = $actual_module_root;
}
$this->tree = $modules;
}
private function getDataModuleGroup() {
// ACL Group
if (isset($this->userGroups) && $this->userGroups === false)
return array();
$group_acl = "";
if (!empty($this->userGroups)) {
$user_groups_str = implode(",", array_keys($this->userGroups));
$group_acl = " AND ta.id_grupo IN ($user_groups_str) ";
}
// Agent name filter
$agent_search = "";
if (!empty($this->filter['searchAgent'])) {
$agent_search = " AND ta.nombre LIKE '%".$this->filter['searchAgent']."%' ";
}
// Module name filter
$module_search = "";
if (!empty($this->filter['searchModule'])) {
$module_search = " AND tam.nombre LIKE '%".$this->filter['searchModule']."%' ";
}
$sql = "SELECT tam.id_agente_modulo, tam.nombre AS module_name,
tam.id_tipo_modulo, tam.id_modulo,
ta.id_agente, ta.nombre AS agent_name, ta.fired_count,
ta.normal_count, ta.warning_count, ta.critical_count,
ta.unknown_count, ta.notinit_count, ta.total_count,
2015-01-12 12:47:54 +01:00
tmg.id_mg, tmg.name AS module_group_name,
tae.estado, tae.datos
FROM tagente_modulo AS tam
INNER JOIN tagente AS ta
ON ta.id_agente = tam.id_agente
AND ta.disabled = 0
2015-01-14 17:56:42 +01:00
$agent_search
$group_acl
2015-01-12 12:47:54 +01:00
INNER JOIN tagente_estado AS tae
ON tae.id_agente_modulo = tam.id_agente_modulo
LEFT JOIN tmodule_group AS tmg
ON tmg.id_mg = tam.id_module_group
WHERE tam.disabled = 0
$module_search
ORDER BY tmg.name ASC, tmg.id_mg ASC, ta.nombre ASC, tam.nombre ASC";
$data = db_process_sql($sql);
if (empty($data)) {
$data = array();
}
$nodes = array();
$actual_module_group_root = array(
'id' => -1,
'name' => '',
'children' => array(),
'counters' => array()
);
$actual_agent = array();
foreach ($data as $key => $value) {
// Module
$module = array();
$module['id_agente_modulo'] = (int) $value['id_agente_modulo'];
$module['nombre'] = $value['module_name'];
$module['id_tipo_modulo'] = (int) $value['id_tipo_modulo'];
$module['id_module_group'] = (int) $value['id_mg'];
$module['server_type'] = (int) $value['id_modulo'];
2015-01-12 12:47:54 +01:00
$module['status'] = (int) $value['estado'];
$module['value'] = $value['data'];
$this->processModule($module);
// Module group
if ($actual_module_group_root['id'] === $module['id_module_group']) {
// Agent
if (empty($actual_agent) || $actual_agent['id'] !== (int)$value['id_agente']) {
// Add the last agent to the agent module
if (!empty($actual_agent))
$actual_module_group_root['children'][] = $actual_agent;
// Create the new agent
$actual_agent = array();
2015-01-02 09:45:53 +01:00
$actual_agent['id_agente'] = (int) $value['id_agente'];
$actual_agent['nombre'] = $value['agent_name'];
$actual_agent['children'] = array();
2015-01-14 17:56:42 +01:00
$actual_agent['counters'] = array();
$actual_agent['counters']['total'] = (int) $value['total_count'];
$actual_agent['counters']['alerts'] = (int) $value['fired_count_count'];
$actual_agent['counters']['critical'] = (int) $value['critical_count'];
$actual_agent['counters']['warning'] = (int) $value['warning_count'];
$actual_agent['counters']['unknown'] = (int) $value['unknown_count'];
$actual_agent['counters']['not_init'] = (int) $value['notinit_count'];
$actual_agent['counters']['ok'] = (int) $value['normal_count'];
2015-01-15 13:23:08 +01:00
$this->processAgent($actual_agent, array(), false);
// Add the module to the agent
$actual_agent['children'][] = $module;
// Increase counters
$actual_module_group_root['counters']['total']++;
if (isset($actual_module_group_root['counters'][$actual_agent['status']]))
$actual_module_group_root['counters'][$actual_agent['status']]++;
}
else {
$actual_agent['children'][] = $module;
}
}
else {
// The first iteration doesn't enter here
if ($actual_module_group_root['id'] !== -1) {
2015-01-02 09:45:53 +01:00
// Add the agent to the module group
$actual_module_group_root['children'][] = $actual_agent;
2015-01-02 09:45:53 +01:00
// Add the module group to the branch
$nodes[] = $actual_module_group_root;
}
2015-01-02 09:45:53 +01:00
// Create the new agent
$actual_agent = array();
$actual_agent['id_agente'] = (int) $value['id_agente'];
$actual_agent['nombre'] = $value['agent_name'];
$actual_agent['children'] = array();
2015-01-14 17:56:42 +01:00
$actual_agent['counters'] = array();
$actual_agent['counters']['total'] = (int) $value['total_count'];
$actual_agent['counters']['alerts'] = (int) $value['fired_count_count'];
$actual_agent['counters']['critical'] = (int) $value['critical_count'];
$actual_agent['counters']['warning'] = (int) $value['warning_count'];
$actual_agent['counters']['unknown'] = (int) $value['unknown_count'];
$actual_agent['counters']['not_init'] = (int) $value['notinit_count'];
$actual_agent['counters']['ok'] = (int) $value['normal_count'];
2015-01-15 13:23:08 +01:00
$this->processAgent($actual_agent, array(), false);
2015-01-02 09:45:53 +01:00
// Add the module to the agent
$actual_agent['children'][] = $module;
// Create new module group
$actual_module_group_root = array();
$actual_module_group_root['id'] = $module['id_module_group'];
2015-01-02 12:37:19 +01:00
$actual_module_group_root['type'] = $this->type;
if (!empty($value['module_group_name'])) {
$actual_module_group_root['name'] = $value['module_group_name'];
}
else {
$actual_module_group_root['name'] = __('Not assigned');
}
// Initialize counters
$actual_module_group_root['counters'] = array();
$actual_module_group_root['counters']['total'] = 0;
$actual_module_group_root['counters']['alerts'] = 0;
$actual_module_group_root['counters']['critical'] = 0;
$actual_module_group_root['counters']['warning'] = 0;
$actual_module_group_root['counters']['unknown'] = 0;
$actual_module_group_root['counters']['not_init'] = 0;
$actual_module_group_root['counters']['ok'] = 0;
// Increase counters
$actual_module_group_root['counters']['total']++;
if (isset($actual_module_group_root['counters'][$actual_agent['status']]))
$actual_module_group_root['counters'][$actual_agent['status']]++;
}
}
2015-01-02 12:37:19 +01:00
// If there is an agent and a module group opened and not saved
if ($actual_module_group_root['id'] !== -1) {
2015-01-02 09:45:53 +01:00
// Add the last agent to the module group
$actual_module_group_root['children'][] = $actual_agent;
2015-01-02 09:45:53 +01:00
// Add the last module group to the branch
$nodes[] = $actual_module_group_root;
}
$this->tree = $nodes;
2014-12-16 16:39:00 +01:00
}
private function getDataOS() {
// ACL Group
if (isset($this->userGroups) && $this->userGroups === false)
return array();
$group_acl = "";
if (!empty($this->userGroups)) {
$user_groups_str = implode(",", array_keys($this->userGroups));
$group_acl = " AND ta.id_grupo IN ($user_groups_str) ";
}
2015-01-05 16:48:11 +01:00
// Agent name filter
$agent_search = "";
if (!empty($this->filter['searchAgent'])) {
$agent_search = " AND ta.nombre LIKE '%".$this->filter['searchAgent']."%' ";
}
// Module name filter
$module_search = "";
if (!empty($this->filter['searchModule'])) {
$module_search = " AND tam.nombre LIKE '%".$this->filter['searchModule']."%' ";
}
$sql = "SELECT tam.id_agente_modulo, tam.nombre AS module_name,
tam.id_tipo_modulo, tam.id_modulo,
ta.id_agente, ta.nombre AS agent_name, ta.fired_count,
ta.normal_count, ta.warning_count, ta.critical_count,
ta.unknown_count, ta.notinit_count, ta.total_count,
2015-01-12 12:47:54 +01:00
tos.id_os, tos.name AS os_name, tos.icon_name AS os_icon,
tae.estado, tae.datos
FROM tagente_modulo AS tam
INNER JOIN tagente AS ta
ON ta.id_agente = tam.id_agente
AND ta.disabled = 0
2015-01-14 17:56:42 +01:00
$agent_search
$group_acl
2015-01-12 12:47:54 +01:00
INNER JOIN tagente_estado AS tae
ON tae.id_agente_modulo = tam.id_agente_modulo
LEFT JOIN tconfig_os AS tos
ON tos.id_os = ta.id_os
WHERE tam.disabled = 0
$module_search
ORDER BY tos.icon_name ASC, tos.id_os ASC, ta.nombre ASC, tam.nombre";
$data = db_process_sql($sql);
if (empty($data)) {
$data = array();
}
$nodes = array();
$actual_os_root = array(
'id' => -1,
'name' => '',
'icon' => '',
'children' => array(),
'counters' => array()
);
$actual_agent = array();
foreach ($data as $key => $value) {
// Module
$module = array();
$module['id_agente_modulo'] = (int) $value['id_agente_modulo'];
$module['nombre'] = $value['module_name'];
$module['id_tipo_modulo'] = (int) $value['id_tipo_modulo'];
$module['server_type'] = (int) $value['id_modulo'];
2015-01-12 12:47:54 +01:00
$module['status'] = (int) $value['estado'];
$module['value'] = $value['datos'];
$this->processModule($module);
// OS item
if ($actual_os_root['id'] === (int)$value['id_os']) {
// Agent
if (empty($actual_agent) || $actual_agent['id'] !== (int)$value['id_agente']) {
// Add the last agent to the os item
if (!empty($actual_agent))
$actual_os_root['children'][] = $actual_agent;
// Create the new agent
$actual_agent = array();
$actual_agent['id_agente'] = (int) $value['id_agente'];
$actual_agent['nombre'] = $value['agent_name'];
$actual_agent['children'] = array();
2015-01-14 17:56:42 +01:00
$actual_agent['counters'] = array();
$actual_agent['counters']['total'] = (int) $value['total_count'];
$actual_agent['counters']['alerts'] = (int) $value['fired_count_count'];
$actual_agent['counters']['critical'] = (int) $value['critical_count'];
$actual_agent['counters']['warning'] = (int) $value['warning_count'];
$actual_agent['counters']['unknown'] = (int) $value['unknown_count'];
$actual_agent['counters']['not_init'] = (int) $value['notinit_count'];
$actual_agent['counters']['ok'] = (int) $value['normal_count'];
2015-01-15 13:23:08 +01:00
$this->processAgent($actual_agent, array(), false);
// Add the module to the agent
$actual_agent['children'][] = $module;
// Increase counters
$actual_os_root['counters']['total']++;
if (isset($actual_os_root['counters'][$actual_agent['status']]))
$actual_os_root['counters'][$actual_agent['status']]++;
}
else {
// Add the module to the agent
$actual_agent['children'][] = $module;
}
}
else {
// The first iteration doesn't enter here
if ($actual_os_root['id'] !== -1) {
// Add the agent to the os item
$actual_os_root['children'][] = $actual_agent;
// Add the os the branch
$nodes[] = $actual_os_root;
}
// Create new os item
$actual_os_root = array();
$actual_os_root['id'] = (int) $value['id_os'];
$actual_os_root['type'] = $this->type;
if (!empty($actual_os_root['id'])) {
$actual_os_root['name'] = $value['os_name'];
$actual_os_root['icon'] = $value['os_icon'];
}
else {
$actual_os_root['name'] = __('None');
$actual_os_root['icon'] = 'so_other.png';
}
// Create the new agent
$actual_agent = array();
$actual_agent['id_agente'] = (int) $value['id_agente'];
$actual_agent['nombre'] = $value['agent_name'];
$actual_agent['children'] = array();
2015-01-14 17:56:42 +01:00
$actual_agent['counters'] = array();
$actual_agent['counters']['total'] = (int) $value['total_count'];
$actual_agent['counters']['alerts'] = (int) $value['fired_count_count'];
$actual_agent['counters']['critical'] = (int) $value['critical_count'];
$actual_agent['counters']['warning'] = (int) $value['warning_count'];
$actual_agent['counters']['unknown'] = (int) $value['unknown_count'];
$actual_agent['counters']['not_init'] = (int) $value['notinit_count'];
$actual_agent['counters']['ok'] = (int) $value['normal_count'];
2015-01-15 13:23:08 +01:00
$this->processAgent($actual_agent, array(), false);
// Add the module to the agent
$actual_agent['children'][] = $module;
// Initialize counters
$actual_os_root['counters'] = array();
$actual_os_root['counters']['total'] = 0;
$actual_os_root['counters']['alerts'] = 0;
$actual_os_root['counters']['critical'] = 0;
$actual_os_root['counters']['warning'] = 0;
$actual_os_root['counters']['unknown'] = 0;
$actual_os_root['counters']['not_init'] = 0;
$actual_os_root['counters']['ok'] = 0;
// Increase counters
$actual_os_root['counters']['total']++;
if (isset($actual_os_root['counters'][$actual_agent['status']]))
$actual_os_root['counters'][$actual_agent['status']]++;
}
}
// If there is an agent and an os item opened and not saved
if ($actual_os_root['id'] !== -1) {
// Add the last agent to the os item
$actual_os_root['children'][] = $actual_agent;
// Add the last os to the branch
$nodes[] = $actual_os_root;
}
$this->tree = $nodes;
}
private function getDataTag() {
2015-01-05 17:08:33 +01:00
2015-01-14 17:56:42 +01:00
// Get the parent
if (empty($this->root))
$parent = 0;
else
$parent = $this->root;
2015-01-05 16:48:11 +01:00
2015-01-14 17:56:42 +01:00
// Get all groups
if (empty($parent)) {
// ACL Group
if (isset($this->userGroups) && $this->userGroups === false)
return array();
2015-01-05 16:48:11 +01:00
2015-01-14 17:56:42 +01:00
$group_acl = "";
if (!empty($this->userGroups)) {
$user_groups_str = implode(",", array_keys($this->userGroups));
$group_acl = " AND ta.id_grupo IN ($user_groups_str) ";
}
2015-01-05 16:48:11 +01:00
2015-01-14 17:56:42 +01:00
// Agent name filter
$agent_search = "";
if (!empty($this->filter['searchAgent'])) {
$agent_search = " AND ta.nombre LIKE '%".$this->filter['searchAgent']."%' ";
}
// Module name filter
$module_search = "";
if (!empty($this->filter['searchModule'])) {
$module_search = " AND tam.nombre LIKE '%".$this->filter['searchModule']."%' ";
}
$sql = "SELECT tam.id_agente_modulo, tam.nombre AS module_name,
tam.id_tipo_modulo, tam.id_modulo,
ta.id_agente, ta.nombre AS agent_name, ta.fired_count,
ta.normal_count, ta.warning_count, ta.critical_count,
ta.unknown_count, ta.notinit_count, ta.total_count,
tt.id_tag, tt.name AS tag_name,
tae.estado, tae.estado
FROM tagente_modulo AS tam
INNER JOIN tagente AS ta
ON ta.id_agente = tam.id_agente
AND ta.disabled = 0
INNER JOIN tagente_estado AS tae
ON tae.id_agente_modulo = tam.id_agente_modulo
INNER JOIN ttag_module AS ttm
ON ttm.id_agente_modulo = tam.id_agente_modulo
INNER JOIN ttag AS tt
ON tt.id_tag = ttm.id_tag
WHERE tam.disabled = 0
$agent_search
$module_search
$group_acl
ORDER BY tt.name ASC, tt.id_tag ASC, ta.nombre ASC, tam.nombre ASC";
$data = db_process_sql($sql);
if (empty($data)) {
$data = array();
}
2015-01-05 16:48:11 +01:00
2015-01-14 17:56:42 +01:00
$nodes = array();
$actual_tag_root = array(
'id' => null,
'name' => '',
'children' => array(),
'counters' => array()
);
$actual_agent = array();
foreach ($data as $key => $value) {
// Module
$module = array();
$module['id_agente_modulo'] = (int) $value['id_agente_modulo'];
$module['nombre'] = $value['module_name'];
$module['id_tipo_modulo'] = (int) $value['id_tipo_modulo'];
$module['server_type'] = (int) $value['id_modulo'];
$module['status'] = (int) $value['estado'];
$module['value'] = $value['datos'];
2015-01-05 16:48:11 +01:00
2015-01-14 17:56:42 +01:00
$this->processModule($module);
2015-01-05 16:48:11 +01:00
2015-01-14 17:56:42 +01:00
// Tag
if ($actual_tag_root['id'] === (int)$value['id_tag']) {
// Agent
if (empty($actual_agent) || $actual_agent['id'] !== (int)$value['id_agente']) {
// Add the last agent to the tag
if (!empty($actual_agent))
$actual_tag_root['children'][] = $actual_agent;
// Create the new agent
$actual_agent = array();
$actual_agent['id_agente'] = (int) $value['id_agente'];
$actual_agent['nombre'] = $value['agent_name'];
$actual_agent['children'] = array();
2015-01-15 13:23:08 +01:00
$this->processAgent($actual_agent, array(), false);
2015-01-14 17:56:42 +01:00
// Add the module to the agent
$actual_agent['children'][] = $module;
// Increase counters
$actual_tag_root['counters']['total']++;
if (isset($actual_tag_root['counters'][$actual_agent['status']]))
$actual_tag_root['counters'][$actual_agent['status']]++;
}
else {
$actual_agent['children'][] = $module;
}
}
else {
// The first iteration doesn't enter here
if ($actual_tag_root['id'] !== null) {
// Add the agent to the tag
2015-01-05 16:48:11 +01:00
$actual_tag_root['children'][] = $actual_agent;
2015-01-14 17:56:42 +01:00
// Add the tag to the branch
$nodes[] = $actual_tag_root;
}
2015-01-05 16:48:11 +01:00
// Create the new agent
$actual_agent = array();
$actual_agent['id_agente'] = (int) $value['id_agente'];
$actual_agent['nombre'] = $value['agent_name'];
$actual_agent['children'] = array();
2015-01-15 13:23:08 +01:00
$this->processAgent($actual_agent, array(), false);
2015-01-05 16:48:11 +01:00
// Add the module to the agent
$actual_agent['children'][] = $module;
2015-01-14 17:56:42 +01:00
// Create new tag
$actual_tag_root = array();
$actual_tag_root['id'] = (int) $value['id_tag'];
$actual_tag_root['name'] = $value['tag_name'];
$actual_tag_root['type'] = $this->type;
// Initialize counters
$actual_tag_root['counters'] = array();
$actual_tag_root['counters']['total'] = 0;
$actual_tag_root['counters']['alerts'] = 0;
$actual_tag_root['counters']['critical'] = 0;
$actual_tag_root['counters']['warning'] = 0;
$actual_tag_root['counters']['unknown'] = 0;
$actual_tag_root['counters']['not_init'] = 0;
$actual_tag_root['counters']['ok'] = 0;
2015-01-05 16:48:11 +01:00
// Increase counters
$actual_tag_root['counters']['total']++;
if (isset($actual_tag_root['counters'][$actual_agent['status']]))
$actual_tag_root['counters'][$actual_agent['status']]++;
}
}
2015-01-14 17:56:42 +01:00
// If there is an agent and a tag opened and not saved
if ($actual_tag_root['id'] !== null) {
// Add the last agent to the tag
$actual_tag_root['children'][] = $actual_agent;
// Add the last tag to the branch
$nodes[] = $actual_tag_root;
2015-01-05 16:48:11 +01:00
}
2015-01-14 17:56:42 +01:00
$this->tree = $nodes;
2015-01-05 16:48:11 +01:00
}
2015-01-14 17:56:42 +01:00
else {
if (! defined ('METACONSOLE')) {
$this->tree = $this->getAgents($parent, $this->type);
}
else {
function cmpSortAgentNames($a, $b) {
return strcmp($a["name"], $b["name"]);
}
$agents = array();
foreach ($parent as $server_id => $tag_id) {
$server = metaconsole_get_servers($server_id);
if (!empty($server)) {
if (metaconsole_connect($server) != NOERR)
continue;
$agents += $this->tree = $this->getAgents($tag_id, $this->type, $server_id);
metaconsole_restore_db();
}
}
if (!empty($agents))
usort($agents, "cmpSortAgentNames");
$this->tree = $agents;
}
2015-01-05 16:48:11 +01:00
}
2014-12-16 16:39:00 +01:00
}
2014-12-17 18:58:34 +01:00
public function getJSON() {
$this->getData();
2014-12-16 16:39:00 +01:00
return json_encode($this->tree);
}
2014-12-17 18:58:34 +01:00
public function getArray() {
$this->getData();
return $this->tree;
}
2014-12-16 16:39:00 +01:00
}
?>