type = $type; $this->rootType = !empty($rootType) ? $rootType : $type; $this->id = $id; $this->rootID = !empty($rootID) ? $rootID : $id; $this->serverID = $serverID; $this->childrenMethod = $childrenMethod; $this->access = $access; $userGroupsACL = users_get_groups(false, $this->access); $this->userGroupsACL = empty($userGroupsACL) ? false : $userGroupsACL; $this->userGroups = $this->userGroupsACL; global $config; include_once($config['homedir']."/include/functions_servers.php"); include_once($config['homedir']."/include/functions_modules.php"); require_once($config['homedir']."/include/functions_tags.php"); if (is_metaconsole()) enterprise_include_once("meta/include/functions_ui_meta.php"); $this->strictACL = (bool) db_get_value("strict_acl", "tusuario", "id_user", $config['id_user']); $this->acltags = tags_get_user_groups_and_tags($config['id_user'], $this->access); } public function setFilter($filter) { $this->filter = $filter; } protected function getAgentStatusFilter ($status = -1) { if ($status == -1) $status = $this->filter['statusAgent']; $agent_status_filter = ""; switch ($status) { case AGENT_STATUS_NOT_INIT: $agent_status_filter = " AND (ta.total_count = 0 OR ta.total_count = ta.notinit_count) "; break; case AGENT_STATUS_CRITICAL: $agent_status_filter = " AND ta.critical_count > 0 "; break; case AGENT_STATUS_WARNING: $agent_status_filter = " AND (ta.critical_count = 0 AND ta.warning_count > 0) "; break; case AGENT_STATUS_UNKNOWN: $agent_status_filter = " AND (ta.critical_count = 0 AND ta.warning_count = 0 AND ta.unknown_count > 0) "; break; case AGENT_STATUS_NORMAL: $agent_status_filter = " AND (ta.critical_count = 0 AND ta.warning_count = 0 AND ta.unknown_count = 0 AND ta.normal_count > 0) "; break; } return $agent_status_filter; } protected function getAgentCounterColumnsSql ($agent_table) { // Add the agent counters to the columns if ($this->filter['statusAgent'] == -1) { // Critical $agent_critical_filter = $this->getAgentStatusFilter(AGENT_STATUS_CRITICAL); $agents_critical_count = "($agent_table $agent_critical_filter) AS total_critical_count"; // Warning $agent_warning_filter = $this->getAgentStatusFilter(AGENT_STATUS_WARNING); $agents_warning_count = "($agent_table $agent_warning_filter) AS total_warning_count"; // Unknown $agent_unknown_filter = $this->getAgentStatusFilter(AGENT_STATUS_UNKNOWN); $agents_unknown_count = "($agent_table $agent_unknown_filter) AS total_unknown_count"; // Normal $agent_normal_filter = $this->getAgentStatusFilter(AGENT_STATUS_NORMAL); $agents_normal_count = "($agent_table $agent_normal_filter) AS total_normal_count"; // Not init $agent_not_init_filter = $this->getAgentStatusFilter(AGENT_STATUS_NOT_INIT); $agents_not_init_count = "($agent_table $agent_not_init_filter) AS total_not_init_count"; // Alerts fired $agents_fired_count = "($agent_table AND ta.fired_count > 0) AS total_fired_count"; // Total $agents_total_count = "($agent_table) AS total_count"; $columns = "$agents_critical_count, $agents_warning_count, " . "$agents_unknown_count, $agents_normal_count, $agents_not_init_count, " . "$agents_fired_count, $agents_total_count"; } else { // Alerts fired $agents_fired_count = "($agent_table AND ta.fired_count > 0) AS total_fired_count"; // Total $agents_total_count = "($agent_table) AS total_count"; switch ($this->filter['statusAgent']) { case AGENT_STATUS_NOT_INIT: // Not init $agent_not_init_filter = $this->getAgentStatusFilter(AGENT_STATUS_NOT_INIT); $agents_not_init_count = "($agent_table $agent_not_init_filter) AS total_not_init_count"; $columns = "$agents_not_init_count, $agents_fired_count, $agents_total_count"; break; case AGENT_STATUS_CRITICAL: // Critical $agent_critical_filter = $this->getAgentStatusFilter(AGENT_STATUS_CRITICAL); $agents_critical_count = "($agent_table $agent_critical_filter) AS total_critical_count"; $columns = "$agents_critical_count, $agents_fired_count, $agents_total_count"; break; case AGENT_STATUS_WARNING: // Warning $agent_warning_filter = $this->getAgentStatusFilter(AGENT_STATUS_WARNING); $agents_warning_count = "($agent_table $agent_warning_filter) AS total_warning_count"; $columns = "$agents_warning_count, $agents_fired_count, $agents_total_count"; break; case AGENT_STATUS_UNKNOWN: // Unknown $agent_unknown_filter = $this->getAgentStatusFilter(AGENT_STATUS_UNKNOWN); $agents_unknown_count = "($agent_table $agent_unknown_filter) AS total_unknown_count"; $columns = "$agents_unknown_count, $agents_fired_count, $agents_total_count"; break; case AGENT_STATUS_NORMAL: // Normal $agent_normal_filter = $this->getAgentStatusFilter(AGENT_STATUS_NORMAL); $agents_normal_count = "($agent_table $agent_normal_filter) AS total_normal_count"; $columns = "$agents_normal_count, $agents_fired_count, $agents_total_count"; break; } } return $columns; } protected function getAgentCountersSql ($agent_table) { global $config; $columns = $this->getAgentCounterColumnsSql($agent_table); switch ($config["dbtype"]) { case "mysql": case "postgresql": $columns = "SELECT $columns FROM dual LIMIT 1"; break; case "oracle": $columns = "SELECT $columns FROM dual WHERE rownum <= 1"; break; } return $columns; } protected function getSql ($item_for_count = false) { // Get the type if (empty($this->type)) $type = 'none'; else $type = $this->type; // Get the root type if (empty($this->rootType)) $rootType = 'none'; else $rootType = $this->rootType; // Get the parent $parent = $this->id; // Get the root id $rootID = $this->rootID; // Get the server id $serverID = $this->serverID; // Agent name filter $agent_search_filter = ""; if (!empty($this->filter['searchAgent'])) { $agent_search_filter = " AND LOWER(ta.alias) LIKE LOWER('%".$this->filter['searchAgent']."%')"; } //Search hirearchy $search_hirearchy = false; if($this->filter['searchHirearchy']){ $search_hirearchy = true; } // Agent status filter $agent_status_filter = ""; if (isset($this->filter['statusAgent']) && $this->filter['statusAgent'] != AGENT_STATUS_ALL && !$this->strictACL) { $agent_status_filter = $this->getAgentStatusFilter($this->filter['statusAgent']); } // Agents join $agents_join = ""; if (!empty($agent_search_filter) || !empty($agent_status_filter)) { $agents_join = "INNER JOIN tagente ta ON ta.disabled = 0 AND tam.id_agente = ta.id_agente $agent_search_filter $agent_status_filter"; } // Module name filter $module_search_filter = ""; if (!empty($this->filter['searchModule'])) { $module_search_filter = " AND tam.nombre LIKE '%".$this->filter['searchModule']."%' "; } // Module status filter $module_status_filter = ""; if (isset($this->filter['statusModule']) && $this->filter['statusModule'] != -1) { switch ($this->filter['statusModule']) { case AGENT_MODULE_STATUS_CRITICAL_ALERT: case AGENT_MODULE_STATUS_CRITICAL_BAD: $module_status_filter = " AND (tae.estado = ".AGENT_MODULE_STATUS_CRITICAL_ALERT." OR tae.estado = ".AGENT_MODULE_STATUS_CRITICAL_BAD.") "; break; case AGENT_MODULE_STATUS_WARNING_ALERT: case AGENT_MODULE_STATUS_WARNING: $module_status_filter = " AND (tae.estado = ".AGENT_MODULE_STATUS_WARNING_ALERT." OR tae.estado = ".AGENT_MODULE_STATUS_WARNING.") "; break; case AGENT_MODULE_STATUS_UNKNOWN: $module_status_filter = " AND tae.estado = ".AGENT_MODULE_STATUS_UNKNOWN." "; break; case AGENT_MODULE_STATUS_NO_DATA: case AGENT_MODULE_STATUS_NOT_INIT: $module_status_filter = " AND (tae.estado = ".AGENT_MODULE_STATUS_NO_DATA." OR tae.estado = ".AGENT_MODULE_STATUS_NOT_INIT.") "; break; case AGENT_MODULE_STATUS_NORMAL_ALERT: case AGENT_MODULE_STATUS_NORMAL: $module_status_filter = " AND (tae.estado = ".AGENT_MODULE_STATUS_NORMAL_ALERT." OR tae.estado = ".AGENT_MODULE_STATUS_NORMAL.") "; break; } } // Modules join $modules_join = ""; $module_status_join = ""; if (!empty($module_search_filter) || !empty($module_status_filter)) { if (!empty($module_status_filter)) { $module_status_join = "INNER JOIN tagente_estado tae ON tam.id_agente_modulo IS NOT NULL AND tam.id_agente_modulo = tae.id_agente_modulo $module_status_filter"; } $modules_join = "INNER JOIN tagente_modulo tam ON tam.disabled = 0 AND ta.id_agente = tam.id_agente $module_search_filter $module_status_join"; } if (empty($module_status_join)) { $module_status_join = "LEFT JOIN tagente_estado tae ON tam.id_agente_modulo = tae.id_agente_modulo"; } $sql = false; switch ($rootType) { case 'group': // ACL Group $user_groups_str = "-1"; $group_filter = ""; if (!$this->strictACL) { if (empty($this->userGroups)) { return; } // Asking for a specific group. if ($item_for_count !== false) { if (!isset($this->userGroups[$item_for_count])) { return; } } // Asking for all groups. else { $user_groups_str = implode(",", array_keys($this->userGroups)); $group_filter = "AND ta.id_grupo IN ($user_groups_str)"; } } else { if (!empty($this->acltags)) { $groups = array(); foreach ($this->acltags as $group_id => $tags_str) { if (empty($tags_str)) { $hierarchy_groups = groups_get_id_recursive($group_id); $groups = array_merge($groups, $hierarchy_groups); } } if (!empty($groups)) { if (array_search(0, $groups) === false) { $user_groups_str = implode(",", $groups); } } } $group_filter = "AND ta.id_grupo IN ($user_groups_str)"; } if(!$search_hirearchy && (!empty($agent_search_filter) || !empty($module_search_filter))){ if(is_metaconsole()){ $query_agent_search = " SELECT DISTINCT(ta.id_grupo) FROM tmetaconsole_agent ta WHERE ta.disabled = 0 $agent_search_filter"; $id_groups_agents = db_get_all_rows_sql($query_agent_search); } else{ $query_agent_search = " SELECT DISTINCT(ta.id_grupo) FROM tagente ta, tagente_modulo tam WHERE tam.id_agente = ta.id_agente AND ta.disabled = 0 $agent_search_filter $module_search_filter"; $id_groups_agents = db_get_all_rows_sql($query_agent_search); } if($id_groups_agents != false){ foreach ($id_groups_agents as $key => $value) { $id_groups_agents_array[] = $value['id_grupo']; } $user_groups_array = explode(",", $user_groups_str); $user_groups_array = array_intersect($user_groups_array, $id_groups_agents_array); $user_groups_str = implode("," , $user_groups_array); } else{ $user_groups_str = false; } } switch ($type) { // Get the agents of a group case 'group': if (empty($rootID) || $rootID == -1) { if(!$search_hirearchy && (!empty($agent_search_filter) || !empty($module_search_filter))){ $columns = 'tg.id_grupo AS id, tg.nombre AS name, tg.icon'; } else{ $columns = 'tg.id_grupo AS id, tg.nombre AS name, tg.parent, tg.icon'; } $order_fields = 'tg.nombre ASC, tg.id_grupo ASC'; if (! is_metaconsole()) { // Groups SQL if ($item_for_count === false) { $sql = "SELECT $columns FROM tgrupo tg WHERE tg.id_grupo IN ($user_groups_str) ORDER BY $order_fields"; } // Counters SQL else { $agent_table = "SELECT COUNT(DISTINCT(ta.id_agente)) FROM tagente ta INNER JOIN tagente_modulo tam ON tam.disabled = 0 AND ta.id_agente = tam.id_agente $module_search_filter $module_status_join WHERE ta.disabled = 0 AND ta.id_grupo = $item_for_count $group_filter $agent_search_filter $agent_status_filter"; $sql = $this->getAgentCountersSql($agent_table); } } // Metaconsole else { // Groups SQL if ($item_for_count === false) { $sql = "SELECT $columns FROM tgrupo tg WHERE tg.id_grupo IN ($user_groups_str) ORDER BY $order_fields"; } // Counters SQL else { $agent_table = "SELECT COUNT(DISTINCT(ta.id_agente)) FROM tmetaconsole_agent ta WHERE ta.disabled = 0 AND ta.id_grupo = $item_for_count $group_filter $agent_search_filter $agent_status_filter"; $sql = $this->getAgentCountersSql($agent_table); } } } else { if (! is_metaconsole() || $this->strictACL) { $columns = 'ta.id_agente AS id, ta.nombre AS name, ta.alias, ta.fired_count, ta.normal_count, ta.warning_count, ta.critical_count, ta.unknown_count, ta.notinit_count, ta.total_count, ta.quiet'; $group_by_fields = 'ta.id_agente, ta.nombre, ta.alias, ta.fired_count, ta.normal_count, ta.warning_count, ta.critical_count, ta.unknown_count, ta.notinit_count, ta.total_count, ta.quiet'; $order_fields = 'ta.alias ASC, ta.id_agente ASC'; $sql = "SELECT $columns FROM tagente ta LEFT JOIN tagente_modulo tam ON tam.disabled = 0 AND ta.id_agente = tam.id_agente $module_search_filter $module_status_join WHERE ta.disabled = 0 AND ta.id_grupo = $rootID $group_filter $agent_search_filter $agent_status_filter GROUP BY $group_by_fields ORDER BY $order_fields"; } else { $columns = 'ta.id_tagente AS id, ta.nombre AS name, ta.alias, ta.fired_count, ta.normal_count, ta.warning_count, ta.critical_count, ta.unknown_count, ta.notinit_count, ta.total_count, ta.quiet, id_tmetaconsole_setup AS server_id'; $order_fields = 'ta.alias ASC, ta.id_tagente ASC'; $sql = "SELECT $columns FROM tmetaconsole_agent ta WHERE ta.disabled = 0 AND ta.id_grupo = $rootID $group_filter $agent_search_filter $agent_status_filter ORDER BY $order_fields"; } } break; // Get the modules of an agent case 'agent': $columns = 'tam.id_agente_modulo AS id, tam.parent_module_id AS parent, tam.nombre AS name, tam.id_tipo_modulo, tam.id_modulo, tae.estado, tae.datos'; $order_fields = 'tam.nombre ASC, tam.id_agente_modulo ASC'; // Set for the common ACL only. The strict ACL case is different (groups and tags divided). // The modules only have visibility in two cases: // 1. The user has access to the group of its agent and this group hasn't tags. // 2. The user has access to the group of its agent, this group has tags and the module // has any of this tags. $tag_join = ''; if (!$this->strictACL) { // $rootID it the agent group id in this case if (!empty($this->acltags) && isset($this->acltags[$rootID])) { $tags_str = $this->acltags[$rootID]; if (!empty($tags_str)) { $tag_join = sprintf('INNER JOIN ttag_module ttm ON tam.id_agente_modulo = ttm.id_agente_modulo AND ttm.id_tag IN (%s)', $tags_str); } } } $sql = "SELECT $columns FROM tagente_modulo tam $tag_join $module_status_join INNER JOIN tagente ta ON ta.disabled = 0 AND tam.id_agente = ta.id_agente AND ta.id_grupo = $rootID $group_filter $agent_search_filter $agent_status_filter WHERE tam.disabled = 0 AND tam.id_agente = $parent $module_search_filter ORDER BY $order_fields"; break; } break; case 'tag': // ACL Group $group_acl = ""; if (!$this->strictACL) { if (!empty($this->userGroups)) { $user_groups_str = implode(",", array_keys($this->userGroups)); $group_acl = " AND ta.id_grupo IN ($user_groups_str) "; } else { $group_acl = "AND ta.id_grupo = -1"; } } else { if (!empty($this->acltags) && !empty($rootID) && $rootID != -1) { $groups = array(); foreach ($this->acltags as $group_id => $tags_str) { if (!empty($tags_str)) { $tags = explode(",", $tags_str); if (in_array($rootID, $tags)) { $hierarchy_groups = groups_get_id_recursive($group_id); $groups = array_merge($groups, $hierarchy_groups); } } } if (!empty($groups)) { if (array_search(0, $groups) === false) { $user_groups_str = implode(",", $groups); $group_acl = " AND ta.id_grupo IN ($user_groups_str) "; } } else { $group_acl = "AND ta.id_grupo = -1"; } } else { $group_acl = "AND ta.id_grupo = -1"; } } switch ($type) { // Get the agents of a tag case 'tag': if (empty($rootID) || $rootID == -1) { if ($this->strictACL) return false; // tagID filter. To access the view from tactical views f.e. $tag_filter = ''; if (!empty($this->filter['tagID'])) { $tag_filter = "WHERE tt.id_tag = " . $this->filter['tagID']; } $columns = 'tt.id_tag AS id, tt.name AS name'; $group_by_fields = 'tt.id_tag, tt.name'; $order_fields = 'tt.name ASC, tt.id_tag ASC'; // Tags SQL if ($item_for_count === false) { $sql = "SELECT $columns FROM ttag tt INNER JOIN ttag_module ttm ON tt.id_tag = ttm.id_tag INNER JOIN tagente_modulo tam ON tam.disabled = 0 AND ttm.id_agente_modulo = tam.id_agente_modulo $module_search_filter $module_status_join INNER JOIN tagente ta ON ta.disabled = 0 AND tam.id_agente = ta.id_agente $group_acl $agent_search_filter $agent_status_filter $tag_filter GROUP BY $group_by_fields ORDER BY $order_fields"; } // Counters SQL else { $agent_table = "SELECT COUNT(DISTINCT(ta.id_agente)) FROM tagente ta INNER JOIN tagente_modulo tam ON tam.disabled = 0 AND ta.id_agente = tam.id_agente $module_search_filter $module_status_join INNER JOIN ttag_module ttm ON tam.id_agente_modulo = ttm.id_agente_modulo AND ttm.id_tag = $item_for_count WHERE ta.disabled = 0 $group_acl $agent_search_filter $agent_status_filter"; $sql = $this->getAgentCountersSql($agent_table); } } else { $columns = 'ta.id_agente AS id, ta.nombre AS name, ta.alias, ta.fired_count, ta.normal_count, ta.warning_count, ta.critical_count, ta.unknown_count, ta.notinit_count, ta.total_count, ta.quiet'; $group_by_fields = 'ta.id_agente, ta.nombre, ta.alias, ta.fired_count, ta.normal_count, ta.warning_count, ta.critical_count, ta.unknown_count, ta.notinit_count, ta.total_count, ta.quiet'; $order_fields = 'ta.alias ASC, ta.id_agente ASC'; $sql = "SELECT $columns FROM tagente ta INNER JOIN tagente_modulo tam ON tam.disabled = 0 AND ta.id_agente = tam.id_agente $module_search_filter $module_status_join INNER JOIN ttag_module ttm ON tam.id_agente_modulo = ttm.id_agente_modulo AND ttm.id_tag = $rootID WHERE ta.disabled = 0 $group_acl $agent_search_filter $agent_status_filter GROUP BY $group_by_fields ORDER BY $order_fields"; } break; // Get the modules of an agent case 'agent': $columns = 'tam.id_agente_modulo AS id, tam.nombre AS name, tam.id_tipo_modulo, tam.id_modulo, tae.estado, tae.datos'; $order_fields = 'tam.nombre ASC, tam.id_agente_modulo ASC'; // Set for the common ACL only. The strict ACL case is different (groups and tags divided). // The modules only have visibility in two cases: // 1. The user has access to the group of its agent and this group hasn't tags. // 2. The user has access to the group of its agent, this group has tags and the module // has any of this tags. $tag_filter = ''; if (!$this->strictACL) { // $parent is the agent id $group_id = (int) db_get_value('id_grupo', 'tagente', 'id_agente', $parent); if (empty($group_id)) { // ACL error, this will restrict (fuck) the module search $tag_filter = 'AND 1=0'; } else if (!empty($this->acltags) && isset($this->acltags[$group_id])) { $tags_str = $this->acltags[$group_id]; if (!empty($tags_str)) { $tag_filter = sprintf('AND ttm.id_tag IN (%s)', $tags_str); } } } $sql = "SELECT $columns FROM tagente_modulo tam INNER JOIN ttag_module ttm ON tam.id_agente_modulo = ttm.id_agente_modulo AND ttm.id_tag = $rootID $tag_filter $module_status_join INNER JOIN tagente ta ON ta.disabled = 0 AND tam.id_agente = ta.id_agente $group_acl $agent_search_filter $agent_status_filter WHERE tam.disabled = 0 AND tam.id_agente = $parent $module_search_filter ORDER BY $order_fields"; break; } break; case 'os': // ACL Group $group_acl = ""; if (!empty($this->userGroups)) { $user_groups_str = implode(",", array_keys($this->userGroups)); $group_acl = " AND ta.id_grupo IN ($user_groups_str) "; } else { $group_acl = "AND ta.id_grupo = -1"; } switch ($type) { // Get the agents of an os case 'os': if (empty($rootID) || $rootID == -1) { $columns = 'tos.id_os AS id, tos.name AS name, tos.icon_name AS os_icon'; $group_by_fields = 'tos.id_os, tos.name, tos.icon_name'; $order_fields = 'tos.icon_name ASC, tos.id_os ASC'; // OS SQL if ($item_for_count === false) { $sql = "SELECT $columns FROM tconfig_os tos INNER JOIN tagente ta ON ta.disabled = 0 AND ta.id_os = tos.id_os $agent_search_filter $agent_status_filter $group_acl $modules_join GROUP BY $group_by_fields ORDER BY $order_fields"; } // Counters SQL else { $agent_table = "SELECT COUNT(DISTINCT(ta.id_agente)) FROM tagente ta $modules_join WHERE ta.disabled = 0 AND ta.id_os = $item_for_count $group_acl $agent_search_filter $agent_status_filter"; $sql = $this->getAgentCountersSql($agent_table); } } else { $columns = 'ta.id_agente AS id, ta.nombre AS name, ta.alias, ta.fired_count, ta.normal_count, ta.warning_count, ta.critical_count, ta.unknown_count, ta.notinit_count, ta.total_count, ta.quiet'; $group_by_fields = 'ta.id_agente, ta.nombre, ta.alias, ta.fired_count, ta.normal_count, ta.warning_count, ta.critical_count, ta.unknown_count, ta.notinit_count, ta.total_count, ta.quiet'; $order_fields = 'ta.alias ASC, ta.id_agente ASC'; $sql = "SELECT $columns FROM tagente ta $modules_join WHERE ta.disabled = 0 AND ta.id_os = $rootID $group_acl $agent_search_filter $agent_status_filter GROUP BY $group_by_fields ORDER BY $order_fields"; } break; // Get the modules of an agent case 'agent': $columns = 'tam.id_agente_modulo AS id, tam.nombre AS name, tam.id_tipo_modulo, tam.id_modulo, tae.estado, tae.datos'; $order_fields = 'tam.nombre ASC, tam.id_agente_modulo ASC'; $os_filter = "AND ta.id_os = $rootID"; $agent_filter = "AND ta.id_agente = $parent"; // Set for the common ACL only. The strict ACL case is different (groups and tags divided). // The modules only have visibility in two cases: // 1. The user has access to the group of its agent and this group hasn't tags. // 2. The user has access to the group of its agent, this group has tags and the module // has any of this tags. $tag_join = ''; if (!$this->strictACL) { // $parent is the agent id $group_id = (int) db_get_value('id_grupo', 'tagente', 'id_agente', $parent); if (empty($group_id)) { // ACL error, this will restrict (fuck) the module search $tag_join = 'INNER JOIN ttag_module tta ON 1=0'; } else if (!empty($this->acltags) && isset($this->acltags[$group_id])) { $tags_str = $this->acltags[$group_id]; if (!empty($tags_str)) { $tag_join = sprintf('INNER JOIN ttag_module ttm ON tam.id_agente_modulo = ttm.id_agente_modulo AND ttm.id_tag IN (%s)', $tags_str); } } } $sql = "SELECT $columns FROM tagente_modulo tam $tag_join $module_status_join INNER JOIN tagente ta ON ta.disabled = 0 AND tam.id_agente = ta.id_agente $os_filter $group_acl $agent_search_filter $agent_status_filter WHERE tam.disabled = 0 $agent_filter $module_search_filter ORDER BY $order_fields"; break; } break; case 'module_group': // ACL Group $group_acl = ""; if (!empty($this->userGroups)) { $user_groups_str = implode(",", array_keys($this->userGroups)); $group_acl = " AND ta.id_grupo IN ($user_groups_str) "; } else { $group_acl = "AND ta.id_grupo = -1"; } switch ($type) { // Get the agents of a module group case 'module_group': if (empty($rootID) || $rootID == -1) { $columns = 'tmg.id_mg AS id, tmg.name AS name'; $group_by_fields = 'tmg.id_mg, tmg.name'; $order_fields = 'tmg.name ASC, tmg.id_mg ASC'; // Module groups SQL if ($item_for_count === false) { $sql = "SELECT $columns FROM tmodule_group tmg INNER JOIN tagente_modulo tam ON tam.disabled = 0 AND tam.id_module_group = tmg.id_mg $module_search_filter $module_status_join INNER JOIN tagente ta ON ta.disabled = 0 AND tam.id_agente = ta.id_agente $group_acl $agent_search_filter $agent_status_filter GROUP BY $group_by_fields ORDER BY $order_fields"; } // Counters SQL else { $agent_table = "SELECT COUNT(DISTINCT(ta.id_agente)) FROM tagente ta INNER JOIN tagente_modulo tam ON tam.disabled = 0 AND ta.id_agente = tam.id_agente AND tam.id_module_group = $item_for_count $module_search_filter $module_status_join WHERE ta.disabled = 0 $group_acl $agent_search_filter $agent_status_filter"; $sql = $this->getAgentCountersSql($agent_table); } } else { $columns = 'ta.id_agente AS id, ta.nombre AS name, ta.alias, ta.fired_count, ta.normal_count, ta.warning_count, ta.critical_count, ta.unknown_count, ta.notinit_count, ta.total_count, ta.quiet'; $group_by_fields = 'ta.id_agente, ta.nombre, ta.alias, ta.fired_count, ta.normal_count, ta.warning_count, ta.critical_count, ta.unknown_count, ta.notinit_count, ta.total_count, ta.quiet'; $order_fields = 'ta.alias ASC, ta.id_agente ASC'; $sql = "SELECT $columns FROM tagente ta INNER JOIN tagente_modulo tam ON tam.disabled = 0 AND ta.id_agente = tam.id_agente AND tam.id_module_group = $rootID $module_search_filter $module_status_join WHERE ta.disabled = 0 $group_acl $agent_search_filter $agent_status_filter GROUP BY $group_by_fields ORDER BY $order_fields"; } break; // Get the modules of an agent case 'agent': $columns = 'tam.id_agente_modulo AS id, tam.nombre AS name, tam.id_tipo_modulo, tam.id_modulo, tae.estado, tae.datos'; $order_fields = 'tam.nombre ASC, tam.id_agente_modulo ASC'; $module_group_filter = "AND tam.id_module_group = $rootID"; $agent_filter = "AND tam.id_agente = $parent"; // Set for the common ACL only. The strict ACL case is different (groups and tags divided). // The modules only have visibility in two cases: // 1. The user has access to the group of its agent and this group hasn't tags. // 2. The user has access to the group of its agent, this group has tags and the module // has any of this tags. $tag_join = ''; if (!$this->strictACL) { // $parent is the agent id $group_id = (int) db_get_value('id_grupo', 'tagente', 'id_agente', $parent); if (empty($group_id)) { // ACL error, this will restrict (fuck) the module search $tag_join = 'INNER JOIN ttag_module tta ON 1=0'; } else if (!empty($this->acltags) && isset($this->acltags[$group_id])) { $tags_str = $this->acltags[$group_id]; if (!empty($tags_str)) { $tag_join = sprintf('INNER JOIN ttag_module ttm ON tam.id_agente_modulo = ttm.id_agente_modulo AND ttm.id_tag IN (%s)', $tags_str); } } } $sql = "SELECT $columns FROM tagente_modulo tam $tag_join $module_status_join INNER JOIN tagente ta ON ta.disabled = 0 AND tam.id_agente = ta.id_agente $group_acl $agent_search_filter $agent_status_filter WHERE tam.disabled = 0 $agent_filter $module_group_filter $module_search_filter ORDER BY $order_fields"; break; } break; case 'module': // ACL Group $group_acl = ""; if (!empty($this->userGroups)) { $user_groups_str = implode(",", array_keys($this->userGroups)); $group_acl = " AND ta.id_grupo IN ($user_groups_str) "; } else { $group_acl = "AND ta.id_grupo = -1"; } switch ($type) { // Get the agents of a module case 'module': if (empty($rootID) || $rootID == -1) { $columns = 'tam.nombre AS name'; $order_fields = 'tam.nombre ASC'; // Modules SQL if ($item_for_count === false) { $sql = "SELECT $columns FROM tagente_modulo tam INNER JOIN tagente ta ON ta.disabled = 0 AND tam.id_agente = ta.id_agente $group_acl $agent_search_filter $agent_status_filter $module_status_join WHERE tam.disabled = 0 $module_search_filter GROUP BY tam.nombre ORDER BY $order_fields"; } // Counters SQL else { $agent_table = "SELECT COUNT(DISTINCT(ta.id_agente)) FROM tagente ta INNER JOIN tagente_modulo tam ON tam.disabled = 0 AND ta.id_agente = tam.id_agente AND tam.nombre = '$item_for_count' $module_group_filter $module_search_filter $module_status_join WHERE ta.disabled = 0 $group_acl $agent_search_filter $agent_status_filter"; $sql = $this->getAgentCountersSql($agent_table); } } else { $columns = 'ta.id_agente AS id, ta.nombre AS name, ta.alias, ta.fired_count, ta.normal_count, ta.warning_count, ta.critical_count, ta.unknown_count, ta.notinit_count, ta.total_count, ta.quiet'; $group_by_fields = 'ta.id_agente, ta.nombre, ta.alias, ta.fired_count, ta.normal_count, ta.warning_count, ta.critical_count, ta.unknown_count, ta.notinit_count, ta.total_count, ta.quiet'; $order_fields = 'ta.alias ASC, ta.id_agente ASC'; $symbols = ' !"#$%&\'()*+,./:;<=>?@[\\]^{|}~'; $name = $rootID; for ($i = 0; $i < strlen($symbols); $i++) { $name = str_replace('_articapandora_' . ord(substr($symbols, $i, 1)) .'_pandoraartica_', substr($symbols, $i, 1), $name); } $name = io_safe_input($name); $sql = "SELECT $columns FROM tagente ta INNER JOIN tagente_modulo tam ON tam.disabled = 0 AND ta.id_agente = tam.id_agente AND tam.nombre = '$name' $module_group_filter $module_search_filter $module_status_join WHERE ta.disabled = 0 $group_acl $agent_search_filter $agent_status_filter GROUP BY $group_by_fields ORDER BY $order_fields"; } break; // Get the modules of an agent case 'agent': $columns = 'tam.id_agente_modulo AS id, tam.nombre AS name, tam.id_tipo_modulo, tam.id_modulo, tae.estado, tae.datos'; $order_fields = 'tam.nombre ASC, tam.id_agente_modulo ASC'; $symbols = ' !"#$%&\'()*+,./:;<=>?@[\\]^{|}~'; $name = $rootID; for ($i = 0; $i < strlen($symbols); $i++) { $name = str_replace('_articapandora_' . ord(substr($symbols, $i, 1)) .'_pandoraartica_', substr($symbols, $i, 1), $name); } $name = io_safe_input($name); $module_name_filter = "AND tam.nombre = '$name'"; $agent_filter = "AND tam.id_agente = $parent"; // We need the agents table if (empty($agents_join)) { $agents_join = "INNER JOIN tagente ta ON ta.disabled = 0 AND tam.id_agente = ta.id_agente $group_acl"; } else { $agents_join .= " $group_acl"; } // Set for the common ACL only. The strict ACL case is different (groups and tags divided). // The modules only have visibility in two cases: // 1. The user has access to the group of its agent and this group hasn't tags. // 2. The user has access to the group of its agent, this group has tags and the module // has any of this tags. $tag_join = ''; if (!$this->strictACL) { // $parent is the agent id $group_id = (int) db_get_value('id_grupo', 'tagente', 'id_agente', $parent); if (empty($group_id)) { // ACL error, this will restrict (fuck) the module search $tag_join = 'INNER JOIN ttag_module tta ON 1=0'; } else if (!empty($this->acltags) && isset($this->acltags[$group_id])) { $tags_str = $this->acltags[$group_id]; if (!empty($tags_str)) { $tag_join = sprintf('INNER JOIN ttag_module ttm ON tam.id_agente_modulo = ttm.id_agente_modulo AND ttm.id_tag IN (%s)', $tags_str); } } } $sql = "SELECT $columns FROM tagente_modulo tam $tag_join $module_status_join INNER JOIN tagente ta ON ta.disabled = 0 AND tam.id_agente = ta.id_agente $group_acl WHERE tam.disabled = 0 $agent_filter $module_name_filter $module_group_filter $module_search_filter ORDER BY $order_fields"; break; } break; default: $sql = $this->getSqlExtended($item_for_count, $type, $rootType, $parent, $rootID, $agent_search_filter, $agent_status_filter, $agents_join, $module_search_filter, $module_status_filter, $modules_join, $module_status_join); } return $sql; } // Override this method protected function getSqlExtended ($item_for_count, $type, $rootType, $parent, $rootID, $agent_search_filter, $agent_status_filter, $agents_join, $module_search_filter, $module_status_filter, $modules_join, $module_status_join) { return false; } protected function getItems ($item_for_count = false) { $sql = $this->getSql($item_for_count); if (empty($sql)) return array(); $data = db_process_sql($sql); if (empty($data)) return array(); // [26/10/2017] It seems the module hierarchy should be only available into the tree by group if ($this->rootType == 'group' && $this->type == 'agent') { $data = $this->getProcessedModules($data); } return $data; } protected function getCounters ($id) { $counters = $this->getItems($id); if (!empty($counters)) { $counters = array_pop($counters); } return $counters; } static function cmpSortNames($a, $b) { return strcmp($a["name"], $b["name"]); } protected function getProcessedGroups ($items, $remove_empty = false) { $processed_groups = array(); // Index and process the groups $groups = array(); foreach ($items as $item) { $groups[$item['id']] = $this->getProcessedItem($item); } // If user have not permissions in parent, set parent node to 0 (all) $user_groups_with_privileges = $this->userGroups; foreach ($groups as $id => $group) { if (!in_array($groups[$id]['parent'], array_keys($user_groups_with_privileges))) { $groups[$id]['parent'] = 0; } } // Build the group hierarchy foreach ($groups as $id => $group) { if (isset($groups[$id]['parent']) && ($groups[$id]['parent'] != 0)) { $parent = $groups[$id]['parent']; // Parent exists if (!isset($groups[$parent]['children'])) { $groups[$parent]['children'] = array(); } // Store a reference to the group into the parent $groups[$parent]['children'][] = &$groups[$id]; // This group was introduced into a parent $groups[$id]['have_parent'] = true; } } // Sort the children groups foreach ($groups as $id => $group) { if (isset($groups[$id]['children'])) { usort($groups[$id]['children'], array("Tree", "cmpSortNames")); } } //Filter groups and eliminates the reference to children groups out of her parent $groups = array_filter($groups, function ($group) { return !$group['have_parent']; }); // Propagate child counters to her parents Tree::processCounters($groups); // Filter groups and eliminates the reference to empty groups if ($remove_empty) { // Filter empty groups $groups = array_filter($groups, function ($group) { return (isset($group['counters']) && isset($group['counters']['total']) && !empty($group['counters']['total'])); }); } usort($groups, array("Tree", "cmpSortNames")); return $groups; } protected function getProcessedItem ($item, $server = false, &$items = array(), &$items_tmp = array(), $remove_empty = false) { if (isset($processed_item['is_processed']) && $processed_item['is_processed']) return $item; // For strict items if (isset($item['_id_'])) { $item['id'] = $item['_id_']; $item['name'] = $item['_name_']; if (isset($item['_is_tag_']) && $item['_is_tag_']) { $item['type'] = 'tag'; $item['rootType'] = 'tag'; } else { $item['type'] = 'group'; $item['rootType'] = 'group'; $item['parent'] = $item['_parent_id_']; if (!empty($item['_iconImg_'])) $item['iconHTML'] = $item['_iconImg_']; } if (isset($item['_agents_unknown_'])) $item['total_unknown_count'] = $item['_agents_unknown_']; if (isset($item['_agents_critical_'])) $item['total_critical_count'] = $item['_agents_critical_']; if (isset($item['_agents_warning_'])) $item['total_warning_count'] = $item['_agents_warning_']; if (isset($item['_agents_not_init_'])) $item['total_not_init_count'] = $item['_agents_not_init_']; if (isset($item['_agents_ok_'])) $item['total_normal_count'] = $item['_agents_ok_']; if (isset($item['_total_agents_'])) $item['total_count'] = $item['_total_agents_']; if (isset($item['_monitors_alerts_fired_'])) $item['total_fired_count'] = $item['_monitors_alerts_fired_']; // Agent filter for Strict ACL users if ($this->filter["statusAgent"] != -1) { switch ($this->filter["statusAgent"]) { case AGENT_STATUS_NOT_INIT: $item['total_count'] = $item['total_not_init_count']; $item['total_unknown_count'] = 0; $item['total_critical_count'] = 0; $item['total_warning_count'] = 0; $item['total_normal_count'] = 0; break; case AGENT_STATUS_CRITICAL: $item['total_count'] = $item['total_critical_count']; $item['total_unknown_count'] = 0; $item['total_warning_count'] = 0; $item['total_not_init_count'] = 0; $item['total_normal_count'] = 0; break; case AGENT_STATUS_WARNING: $item['total_count'] = $item['total_warning_count']; $item['total_unknown_count'] = 0; $item['total_critical_count'] = 0; $item['total_not_init_count'] = 0; $item['total_normal_count'] = 0; break; case AGENT_STATUS_UNKNOWN: $item['total_count'] = $item['total_unknown_count']; $item['total_critical_count'] = 0; $item['total_warning_count'] = 0; $item['total_not_init_count'] = 0; $item['total_normal_count'] = 0; break; case AGENT_STATUS_NORMAL: $item['total_count'] = $item['total_normal_count']; $item['total_unknown_count'] = 0; $item['total_critical_count'] = 0; $item['total_warning_count'] = 0; $item['total_not_init_count'] = 0; break; } } } $processed_item = array(); $processed_item['id'] = $item['id']; $processed_item['name'] = $item['name']; $processed_item['rootID'] = $item['id']; $processed_item['rootType'] = $this->rootType; $processed_item['searchChildren'] = 1; if (isset($item['type'])) $processed_item['type'] = $item['type']; else $processed_item['type'] = $this->type; if (isset($item['rootType'])) $processed_item['rootType'] = $item['rootType']; else $processed_item['rootType'] = $this->rootType; if ($processed_item['type'] == 'group') { $processed_item['parent'] = $item['parent']; if (!empty($item['iconHTML'])) $processed_item['iconHTML'] = $item['iconHTML']; else if (!empty($item['icon'])) $processed_item['icon'] = $item['icon'].".png"; else $processed_item['icon'] = "without_group.png"; } if (is_metaconsole() && !empty($server)) { $processed_item['serverID'] = $server['id']; } // Get the counters of the group (special case) if ($processed_item['type'] == 'group') { $counters = $this->getGroupCounters($item['id']); if (!empty($counters)) { foreach ($counters as $type => $value) { $item[$type] = $value; } } } $counters = array(); if (isset($item['total_unknown_count'])) $counters['unknown'] = $item['total_unknown_count']; if (isset($item['total_critical_count'])) $counters['critical'] = $item['total_critical_count']; if (isset($item['total_warning_count'])) $counters['warning'] = $item['total_warning_count']; if (isset($item['total_not_init_count'])) $counters['not_init'] = $item['total_not_init_count']; if (isset($item['total_normal_count'])) $counters['ok'] = $item['total_normal_count']; if (isset($item['total_count'])) $counters['total'] = $item['total_count']; if (isset($item['total_fired_count'])) $counters['alerts'] = $item['total_fired_count']; if (!empty($counters)) $processed_item['counters'] = $counters; if (!empty($processed_item)) $processed_item['is_processed'] = true; return $processed_item; } // This function should be used only when retrieving the data of the metaconsole's nodes protected function getMergedItems ($items) { // This variable holds the result $mergedItems = array(); foreach ($items as $key => $item) { // Avoid the deleted items if (!isset($items[$key]) || empty($item)) continue; // Store the item in a temporary element $resultItem = $item; // The 'id' parameter will be stored as 'server_id' => 'id' $resultItem['id'] = array(); $resultItem['id'][$item['serverID']] = $item['id']; $resultItem['rootID'] = array(); $resultItem['rootID'][$item['serverID']] = $item['rootID']; $resultItem['serverID'] = array(); $resultItem['serverID'][$item['serverID']] = $item['rootID']; // 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; if ($item['type'] == 'group') { // Add the children if (!isset($resultItem['children'])) $resultItem['children'] = array(); } // Iterate over the list to search items that match the actual item foreach ($items as $key2 => $item2) { // Skip the actual or empty items if ($key == $key2 || !isset($items[$key2])) continue; // Match with the name and type if ($item['name'] == $item2['name'] && $item['type'] == $item2['type']) { // Add the matched ids $resultItem['id'][$item2['serverID']] = $item2['id']; $resultItem['rootID'][$item2['serverID']] = $item2['rootID']; $resultItem['serverID'][$item2['serverID']] = $item2['rootID']; // Add the matched counters if (isset($item2['counters']) && !empty($item2['counters'])) { foreach ($item2['counters'] as $type => $value) { if (isset($resultItem['counters'][$type])) $resultItem['counters'][$type] += $value; } } if ($item['type'] == 'group') { // Add the matched children if (isset($item2['children'])) $resultItem['children'] = array_merge($resultItem['children'], $item2['children']); } // Remove the item unset($items[$key2]); } } if ($item['type'] == 'group') { // Get the merged children (recursion) if (!empty($resultItem['children'])) $resultItem['children'] = $this->getMergedItems($resultItem['children']); } // Add the resulting item if (!empty($resultItem) && !empty($resultItem['counters']['total'])) $mergedItems[] = $resultItem; // Remove the item unset($items[$key]); } usort($mergedItems, array("Tree", "cmpSortNames")); return $mergedItems; } protected function processModule (&$module, $server = false) { global $config; if (isset($module['children'])) { foreach ($module['children'] as $i => $children) { $this->processModule($module['children'][$i], $server); } } $module['type'] = 'module'; $module['id'] = (int) $module['id']; $module['name'] = io_safe_output($module['name']); $module['id_module_type'] = (int) $module['id_tipo_modulo']; $module['server_type'] = (int) $module['id_modulo']; $module['status'] = $module['estado']; $module['value'] = $module['datos']; if (is_metaconsole() && !empty($server)) { $module['serverID'] = $server['id']; $module['serverName'] = $server['server_name']; } else { $module['serverName'] = false; $module['serverID'] = false; } if (!isset($module['value'])) $module['value'] = modules_get_last_value($module['id']); // Status switch ($module['status']) { case AGENT_MODULE_STATUS_CRITICAL_ALERT: $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: $module['alert'] = 1; case AGENT_MODULE_STATUS_WARNING: $statusType = STATUS_MODULE_WARNING_BALL; $statusTitle = __('WARNING'); $module['statusText'] = "warning"; break; case AGENT_MODULE_STATUS_UNKNOWN: $statusType = STATUS_MODULE_UNKNOWN_BALL; $statusTitle = __('UNKNOWN'); $module['statusText'] = "unknown"; break; case AGENT_MODULE_STATUS_NO_DATA: case AGENT_MODULE_STATUS_NOT_INIT: $statusType = STATUS_MODULE_NO_DATA_BALL; $statusTitle = __('NO DATA'); $module['statusText'] = "not_init"; break; case AGENT_MODULE_STATUS_NORMAL_ALERT: $module['alert'] = 1; case AGENT_MODULE_STATUS_NORMAL: default: $statusType = STATUS_MODULE_OK_BALL; $statusTitle = __('NORMAL'); $module['statusText'] = "ok"; break; } 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 // ACL $group_id = (int) modules_get_agent_group($module['id']); $acl_graphs = false; $module["showGraphs"] = 0; // Avoid the check on the metaconsole. Too slow to show/hide an icon depending on the permissions if (!empty($group_id) && !is_metaconsole()) { if ($this->strictACL) { $acl_graphs = tags_check_acl_by_module($module['id'], $config['id_user'], 'RR') === true; } else { $acl_graphs = check_acl($config['id_user'], $group_id, "RR"); } } else if (!empty($group_id)) { $acl_graphs = true; } if ($acl_graphs) { $module["showGraphs"] = 1; } if ($module["showGraphs"]) { $graphType = return_graphtype($module['id_module_type']); $url = ui_get_full_url("operation/agentes/stat_win.php", false, false, false); $winHandle = dechex(crc32($module['id'].$module['name'])); $graph_params = array( "type" => $graphType, "period" => SECONDS_1DAY, "id" => $module['id'], "label" => base64_encode($module['name']), "refresh" => SECONDS_10MINUTES ); if (is_metaconsole() && !empty($server)) { $graph_params["avg_only"] = 1; // Set the server id $graph_params["server"] = $module['serverID']; } $graph_params_str = http_build_query($graph_params); $moduleGraphURL = "$url?$graph_params_str"; $module['moduleGraph'] = array( 'url' => $moduleGraphURL, 'handle' => $winHandle ); } // Alerts fired image $has_alerts = (bool) db_get_value( 'COUNT(DISTINCT(id_agent_module))', 'talert_template_modules', 'id_agent_module', $module['id']); if ($has_alerts) { $module['alertsImageHTML'] = html_print_image("images/bell.png", true, array("title" => __('Module alerts'))); } } protected function processModules (&$modules, $server = false) { foreach ($modules as $iterator => $module) { $this->processModule($modules[$iterator], $server); } } protected function processAgent (&$agent, $server = false) { global $config; $agent['type'] = 'agent'; $agent['id'] = (int) $agent['id']; $agent['name'] = $agent['name']; $agent['rootID'] = $this->rootID; $agent['rootType'] = $this->rootType; if (is_metaconsole()) { if (isset($agent['server_id'])) $agent['serverID'] = $agent['server_id']; else if (!empty($server)) $agent['serverID'] = $server['id']; } // Realtime counters for Strict ACL if ($this->strictACL) { $agent_filter = array("id" => $agent['id']); $module_filter = array(); if (isset($this->filter["statusAgent"])) $agent_filter["status"] = $this->filter["statusAgent"]; if (isset($this->filter["searchAgent"])) $agent_filter["name"] = $this->filter["searchAgent"]; if (isset($this->filter["statusModule"])) $module_filter["status"] = $this->filter["statusModule"]; if (isset($this->filter["searchModule"])) $module_filter["name"] = $this->filter["searchModule"]; $agent['counters'] = array(); $agent['counters']['unknown'] = 0; $agent['counters']['critical'] = 0; $agent['counters']['warning'] = 0; $agent['counters']['not_init'] = 0; $agent['counters']['ok'] = 0; $agent['counters']['total'] = 0; $agent['counters']['alerts'] = 0; if ($agent['rootType'] == "group") { $agent['counters']['alerts'] = agents_get_alerts_fired($agent['id']); // With module filter if (isset($this->filter["statusModule"]) && $this->filter["statusModule"] != AGENT_MODULE_STATUS_ALL) { switch ($this->filter["statusModule"]) { case AGENT_MODULE_STATUS_CRITICAL_ALERT: case AGENT_MODULE_STATUS_CRITICAL_BAD: $agent['counters']['critical'] = (int) groups_get_critical_monitors ($agent['rootID'], $agent_filter, $module_filter, true, $this->acltags); $agent['counters']['total'] = $agent['counters']['critical']; break; case AGENT_MODULE_STATUS_WARNING_ALERT: case AGENT_MODULE_STATUS_WARNING: $agent['counters']['warning'] = (int) groups_get_warning_monitors ($agent['rootID'], $agent_filter, $module_filter, true, $this->acltags); $agent['counters']['total'] = $agent['counters']['warning']; break; case AGENT_MODULE_STATUS_UNKNOWN: $agent['counters']['unknown'] = (int) groups_get_unknown_monitors ($agent['rootID'], $agent_filter, $module_filter, true, $this->acltags); $agent['counters']['total'] = $agent['counters']['unknown']; break; case AGENT_MODULE_STATUS_NO_DATA: case AGENT_MODULE_STATUS_NOT_INIT: $agent['counters']['not_init'] = (int) groups_get_not_init_monitors ($agent['rootID'], $agent_filter, $module_filter, true, $this->acltags); $agent['counters']['total'] = $agent['counters']['not_init']; break; case AGENT_MODULE_STATUS_NORMAL_ALERT: case AGENT_MODULE_STATUS_NORMAL: $agent['counters']['ok'] = (int) groups_get_normal_monitors ($agent['rootID'], $agent_filter, $module_filter, true, $this->acltags); $agent['counters']['total'] = $agent['counters']['ok']; break; } } // Without module filter else { $agent['counters']['unknown'] = (int) groups_get_unknown_monitors ($agent['rootID'], $agent_filter, $module_filter, true, $this->acltags); $agent['counters']['critical'] = (int) groups_get_critical_monitors ($agent['rootID'], $agent_filter, $module_filter, true, $this->acltags); $agent['counters']['warning'] = (int) groups_get_warning_monitors ($agent['rootID'], $agent_filter, $module_filter, true, $this->acltags); $agent['counters']['not_init'] = (int) groups_get_not_init_monitors ($agent['rootID'], $agent_filter, $module_filter, true, $this->acltags); $agent['counters']['ok'] = (int) groups_get_normal_monitors ($agent['rootID'], $agent_filter, $module_filter, true, $this->acltags); $agent['counters']['total'] = (int) groups_get_total_monitors ($agent['rootID'], $agent_filter, $module_filter, true, $this->acltags); } } else if ($agent['rootType'] == "tag") { $agent['counters']['alerts'] = (int) tags_monitors_fired_alerts ($agent['rootID'], $this->acltags, $agent['id']); // With module filter if (isset($this->filter["statusModule"]) && $this->filter["statusModule"] != AGENT_MODULE_STATUS_ALL) { switch ($this->filter["statusModule"]) { case AGENT_MODULE_STATUS_CRITICAL_ALERT: case AGENT_MODULE_STATUS_CRITICAL_BAD: $agent['counters']['critical'] = (int) tags_get_critical_monitors ($agent['rootID'], $this->acltags, $agent_filter, $module_filter); $agent['counters']['total'] = $agent['counters']['critical']; break; case AGENT_MODULE_STATUS_WARNING_ALERT: case AGENT_MODULE_STATUS_WARNING: $agent['counters']['warning'] = (int) tags_get_warning_monitors ($agent['rootID'], $this->acltags, $agent_filter, $module_filter); $agent['counters']['total'] = $agent['counters']['warning']; break; case AGENT_MODULE_STATUS_UNKNOWN: $agent['counters']['unknown'] = (int) tags_get_unknown_monitors ($agent['rootID'], $this->acltags, $agent_filter, $module_filter); $agent['counters']['total'] = $agent['counters']['unknown']; break; case AGENT_MODULE_STATUS_NO_DATA: case AGENT_MODULE_STATUS_NOT_INIT: $agent['counters']['not_init'] = (int) tags_get_not_init_monitors ($agent['rootID'], $this->acltags, $agent_filter, $module_filter); $agent['counters']['total'] = $agent['counters']['not_init']; break; case AGENT_MODULE_STATUS_NORMAL_ALERT: case AGENT_MODULE_STATUS_NORMAL: $agent['counters']['ok'] = (int) tags_get_normal_monitors ($agent['rootID'], $this->acltags, $agent_filter, $module_filter); $agent['counters']['total'] = $agent['counters']['ok']; break; } } // Without module filter else { $agent['counters']['unknown'] = (int) tags_get_unknown_monitors ($agent['rootID'], $this->acltags, $agent_filter, $module_filter); $agent['counters']['critical'] = (int) tags_get_critical_monitors ($agent['rootID'], $this->acltags, $agent_filter, $module_filter); $agent['counters']['warning'] = (int) tags_get_warning_monitors ($agent['rootID'], $this->acltags, $agent_filter, $module_filter); $agent['counters']['not_init'] = (int) tags_get_not_init_monitors ($agent['rootID'], $this->acltags, $agent_filter, $module_filter); $agent['counters']['ok'] = (int) tags_get_normal_monitors ($agent['rootID'], $this->acltags, $agent_filter, $module_filter); $agent['counters']['total'] = (int) tags_get_total_monitors ($agent['rootID'], $this->acltags, $agent_filter, $module_filter); } } if (isset($this->filter["statusAgent"]) && $this->filter["statusAgent"] != AGENT_STATUS_ALL) { switch ($this->filter["statusAgent"]) { case AGENT_STATUS_CRITICAL: if ($agent['counters']['critical'] == 0) $agent = array(); break; case AGENT_STATUS_WARNING: if ($agent['counters']['total'] == 0 || $agent['counters']['critical'] > 0 || $agent['counters']['warning'] == 0) $agent = array(); break; case AGENT_STATUS_UNKNOWN: if ($agent['counters']['critical'] > 0 || $agent['counters']['warning'] > 0 || $agent['counters']['unknown'] == 0) $agent = array(); break; case AGENT_STATUS_NOT_INIT: if ($agent['counters']['total'] != 0 && $agent['counters']['total'] != $agent['counters']['not_init']) $agent = array(); break; case AGENT_STATUS_NORMAL: if ($agent['counters']['critical'] > 0 || $agent['counters']['warning'] > 0 || $agent['counters']['unknown'] > 0 || $agent['counters']['ok'] == 0) $agent = array(); break; } // Leave the function if (empty($agent)) return; } } // Counters if (empty($agent['counters'])) { $agent['counters'] = array(); if (isset($agent['unknown_count'])) $agent['counters']['unknown'] = $agent['unknown_count']; else $agent['counters']['unknown'] = (int) agents_monitor_unknown($agent['id']); if (isset($agent['critical_count'])) $agent['counters']['critical'] = $agent['critical_count']; else $agent['counters']['critical'] = (int) agents_monitor_critical($agent['id']); if (isset($agent['warning_count'])) $agent['counters']['warning'] = $agent['warning_count']; else $agent['counters']['warning'] = (int) agents_monitor_warning($agent['id']); if (isset($agent['notinit_count'])) $agent['counters']['not_init'] = $agent['notinit_count']; else $agent['counters']['not_init'] = (int) agents_monitor_notinit($agent['id']); if (isset($agent['normal_count'])) $agent['counters']['ok'] = $agent['normal_count']; else $agent['counters']['ok'] = (int) agents_monitor_ok($agent['id']); if (isset($agent['total_count'])) $agent['counters']['total'] = $agent['total_count']; else $agent['counters']['total'] = (int) agents_monitor_total($agent['id']); if (isset($agent['fired_count'])) $agent['counters']['alerts'] = $agent['fired_count']; else $agent['counters']['alerts'] = (int) 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']); // Quiet image if (isset($agent['quiet']) && $agent['quiet']) $agent['quietImageHTML'] = html_print_image("/images/dot_green.disabled.png", true, array("title" => __('Quiet'))); // Status $agent['statusRaw'] = agents_get_status($agent['id'], !$this->strictACL); 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 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; } } else { switch ($this->childrenMethod) { case 'on_demand': $agent['searchChildren'] = 0; break; case 'live': $agent['searchChildren'] = 0; break; } } } } protected function processAgents (&$agents, $server = false) { if (!empty($agents)) { foreach ($agents as $iterator => $agent) { $this->processAgent($agents[$iterator], $server); } } } private static function extractGroupsWithIDs ($groups, $ids_hash) { $result_groups = array(); foreach ($groups as $group) { if (isset($ids_hash[$group['id']])) { $result_groups[] = $group; } else if (!empty($group['children'])) { $result = self::extractGroupsWithIDs($group['children'], $ids_hash); // Item found on children if (!empty($result)) { $result_groups = array_merge($result_groups, $result); } } } return $result_groups; } private static function extractItemWithID ($items, $item_id, $item_type = "group", $strictACL = false) { foreach ($items as $item) { if ($item["type"] != $item_type) continue; // Item found if ($strictACL && is_metaconsole()) { foreach ($item["id"] as $server_id => $id) { if ($id == $item_id) return $item; } } else { if ($item["id"] == $item_id) return $item; } if ($item["type"] == "group" && !empty($item["children"])) { $result = self::extractItemWithID($item["children"], $item_id, $item_type, $strictACL); // Item found on children if ($result !== false) return $result; } } // Item not found return false; } public function getData() { if (! is_metaconsole()) { if ($this->strictACL) { switch ($this->type) { case 'group': case 'tag': $this->getDataStrict(); break; case 'agent': $this->getDataAgent(); break; } } else{ 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; case 'agent': $this->getDataAgent(); break; default: $this->getDataExtended(); } } } else if ($this->strictACL) { switch ($this->type) { case 'group': case 'tag': $this->getDataStrict(); break; case 'agent': $this->getDataAgent(); break; } } else { if ($this->type == 'agent') { $this->getDataAgent(); } else { $this->getDataGroup(); } } } protected function getDataExtended () { // Override this method to add new types } private function getDataAgent () { $processed_items = array(); // Module names if ($this->id == -1) { } // Agents else { if (! is_metaconsole()) { $items = $this->getItems(); $this->processModules($items); $processed_items = $items; } else { $items = array(); if ($this->serverID !== false) { $server = metaconsole_get_servers($this->serverID); if (metaconsole_connect($server) == NOERR) { $items = $this->getItems(); $this->processModules($items, $server); metaconsole_restore_db(); } } $processed_items = $items; } } $this->tree = $processed_items; } private function getDataStrict () { global $config; require_once($config['homedir']."/include/functions_groups.php"); $processed_items = array(); // Groups and tags if ($this->id == -1) { $agent_filter = array(); if (isset($this->filter["statusAgent"])) $agent_filter["status"] = $this->filter["statusAgent"]; if (isset($this->filter["searchAgent"])) $agent_filter["name"] = $this->filter["searchAgent"]; $module_filter = array(); if (isset($this->filter["statusModule"])) $module_filter["status"] = $this->filter["statusModule"]; if (isset($this->filter["searchModule"])) $module_filter["name"] = $this->filter["searchModule"]; if (! is_metaconsole()) { $items = group_get_data($config['id_user'], $this->strictACL, $this->acltags, false, 'tree', $agent_filter, $module_filter); // Build the group and tag hierarchy $processed_groups = array(); $processed_tags = array(); foreach ($items as $key => $item) { $processed_item = $this->getProcessedItem($item); if ($processed_item['type'] == 'tag') { if (!empty($processed_item) && isset($processed_item['counters']) && isset($processed_item['counters']['total']) && !empty($processed_item['counters']['total'])) { $processed_tags[] = $processed_item; } } else { $processed_groups[] = $processed_item; } } // Build the groups hierarchy $processed_groups = $this->getProcessedGroups($processed_groups, true); // Sort tags usort($processed_tags, array("Tree", "cmpSortNames")); // Join tags and groups $processed_items = array_merge($processed_groups, $processed_tags); } else { $unmerged_items = array(); $servers = metaconsole_get_servers(); foreach ($servers as $server) { if (metaconsole_connect($server) != NOERR) continue; db_clean_cache(); $items = group_get_data($config['id_user'], $this->strictACL, $this->acltags, false, 'tree', $agent_filter, $module_filter); // Build the group and tag hierarchy $processed_groups = array(); $processed_tags = array(); foreach ($items as $key => $item) { $processed_item = $this->getProcessedItem($item); if ($processed_item['type'] == 'tag') $processed_tags[] = $processed_item; else $processed_groups[] = $processed_item; } // Build the groups hierarchy $processed_groups = $this->getProcessedGroups($processed_groups); // Sort tags usort($processed_tags, array("Tree", "cmpSortNames")); // Join tags and groups $processed_items = array_merge($processed_groups, $processed_tags); $unmerged_items += $processed_items; metaconsole_restore_db(); } $processed_items = $this->getMergedItems($unmerged_items); } if (!empty($processed_items)) { if (!empty($this->filter["groupID"])) { $result = self::extractItemWithID($processed_items, $this->filter["groupID"], "group", $this->strictACL); if ($result === false) $processed_items = array(); else $processed_items = array($result); } else if (!empty($this->filter["tagID"])) { $result = self::extractItemWithID($processed_items, $this->filter["tagID"], "tag", $this->strictACL); if ($result === false) $processed_items = array(); else $processed_items = array($result); } } } // Agents else { if (! is_metaconsole()) { $items = $this->getItems(); $this->processAgents($items); // Remove empty entrys $processed_items = array_filter($items); // Restart the array keys -> Important! $processed_items = array_values($processed_items); } else { $rootIDs = $this->rootID; $items = array(); $j = 1; $server = metaconsole_get_servers(); foreach ($rootIDs as $serverID => $rootID) { if (metaconsole_connect($server[$j]) != NOERR) continue; db_clean_cache(); $this->rootID = $rootID; $newItems = $this->getItems(); $this->processAgents($newItems, $server[$j]); $newItems = array_filter($newItems); $items = array_merge($items, $newItems); metaconsole_restore_db(); $j++; } $this->rootID = $rootIDs; if (!empty($items)) usort($items, array("Tree", "cmpSortNames")); $processed_items = $items; } } $this->tree = $processed_items; } private function getDataGroup() { $processed_items = array(); // Groups if ($this->id == -1) { $items = $this->getItems(); $processed_items = $this->getProcessedGroups($items, true); if (!empty($processed_items)) { // Filter by group name. This should be done after rerieving the items cause we need the possible items descendants if (!empty($this->filter['searchGroup'])) { // Save the groups which intersect with the user groups $groups = db_get_all_rows_filter('tgrupo', array('nombre' => '%' . $this->filter['searchGroup'] . '%')); if ($groups == false) $groups = array(); $userGroupsACL = $this->userGroupsACL; $ids_hash = array_reduce($groups, function ($userGroups, $group) use ($userGroupsACL) { $group_id = $group['id_grupo']; if (isset($userGroupsACL[$group_id])) { $userGroups[$group_id] = $userGroupsACL[$group_id]; } return $userGroups; }, array()); $result = self::extractGroupsWithIDs($processed_items, $ids_hash); $processed_items = ($result === false) ? array() : $result; } // groupID filter. To access the view from tactical views f.e. if (!empty($this->filter['groupID'])) { $result = self::extractItemWithID($processed_items, $this->filter['groupID'], "group", $this->strictACL); $processed_items = ($result === false) ? array() : array($result); } } } // Agents else { $items = $this->getItems(); $this->processAgents($items); $processed_items = $items; } $this->tree = $processed_items; } private function getDataTag() { $processed_items = array(); // Tags if ($this->id == -1) { if (! is_metaconsole()) { $items = $this->getItems(); foreach ($items as $key => $item) { $counters = $this->getCounters($item['id']); if (!empty($counters)) { foreach ($counters as $type => $value) { $item[$type] = $value; } } $processed_item = $this->getProcessedItem($item); $processed_items[] = $processed_item; } } else { $servers = metaconsole_get_servers(); $item_list = array(); foreach ($servers as $server) { if (metaconsole_connect($server) != NOERR) continue; db_clean_cache(); $items = $this->getItems(); $processed_items = array(); foreach ($items as $key => $item) { $counters = $this->getCounters($item['id']); if (!empty($counters)) { foreach ($counters as $type => $value) { $item[$type] = $value; } } $processed_item = $this->getProcessedItem($item, $server); $processed_items[] = $processed_item; } $item_list = array_merge($item_list, $processed_items); metaconsole_restore_db(); } $processed_items = $this->getMergedItems($item_list); } } // Agents else { if (! is_metaconsole()) { $items = $this->getItems(); $this->processAgents($items); $processed_items = $items; } else { $rootIDs = $this->rootID; $items = array(); foreach ($rootIDs as $serverID => $rootID) { $server = metaconsole_get_servers($serverID); if (metaconsole_connect($server) != NOERR) continue; db_clean_cache(); $this->rootID = $rootID; $newItems = $this->getItems(); $this->processAgents($newItems, $server); $items = array_merge($items, $newItems); metaconsole_restore_db(); } $this->rootID = $rootIDs; if (!empty($items)) usort($items, array("Tree", "cmpSortNames")); $processed_items = $items; } } $this->tree = $processed_items; } private function getDataModules() { $processed_items = array(); // Module names if ($this->id == -1) { if (! is_metaconsole()) { $items = $this->getItems(); foreach ($items as $key => $item) { $counters = $this->getCounters($item['name']); if (!empty($counters)) { foreach ($counters as $type => $value) { $item[$type] = $value; } } $name = str_replace(array(' ','#','/','.','(',')','¿','?','¡','!'), array( '_articapandora_'.ord(' ').'_pandoraartica_', '_articapandora_'.ord('#').'_pandoraartica_', '_articapandora_'.ord('/').'_pandoraartica_', '_articapandora_'.ord('.').'_pandoraartica_', '_articapandora_'.ord('(').'_pandoraartica_', '_articapandora_'.ord(')').'_pandoraartica_', '_articapandora_'.ord('¿').'_pandoraartica_', '_articapandora_'.ord('?').'_pandoraartica_', '_articapandora_'.ord('¡').'_pandoraartica_', '_articapandora_'.ord('!').'_pandoraartica_'), io_safe_output($item['name'])); $processed_item = $this->getProcessedItem($item); $processed_item['id'] = $name; $processed_item['rootID'] = $name; $processed_items[] = $processed_item; } } else { $servers = metaconsole_get_servers(); $item_list = array(); foreach ($servers as $server) { if (metaconsole_connect($server) != NOERR) continue; db_clean_cache(); $items = $this->getItems(); $processed_items = array(); foreach ($items as $key => $item) { $counters = $this->getCounters($item['name']); if (!empty($counters)) { foreach ($counters as $type => $value) { $item[$type] = $value; } } $name = str_replace(array(' ','#','/','.','(',')','¿','?','¡','!'), array( '_articapandora_'.ord(' ').'_pandoraartica_', '_articapandora_'.ord('#').'_pandoraartica_', '_articapandora_'.ord('/').'_pandoraartica_', '_articapandora_'.ord('.').'_pandoraartica_', '_articapandora_'.ord('(').'_pandoraartica_', '_articapandora_'.ord(')').'_pandoraartica_', '_articapandora_'.ord('¿').'_pandoraartica_', '_articapandora_'.ord('?').'_pandoraartica_', '_articapandora_'.ord('¡').'_pandoraartica_', '_articapandora_'.ord('!').'_pandoraartica_'), io_safe_output($item['name'])); $processed_item = $this->getProcessedItem($item, $server); $processed_item['id'] = $name; $processed_item['rootID'] = $name; $processed_items[] = $processed_item; } $item_list = array_merge($item_list, $processed_items); metaconsole_restore_db(); } $processed_items = $this->getMergedItems($item_list); } } // Agents else { if (! is_metaconsole()) { $items = $this->getItems(); $this->processAgents($items); $processed_items = $items; } else { $rootIDs = $this->rootID; $items = array(); foreach ($rootIDs as $serverID => $rootID) { $server = metaconsole_get_servers($serverID); if (metaconsole_connect($server) != NOERR) continue; db_clean_cache(); $this->rootID = $rootID; $newItems = $this->getItems(); $this->processAgents($newItems, $server); $items = array_merge($items, $newItems); metaconsole_restore_db(); } $this->rootID = $rootIDs; if (!empty($items)) usort($items, array("Tree", "cmpSortNames")); $processed_items = $items; } } $this->tree = $processed_items; } private function getDataModuleGroup() { $processed_items = array(); // Module groups if ($this->id == -1) { if (! is_metaconsole()) { $items = $this->getItems(); foreach ($items as $key => $item) { $counters = $this->getCounters($item['id']); if (!empty($counters)) { foreach ($counters as $type => $value) { $item[$type] = $value; } } $processed_item = $this->getProcessedItem($item); $processed_items[] = $processed_item; } } else { $servers = metaconsole_get_servers(); $item_list = array(); foreach ($servers as $server) { if (metaconsole_connect($server) != NOERR) continue; db_clean_cache(); $items = $this->getItems(); $processed_items = array(); foreach ($items as $key => $item) { $counters = $this->getCounters($item['id']); if (!empty($counters)) { foreach ($counters as $type => $value) { $item[$type] = $value; } } $processed_item = $this->getProcessedItem($item, $server); $processed_items[] = $processed_item; } $item_list = array_merge($item_list, $processed_items); metaconsole_restore_db(); } $processed_items = $this->getMergedItems($item_list); } } // Agents else { if (! is_metaconsole()) { $items = $this->getItems(); $this->processAgents($items); $processed_items = $items; } else { $rootIDs = $this->rootID; $items = array(); foreach ($rootIDs as $serverID => $rootID) { $server = metaconsole_get_servers($serverID); if (metaconsole_connect($server) != NOERR) continue; db_clean_cache(); $this->rootID = $rootID; $newItems = $this->getItems(); $this->processAgents($newItems, $server); $items = array_merge($items, $newItems); metaconsole_restore_db(); } $this->rootID = $rootIDs; if (!empty($items)) usort($items, array("Tree", "cmpSortNames")); $processed_items = $items; } } $this->tree = $processed_items; } private function getDataOS() { $processed_items = array(); // OS if ($this->id == -1) { if (! is_metaconsole()) { $items = $this->getItems(); foreach ($items as $key => $item) { $counters = $this->getCounters($item['id']); if (!empty($counters)) { foreach ($counters as $type => $value) { $item[$type] = $value; } } $processed_item = $this->getProcessedItem($item); $processed_item['icon'] = $item['os_icon']; $processed_items[] = $processed_item; } } else { $servers = metaconsole_get_servers(); $item_list = array(); foreach ($servers as $server) { if (metaconsole_connect($server) != NOERR) continue; db_clean_cache(); $items = $this->getItems(); $processed_items = array(); foreach ($items as $key => $item) { $counters = $this->getCounters($item['id']); if (!empty($counters)) { foreach ($counters as $type => $value) { $item[$type] = $value; } } $processed_item = $this->getProcessedItem($item, $server); $processed_item['icon'] = $item['os_icon']; $processed_items[] = $processed_item; } $item_list = array_merge($item_list, $processed_items); metaconsole_restore_db(); } $processed_items = $this->getMergedItems($item_list); } } // Agents else { if (! is_metaconsole()) { $items = $this->getItems(); $this->processAgents($items); $processed_items = $items; } else { $rootIDs = $this->rootID; $items = array(); foreach ($rootIDs as $serverID => $rootID) { $server = metaconsole_get_servers($serverID); if (metaconsole_connect($server) != NOERR) continue; db_clean_cache(); $this->rootID = $rootID; $newItems = $this->getItems(); $this->processAgents($newItems, $server); $items = array_merge($items, $newItems); metaconsole_restore_db(); } $this->rootID = $rootIDs; if (!empty($items)) usort($items, array("Tree", "cmpSortNames")); $processed_items = $items; } } $this->tree = $processed_items; } public function getJSON() { $this->getData(); return json_encode($this->tree); } public function getArray() { $this->getData(); return $this->tree; } static function processCounters(&$groups) { $all_counters = array(); foreach ($groups as $id => $group) { $child_counters = array(); if (!empty($groups[$id]['children'])) { $child_counters = Tree::processCounters($groups[$id]['children']); } if (!empty($child_counters)) { foreach($child_counters as $type => $value) { $groups[$id]['counters'][$type] += $value; } } foreach($groups[$id]['counters'] as $type => $value) { $all_counters[$type] += $value; } } return $all_counters; } protected function getProcessedModules($modules_tree) { $tree_modules = array(); $new_modules_root = array_filter($modules_tree, function ($module) { return (isset($module['parent']) && ($module['parent'] == 0)); }); $new_modules_child = array_filter($modules_tree, function ($module) { return (isset($module['parent']) && ($module['parent'] != 0)); }); while (!empty($new_modules_child)) { foreach ($new_modules_child as $i => $child) { Tree::recursive_modules_tree_view($new_modules_root, $new_modules_child, $i, $child); } } foreach ($new_modules_root as $m) { $tree_modules[] = $m; } return $tree_modules; } protected function getGroupCounters($group_id) { global $config; static $group_stats = false; # Do not use the group stat cache when using tags or real time group stats. if ($config['realtimestats'] == 1 || (isset($this->userGroups[$group_id]['tags']) && $this->userGroups[$group_id]['tags'] != "") || !empty($this->filter['searchAgent']) ) { return $this->getCounters($group_id); } # Update the group stat cache. if ( $group_stats === false) { $group_stats = array(); $stats = db_get_all_rows_sql('SELECT * FROM tgroup_stat'); foreach ($stats as $group) { if ($group['modules'] > 0) { $group_stats[$group['id_group']]['total_count'] = $group['modules'] > 0 ? $group['agents'] : 0; $group_stats[$group['id_group']]['total_critical_count'] = $group['critical']; $group_stats[$group['id_group']]['total_unknown_count'] = $group['unknown']; $group_stats[$group['id_group']]['total_warning_count'] = $group['warning']; $group_stats[$group['id_group']]['total_not_init_count'] = $group['non-init']; $group_stats[$group['id_group']]['total_normal_count'] = $group['normal']; $group_stats[$group['id_group']]['total_fired_count'] = $group['alerts_fired']; } # Skip groups without modules. else { $group_stats[$group['id_group']]['total_count'] = 0; $group_stats[$group['id_group']]['total_critical_count'] = 0; $group_stats[$group['id_group']]['total_unknown_count'] = 0; $group_stats[$group['id_group']]['total_warning_count'] = 0; $group_stats[$group['id_group']]['total_not_init_count'] = 0; $group_stats[$group['id_group']]['total_normal_count'] = 0; $group_stats[$group['id_group']]['total_fired_count'] = 0; } } } if ($group_stats !== false && isset($group_stats[$group_id])) { return $group_stats[$group_id]; } return $this->getCounters($group_id); } static function recursive_modules_tree_view (&$new_modules, &$new_modules_child, $i, $child) { foreach ($new_modules as $index => $module) { if ($module['id'] == $child['parent']) { $new_modules[$index]['children'][] = $child; unset($new_modules_child[$i]); break; } else if (isset($new_modules[$index]['children'])) { Tree::recursive_modules_tree_view ($new_modules[$index]['children'], $new_modules_child, $i, $child); } } } } ?>