0) { $last_contact = agents_get_next_contact_time_left($id_agente); $progress = agents_get_next_contact($id_agente); if ($progress < 0 || $progress > 100) { $progress = 100; } echo json_encode( [ 'progress' => $progress, 'last_contact' => $last_contact, ] ); } return; } if ($get_agents_group_json) { $id_group = (int) get_parameter('id_group'); $recursion = (bool) get_parameter('recursion'); $id_os = get_parameter('id_os', ''); $agent_name = get_parameter('name', ''); $privilege = (string) get_parameter('privilege', 'AR'); // Is is possible add keys prefix to avoid auto sorting in js object conversion. $keys_prefix = (string) get_parameter('keys_prefix', ''); $status_agents = (int) get_parameter('status_agents', AGENT_STATUS_ALL); // Build filter. $filter = []; if (!empty($id_os)) { $filter['id_os'] = $id_os; } if (!empty($agent_name)) { $filter['nombre'] = '%'.$agent_name.'%'; } if (!empty($agent_alias)) { $filter['alias'] = '%'.$agent_alias.'%'; } $filter['status'] = $status_agents; if ($cluster_mode) { $agent_id_os = db_get_all_rows_sql('select id_os from tconfig_os where id_os != 100'); foreach ($agent_id_os as $key => $value) { $agent_id_os_array[] = $agent_id_os[$key]['id_os']; } $filter['id_os'] = $agent_id_os_array; if ($agents_inserted[0] != '') { $agents_id_list = ''; foreach ($agents_inserted as $elem) { if ($elem === end($agents_inserted)) { $agents_id_list .= $elem; } else { $agents_id_list .= $elem.','; } } $agent_id_agente = db_get_all_rows_sql('select id_agente from tagente where id_agente not in ('.$agents_id_list.')'); foreach ($agent_id_agente as $key => $value) { $agent_id_agente_array[] = $agent_id_agente[$key]['id_agente']; } $filter['id_agente'] = $agent_id_agente_array; } } // Perform search. $agents = agents_get_group_agents( $id_group, $filter, 'lower', false, $recursion, false, '|', $cluster_mode ); if (empty($agents)) { $agents = []; } // Add keys prefix. if ($keys_prefix !== '') { $i = 0; foreach ($agents as $k => $v) { $agents[$keys_prefix.$i] = [ 'id_agente' => $k, 'alias' => io_safe_output($v), ]; unset($agents[$k]); $i++; } } echo json_encode($agents); return; } if ($get_modules_group_json) { $id_group = (int) get_parameter('id_module_group', 0); $id_agents = get_parameter('id_agents'); $selection = get_parameter('selection'); select_modules_for_agent_group($id_group, $id_agents, $selection); } if ($get_modules_group_value_name_json) { $id_agents = get_parameter('id_agents'); $selection = get_parameter('selection'); // No filter by module group. $modules = select_modules_for_agent_group(0, $id_agents, $selection, false, true); echo json_encode($modules); return; } if ($get_agent_json) { $id_agent = (int) get_parameter('id_agent'); $agent = db_get_row('tagente', 'id_agente', $id_agent); echo json_encode($agent); return; } if ($get_agent_modules_json_for_multiple_agents_id) { $idAgents = get_parameter('id_agent'); $modules = db_get_all_rows_sql( ' SELECT nombre, id_agente_modulo FROM tagente_modulo WHERE id_agente IN ('.implode(',', $idAgents).')' ); $return = []; foreach ($modules as $module) { $return[$module['id_agente_modulo']] = io_safe_output($module['nombre']); } echo json_encode($return); return; } if ($get_agents_json_for_multiple_modules) { $nameModules = get_parameter('module_name'); $selection_mode = get_parameter('selection_mode', 'common') == 'all'; $status_modulo = (int) get_parameter('status_module', -1); $tags_selected = (array) get_parameter('tags', []); $names = select_agents_for_module_group( $nameModules, $selection_mode, [ 'status' => $status_modulo, 'tags' => $tags_selected, ], 'AW' ); echo json_encode($names); return; } if ($get_agent_modules_alerts_json_for_multiple_agents) { $idAgents = (array) get_parameter('id_agent'); $templates = (array) get_parameter('templates'); $selection_mode = get_parameter('selection_mode', 'common'); $sql = 'SELECT DISTINCT(nombre) FROM tagente_modulo t1, talert_template_modules t2 WHERE t2.id_agent_module = t1.id_agente_modulo AND delete_pending = 0 AND id_alert_template IN ('.implode(',', $templates).') AND id_agente IN ('.implode(',', $idAgents).')'; if ($selection_mode == 'common') { $sql .= ' AND ( SELECT count(nombre) FROM tagente_modulo t3, talert_template_modules t4 WHERE t4.id_agent_module = t3.id_agente_modulo AND delete_pending = 0 AND t1.nombre = t3.nombre AND id_agente IN ('.implode(',', $idAgents).') AND id_alert_template IN ('.implode(',', $templates).')) = ('.count($idAgents).')'; } $sql .= ' ORDER BY t1.nombre'; $nameModules = db_get_all_rows_sql($sql); if ($nameModules == false) { $nameModules = []; } $result = []; foreach ($nameModules as $nameModule) { $result[] = io_safe_output($nameModule['nombre']); } echo json_encode($result); return; } if ($get_agent_modules_multiple_alerts_json_for_multiple_agents) { $idAgents = get_parameter('id_agent'); $id_template = get_parameter('template'); $selection_mode = get_parameter('selection_mode', 'common'); $sql = 'SELECT DISTINCT(nombre) FROM tagente_modulo t1, talert_template_modules t2 WHERE t2.id_agent_module = t1.id_agente_modulo AND delete_pending = 0 AND id_alert_template = '.$id_template.' AND id_agente IN ('.implode(',', $idAgents).')'; if ($selection_mode == 'common') { $sql .= ' AND ( SELECT count(nombre) FROM tagente_modulo t3, talert_template_modules t4 WHERE t4.id_agent_module = t3.id_agente_modulo AND delete_pending = 0 AND t1.nombre = t3.nombre AND id_agente IN ('.implode(',', $idAgents).') AND id_alert_template = '.$id_template.') = ('.count($idAgents).')'; } $sql .= ' ORDER BY t1.nombre'; $nameModules = db_get_all_rows_sql($sql); if ($nameModules == false) { $nameModules = []; } $result = []; foreach ($nameModules as $nameModule) { $result[] = io_safe_output($nameModule['nombre']); } echo json_encode($result); return; } if ($get_agent_modules_json_for_multiple_agents) { $idAgents = (array) get_parameter('id_agent'); $tags = get_parameter('tags', null); $module_types_excluded = get_parameter('module_types_excluded', []); $module_name = (string) get_parameter('name'); $selection_mode = get_parameter('selection_mode', 'common'); $serialized = get_parameter('serialized', ''); $id_server = (int) get_parameter('id_server', 0); $status_modulo = (int) get_parameter('status_module', -1); $metaconsole_server_name = null; if (!empty($id_server)) { $metaconsole_server_name = db_get_value( 'server_name', 'tmetaconsole_setup', 'id', $id_server ); } if (empty($idAgents[0])) { echo json_encode([]); return; } $filter = '1 = 1'; $all = (string) get_parameter('all', 'all'); switch ($all) { default: case 'all': $filter .= ' AND 1 = 1'; break; case 'enabled': $filter .= ' AND t1.disabled = 0'; break; } if (!empty($module_types_excluded) && is_array($module_types_excluded)) { $filter .= ' AND t1.id_tipo_modulo NOT IN ('.implode($module_types_excluded).')'; } if (!empty($module_name)) { $filter .= " AND t1.nombre COLLATE utf8_general_ci LIKE '%".$module_name."%'"; } // Status selector. if ($status_modulo == AGENT_MODULE_STATUS_NORMAL) { // Normal. $sql_conditions .= ' estado = 0 AND utimestamp > 0 ) OR (t1.id_tipo_modulo IN(21,22,23,100)) '; } else if ($status_modulo == AGENT_MODULE_STATUS_CRITICAL_BAD) { // Critical. $sql_conditions .= ' estado = 1 AND utimestamp > 0 )'; } else if ($status_modulo == AGENT_MODULE_STATUS_WARNING) { // Warning. $sql_conditions .= ' estado = 2 AND utimestamp > 0 )'; } else if ($status_modulo == AGENT_MODULE_STATUS_NOT_NORMAL) { // Not normal. $sql_conditions .= ' estado <> 0)'; } else if ($status_modulo == AGENT_MODULE_STATUS_UNKNOWN) { // Unknown. $sql_conditions .= ' estado = 3 AND utimestamp <> 0 )'; } else if ($status_modulo == AGENT_MODULE_STATUS_NOT_INIT) { // Not init. $sql_conditions .= ' utimestamp = 0 ) AND t1.id_tipo_modulo NOT IN (21,22,23,100)'; } if ($status_modulo != -1) { $filter .= ' AND t1.id_agente_modulo IN (SELECT id_agente_modulo FROM tagente_estado where '.$sql_conditions; } $sql_tags_join = ''; $where_tags = ''; if (tags_has_user_acl_tags($config['id_user'])) { $where_tags = tags_get_acl_tags( $config['id_user'], $id_groups, 'AR', 'module_condition', 'AND', 'tagente_modulo', false, [], true ); $sql_tags_join = 'INNER JOIN tagente ON tagente.id_agente = t1.id_agente INNER JOIN ttag_module ON ttag_module.id_agente_modulo = t1.id_agente_modulo LEFT JOIN tagent_secondary_group tasg ON tagente.id_agente = tasg.id_agent'; } if (is_metaconsole()) { $result = []; $nameModules = []; $temp = []; $first = true; $temp_element = []; $counter = 0; $first_elements = []; $array_mapped = array_map( function ($item) use ($metaconsole_server_name) { if (empty($metaconsole_server_name)) { if (strstr($item, '|@_@|')) { $row = explode('|@_@|', $item); } else { $row = explode('|', $item); } $server_name = array_shift($row); $id_agent = array_shift($row); } else { $server_name = $metaconsole_server_name; $id_agent = $item; } return [ 'server_name' => $server_name, 'id_agent' => $id_agent, ]; }, $idAgents ); $array_reduced = array_reduce( $array_mapped, function ($carry, $item) { if (!isset($carry[$item['server_name']])) { $carry[$item['server_name']] = []; } $carry[$item['server_name']][] = $item['id_agent']; return $carry; }, [] ); $last_modules_set = []; foreach ($array_reduced as $server_name => $id_agents) { // Metaconsole db connection // $server_name can be the server id (ugly hack, I know). if (is_numeric($server_name)) { $connection = metaconsole_get_connection_by_id($server_name); } else { $connection = metaconsole_get_connection($server_name); } if (metaconsole_load_external_db($connection) != NOERR) { continue; } // Get agent's modules. $sql = sprintf( 'SELECT t1.id_agente, t1.id_agente_modulo, t1.nombre FROM tagente_modulo t1 %s WHERE %s %s AND t1.delete_pending = 0 AND t1.id_agente IN (%s) AND ( SELECT COUNT(nombre) FROM tagente_modulo t2 WHERE t2.delete_pending = 0 AND t1.nombre = t2.nombre AND t2.id_agente IN (%s)) = (%d)', $sql_tags_join, $filter, $where_tags, implode(',', $id_agents), implode(',', $id_agents), count($id_agents) ); $modules = db_get_all_rows_sql($sql); if (empty($modules)) { $modules = []; } $modules_aux = []; foreach ($modules as $key => $module) { // Don't change this order, is used in the serialization. $module_data = [ 'id_module' => $module['id_agente_modulo'], 'id_agent' => $module['id_agente'], 'server_name' => $server_name, ]; if (!isset($modules_aux[$module['nombre']])) { $modules_aux[$module['nombre']] = []; } $modules_aux[$module['nombre']][] = $module_data; } $modules = $modules_aux; // Build the next array using the common values. if (!empty($last_modules_set)) { $modules = array_intersect_key($modules, $last_modules_set); array_walk( $modules, function (&$module_data, $module_name) use ($last_modules_set) { $module_data = array_merge($module_data, $last_modules_set[$module_name]); } ); } $last_modules_set = $modules; // Restore db connection. metaconsole_restore_db(); } $result = []; foreach ($last_modules_set as $module_name => $module_data) { $value = ui_print_truncate_text(io_safe_output($module_name), 'module_medium', false, true); $module_data_processed = array_map( function ($item) { return implode('|', $item); }, $module_data ); $key = implode(';', $module_data_processed); $result[$key] = $value; } asort($result); } else { if ($idAgents[0] < 0) { if ($selection_mode == 'common') { $sql_agent_total = 'SELECT count(*) FROM tagente WHERE disabled=0'; $agent_total = db_get_value_sql($sql_agent_total); $sql = sprintf( "SELECT t1.nombre, t1.id_agente_modulo FROM tagente_modulo t1 JOIN (SELECT COUNT(*) AS num_names, nombre FROM tagente_modulo WHERE disabled=0 AND delete_pending=0 GROUP BY nombre) AS tj ON tj.num_names = $agent_total AND tj.nombre = t1.nombre %s %s", $sql_tags_join, (empty($where_tags)) ? '' : " WHERE 1=1 $where_tags" ); } else { $sql = sprintf( 'SELECT t1.nombre, t1.id_agente_modulo FROM tagente_modulo t1 %s %s', $sql_tags_join, (empty($where_tags)) ? '' : " WHERE 1=1 $where_tags" ); } } else { $sql = sprintf( 'SELECT DISTINCT t1.nombre, t1.id_agente_modulo FROM tagente_modulo t1 INNER JOIN tagente_estado t2 ON t1.id_agente_modulo = t2.id_agente_modulo %s WHERE %s AND t1.delete_pending = 0 AND t1.id_agente IN ('.implode(',', $idAgents).') %s %s', $sql_tags_join, $filter, ' AND t2.datos NOT LIKE "%image%"', $where_tags ); if ($selection_mode == 'common') { $sql .= ' AND ( SELECT count(nombre) FROM tagente_modulo t2 WHERE t2.delete_pending = 0 AND t1.nombre = t2.nombre AND t2.id_agente IN ('.implode(',', $idAgents).')) = ('.count($idAgents).')'; } else if ($selection_mode == 'unknown') { $sql .= 'AND t1.id_agente_modulo IN (SELECT id_agente_modulo FROM tagente_estado where estado = 3 OR estado = 4)'; } } $sql .= ' ORDER BY nombre'; $nameModules = db_get_all_rows_sql($sql); if ($tags != null) { if ((count($tags) >= 1) && ($tags[0] != '') && ($tags[0] != -1)) { $implode_tags = implode(',', $tags); $tag_modules = db_get_all_rows_sql('SELECT DISTINCT id_agente_modulo FROM ttag_module WHERE id_tag IN ('.$implode_tags.')'); if ($tag_modules) { $final_modules = []; foreach ($nameModules as $key => $module) { $in_array = false; foreach ($tag_modules as $t_module) { if ($module['id_agente_modulo'] == $t_module['id_agente_modulo']) { $in_array = true; } } if ($in_array) { $final_modules[] = $module; } } $nameModules = $final_modules; } else { $nameModules = []; } } } if ($nameModules == false) { $nameModules = []; } $result = []; foreach ($nameModules as $nameModule) { if (empty($serialized)) { $result[io_safe_output($nameModule['nombre'])] = ui_print_truncate_text( io_safe_output($nameModule['nombre']), 'module_medium', false, true ); } else { $result[io_safe_output($nameModule['nombre']).'$*$'.implode('|', $idAgents)] = ui_print_truncate_text(io_safe_output($nameModule['nombre']), 'module_medium', false, true); } } } echo json_encode($result); return; } if ($get_agent_modules_json) { $id_agent = (int) get_parameter('id_agent'); // Use -1 as not received. $disabled = (int) get_parameter('disabled', -1); $delete_pending = (int) get_parameter('delete_pending', -1); // Use 0 as not received. $id_tipo_modulo = (int) get_parameter('id_tipo_modulo', 0); $status_modulo = (int) get_parameter('status_module', -1); $tags = (array) get_parameter('tags', []); // Filter. $filter = []; if ($disabled !== -1) { $filter['disabled'] = $disabled; } if ($delete_pending !== -1) { $filter['delete_pending'] = $delete_pending; } if (!empty($id_tipo_modulo)) { $filter['id_tipo_modulo'] = $id_tipo_modulo; } if (empty($filter)) { $filter = false; } $get_only_string_modules = get_parameter( 'get_only_string_modules', false ); if ($get_only_string_modules) { $filter['tagente_modulo.id_tipo_modulo IN'] = '(17,23,3,10,33)'; } // Status selector. if ($status_modulo == AGENT_MODULE_STATUS_NORMAL) { // Normal. $sql_conditions .= ' estado = 0 AND utimestamp > 0 ) OR (tagente_modulo.id_tipo_modulo IN(21,22,23,100)) '; } else if ($status_modulo == AGENT_MODULE_STATUS_CRITICAL_BAD) { // Critical. $sql_conditions .= ' estado = 1 AND utimestamp > 0 )'; } else if ($status_modulo == AGENT_MODULE_STATUS_WARNING) { // Warning. $sql_conditions .= ' estado = 2 AND utimestamp > 0 )'; } else if ($status_modulo == AGENT_MODULE_STATUS_NOT_NORMAL) { // Not normal. $sql_conditions .= ' estado <> 0 )'; } else if ($status_modulo == AGENT_MODULE_STATUS_UNKNOWN) { // Unknown. $sql_conditions .= ' estado = 3 AND utimestamp <> 0 )'; } else if ($status_modulo == AGENT_MODULE_STATUS_NOT_INIT) { // Not init. $sql_conditions .= ' utimestamp = 0 ) AND tagente_modulo.id_tipo_modulo NOT IN (21,22,23,100)'; } if ($status_modulo != -1) { $filter['tagente_modulo.id_agente_modulo IN'] = ' (SELECT id_agente_modulo FROM tagente_estado where '.$sql_conditions; } $get_id_and_name = (bool) get_parameter('get_id_and_name'); $get_distinct_name = (bool) get_parameter('get_distinct_name'); // Fields. $fields = '*'; if ($get_id_and_name) { $fields = [ 'id_agente_modulo', 'nombre', ]; } if ($get_distinct_name) { $fields = ['DISTINCT(tagente_modulo.nombre)']; } $indexed = (bool) get_parameter('indexed', true); $agentName = (string) get_parameter('agent_name', null); $server_name = (string) get_parameter('server_name', null); $server_id = (int) get_parameter('server_id', 0); // This will force to get local modules although metaconsole is active, // by default get all modules from all nodes. $force_local_modules = (int) get_parameter('force_local_modules', 0); if ($agentName != null) { $search = []; $search['alias'] = io_safe_output($agentName); } else { $search = false; } $force_tags = !empty($tags); if ($force_tags) { $filter['ttag_module.id_tag IN '] = '('.implode(',', $tags).')'; } if (is_metaconsole() && !$force_local_modules) { if (enterprise_include_once('include/functions_metaconsole.php') !== ENTERPRISE_NOT_HOOK) { $connection = metaconsole_get_connection($server_name); if ($server_id > 0) { $connection = metaconsole_get_connection_by_id($server_id); } if (metaconsole_load_external_db($connection) == NOERR) { // Get all agents if no agent was given. if ($id_agent == 0) { $id_agent = array_keys( agents_get_group_agents( array_keys(users_get_groups()), $search, 'none' ) ); } $agent_modules = agents_get_modules($id_agent, $fields, $filter, $indexed, true, $force_tags); } // Restore db connection. metaconsole_restore_db(); } } else { // Get all agents if no agent was given. if ($id_agent == 0) { $id_agent = array_keys( agents_get_group_agents( array_keys(users_get_groups()), $search, 'none' ) ); } $agent_modules = agents_get_modules($id_agent, $fields, $filter, $indexed, true, $force_tags); } if (empty($agent_modules)) { $agent_modules = []; } foreach ($agent_modules as $key => $module) { $agent_modules[$key]['nombre'] = io_safe_output($module['nombre']); } $get_order_json = (bool) get_parameter('get_order_json', false); if ($get_order_json) { $new_elements = []; $index = 0; foreach ($agent_modules as $key => $module) { $new_elements[$index]['id_agente_modulo'] = $module['id_agente_modulo']; $new_elements[$index]['nombre'] = io_safe_output($module['nombre']); $index++; } $agent_modules = $new_elements; } echo json_encode($agent_modules); return; } if ($get_agent_status_tooltip) { $id_agent = (int) get_parameter('id_agent'); $metaconsole = (bool) get_parameter('metaconsole', false); $id_server = (int) get_parameter('id_server', 0); // Metaconsole. $server = null; if ($metaconsole) { $filter = []; if (!empty($id_agent)) { $filter['id_tagente'] = $id_agent; } if (!empty($id_server)) { $filter['id_tmetaconsole_setup'] = $id_server; } $agent = db_get_row_filter('tmetaconsole_agent', $filter); } else { $agent = db_get_row('tagente', 'id_agente', $id_agent); } if ($agent === false) { return; } echo '