pandorafms/pandora_console/include/functions_db.php

<?php

// Pandora FMS - the Flexible Monitoring System
// ============================================
// Copyright (c) 2008 Artica Soluciones Tecnologicas, http://www.artica.es
// Please see http://pandora.sourceforge.net 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 (LGPL)
// as published by the Free Software Foundation for version 2.
// 
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.

/** 
 * Check if login session variables are set.
 *
 * It will stop the execution if those variables were not set
 * 
 * @return 0 on success
 */

function check_login () {
	global $config;
	if (! isset ($config["homedir"])) {
		// No exists $config. Exit inmediatly
		include("general/noaccess.php");
		exit;
	}
	if ((isset($_SESSION["id_usuario"])) AND ($_SESSION["id_usuario"] != "")) {
		$id = get_db_value("id_usuario","tusuario","id_usuario",$_SESSION["id_usuario"]);
		if ( $_SESSION["id_usuario"] == $id) {
			return 0;
		}
	}
	audit_db ("N/A", getenv ("REMOTE_ADDR"), "No session", "Trying to access without a valid session");
	include ($config["homedir"]."/general/noaccess.php");
	exit;
}
	
/**
 * Check access privileges to resources
 *
 * Access can be:
 * IR - Incident Read
 * IW - Incident Write
 * IM - Incident Management
 * AR - Agent Read
 * AW - Agent Write
 * LW - Alert Write
 * UM - User Management
 * DM - DB Management
 * LM - Alert Management
 * PM - Pandora Management
 *
 * @param id_user User id
 * @param id_group Agents group id
 * @param access Access privilege
 *
 * @return 1 if the user has privileges, 0 if not.
**/
function give_acl ($id_user, $id_group, $access) {
	// IF user is level = 1 then always return 1

	global $config;
	$nivel = get_db_value("nivel","tusuario","id_usuario",$id_user);
	if ($nivel == 1) {
		return 1;
		//Apparently nivel is 1 if user has full admin access
	} 
	
	//Joined multiple queries into one. That saves on the query overhead and query cache.
	if ($id_group == 0) {
		$query1=sprintf("SELECT tperfil.incident_view,tperfil.incident_edit,tperfil.incident_management,tperfil.agent_view,tperfil.agent_edit,tperfil.alert_edit,tperfil.alert_management,tperfil.pandora_management,tperfil.db_management,tperfil.user_management FROM tusuario_perfil,tperfil WHERE tusuario_perfil.id_perfil = tperfil.id_perfil AND tusuario_perfil.id_usuario = '%s'", $id_user);
		//GroupID = 0, access doesnt matter (use with caution!) - Any user gets access to group 0
	} else {
		$query1=sprintf("SELECT tperfil.incident_view,tperfil.incident_edit,tperfil.incident_management,tperfil.agent_view,tperfil.agent_edit,tperfil.alert_edit,tperfil.alert_management,tperfil.pandora_management,tperfil.db_management,tperfil.user_management FROM tusuario_perfil,tperfil WHERE tusuario_perfil.id_perfil = tperfil.id_perfil 
AND tusuario_perfil.id_usuario = '%s' AND (tusuario_perfil.id_grupo = %d OR tusuario_perfil.id_grupo= 1)", $id_user, $id_group);
	}

	$rowdup = get_db_all_rows_sql($query1);
	$result = 0;

	if (!$rowdup)
		return $result;

	foreach($rowdup as $row) {
		// For each profile for this pair of group and user do...
			switch ($access) {
			case "IR":
				$result += $row["incident_view"];
				break;
			case "IW":
				$result += $row["incident_edit"];
				break;
			case "IM":
				$result += $row["incident_management"];
				break;
			case "AR":
				$result += $row["agent_view"];
				break;
			case "AW":
				$result += $row["agent_edit"];
				break;
			case "LW":
				$result += $row["alert_edit"];
				break;
			case "LM":
				$result += $row["alert_management"];
				break;
			case "PM":
				$result += $row["pandora_management"];
				break;
			case "DM":
				$result += $row["db_management"];
				break;
			case "UM":
				$result += $row["user_management"];
				break;
			}
	}
	if ($result > 1)
		$result = 1;
	return $result; 
} 

/** 
 * Adds an audit log entry.
 * 
 * @param id User id
 * @param ip Client IP
 * @param accion Action description
 * @param descripcion Long action description
 */
function audit_db ($id, $ip, $accion, $descripcion){
	$accion = safe_input($accion);
	$descripcion = safe_input($descripcion);
	$sql = sprintf ("INSERT INTO tsesion (ID_usuario, accion, fecha, IP_origen,descripcion, utimestamp) VALUES ('%s','%s',NOW(),'%s','%s',UNIX_TIMESTAMP(NOW()))",$id,$accion,$ip,$descripcion);
	process_sql ($sql);
}

/**
 * Log in a user into Pandora.
 *
 * @param id_user User id
 * @param ip Client user IP address.
 */
function logon_db ($id_user, $ip) {
	audit_db ($id_user, $ip, "Logon", "Logged in");
	// Update last registry of user to set last logon. How do we audit when the user was created then?
	$sql = sprintf ("UPDATE tusuario SET fecha_registro = NOW() WHERE id_usuario = '%s'", $id_user);
	process_sql ($sql);
}

/**
 * Log out a user into Pandora.
 *
 * @param id_user User id
 * @param ip Client user IP address.
 */
function logoff_db ($id_user, $ip) {
	audit_db ($id_user, $ip, "Logoff", "Logged out");
}

/**
 * Get profile name from id.
 * 
 * @param id_profile Id profile in tperfil
 * 
 * @return Profile name of the given id
 */
function dame_perfil ($id_profile) {
	return (string) get_db_value ('name', 'tperfil', 'id_perfil', (int) $id_profile);
}

/** 
 * Get disabled field of a group
 * 
 * @param id_group Group id
 * 
 * @return Disabled field of given group
 */
function give_disabled_group ($id_group) {
	return (bool) get_db_value ('disabled', 'tgrupo', 'id_grupo', (int) $id_group);
}

/**
 * Get all the agents in a group.
 *
 * @param id_group Group id
 * @param disabled Add disabled agents to agents. Default: False.
 *
 * @return An array with all agents in the group.
 */
function get_agents_in_group ($id_group, $disabled = false) {
	/* 'All' group must return all agents */
	if ($id_group == 1) {
		if ($disabled) {
			return get_db_all_rows_in_table ('tagente', 'nombre');
		} else {
			return get_db_all_rows_field_filter ('tagente', 'disabled', 0, 'nombre');
		}
	} elseif ($disabled && $id_group != 1) {
		return get_db_all_rows_field_filter ('tagente', 'id_grupo', (int) $id_group, 'nombre');
	} else {
		$sql = sprintf ("SELECT * FROM tagente WHERE id_grupo = %d AND disabled = 0 ORDER BY nombre",$id_group);
		return get_db_all_rows_sql ($sql);
	}
}

/**
 * Get all the modules in an agent.
 *
 * @param $id_agent Agent id
 *
 * @return An array with all modules in the agent.
 */
function get_modules_in_agent ($id_agent) {
	return get_db_all_rows_field_filter ('tagente_modulo', 'id_agente', (int) $id_agent);
}

/**
 * Get all the simple alerts of an agent.
 *
 * @param $id_agent Agent id
 *
 * @return An array with all simple alerts defined for an agent.
 */
function get_simple_alerts_in_agent ($id_agent) {
	$sql = sprintf ("SELECT talerta_agente_modulo.* FROM talerta_agente_modulo, tagente_modulo WHERE talerta_agente_modulo.id_agente_modulo = tagente_modulo.id_agente_modulo AND tagente_modulo.id_agente = %d", $id_agent);
	$alerts = get_db_all_rows_sql ($sql);
	
	if ($alerts === false)
		return array ();
	return $alerts;
}

/**
 * Get all the combined alerts of an agent.
 *
 * @param $id_agent Agent id
 *
 * @return An array with all combined alerts defined for an agent.
 */
function get_combined_alerts_in_agent ($id_agent) {
	$alerts = get_db_all_rows_field_filter ('talerta_agente_modulo', 'id_agent', (int) $id_agent);
	
	if ($alerts === false)
		return array ();
	return $alerts;
}

/**
 * Get all the alerts of an agent, simple and combined.
 *
 * @param $id_agent Agent id
 *
 * @return An array with all alerts defined for an agent.
 */
function get_alerts_in_agent ($id_agent) {
	$simple_alerts = get_simple_alerts_in_agent ($id_agent);
	$combined_alerts = get_combined_alerts_in_agent ($id_agent);
	
	return array_merge ($simple_alerts, $combined_alerts);
}

/**
 * Get a list of the reports the user can view.
 *
 * A user can view a report by two ways:
 *  - The user created the report (id_user field in treport)
 *  - The report is not private and the user has reading privileges on 
 *    the group associated to the report
 *
 * @param $id_user User id
 *
 * @return An array with all the reports the user can view.
 */
function get_reports ($id_user) {
	$user_reports = array ();
	$all_reports = get_db_all_rows_in_table ('treport', 'name');
	if ($all_reports === false) {
		return $user_reports;
	}
	foreach ($all_reports as $report) {
		/* The report is private and it does not belong to the user */
		if ($report['private'] && $report['id_user'] != $id_user)
			continue;
		/* Check ACL privileges on report group */
		if (! give_acl ($id_user, $report['id_group'], 'AR'))
			continue;
		array_push ($user_reports, $report);
	}
	return $user_reports;
}

/** 
 * Get group name from group.
 * 
 * @param id_group Id group to get the name.
 * 
 * @return The name of the given group
 */
function dame_grupo ($id_group) {
	return (string) get_db_value ('nombre', 'tgrupo', 'id_grupo', (int) $id_group);
}

/** 
 * Get group icon from group.
 * 
 * @param id_group Id group to get the icon
 * 
 * @return Icon path of the given group
 */
function dame_grupo_icono ($id_group) {
	return (string) get_db_value ('icon', 'tgrupo', 'id_grupo', (int) $id_group);
}

/** 
 * Get agent id from an agent name.
 * 
 * @param agent_name Agent name to get its id.
 * 
 * @return Id from the agent of the given name.
 */
function dame_agente_id ($agent_name) {
	return (int) get_db_value ('id_agente', 'tagente', 'nombre', $agent_name);
}

/** 
 * Get user id of a note.
 * 
 * @param id_note Note id.
 * 
 * @return User id of the given note.
 */
function give_note_author ($id_note) {
	return (int) get_db_value ('id_usuario', 'tnota', 'id_nota', (int) $id_note);
}

/** 
 * Get description of an event.
 * 
 * @param id_event Event id.
 * 
 * @return Description of the given event.
 */
function return_event_description ($id_event) {
	return (string) get_db_value ('evento', 'tevento', 'id_evento', (int) $id_event);
}

/** 
 * Get group id of an event.
 * 
 * @param id_event Event id
 * 
 * @return Group id of the given event.
 */
function gime_idgroup_from_idevent ($id_event) {
	return (int) get_db_value ('id_grupo', 'tevento', 'id_evento', (int) $id_event);
}

/** 
 * Get name of an agent.
 * 
 * @param id_agent Agent id.
 * 
 * @return Name of the given agent.
 */
function dame_nombre_agente ($id_agent) {
	return (string) get_db_value ('nombre', 'tagente', 'id_agente', (int) $id_agent);
}

/** 
 * Get password of an user.
 * 
 * @param id_usuario User id.
 * 
 * @return Password of an user.
 */
function get_user_password ($id_user) {
	return (string) get_db_value ('password', 'tusuario', 'id_usuario', $id_user);
}

/** 
 * Get name of an alert
 * 
 * @param id_alert Alert id.
 * 
 * @return Name of the alert.
 */
function dame_nombre_alerta ($id_alert) {
	return (string) get_db_value ('nombre', 'talerta', 'id_alerta', (int) $id_alert);
}

/** 
 * Get name of a module group.
 * 
 * @param id_module_group Module group id.
 * 
 * @return Name of the given module group.
 */
function dame_nombre_grupomodulo ($id_module_group) {
	return (string) get_db_value ('name', 'tmodule_group', 'id_mg', (int) $id_module_group);
}

/** 
 * Get the name of an exporting server
 * 
 * @param id_server Server id
 * 
 * @return The name of given server.
 */
function dame_nombre_servidorexportacion ($id_server) {
	return (string) get_db_value ('name', 'tserver_export', 'id', (int) $id_server);
}

/** 
 * Get the name of a plugin
 * 
 * @param id_plugin Plugin id.
 * 
 * @return The name of the given plugin
 */
function dame_nombre_pluginid ($id_plugin) {
	return (string) get_db_value ('name', 'tplugin', 'id', (int) $id_plugin);
}

/** 
 * Get the name of a module type
 * 
 * @param id_type Type id
 * 
 * @return The name of the given type.
 */
function giveme_module_type ($id_type) {
	return (string) get_db_value ('nombre', 'ttipo_modulo', 'id_tipo', (int) $id_type);
}

/** 
 * Get agent name of an agent module.
 * 
 * @param id_agente_modulo Agent module id.
 * 
 * @return The name of the given agent module.
 */
function dame_nombre_agente_agentemodulo ($id_agente_modulo) {
	$id_agent = get_db_value ('id_agente', 'tagente_modulo', 'id_agente_modulo', (int) $id_agente_modulo);
	if ($id_agent)
		return dame_nombre_agente ($id_agent);
	return '';
}

/** 
 * Get the module name of an agent module.
 * 
 * @param id_agente_modulo Agent module id.
 * 
 * @return Name of the given agent module.
 */
function dame_nombre_modulo_agentemodulo ($id_agente_modulo) {
	return (string) get_db_value ('nombre', 'tagente_modulo', 'id_agente_modulo', (int) $id_agente_modulo);
}

/** 
 * Get the module type of an agent module.
 * 
 * @param id_agente_modulo Agent module id.
 * 
 * @return Module type of the given agent module.
 */
function dame_id_tipo_modulo_agentemodulo ($id_agente_modulo) {
	return (int) get_db_value ('id_tipo_modulo', 'tagente_modulo', 'id_agente_modulo', (int) $id_agente_modulo);
}

/** 
 * Get the real name of an user.
 * 
 * @param id_user User id
 * 
 * @return Real name of given user.
 */
function dame_nombre_real ($id_user) {
	return (string) get_db_value ('nombre_real', 'tusuario', 'id_usuario', (int) $id_user);
}

/**
 * Get all the times a monitor went down during a period.
 * 
 * @param $id_agent_module Agent module of the monitor.
 * @param $period Period timed to check from date
 * @param $date Date to check (now by default)
 *
 * @return The number of times a monitor went down.
 */
function get_monitor_downs_in_period ($id_agent_module, $period, $date = 0) {
	if ($date == 0) {
		$date = time ();
	}
	$datelimit = $date - $period;
	$sql = sprintf ("SELECT COUNT(`id_agentmodule`) FROM `tevento` WHERE 
			`event_type` = 'monitor_down' 
			AND `id_agentmodule` = %d 
			AND `utimestamp` > %d 
			AND `utimestamp` <= %d",
			$id_agent_module, $datelimit, $date);
	 
	return get_db_sql ($sql);
}

/**
 * Get the last time a monitor went down during a period.
 * 
 * @param $id_agent_module Agent module of the monitor.
 * @param $period Period timed to check from date
 * @param $date Date to check (now by default)
 *
 * @return The last time a monitor went down.
 */
function get_monitor_last_down_timestamp_in_period ($id_agent_module, $period, $date = 0) {
	if ($date == 0) {
		$date = time ();
	}
	$datelimit = $date - $period;
	$sql = sprintf ("SELECT MAX(`timestamp`) FROM `tevento` WHERE 
			event_type = 'monitor_down' 
			AND `id_agentmodule` = %d 
			AND `utimestamp` > %d 
			AND `utimestamp` <= %d",
			$id_agent_module, $datelimit, $date);
	
	return get_db_sql ($sql);
}

/**
 * Get all the monitors defined in an group.
 * 
 * @param id_group Group id to get all the monitors.
 * 
 * @return An array with all the monitors defined in the group (tagente_modulo).
 */
function get_monitors_in_group ($id_group) {
	$sql = sprintf ("SELECT `tagente_modulo`.* FROM `tagente_modulo`, `ttipo_modulo`, `tagente` WHERE 
			`id_tipo_modulo` = `id_tipo` 
			AND `tagente`.`id_agente` = `tagente_modulo`.`id_agente` 
			AND `ttipo_modulo`.`nombre` LIKE '%%_proc' 
			AND `tagente`.`id_grupo` = %d", $id_group);
	return get_db_all_rows_sql ($sql);
}

/** 
 * Get all the monitors defined in an agent.
 * 
 * @param id_agent Agent id to get all the monitors.
 * 
 * @return An array with all the monitors defined (tagente_modulo).
 */
function get_monitors_in_agent ($id_agent) {
	$sql = sprintf ("SELECT `tagente_modulo`.*
			FROM `tagente_modulo`, `ttipo_modulo`, `tagente`
			WHERE `id_tipo_modulo` = `id_tipo`
			AND `tagente`.`id_agente` = `tagente_modulo`.`id_agente`
			AND `ttipo_modulo`.`nombre` LIKE '%%_proc'
			AND `tagente`.`id_agente` = %d", $id_agent);
	return get_db_all_rows_sql ($sql);
}

/** 
 * Get all the monitors down during a period of time.
 * 
 * @param monitors An array with all the monitors to check. Each
 * element of the array must be a dictionary.
 * @param period Period of time to check the monitors.
 * @param date Beginning date to check the monitors.
 * 
 * @return An array with all the monitors that went down in that
 * period of time.
 */
function get_monitors_down ($monitors, $period = 0, $date = 0) {
	$monitors_down = array ();
	if (! $monitors)
		return $monitors_down;

	foreach ($monitors as $monitor) {
		$down = get_monitor_downs_in_period ($monitor['id_agente_modulo'], $period, $date);
		if ($down)
			array_push ($monitors_down, $monitor);
	}
	return $monitors_down;
}

/**
 * Get all the times an alerts fired during a period.
 * 
 * @param $id_agent_module Agent module of the alert.
 * @param $period Period timed to check from date
 * @param $date Date to check (now by default)
 *
 * @return The number of times an alert fired.
 */
function get_alert_fires_in_period ($id_agent_module, $period, $date = 0) {
	if (!$date)
		$date = time ();
	$datelimit = $date - $period;
	$sql = sprintf ("SELECT COUNT(`id_agentmodule`) FROM `tevento` WHERE
			`event_type` = 'alert_fired'
			AND `id_agentmodule` = %d
			AND `utimestamp` > %d 
			AND `utimestamp` <= %d",
			$id_agent_module, $datelimit, $date);
	return (int) get_db_sql ($sql);
}

/** 
 * Get all the alerts defined in a group.
 *
 * It gets all the alerts of all the agents on a given group.
 * 
 * @param id_group Group id to check.
 * 
 * @return An array with alerts dictionaries defined in a group.
 */
function get_alerts_in_group ($id_group) {
	$alerts = array ();
	$agents = get_agents_in_group ($id_group);
	if (!$agents)
		return;
	foreach ($agents as $agent) {
		$agent_alerts = get_alerts_in_agent ($agent["id_agente"]);
		$alerts = array_merge ($alerts, $agent_alerts);
	}
	
	return $alerts;
}

/** 
 * Get all the alerts fired during a period, given a list of alerts.
 * 
 * @param alerts A list of alerts to check. See get_alerts_in_group()
 * @param period Period of time to check fired alerts.
 * @param date Beginning date to check fired alerts in UNIX format (current date by default)
 * 
 * @return An array with the alert id as key and the number of times
 * the alert was fired (only included if it was fired).
 */
function get_alerts_fired ($alerts, $period = 0, $date = 0) {
	if (! $date)
		$date = time ();
	$datelimit = $date - $period;

	$alerts_fired = array ();
	$agents = array ();
	foreach ($alerts as $alert) {
		$fires = get_alert_fires_in_period ($alert['id_agente_modulo'], $period, $date);
		if (! $fires) {
			continue;
		}
		$alerts_fired[$alert['id_aam']] = $fires;
	}
	return $alerts_fired;
}

/**
 * Get the last time an alert fired during a period.
 * 
 * @param $id_agent_module Agent module of the monitor.
 * @param $period Period timed to check from date
 * @param $date Date to check (now by default)
 *
 * @return The last time an alert fired.
 */
function get_alert_last_fire_timestamp_in_period ($id_agent_module, $period, $date = 0) {
	if ($date == 0) {
		$date = time ();
	}
	$datelimit = $date - $period;
	$sql = sprintf ("SELECT MAX(`timestamp`) FROM `tevento` WHERE
			`event_type` = 'alert_fired'
			AND `id_agentmodule` = %d
			AND `utimestamp` > %d 
			AND `utimestamp` <= %d",
			$id_agent_module, $datelimit, $date);
	return get_db_sql ($sql);
}

/** 
 * Get the author of an incident.
 * 
 * @param id_incident Incident id.
 * 
 * @return The author of an incident
 */
function give_incident_author ($id_incident) {
	return (string) get_db_value ('id_usuario', 'tincidencia', 'id_incidencia', (int) $id_incident);
}

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

/** 
 * Get the module type name.
 * 
 * @param id_type Type id
 * 
 * @return Name of the given type.
 */
function dame_nombre_tipo_modulo ($id_type) {
	return (string) get_db_value ('nombre', 'ttipo_modulo', 'id_tipo', $id_type);
} 

/** 
 * Get group name from the id
 * 
 * @param id_group Group id
 * 
 * @return The name of the given group
 */
function dame_nombre_grupo ($id_group) {
	return (string) get_db_value ('nombre', 'tgrupo', 'id_grupo', $id_group);
} 

/** 
 * Get group id of an agent.
 * 
 * @param id_agent Agent id
 * 
 * @return Group of the given agent
 */
function dame_id_grupo ($id_agent) {
	return (int) get_db_value ('id_grupo', 'tagente', 'id_agente', $id_agent);
}

/** 
 * Get the number of notes in a incident.
 * 
 * @param id_incident Incident id
 * 
 * @return The number of notes in given incident.
 */
function dame_numero_notas ($id_incident) {
	return (int) get_db_value ('COUNT(*)', 'tnota_inc', 'id_incidencia', $id_incident);
}

/** 
 * Get the number of pandora data in the database.
 * 
 * @return 
 */
function dame_numero_datos () {
	return (int) get_db_sql ("SELECT COUNT(*) FROM `tagente_datos`");
}

/** 
 * Get the data value of a agent module of string type.
 * 
 * @param id Agent module string id
 * 
 * @return Data value of the agent module.
 */
function dame_generic_string_data ($id) {
	return (string) get_db_value ('datos', 'tagente_datos_string', 'id_tagente_datos_string', $id);
}

/** 
 * Delete an incident of the database.
 * 
 * @param id_inc Incident id
 */
function borrar_incidencia ($id_inc) {
	global $config;
	
	$sql = sprintf ("DELETE FROM `tincidencia` WHERE `id_incidencia` = %d", $id_inc);
	process_sql ($sql);
	$sql = sprintf ("SELECT `id_nota` FROM `tnota_inc` WHERE `id_incidencia` = %d ", $id_inc);
	$rows = get_db_all_rows_sql ($sql);
	if ($rows){
		foreach ($rows as $row) {
			$sql = sprintf ("DELETE FROM `tnota` WHERE `id_nota` = %d",$row["id_nota"]);
			process_sql ($sql);
		}
		$sql = "DELETE FROM `tnota_inc` WHERE `id_incidencia` = $id_inc";
		process_sql ($sql);
	}
	
	// Delete attachments
	$sql = sprintf ("SELECT `id_attachment`,`filename` FROM `tattachment` WHERE `id_incidencia` = %d", $id_inc);
	$rows = get_db_all_rows_sql ($sql);
	if ($rows){
		foreach ($rows as $row) {
			// Unlink all attached files for this incident
			unlink ($attachment_store."attachment/pand".$row["id_attachment"]."_".$row["filename"]);
		}
		$sql = sprintf ("DELETE FROM `tattachment` WHERE `id_incidencia` = %d",$id_inc);
		process_sql ($sql);
	}
}

/** 
 * Get the operating system name.
 * 
 * @param id_os Operating system id.
 * 
 * @return Name of the given operating system.
 */
function dame_so_name ($id_os) {
	return (string) get_db_value ('name', 'tconfig_os', 'id_os', $id_os);
}

/** 
 * Update user last login timestamp.
 * 
 * @param id_user User id
 */
function update_user_contact ($id_user) {
	global $config;
	
	$sql = sprintf ("UPDATE `tusuario` set `fecha_registro` = NOW() WHERE 'id_usuario' = %d",$id_user);
	process_sql ($sql);
}

/** 
 * Get the icon of an operating system.
 *
 * The path of the icons is 'images/' which must be append by the
 * caller (including slash and filename extension .png)
 * 
 * @param id_os Operating system id
 * 
 * @return Icon filename of the operating system
 */
function dame_so_icon ($id_os) {
	return (string) get_db_value ('icon_name', 'tconfig_os', 'id_os', $id_os);
}

/** 
 * Get the user email
 * 
 * @param id_user User id.
 * 
 * @return Get the email address of an user
 */
function dame_email ($id_user) {
	return (string) get_db_value ('direccion', 'tusuario', 'id_usuario', $id_user);
}

/** 
 * Checks if a user is administrator.
 * 
 * @param id_user User id.
 * 
 * @return True is the user is admin
 */
function dame_admin ($id_user) {
	$level = get_db_value ('nivel', 'tusuario', 'id_usuario', $id_user);
	if ($level == 1) {
		return true;
	} else {
		return false;
	}
}

/** 
 * WARNING: This is a deprectad function and must not be used
 */
function comprueba_login() {
	return check_login ();
}

/** 
 * Check if an agent has alerts fired.
 * 
 * @param id_agent Agent id.
 * 
 * @return True if the agent has fired alerts.
 */
function check_alert_fired ($id_agent) {
	$sql = "SELECT COUNT(*) FROM talerta_agente_modulo, tagente_modulo
		WHERE talerta_agente_modulo.id_agente_modulo = tagente_modulo.id_agente_modulo
		AND times_fired > 0 AND id_agente = ".$id_agent;
	
	$value = get_db_sql ($sql);
	if ($value > 0)
		return true;
	return false;
}

/** 
 * Check is a user exists in the system
 * 
 * @param id_user User id.
 * 
 * @return True if the user exists.
 */
function existe ($id_user) {
	$user = get_db_row ('tusuario', 'id_usuario', $id_user);
	if (! $user)
		return false;
	return true;
}

/** 
 * Insert a event in the event log system.
 * 
 * @param event 
 * @param id_group 
 * @param id_agent 
 * @param status 
 * @param id_user 
 * @param event_type 
 * @param priority 
 * @param id_agent_module 
 * @param id_aam 
 */
function event_insert ($event, $id_group, $id_agent, $status = 0,
			$id_user = '', $event_type = "unknown", $priority = 0,
			$id_agent_module = 0, $id_aam = 0) {
	$sql = sprintf ('INSERT INTO tevento (id_agente, id_grupo, evento, timestamp, 
			estado, utimestamp, id_usuario, event_type, criticity,
			id_agentmodule, id_alert_am) 
			VALUES (%d, %d, "%s", NOW(), %d, NOW(), "%s", "%s", %d, %d, %d)',
			$id_agent, $id_group, $event, $status, $id_user, $event_type,
			$priority, $id_agent_module, $id_aam);

	process_sql ($sql);
}

/** 
 * Get the interval value of an agent module.
 *
 * If the module interval is not set, the agent interval is returned
 * 
 * @param id_agent_module Id agent module to get the interval value.
 * 
 * @return 
 */
function get_module_interval ($id_agent_module) {
	$interval = (int) get_db_value ('module_interval', 'tagente_modulo', 'id_agente_modulo', $id_agent_module);
	if ($interval)
		return $interval;
	$id_agent = get_db_value ('id_agente', 'tagente_modulo', 'id_agente_modulo', (int) $id_agent_module);
	
	return (int) give_agentinterval ($id_agent);
}

/** 
 * Get the interval of an agent.
 * 
 * @param id_agent Agent id.
 * 
 * @return The interval value of a given agent
 */
function give_agentinterval ($id_agent) {
	return (int) get_db_value ('intervalo', 'tagente', 'id_agente', $id_agent);
}

/** 
 * Get the flag value of an agent module.
 * 
 * @param id_agent_module Agent module id.
 * 
 * @return The flag value of an agent module.
 */
function give_agentmodule_flag ($id_agent_module) {
	return get_db_value ('flag', 'tagente_modulo', 'id_agente_modulo', $id_agent_module);
}

/** 
 * Prints a list of <options> HTML tags with the groups the user has
 * reading privileges.
 * 
 * @param id_user User id
 * @param show_all Flag to show all the groups or not. True by default.
 * 
 * @return An array with all the groups
 */
function list_group ($id_user, $show_all = 1){
	$mis_grupos = array (); // Define array mis_grupos to put here all groups with Agent Read permission
	$sql = 'SELECT id_grupo, nombre FROM tgrupo';
	$result = get_db_all_rows_sql ($sql);
	if (!$result)
		return $mis_grupos;
	foreach ($result as $row) {
		if (($row["id_grupo"] != 1 || $show_all == 1) && $row["id_grupo"] != 0 && give_acl($id_user,$row["id_grupo"], "AR") == 1) {
			//Put in  an array all the groups the user belongs to
			array_push ($mis_grupos, $row["id_grupo"]);
			echo '<option value="'.$row["id_grupo"].'">'.$row["nombre"].'</option>';
		}
	}
	return ($mis_grupos);
}

/** 
 * Get a list of the groups a user has reading privileges.
 *
 * DEPRECATED: Use get_user_groups () instead
 * 
 * @param id_user User id
 * 
 * @return A list of the groups the user has reading privileges.
 */
function list_group2 ($id_user) {
	$mis_grupos = array (); // Define array mis_grupos to put here all groups with Agent Read permission
	$result = get_db_all_fields_in_table ("tgrupo","id_grupo");
	if (!$result)
		return $mis_grupos;
	foreach ($result as $row) {
		if (give_acl ($id_user, $row["id_grupo"], "AR") == 1) {
			array_push ($mis_grupos, $row["id_grupo"]); //Put in array all the groups the user belongs to
		}
	}	
	
	return ($mis_grupos);
}

/** 
 * Get all the groups a user has reading privileges.
 * 
 * @param id_user User id
 * 
 * @return A list of the groups the user has reading privileges.
 */
function get_user_groups ($id_user) {
	$user_groups = array ();
	$groups = get_db_all_rows_in_table ('tgrupo', 'nombre');

	if (!$groups)
		return $user_groups;

	foreach ($groups as $group) {
		if (! give_acl ($id_user, $group["id_grupo"], "AR"))
			continue;
		$user_groups[$group['id_grupo']] = $group['nombre'];
	}
	
	return $user_groups;
}


/** 
 * Get group icon
 *
 * The path of the icons is 'images/' or 'images/group_small/', which
 * must be append by the caller (including slash and filename
 * extension .png)
 * 
 * @param id_group Group id
 * 
 * @return Icon filename of the given group
 */
function show_icon_group ($id_group) {
	return (string) get_db_value ('icon', 'tgrupo', 'id_grupo', $id_group);
}

/** 
 * Get module type icon.
 *
 * The path of the icons is 'images/', which must be append by the
 * caller (including final slash).
 * 
 * @param id_tipo Module type id
 * 
 * @return Icon filename of the given group
 */
function show_icon_type ($id_type) { 
	return (string) get_db_value ('icon', 'ttipo_modulo', 'id_tipo', $id_type);
}

/**
 * Return a string containing image tag for a given target id (server)
 *
 * @param int Server type id
 * @return string Fully formatted  IMG HTML tag with icon
 */
function show_server_type ($id){ 
	global $config;
	switch ($id) {
	case 1:
		return '<img src="images/data.png" title="Pandora FMS Data server">';
		break;
	case 2:
		return '<img src="images/network.png" title="Pandora FMS Network server">';
		break;
	case 4:
		return '<img src="images/plugin.png" title="Pandora FMS Plugin server">';
		break;
	case 5:
		return '<img src="images/chart_bar.png" title="Pandora FMS Prediction server">';
		break;
	case 6:
		return '<img src="images/wmi.png" title="Pandora FMS WMI server">';
		break;
	default: return "--";
	}
}

/** 
 * Get a module category name
 * 
 * @param id_category Id category
 * 
 * @return Name of the given category
 */
function give_modulecategory_name ($id_category) {
	switch ($id_category) {
	case 0: 
		return __('Software agent data');
		break;
	case 1: 
		return __('Software agent monitor');
		break;
	case 2: 
		return __('Network agent data');
		break;
	case 3: 
		return __('Network agent monitor');
		break;
	}
	return __('Unknown');
}

/** 
 * Get a network component group name
 * 
 * @param id_network_component_group Id network component group.
 * 
 * @return Name of the given network component group
 */
function give_network_component_group_name ($id_network_component_group) {
	return (string) get_db_value ('name', 'tnetwork_component_group', 'id_sg', $id_network_component_group);
}

/** 
 * Get a network profile name.
 * 
 * @param id_network_profile Id network profile
 * 
 * @return Name of the given network profile.
 */
function give_network_profile_name ($id_network_profile) {
	return (string) get_db_value ('name', 'tnetwork_profile', 'id_np', $id_network_profile);
}

/** 
 * Assign an IP address to an agent.
 * 
 * @param id_agent Agent id
 * @param ip_address IP address to assign
 */
function agent_add_address ($id_agent, $ip_address) {
	// Check if already is attached to agent
	$sql = sprintf ("SELECT COUNT(`ip`) FROM taddress_agent, taddress
		WHERE taddress_agent.id_a = taddress.id_a
		AND ip = '%s' AND id_agent = %d",$ip_address,$id_agent);
	$current_address = get_db_sql ($sql);
	if ($current_address > 0)
		return;
	
	// Look for a record with this IP Address
	$id_address = (int) get_db_value ('id_a', 'taddress', 'ip', $ip_address);
	
	if ($id_address === 0) {
		// Create IP address in tadress table
		$sql = sprintf("INSERT INTO taddress (ip) VALUES ('%s')",$ip_address);
		$id_address = process_sql ($sql, "insert_id");
	}
	
	// Add address to agent
	$sql = sprintf("INSERT INTO taddress_agent
			(id_a, id_agent) VALUES
			(%d, %d)",$id_address, $id_agent);
	process_sql ($sql);
}

/** 
 * Unassign an IP address from an agent.
 * 
 * @param id_agent Agent id
 * @param ip_address IP address to unassign
 */
function agent_delete_address ($id_agent, $ip_address) {
	$sql = sprintf ("SELECT id_ag FROM taddress_agent, taddress
		WHERE taddress_agent.id_a = taddress.id_a AND ip = '%s'
		AND id_agent = %d",$ip_address, $id_agent);
	$id_ag = get_db_sql ($sql);
	if ($id_ag !== false) {
		$sql = sprintf ("DELETE FROM taddress_agent WHERE id_ag = %d",$id_ag);	
		process_sql ($sql);
	}
	// Need to change main address ? 
	if (give_agent_address ($id_agent) == $ip_address) {
		$new_ip = give_agent_address_from_list ($id_agent);
		// Change main address in agent to whis one
		$query = sprintf ("UPDATE tagente SET `direccion` = '%s' WHERE id_agente = %d",$new_ip,$id_agent);
		process_sql ($query);
	}
}

/** 
 * Get address of an agent.
 * 
 * @param id_agent Agent id
 * 
 * @return The address of the given agent 
 */
function give_agent_address ($id_agent) {
	return (string) get_db_value ('direccion', 'tagente', 'id_agente', $id_agent);
}

/** 
 * Get IP address of an agent from address list
 * 
 * @param id_agent Agent id
 * 
 * @return The IP address of the given agent.
 */
function give_agent_address_from_list ($id_agent){
	$sql = "SELECT ip FROM taddress_agent, taddress
		WHERE taddress_agent.id_a = taddress.id_a
		AND id_agent = $id_agent";
	return (string) get_db_sql ($sql);
}

/** 
 * Get agent id from an agent module.
 * 
 * @param id_agent_module Id of the agent module.
 * 
 * @return The agent if of the given module.
 */
function give_agent_id_from_module_id ($id_agent_module) {
	return (int) get_db_value ('id_agente', 'tagente_modulo', 'id_agente_modulo', $id_agent_module);
}

$sql_cache = array ('saved' => 0);

/** 
 * Get the first value of the first row of a table in the database.
 * 
 * @param field Field name to get
 * @param table Table to retrieve the data
 * @param field_search Field to filter elements
 * @param condition Condition the field must have
 *
 * @return Value of first column of the first row. False if there were no row.
 */  
function get_db_value ($field, $table, $field_search = 1, $condition = 1) {

	if (is_int ($condition)) {
		$sql = sprintf ("SELECT %s FROM `%s` WHERE `%s` = %d LIMIT 1",
				$field, $table, $field_search, $condition);
	} else if (is_float ($condition) || is_double ($condition)) {
		$sql = sprintf ("SELECT %s FROM `%s` WHERE `%s` = %f LIMIT 1",
				$field, $table, $field_search, $condition);
	} else {
		$sql = sprintf ("SELECT %s FROM `%s` WHERE `%s` = '%s' LIMIT 1",
				$field, $table, $field_search, $condition);
	}
	$result = get_db_all_rows_sql ($sql);
	
	if($result === false)
		return false;
	
	return $result[0][$field];
}

/** 
 * Get the first row of an SQL database query.
 * 
 * @param sql SQL select statement to execute.
 * 
 * @return The first row of the result or something empty.
 */
function get_db_row_sql ($sql) {
	$sql .= " LIMIT 1";
	$result = get_db_all_rows_sql ($sql);
	
	if($result === false) 
		return false;
	
	return $result[0];
}

/** 
 * Get the first row of a database query into a table.
 *
 * The SQL statement executed would be something like:
 * "SELECT * FROM $table WHERE $field_search = $condition"
 *
 * @param table Table to get the row
 * @param field_search Field to filter elementes
 * @param condition Condition the field must have.
 * 
 * @return The first row of a database query.
 */
function get_db_row ($table, $field_search, $condition) {
	
	if (is_int ($condition)) {
		$sql = sprintf ("SELECT * FROM `%s` WHERE `%s` = %d LIMIT 1", $table, $field_search, $condition);
	} else if (is_float ($condition) || is_double ($condition)) {
		$sql = sprintf ("SELECT * FROM `%s` WHERE `%s` = %f LIMIT 1", $table, $field_search, $condition);
	} else {
		$sql = sprintf ("SELECT * FROM `%s` WHERE `%s` = '%s' LIMIT 1", $table, $field_search, $condition);
	}
	$result = get_db_all_rows_sql ($sql);
		
	if($result === false) 
		return false;
	
	return $result[0];
}

/** 
 * Get a single field in the databse from a SQL query.
 *
 * @param sql SQL statement to execute
 * @param field Field number to get, beggining by 0. Default: 0
 * @param cache Cache the query while generating this page. Default: 1
 * @return The selected field of the first row in a select statement.
 */
function get_db_sql ($sql, $field = 0) {
	$result = get_db_all_rows_sql ($sql);
	if($result === false)
		return false;

	return $result[0][$field];
}

/**
 * Get all the result rows using an SQL statement.
 * 
 * @param $sql SQL statement to execute.
 *
 * @return A matrix with all the values returned from the SQL statement or
 * false in case of empty result
 */
function get_db_all_rows_sql ($sql) {
	$return = process_sql ($sql);
	
	if (! empty ($return))
		return $return;
	//Return false, check with === or !==
	return false;
}

/**
 * This function comes back with an array in case of SELECT
 * in case of UPDATE, DELETE etc. with affected rows
 * an empty array in case of SELECT without results
 * Queries that return data will be cached so queries don't get repeated
 *
 * @param $sql SQL statement to execute
 *
 * @param $rettype (optional) What type of info to return in case of INSERT/UPDATE.
 *        insert_id will return the ID of an autoincrement value
 *        info will return the full (debug) information of a query
 *        default will return mysql_affected_rows
 *
 * @return An array with the rows, columns and values in a multidimensional array 
 */
function process_sql ($sql,$rettype = "affected_rows") {
	global $config;
	global $sql_cache;
	$retval = array();

	if (! empty ($sql_cache[$sql])) {
		$retval = $sql_cache[$sql];
		$sql_cache['saved']++;
	} else {
		$result = mysql_query ($sql);
		if ($result === false) {
			echo '<strong>Error:</strong> get_db_all_rows_sql ("'.$sql.'") :'. mysql_error ().'<br />';
			return false;
		} elseif ($result === true) {
			if ($rettype == "insert_id") {
				return mysql_insert_id ();
			} elseif ($rettype == "info") {
				return mysql_info ();
			}
			return mysql_affected_rows (); //This happens in case the statement was executed but didn't need a resource
		} else {
			while ($row = mysql_fetch_array ($result)) {
				array_push ($retval, $row);
			}
			$sql_cache[$sql] = $retval;
			mysql_free_result ($result);
		}
	}
	if (! empty ($retval))
		return $retval;
	//Return false, check with === or !==
	return false;
}

/**
 * Get all the rows in a table of the database.
 * 
 * @param $table Database table name.
 *
 * @return A matrix with all the values in the table
 */
function get_db_all_rows_in_table ($table, $order_field = "") {
	if ($order_field != "") {
		return get_db_all_rows_sql ("SELECT * FROM `".$table."` ORDER BY `".$order_field."` ");
	} else {	
		return get_db_all_rows_sql ("SELECT * FROM `".$table."`");
	}
}

/**
 * Get all the rows in a table of the databes filtering from a field.
 * 
 * @param $table Database table name.
 * @param $field Field of the table.
 * @param $condition Condition the field must have to be selected.
 *
 * @return A matrix with all the values in the table that matches the condition in the field
 */
function get_db_all_rows_field_filter ($table, $field, $condition, $order_field = "") {
	if (is_int ($condition)) {
		$sql = sprintf ("SELECT * FROM `%s` WHERE `%s` = '%d'", $table, $field, $condition);
	} else if (is_float ($condition) || is_double ($condition)) {
		$sql = sprintf ("SELECT * FROM `%s` WHERE `%s` = '%f'", $table, $field, $condition);
	} else {
		$sql = sprintf ("SELECT * FROM `%s` WHERE `%s` = '%s'", $table, $field, $condition);
	}

	if ($order_field != "")
		$sql .= sprintf(" ORDER BY `%s`",$order_field);	
	return get_db_all_rows_sql ($sql);
}

/**
 * Get all the rows in a table of the databes filtering from a field.
 * 
 * @param $table Database table name.
 * @param $field Field of the table.
 * @param $condition Condition the field must have to be selected.
 *
 * @return A matrix with all the values in the table that matches the condition in the field
 */
function get_db_all_fields_in_table ($table, $field, $condition='') {
	$sql = sprintf ("SELECT * FROM `%s`", $table);
	if($condition != '') {
		$sql .= sprintf (" WHERE `%s` = '%s'", $field, $condition);
	}
	return get_db_all_rows_sql ($sql);
}

/** 
 * Get the status of an alert assigned to an agent module.
 * 
 * @param id_agentmodule Id agent module to check.
 * 
 * @return True if there were alerts fired.
 */
function return_status_agent_module ($id_agentmodule = 0){
	$sql = sprintf ('SELECT `estado` FROM `tagente_estado` WHERE `id_agente_modulo` = %d', $id_agentmodule);
	$estado = get_db_sql($sql); 
	if ($estado == 100) {
		// We need to check if there are any alert on this item
		$sql = sprintf ('SELECT SUM(times_fired) FROM `talerta_agente_modulo` WHERE `id_agente_modulo` = %d', $id_agentmodule);
		$times_fired = get_db_sql($sql);
		if ($times_fired > 0){
			return 0;
		}
		// No alerts fired for this agent module
		return 1;
	} elseif ($estado == 0) { // 0 is ok for estado field
		return 1;
	} else {
		return 0;
	}
}

/** 
 * Get the status of a layout.
 *
 * It gets all the data of the contained elements (including nested
 * layouts), and makes an AND operation to be sure that all the items
 * are OK. If any of them is down, then result is down (0)
 * 
 * @param id_layout Id of the layout
 * 
 * @return The status of the given layout.
 */
function return_status_layout ($id_layout = 0) {
	$temp_status = 0;
	$temp_total = 0;
	$sql = sprintf ('SELECT id_agente_modulo, parent_item, id_layout_linked FROM `tlayout_data` WHERE `id_layout` = %d', $id_layout);
	$result = get_db_all_rows_sql ($sql);
	if ($result === false)
		return 0;
	
	foreach ($result as $rownum => $data) {
		if (($data["id_layout_linked"] != 0) && ($data["id_agente_modulo"] == 0)) {
			$temp_status += return_status_layout ($data["id_layout_linked"]);
			$temp_total++;
		} else {
			$temp_status += return_status_agent_module ($data["id_agente_modulo"]);
			$temp_total++;
		}
	}
	if ($temp_status == $temp_total) {
		return 1;
	}
	
	return 0;
}

/** 
 * Get the current value of an agent module.
 * 
 * @param id_agentmodule 
 * 
 * @return 
 */
function return_value_agent_module ($id_agentmodule) {
	return format_numeric (get_db_value ('datos', 'tagente_estado', 'id_agente_modulo', $id_agentmodule));
}

/** 
 * Get the X axis coordinate of a layout item
 * 
 * @param id_layoutdata Id of the layout to get.
 * 
 * @return The X axis coordinate value.
 */
function get_layoutdata_x ($id_layoutdata) {
	return (float) get_db_value ('pos_x', 'tlayout_data', 'id', $id_layoutdata);
}

/** 
 * Get the X axis coordinate of a layout item
 * 
 * @param id_layoutdata Id of the layout to get.
 * 
 * @return The X axis coordinate value.
 */
function get_layoutdata_y ($id_layoutdata){
	return (float) get_db_value ('pos_y', 'tlayout_data', 'id', $id_layoutdata);
}

/**
 * Get the previous data to the timestamp provided.
 *
 * It's useful to know the first value of a module in an interval, 
 * since it will be the last value in the table which has a timestamp 
 * before the beginning of the interval. All this calculation is due
 * to the data compression algorithm.
 *
 * @param $id_agent_module Agent module id
 * @param $utimestamp The timestamp to look backwards from and get the data.
 *
 * @return The row of tagente_datos of the last period. NULL if there were no data.
 */
function get_previous_data ($id_agent_module, $utimestamp) {
	$interval = get_module_interval ($id_agent_module);
	$sql = sprintf ('SELECT * FROM tagente_datos 
			WHERE id_agente_modulo = %d 
			AND utimestamp <= %d 
			AND utimestamp > %d
			ORDER BY utimestamp DESC',
			$id_agent_module, $utimestamp, $utimestamp - $interval);
	
	return get_db_row_sql ($sql);
}

/** 
 * Get the average value of an agent module in a period of time.
 * 
 * @param id_agent_module Agent module id
 * @param period Period of time to check (in seconds)
 * @param date Top date to check the values. Default current time.
 * 
 * @return The average module value in the interval.
 */
function get_agent_module_value_average ($id_agent_module, $period, $date = 0) {
	if (! $date)
		$date = time ();
	$datelimit = $date - $period;
	
	$sql = sprintf ("SELECT SUM(datos), COUNT(*) FROM tagente_datos 
			WHERE id_agente_modulo = %d 
			AND utimestamp > %d AND utimestamp <= %d 
			ORDER BY utimestamp ASC",
			$id_agent_module, $datelimit, $date);
	$values = get_db_row_sql ($sql);
	$sum = (float) $values[0];
	$total = (int) $values[1];
	
	/* Get also the previous data before the selected interval. */
	$previous_data = get_previous_data ($id_agent_module, $datelimit);
	if ($previous_data)
		return ($previous_data['datos'] + $sum) / ($total + 1);
	if ($total > 0)
		return $sum / $total;
	return 0;
}

/** 
 * Get the maximum value of an agent module in a period of time.
 * 
 * @param id_agent_module Agent module id to get the maximum value.
 * @param period Period of time to check (in seconds)
 * @param date Top date to check the values. Default current time.
 * 
 * @return The maximum module value in the interval.
 */
function get_agent_module_value_max ($id_agent_module, $period, $date = 0) {
	if (! $date)
		$date = time ();
	$datelimit = $date - $period;
	
	$sql = sprintf ("SELECT MAX(datos) FROM tagente_datos 
			WHERE id_agente_modulo = %d 
			AND utimestamp > %d  AND utimestamp <= %d",
			$id_agent_module, $datelimit, $date);
	$max = (float) get_db_sql ($sql);
	
	/* Get also the previous report before the selected interval. */
	$previous_data = get_previous_data ($id_agent_module, $datelimit);
	if ($previous_data)
		return max ($previous_data['datos'], $max);
	
	return max ($previous_data, $max);
}

/** 
 * Get the minimum value of an agent module in a period of time.
 * 
 * @param id_agent_module Agent module id to get the minimum value.
 * @param period Period of time to check (in seconds)
 * @param date Top date to check the values. Default current time.
 * 
 * @return The minimum module value of the module
 */
function get_agent_module_value_min ($id_agent_module, $period, $date = 0) {
	if (! $date)
		$date = time ();
	$datelimit = $date - $period;
	
	$sql = sprintf ("SELECT MIN(datos) FROM tagente_datos 
			WHERE id_agente_modulo = %d 
			AND utimestamp > %d AND utimestamp <= %d",
			$id_agent_module, $datelimit, $date);
	$min = (float) get_db_sql ($sql);
	
	/* Get also the previous data before the selected interval. */
	$previous_data = get_previous_data ($id_agent_module, $datelimit);
	if ($previous_data)
		return min ($previous_data['datos'], $min);
	return $min;
}

/** 
 * Get the sumatory of values of an agent module in a period of time.
 * 
 * @param id_agent_module Agent module id to get the sumatory.
 * @param period Period of time to check (in seconds)
 * @param date Top date to check the values. Default current time.
 * 
 * @return The sumatory of the module values in the interval.
 */
function get_agent_module_value_sumatory ($id_agent_module, $period, $date = 0) {
	if (! $date)
		$date = time ();
	$datelimit = $date - $period; // limit date
	$id_module_type = get_db_value ('id_tipo_modulo', 'tagente_modulo','id_agente_modulo', $id_agent_module);
	$module_name = get_db_value ('nombre', 'ttipo_modulo', 'id_tipo', $id_module_type);
	
	if (is_module_data_string ($module_name)) {
		return __('Wrong module type');
	}
	
	// Get the whole interval of data
	$sql = sprintf ('SELECT utimestamp, datos FROM tagente_datos 
			WHERE id_agente_modulo = %d 
			AND utimestamp > %d AND utimestamp <= %d 
			ORDER BY utimestamp ASC',
			$id_agent_module, $datelimit, $date);
	$datas = get_db_all_rows_sql ($sql);
	
	/* Get also the previous data before the selected interval. */
	$previous_data = get_previous_data ($id_agent_module, $datelimit);
	if ($previous_data) {
		/* Add data to the beginning */
		array_unshift ($datas, $previous_data);
	}
	if ($datas === false) {
		return 0;
	}
	
	$last_data = "";
	$total_badtime = 0;
	$module_interval = get_module_interval ($id_agent_module);
	$timestamp_begin = $datelimit + $module_interval;
	$timestamp_end = 0;
	$sum = 0;
	$data_value = 0;
	
	foreach ($datas as $data) {
		$timestamp_end = $data["utimestamp"];
		$elapsed = $timestamp_end - $timestamp_begin;
		$times = intval ($elapsed / $module_interval);
			
		if (is_module_inc ($module_name)) {
			$data_value = $data['datos'] * $module_interval;
		} else {
			$data_value = $data['datos'];
		}
		
		$sum += $times * $data_value;
		$timestamp_begin = $data["utimestamp"];
	}

	/* The last value must be get from tagente_estado, but
	   it will count only if it's not older than date demanded
	*/
	$timestamp_end = get_db_value ('utimestamp', 'tagente_estado', 'id_agente_modulo', $id_agent_module);
	if ($timestamp_end <= $datelimit) {
		$elapsed = $timestamp_end - $timestamp_begin;
		$times = intval ($elapsed / $module_interval);
		if (is_module_inc ($module_name)) {
			$data_value = $data['datos'] * $module_interval;
		} else {
			$data_value = $data['datos'];
		}
		$sum += $times * $data_value;
	}
	
	return (float) $sum;
}
/** 
 * Get a translated string (alias version of lang_string().
 * 
 * @param string String to translate
 * 
 * @return The translated string. If not defined, the same string will be returned
 */
function __ ($string) {
	return lang_string ($string);
}

/** 
 * Get a translated string.
 * 
 * @param string String to translate
 * 
 * @return The translated string. If not defined, the same string will be returned
 */
function lang_string ($string) {
	global $l10n;
	
	if (is_null ($l10n))
		return $string;
	return $l10n->translate ($string);
}

/** 
 * Get the numbers of servers up.
 *
 * This check assumes that server_keepalive should be at least 15 minutes.
 * 
 * @return The number of agents alive.
 */
function check_server_status () {
	$sql = "SELECT COUNT(id_server) FROM tserver WHERE status = 1 AND keepalive > NOW() - INTERVAL 15 MINUTE";
	$status = get_db_sql ($sql);
	// Set servers to down
	if ($status == 0){ 
		process_sql ("UPDATE tserver SET status = 0");
	}
	return $status;
}

/** 
 * 
 * 
 * @param id_combined_alert 
 * 
 * @return 
 */
function show_alert_row_mini ($id_combined_alert) {
	$color=1;
	$sql = sprintf("SELECT talerta_agente_modulo.*, tcompound_alert.operation FROM talerta_agente_modulo, tcompound_alert 
	WHERE tcompound_alert.id_aam = talerta_agente_modulo.id_aam AND tcompound_alert.id = %d",$id_combined_alert);
	$result = get_db_all_rows_sql ($sql);
	
	if (!$result)
		return;

	echo "<table width=400 cellpadding=2 cellspacing=2 class='databox'>";
	echo "<th>".__('Name')."</th>";
	echo "<th>".__('Oper')."</th>";
	echo "<th>".__('Tt')."</th>";
	echo "<th>".__('Firing')."</th>";
	echo "<th>".__('Time')."</th>";
	echo "<th>".__('Desc')."</th>";
	echo "<th>".__('Recovery')."</th>";
	echo "<th>".__('MinMax.Al')."</th>";
	echo "<th>".__('Days')."</th>";
	echo "<th>".__('Fired')."</th>";

	foreach ($result as $row2) {
		if ($color == 1) {
			$tdcolor = "datos";
			$color = 0;
		} else {
			$tdcolor = "datos2";
			$color = 1;
		}
		echo "<tr>";
		if ($row2["disable"] == 1) {
			$tdcolor = "datos3";
		}
		echo "<td class=$tdcolor>".get_db_sql ("SELECT nombre FROM tagente_modulo WHERE id_agente_modulo =".$row2["id_agente_modulo"])."</td>";
		echo "<td class=$tdcolor>".$row2["operation"]."</td>";

		echo "<td class='$tdcolor'>".human_time_description ($row2["time_threshold"])."</td>";

		if ($row2["dis_min"]!=0) {
			$mytempdata = fmod ($row2["dis_min"], 1);
			if ($mytempdata == 0) {
				$mymin = intval ($row2["dis_min"]);
			} else {
				$mymin = format_for_graph ($row2["dis_min"]);
			}
		} else {
			$mymin = 0;
		}

		if ($row2["dis_max"]!=0) {
			$mytempdata = fmod ($row2["dis_max"], 1);
			if ($mytempdata == 0) {
				$mymax = intval ($row2["dis_max"]);
			} else {
				$mymax = format_for_graph ($row2["dis_max"]);
			}
		} else {
			$mymax = 0;
		}

		if (($mymin == 0) && ($mymax == 0)) {
			$mymin = __('N/A');
			$mymax = $mymin;
		}

		// We have alert text ?
		if ($row2["alert_text"]!= "") {
			echo "<td class='$tdcolor'>".__('Text')."</td>";
		} else {
			echo "<td class='$tdcolor'>".$mymin."/".$mymax."</td>";
		}

		// Alert times
		echo "<td class='$tdcolor'>";
		echo get_alert_times ($row2);

		// Description
		echo "</td><td class='$tdcolor'>".substr ($row2["descripcion"],0,20);

		// Has recovery notify activated ?
		if ($row2["recovery_notify"] > 0) {
			$recovery_notify = __('Yes');
		} else {
			$recovery_notify = __('No');
		}
		echo "</td><td class='$tdcolor'>".$recovery_notify;

		// calculare firing conditions
		if ($row2["alert_text"] != ""){
			$firing_cond = __('Text')."(".substr ($row2["alert_text"],0,8).")";
		} else {
			$firing_cond = $row2["min_alerts"]." / ".$row2["max_alerts"];
		}
		echo "</td><td class='$tdcolor'>".$firing_cond;

		// calculate days
		$firing_days = get_alert_days ( $row2 );
		echo "</td><td class='$tdcolor'>".$firing_days;

		// Fired ?
		if ($row2["times_fired"]>0) {
			echo "<td class='".$tdcolor."' align='center'><img width='20' height='9' src='images/pixel_red.png' title='".__('Alert fired')."'></td>";
		} else {
			echo "<td class='".$tdcolor."' align='center'><img width='20' height='9' src='images/pixel_green.png' title='".__('Alert not fired')."'></td>";
		}
	}
	echo "</table>";
}

/** 
 * 
 * 
 * @param filter 
 * @param limit 
 * @param width 
 * 
 * @return 
 */
function smal_event_table ($filter = "", $limit = 10, $width = 440) {
	global $config;

	$sql = sprintf ("SELECT * FROM tevento %s ORDER BY timestamp DESC LIMIT %d",$filter,$limit);
	echo "<table cellpadding='4' cellspacing='4' width='$width' border=0 class='databox'>";
	echo "<tr>";
	echo "<th colspan=6>".__('Latest events')."</th>";
	echo "<tr>";
	echo "<th class='datos3 f9'>".__('St')."</th>";
	echo "<th class='datos3 f9'>".__('Type')."</th>";
	echo "<th class='datos3 f9'>".__('Event name')."</th>";
	echo "<th class='datos3 f9'>".__('Agent name')."</th>";
	echo "<th class='datos3 f9'>".__('User ID')."</th>";
	echo "<th class='datos3 f9'>".__('Timestamp')."</th>";
	$result = get_db_all_rows_sql ($sql);
	if($result === false) 
		$result = array();
	foreach ($result as $event) {
		$id_grupo = $event["id_grupo"];
		if (! give_acl ($config["id_user"], $id_grupo, "AR")) {
			continue;
		}
		
		/* Only incident read access to view data ! */
		switch ($event["criticity"]) {
		case 0: 
			$tdclass = "datos_blue";
			break;
		case 1: 
			$tdclass = "datos_grey";
			break;
		case 2: 
			$tdclass = "datos_green";
			break;
		case 3: 
			$tdclass = "datos_yellow";
			break;
		case 4: 
			$tdclass = "datos_red";
			break;
		default:
			$tdclass = "datos_grey";
		}
		
		$criticity_label = return_priority ($event["criticity"]);
		/* Colored box */
		echo "<tr><td class='$tdclass' title='$criticity_label' align='center'>";
		if ($event["estado"] == 0) {
			echo "<img src='images/pixel_red.png' width=20 height=20>";
		} else {
			echo "<img src='images/pixel_green.png' width=20 height=20>";
		}
		/* Event type */
		echo "<td class='".$tdclass."' title='".$event["event_type"]."'>";
		switch ($event["event_type"]) {
		case "unknown": 
			echo "<img src='images/err.png'>";
			break;
		case "alert_recovered": 
			echo "<img src='images/error.png'>";
			break;
		case "alert_manual_validation": 
			echo "<img src='images/eye.png'>";
			break;
		case "monitor_up":
			echo "<img src='images/lightbulb.png'>";
			break;
		case "monitor_down":
			echo "<img src='images/lightbulb_off.png'>";
			break;
		case "alert_fired":
			echo "<img src='images/bell.png'>";
			break;
		case "system";
			echo "<img src='images/cog.png'>";
			break;
		case "recon_host_detected";
			echo "<img src='images/network.png'>";
			break;
		}
	
		// Event description
		echo "<td class='".$tdclass."f9' title='".$event["evento"]."'>";
		echo substr ($event["evento"],0,45);
		if (strlen ($event["evento"]) > 45) {
			echo "..";
		}
		if ($event["id_agente"] > 0) {
			// Agent name
			$agent_name = dame_nombre_agente ($event["id_agente"]);
			echo "<td class='".$tdclass."f9' title='$agent_name'><a href='index.php?sec=estado&sec2=operation/agentes/ver_agente&id_agente=".$event["id_agente"]."'><b>";
			echo substr ($agent_name, 0, 14);
			if (strlen ($agent_name) > 14)
				echo "..";
			echo "</b></a>";
		
			// for System or SNMP generated alerts
		} else { 
			if ($event["event_type"] == "system") {
				echo "<td class='$tdclass'>".__('System');
			} else {
				echo "<td class='$tdclass'>".__('Alert')."SNMP";
			}
		}
	
		// User who validated event
		echo "<td class='$tdclass'>";
		if ($event["estado"] != 0) {
			echo "<a href='index.php?sec=usuario&sec2=operation/users/user_edit&ver=".$event["id_usuario"]."'>".substr ($event["id_usuario"],0,8)."<a href='#' class='tip'> <span>".dame_nombre_real ($event["id_usuario"])."</span></a></a>";
		}
		// Timestamp
		echo "<td class='".$tdclass."f9' title='".$event["timestamp"]."'>";
		echo human_time_comparation ($event["timestamp"]);
	}
	echo "</table>";
}


/** 
 * Get statistical information for a given server
 * 
 * @param id_server 
 *
 * @return : Serverifo array with following keys:
 	type 		- Type of server (descriptive)
 	modules		- Modules running on this server
	module_lag	- Number of modules of time
	lag		- Lag time in sec
*/
function server_status ($id_server) {
	$server = get_db_row_sql ( "SELECT * FROM tserver WHERE id_server = $id_server" );
	$serverinfo = array();
	
	if ($server["network_server"] == 1)
		$serverinfo["type"] = "network";
	elseif ($server["data_server"] == 1)
		$serverinfo["type"] = "data";
	elseif ($server["plugin_server"] == 1)
		$serverinfo["type"] = "plugin";
	elseif ($server["wmi_server"] == 1)
		$serverinfo["type"] = "wmi";
	elseif ($server["recon_server"] == 1)
		$serverinfo["type"] = "recon";
	elseif ($server["snmp_server"] == 1)
		$serverinfo["type"] = "snmp";
	elseif ($server["prediction_server"] == 1)
		$serverinfo["type"] = "prediction";
	
	// Get type of modules that runs this server
	$sql = sprintf ("SELECT DISTINCT(id_modulo) 
			FROM tagente_estado, tagente_modulo
			WHERE tagente_modulo.id_agente_modulo = tagente_estado.id_agente_modulo
			AND tagente_modulo.disabled = 0
			AND tagente_estado.running_by = %d
			ORDER BY tagente_modulo.id_agente_modulo",
			$id_server);
	$moduletype = get_db_all_rows_sql ($sql);
	if ($moduletype) {
		$serverinfo["modules"] = get_db_sql ("SELECT COUNT(*)
						FROM tagente_estado, tagente_modulo
						WHERE tagente_modulo.id_agente_modulo = tagente_estado.id_agente_modulo
						AND tagente_modulo.disabled = 0
						AND tagente_estado.running_by = $id_server");

		$serverinfo["module_lag"] = get_db_sql ("SELECT COUNT(*)
						FROM tagente_estado, tagente_modulo, tagente
						WHERE tagente_estado.last_execution_try > 0
						AND tagente_estado.running_by = $id_server
						AND tagente_modulo.id_agente = tagente.id_agente
						AND tagente.disabled = 0
						AND tagente_modulo.disabled = 0
						AND tagente_estado.id_agente_modulo = tagente_modulo.id_agente_modulo
						AND (UNIX_TIMESTAMP() - tagente_estado.last_execution_try - tagente_estado.current_interval < 1200)");

		// Lag over 1200 seconds is not lag, is module without contacting data in several time.or with a 
		// 1200 sec is 20 min
		$serverinfo["lag"] = get_db_sql ("SELECT MAX(tagente_estado.last_execution_try - tagente_estado.current_interval)
						FROM tagente_estado, tagente_modulo, tagente
						WHERE tagente_estado.last_execution_try > 0
						AND tagente_estado.running_by = $id_server
						AND tagente_modulo.id_agente = tagente.id_agente
						AND tagente.disabled = 0
						AND tagente_modulo.disabled = 0
						AND tagente_estado.id_agente_modulo = tagente_modulo.id_agente_modulo
						AND (UNIX_TIMESTAMP() - tagente_estado.last_execution_try - tagente_estado.current_interval < 1200)");

		if ($serverinfo["lag"] == "")
			$serverinfo["lag"] = 0;
		else
			$serverinfo["lag"] = $serverinfo["lag"] ;
	} else {
		$serverinfo["modules_total"] = 0;
		$serverinfo["modules"] = 0;
		$serverinfo["module_lag"] = 0;
		$serverinfo["lag"] = 0;
	}

	$nowtime = time();		
	if ($serverinfo["lag"] != 0){
		$serverinfo["lag"] = $nowtime - $serverinfo["lag"];
	}
	
	return $serverinfo;
}
?>