pandorafms/pandora_console/godmode/agentes/manage_config.php

<?php

// Pandora FMS - the Flexible Monitoring System
// ============================================
// Copyright (c) 2008 Artica Soluciones Tecnológicas, 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 General Public License
// as published by the Free Software Foundation; either version 2
// of the License, or (at your option) any later version.
// 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.

// Load global vars
require ("include/config.php");

check_login ();

if (! give_acl ($config['id_user'], 0, "LM")) {
	audit_db ($config['id_user'], $REMOTE_ADDR, "ACL Violation",
		"Trying to access Agent Config Management Admin section");
	require ("general/noaccess.php");
	return;
}


$id_group = get_parameter ("id_group", 0);
$origen = get_parameter ("origen", -1);
$update_agent = get_parameter ("update_agent", -1);
$update_group = get_parameter ("update_group", -1);

// Operations
// ---------------
if ((isset($_GET["operacion"])) && ($update_agent == -1) && ($update_group == -1)) {
	// DATA COPY
	// ---------
	if (isset($_POST["copy"])) {
		echo "<h2>".__('Data Copy')."</h2>";
		// Initial checkings

		// if selected more than 0 agents
		if (isset($_POST["destino"])) 
			$destino = $_POST["destino"];
		if ((!isset($_POST["destino"])) OR (count($destino) <= 0)) {
			echo "<h3 class='error'>ERROR: ".__('No selected agents to copy')."</h3>";
			return;
		}
		if (isset($_POST["origen_modulo"]))
			$origen_modulo = $_POST["origen_modulo"];
		
		if ((!isset($_POST["origen_modulo"])) OR (count($origen_modulo) <= 0)) {
			echo "<h3 class='error'>ERROR: ".__('No modules has been selected')."</h3>";
			return;
		}

		$multiple=1;

		// Source
		$id_origen = $_POST["origen"];
		
		// If selected modules or alerts
		if (isset($_POST["modules"]))
			$modulos = 1;
		else
			$modulos = 0;
		if (isset($_POST["alerts"]))
			$alertas = 1;
		else
			$alertas = 0;
		if (($alertas + $modulos) == 0){
			echo "<h3 class='error'>ERROR: ".__('You must select modules and/or alerts for copy operation')."</h3>";;
			echo "</table>";
			include ("general/footer.php");
			exit;
		}
		
		// Copy
		// ----	
		for ($a=0;$a <count($destino); $a++){ 
			// For every agent in destination

			$id_agente = $destino[$a];
			echo "<br><br>".__('copyage')."<b> [".dame_nombre_agente($id_origen)."] -> [".dame_nombre_agente($id_agente)."]</b>";
			if ($multiple == 0)
				$b = -1;
			else
				$b = 0;

			// Module read
			if ($modulos == 1) {
				for ($b=$b; $b < count($origen_modulo); $b++){
					if ($multiple == 0)	
						$sql1='SELECT * FROM tagente_modulo WHERE id_agente = '.$id_origen;
					else
						$sql1='SELECT * FROM tagente_modulo WHERE id_agente_modulo = '.$origen_modulo[$b];
					$result1=mysql_query($sql1);
					while ($row=mysql_fetch_array($result1)){
						$o_id_agente_modulo = $row["id_agente_modulo"];
						$o_id_tipo_modulo = $row["id_tipo_modulo"];
						$o_nombre = $row["nombre"];
						$d_id_agente = $id_agente; // Rapelace with destination agent id
						// Read every module in source agent				
						$o_descripcion = $row["descripcion"];
						$o_max = $row["max"];
						$o_min = $row["min"];
						$o_module_interval = $row["module_interval"];
						$o_tcp_port = $row["tcp_port"];
						$o_tcp_send = $row["tcp_send"];
						$o_tcp_rcv = $row["tcp_rcv"];
						$o_snmp_community = $row["snmp_community"];
						$o_snmp_oid = $row["snmp_oid"];
						// Replace IP Address for main ip address of destination module
						$real_ip_address = give_agent_address ($id_agente);
						$o_ip_target = $real_ip_address;
						$o_id_module_group = $row["id_module_group"];
						// 2.0 new modules
						$o_max_timeout = $row["max_timeout"];
						$o_prediction_module = $row["prediction_module"];
						$o_post_process = $row["post_process"];
						$o_id_plugin = $row["id_plugin"];
						$o_plugin_parameter = $row["plugin_parameter"];
						$o_plugin_user = $row["plugin_user"];
						$o_plugin_pass = $row["plugin_pass"];
						$o_id_modulo = $row["id_modulo"];

						
						// Write every module in destination agent
						$sql = "INSERT INTO tagente_modulo (
								id_agente,id_tipo_modulo,descripcion, nombre, max, min, 
								module_interval, tcp_port, tcp_send, tcp_rcv, snmp_community, 
								snmp_oid, ip_target, id_module_group, flag, 
								max_timeout, prediction_module, post_process, id_plugin, 
								plugin_parameter, plugin_user, plugin_pass, id_modulo
							) VALUES (
							$d_id_agente, '$o_id_tipo_modulo', '$o_descripcion',
							'$o_nombre', '$o_max', '$o_min', '$o_module_interval',
							'$o_tcp_port', '$o_tcp_send', '$o_tcp_rcv', '$o_snmp_community',
							'$o_snmp_oid', '$o_ip_target', $o_id_module_group, 1,
							$o_max_timeout, $o_prediction_module, '$o_post_process',
							$o_id_plugin, '$o_plugin_parameter', '$o_plugin_user',
							'$o_plugin_pass', $o_id_modulo
							)";
						$result2=mysql_query($sql);
						if (! $result2)
							echo "<h3 class=error>".__('Problem updating database')."</h3>";
						$o_id_agente_modulo = mysql_insert_id();
						
						// Create with different estado if proc type or data type
						if (
						($o_id_agente_modulo != "") AND (
						($o_id_tipo_modulo == 2) ||
						($o_id_tipo_modulo == 6) || 
						($o_id_tipo_modulo == 9) ||
						($o_id_tipo_modulo == 100) || 
						($o_id_tipo_modulo == 21) || 
						($o_id_tipo_modulo == 18))){
							$sql_status_insert = "INSERT INTO tagente_estado 
							(id_agente_modulo,datos,timestamp,cambio,estado,id_agente, utimestamp) 
							VALUES (
							$o_id_agente_modulo, 0,'0000-00-00 00:00:00',0,0,'".$d_id_agente."',0
							)";
						} else { 
							$sql_status_insert = "INSERT INTO tagente_estado
							(id_agente_modulo,datos,timestamp,cambio,estado,id_agente, utimestamp) 
							VALUES (
							$o_id_agente_modulo, 0,'0000-00-00 00:00:00',0,100,'".$d_id_agente."',0
							)";
						}
						$result_status=mysql_query($sql_status_insert);
						echo "<br>&nbsp;&nbsp;".__('Copying module')." ->".$o_nombre;
					}
				}
			}
			if ($multiple == 0)
					$b=-1;
			else
					$b=0;

			// Alerts
			// ------
			if ($alertas == 1){
				for ($b=$b; $b < count($origen_modulo); $b++){
					if ($multiple == 0)
						$sql1='SELECT * FROM tagente_modulo WHERE id_agente = '.$id_origen;
					else
						$sql1='SELECT * FROM tagente_modulo WHERE id_agente_modulo = '.$origen_modulo[$b];
					$result1=mysql_query($sql1);
					while ($row=mysql_fetch_array($result1)){
						$o_id_agente_modulo = $row["id_agente_modulo"];
						$o_id_tipo_modulo = $row["id_tipo_modulo"];
						$o_nombre = $row["nombre"];
						$d_id_agente = $id_agente; // destination agent id
						// For each agent module, given as $o_id_agente_modulo:
						// Searching if destination agent has a agente_modulo with same type and name that source
						$sqlp="SELECT * FROM tagente_modulo WHERE id_agente = ".$d_id_agente." AND nombre = '".$o_nombre."' AND id_tipo_modulo = ".$o_id_tipo_modulo;
						$resultp=mysql_query($sqlp);
						if ( $rowp=mysql_fetch_array($resultp)){
							// If rowp success get  ID
							$d_id_agente_modulo = $rowp["id_agente_modulo"];
							// Read every alert from source agent
							$sql2='SELECT * FROM talerta_agente_modulo WHERE id_agente_modulo = '.$o_id_agente_modulo;
							$result3=mysql_query($sql2);
							while ($row3=mysql_fetch_array($result3)){
								$o_id_alerta = $row3["id_alerta"];
								$o_al_campo1 = $row3["al_campo1"];
								$o_al_campo2 = $row3["al_campo2"];
								$o_al_campo3 = $row3["al_campo3"];
								$o_descripcion = $row3["descripcion"];
								$o_dis_max = $row3["dis_max"];
								$o_dis_min = $row3["dis_min"];
								$o_time_threshold = $row3["time_threshold"];
								$o_last_fired = "2001-01-01 00:00:00";
								$o_max_alerts = $row3["max_alerts"];
								$o_min_alerts = $row3["min_alerts"];
								$o_times_fired = 0;

								$o_alert_text = $row3["alert_text"];
								$o_time_from = $row3["time_from"];
								$o_time_to = $row3["time_to"];
								$o_monday = $row3["monday"];
								$o_tuesday = $row3["tuesday"];
								$o_wednesday = $row3["wednesday"];
								$o_thursday = $row3["thursday"];
								$o_friday = $row3["friday"];
								$o_saturday = $row3["saturday"];
								$o_sunday = $row3["sunday"];
								$o_recovery_notify = $row3["recovery_notify"];
								$o_priority = $row3["priority"];
								$o_al_f2_recovery= $row3["al_f2_recovery"];
								$o_al_f3_recovery= $row3["al_f3_recovery"];	

								// Insert
								$sql_al="INSERT INTO talerta_agente_modulo (id_agente_modulo, id_alerta, al_campo1, al_campo2, al_campo3, descripcion, dis_max, dis_min, time_threshold, last_fired, max_alerts, times_fired, min_alerts,
								alert_text, time_from, time_to, monday, tuesday, wednesday, 
								thursday, friday, saturday, sunday, recovery_notify, priority,
								al_f2_recovery, al_f3_recovery ) 
								VALUES ( $d_id_agente_modulo , $o_id_alerta, '$o_al_campo1',
								'$o_al_campo2', '$o_al_campo3', '$o_descripcion', $o_dis_max,
								$o_dis_min, $o_time_threshold, '$o_last_fired', $o_max_alerts,
								$o_times_fired, $o_min_alerts, '$o_alert_text', '$o_time_from',
								'$o_time_to', '$o_monday', '$o_tuesday', '$o_wednesday', 
								'$o_thursday', '$o_friday', '$o_saturday', '$o_sunday', 
								$o_recovery_notify, $o_priority, '$o_al_f2_recovery', 
								'$o_al_f3_recovery' )";
								$result_al=mysql_query($sql_al);
								echo "<br>&nbsp;&nbsp;".__('Copying alert')." ->".$o_descripcion;
							}
						} else 
							echo "<br><h3 class='error'>ERROR: ".__('Not found').$o_nombre.__(' in agent ').dame_nombre_agente($d_id_agente)."</h3>";
					} //while
				} // for
			} // Alerts
		} // for each destination agent
	} //end if copy modules or alerts


	// -----------
	// DELETE DATA
	// -----------

	elseif (isset($_POST["delete"])) {
		echo "<h2>".__('Delete Data')."</h2>";
		// Initial checkings
		
		//  if selected more than 0 agents
		$destino = $_POST["destino"];
		if (count($destino) <= 0) {
			break;
		}
		
		// If selected modules or alerts
		if (isset($_POST["modules"]))
			$modulos = 1;
		else
			$modulos = 0;
		if (isset($_POST["alerts"]))
			$alertas = 1;
		else
			$alertas = 0;			
		if (($alertas + $modulos) >= 0)
		// Delete
		for ($a=0;$a <count($destino); $a++){ // for each agent
			$id_agente = $destino[$a];
			if ($modulos == 1){
				echo "<br>".__('Deleting data')." -> ".dame_nombre_agente($id_agente);
			
				// Deleting data
				$sql1='SELECT * FROM tagente_modulo WHERE id_agente = '.$id_agente;
				$result1=mysql_query($sql1);
				while ($row=mysql_fetch_array($result1)){
					$sql_delete1="DELETE FROM tagente_datos WHERE id_agente_modulo=".$row["id_agente_modulo"];
					$sql_delete2="DELETE FROM tagente_datos_inc WHERE id_agente_modulo=".$row["id_agente_modulo"];
					$sql_delete3="DELETE FROM tagente_datos_string WHERE id_agente_modulo=".$row["id_agente_modulo"];
					$result=mysql_query($sql_delete1);
					$result=mysql_query($sql_delete2);
					$result=mysql_query($sql_delete3);
				}
			
			// Delete conf
			$sql_delete5 ="DELETE FROM tagente_modulo WHERE id_agente = ".$id_agente; // delete from table tagente_modulo
			$sql_delete6 ="DELETE FROM tagente_estado WHERE id_agente = ".$id_agente; // detele from table tagente_estado
			$result=mysql_query($sql_delete5);
			$result=mysql_query($sql_delete6);		
			}
			// delete alerts definitions
			if ($alertas == 1){ 
				// delete data
				$sql1='SELECT * FROM tagente_modulo WHERE id_agente = '.$id_agente;
				$result1=mysql_query($sql1);
				while ($row=mysql_fetch_array($result1)){
					$sql_delete1="DELETE FROM talerta_agente_modulo WHERE id_agente_modulo=".$row["id_agente_modulo"];
					$result = mysql_query($sql_delete1);
				} // while			
			}//if 
		}// for
	}//delete
	elseif (isset($_POST["delete_agent"])) {
		echo "<h2>".__('Delete agents')."</h2>";
		// Initial checkings
		
		//  if selected more than 0 agents
		$destino = $_POST["destino"];
		if (count($destino) <= 0) {
			break;
		}
		
		// Delete
		for ($a=0;$a <count($destino); $a++){ // for each agent
			$id_agente = $destino[$a];
			
			echo "<br>".__('Deleting data')." -> ".dame_nombre_agente($id_agente);
		
			// Deleting data
			$sql1='SELECT * FROM tagente_modulo WHERE id_agente = '.$id_agente;
			$result1=mysql_query($sql1);
			while ($row=mysql_fetch_array($result1)){
				$sql_delete1="DELETE FROM tagente_datos WHERE id_agente_modulo=".$row["id_agente_modulo"];
				$sql_delete2="DELETE FROM tagente_datos_inc WHERE id_agente_modulo=".$row["id_agente_modulo"];
				$sql_delete3="DELETE FROM tagente_datos_string WHERE id_agente_modulo=".$row["id_agente_modulo"];
				$result=mysql_query($sql_delete1);
				$result=mysql_query($sql_delete2);
				$result=mysql_query($sql_delete3);
			}
			
			// Delete conf
			$sql_delete5 ="DELETE FROM tagente_modulo WHERE id_agente = ".$id_agente; // delete from table tagente_modulo
			$sql_delete6 ="DELETE FROM tagente_estado WHERE id_agente = ".$id_agente; // detele from table tagente_estado
			$result=mysql_query($sql_delete5);
			$result=mysql_query($sql_delete6);		
			
			// delete alerts definitions
			
			// delete data
			$sql1='SELECT * FROM tagente_modulo WHERE id_agente = '.$id_agente;
			$result1=mysql_query($sql1);
			while ($row=mysql_fetch_array($result1)){
				$sql_delete1="DELETE FROM talerta_agente_modulo WHERE id_agente_modulo=".$row["id_agente_modulo"];
				$result = mysql_query($sql_delete1);
			} // while			
			
			// delete agent
			$sql1='DELETE FROM tagente WHERE id_agente = '.$id_agente;
			$result1=mysql_query($sql1);
		}// for
	}//delete

	// ============	
	// Form view
	// ============
	} else { 
		
		// title
		echo '<h2>'.__('Agent configuration'). '&gt;'. __('Configuration Management').'</h2>';
		echo '<form method="post" action="index.php?sec=gagente&sec2=godmode/agentes/manage_config&operacion=1">';
		echo "<table width='650' border='0' cellspacing='4' cellpadding='4' class='databox'>";
		
		// Source group
		echo '<tr><td class="datost"><b>'. __('Source group'). '</b><br><br>';
		echo '<select name="id_group" style="width:200px">';
		if ($id_group != 0)
			echo "<option value=$id_group>".dame_nombre_grupo ($id_group);
		echo "<option value=0>".__('All');
		list_group ($config["id_user"]);
		echo '</select>';
		echo '&nbsp;&nbsp;';
		echo '<input type=submit name="update_group" class="sub upd"  value="'.__('Filter').'">';
		echo '<br><br>';

		// Source agent
		echo '<b>'. __('Source agent').'</b><br><br>';

		// Show combo with SOURCE agents
		if ($id_group != 0)
			$sql1 = "SELECT * FROM tagente WHERE id_grupo = $id_group ORDER BY nombre ";
		else
			$sql1 = 'SELECT * FROM tagente ORDER BY nombre';
		echo '<select name="origen" style="width:200px">';			
		if (($update_agent != 1) AND ($origen != -1))
			echo "<option value=".$_POST["origen"].">".dame_nombre_agente($origen)."</option>";
		$result=mysql_query($sql1);
		while ($row=mysql_fetch_array($result)){
			if (give_acl ($config["id_user"], $row["id_grupo"], "AR")){
				if ( $origen != $row["id_agente"])
					echo "<option value=".$row["id_agente"].">".$row["nombre"]."</option>";
			}
		}
		echo '</select>';

		echo '&nbsp;&nbsp;';
		echo '<input type=submit name="update_agent" class="sub upd" value="'.__('Get Info').'">';
		echo '<br><br>';

		// Source Module(s)
		echo "<b>".__('Modules')."</b><br><br>";
		echo "<select name='origen_modulo[]' size=10 multiple=yes style='width: 250px;'>";
		if ( (isset($_POST["update_agent"])) AND (isset($_POST["origen"])) ) {
				// Populate Module/Agent combo
			$agente = $_POST["origen"];
			$sql1="SELECT * FROM tagente_modulo WHERE id_agente = ".$agente. " ORDER BY nombre";	
			$result = mysql_query($sql1);
			while ($row=mysql_fetch_array($result)){
				echo "<option value=".$row["id_agente_modulo"].">".$row["nombre"]."</option>";	
			}
		}
		echo "</select>";
		
		echo '<td class="datost">';
		echo '<b>'.__('Copy Configuration'). '</b><br><br>';
		echo '<table>';
		echo '<tr class=datos><td>'.__('Modules');
		echo '<td><input type="checkbox" name="modules" value="1" class="chk">';
		echo '<tr class=datos><td>'.__('Alerts');
		echo '<td><input type="checkbox" name="alerts" value="1" class="chk">';
		echo '</table>';
		

		// Destination agent
		echo '<tr><td class="datost">';
		echo '<b>'.__('To Agent(s):').'</b><br><br>';
		echo "<select name=destino[] size=10 multiple=yes style='width: 250px;'>";
		$sql1='SELECT * FROM tagente ORDER BY nombre';
		$result=mysql_query($sql1);
		while ($row=mysql_fetch_array($result)){
			if (give_acl ($config["id_user"], $row["id_grupo"], "AW"))
				echo "<option value=".$row["id_agente"].">".$row["nombre"]."</option>";
		}
		echo '</select>';
		
		// Form buttons
		echo '<td align="left" class="datosb">';
		echo "<br><br>";
		echo '<input type="submit" name="copy" class="sub copy" value="'.__('Copy').'" onClick="if (!confirm("'.__('Are you sure?').'")) return false;>';
		echo "<br><br>";
		echo '<input type="submit" name="delete" class="sub delete" value="'. __('Delete').'" onClick="if (!confirm("'.__('Are you sure?').'")) return false;>';
		echo "<br><br>";
		echo '<input type="submit" name="delete_agent" class="sub delete" value="'. __('Delete Agents').'" onClick="if (!confirm("'.__('Are you sure?').'")) return false;>';

		echo '<tr><td colspan=2>';
		echo '</div></td></tr>';
		echo '</table>';

	}

?>