tyler.durden
/
pandorafms
mirror of https://github.com/pandorafms/pandorafms.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

2012-01-19 Juan Manuel Ramon <juanmanuel.ramon@artica.es> 

* include/functions_api.php
	 include/functions_agents.php
	 include/functions_alerts.php: New functionality for the Api.



git-svn-id: https://svn.code.sf.net/p/pandora/code/trunk@5393 c3f86ba8-e40f-0410-aaad-9ba5e7f4b01f
This commit is contained in:
juanmanuelr 2012-01-19 17:45:59 +00:00
parent 4f9aacb7f0
commit 7b7c651fe6
4 changed files with 768 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pandora_console/ChangeLog
View File

@ -1,3 +1,9 @@
2012-01-19 Juan Manuel Ramon <juanmanuel.ramon@artica.es>
* include/functions_api.php
include/functions_agents.php
include/functions_alerts.php: New functionality for the Api.
2012-01-18 Vanessa Gil <vanessa.gil@artica.es> 2012-01-18 Vanessa Gil <vanessa.gil@artica.es>
* operation/reporting/reporting_viewer.php: Check that the date range * operation/reporting/reporting_viewer.php: Check that the date range

34
pandora_console/include/functions_agents.php
View File

@ -170,10 +170,10 @@ function agents_get_alerts_simple ($id_agent = false, $filter = '', $options = f
else { else {
$id_agent = (array) $id_agent; $id_agent = (array) $id_agent;
$id_modules = array_keys (agents_get_modules ($id_agent, false, array('delete_pending' => 0))); $id_modules = array_keys (agents_get_modules ($id_agent, false, array('delete_pending' => 0)));
if (empty ($id_modules)) if (empty ($id_modules))
return array (); return array ();
$subQuery = implode (",", $id_modules); $subQuery = implode (",", $id_modules);
} }
@ -422,7 +422,7 @@ function agents_get_agents ($filter = false, $fields = false, $access = 'AR', $o
$agents = oracle_recode_query ($sql, $set, 'AND', false); $agents = oracle_recode_query ($sql, $set, 'AND', false);
break; break;
} }
return $agents; return $agents;
return db_get_all_rows_sql($sql); return db_get_all_rows_sql($sql);
} }
@ -799,7 +799,7 @@ function agents_get_group_agents ($id_group = 0, $search = false, $case = "lower
return array (); return array ();
} }
} }
if ($childGroups) { if ($childGroups) {
if (is_array($id_group)) { if (is_array($id_group)) {
foreach ($id_group as $parent) { foreach ($id_group as $parent) {
@ -949,7 +949,7 @@ function agents_get_group_agents ($id_group = 0, $search = false, $case = "lower
* @return array An array with all modules in the agent. * @return array An array with all modules in the agent.
* If multiple rows are selected, they will be in an array * If multiple rows are selected, they will be in an array
*/ */
function agents_get_modules ($id_agent = null, $details = false, $filter = false, $indexed = true, $get_not_init_modules = true) { function agents_get_modules ($id_agent = null, $details = false, $filter = false, $indexed = true, $get_not_init_modules = true, $noACLs = false) {
global $config; global $config;
if ($id_agent === null) { if ($id_agent === null) {
@ -990,7 +990,7 @@ function agents_get_modules ($id_agent = null, $details = false, $filter = false
} }
$userGroups = users_get_groups($config['id_user'], 'AR', false); $userGroups = users_get_groups($config['id_user'], 'AR', false);
if(empty($userGroups)) { if(empty($userGroups)) {
return array(); return array();
} }
@ -1470,14 +1470,32 @@ function agents_get_addresses ($id_agent) {
* Get the worst status of all modules of a given agent. * Get the worst status of all modules of a given agent.
* *
* @param int Id agent to check. * @param int Id agent to check.
* @param bool Whether the call check ACLs or not
* *
* @return int Worst status of an agent for all of its modules. * @return int Worst status of an agent for all of its modules.
* The value -1 is returned in case the agent has exceed its interval. * The value -1 is returned in case the agent has exceed its interval.
*/ */
function agents_get_status($id_agent = 0) { function agents_get_status($id_agent = 0, $noACLs = false) {
global $config; global $config;
$modules = agents_get_modules ($id_agent, 'id_agente_modulo', array('disabled' => 0), true, false); if (!$noACLs){
$modules = agents_get_modules ($id_agent, 'id_agente_modulo', array('disabled' => 0), true, false);
}
else{
$filter_modules['id_agente'] = $id_agent;
$filter_modules['disabled'] = 0;
$filter_modules['delete_pending'] = 0;
// Get all non disabled modules of the agent
$all_modules = db_get_all_rows_filter('tagente_modulo', $filter_modules, 'id_agente_modulo');
$result_modules = array();
// Skip non init modules
foreach ($all_modules as $module){
if (modules_get_agentmodule_is_init($module['id_agente_modulo'])){
$modules[] = $module['id_agente_modulo'];
}
}
}
$modules_status = array(); $modules_status = array();
$modules_async = 0; $modules_async = 0;

13
pandora_console/include/functions_alerts.php
View File

@ -1133,13 +1133,14 @@ function alerts_get_alert_agent_module_actions ($id_alert_agent_module, $fields
* Validates an alert id or an array of alert id's. * Validates an alert id or an array of alert id's.
* *
* @param mixed Array of alerts ids or single id. * @param mixed Array of alerts ids or single id.
* @param bool Whether to check ACLs
* *
* @return bool True if it was successful, false otherwise. * @return bool True if it was successful, false otherwise.
*/ */
function alerts_validate_alert_agent_module ($id_alert_agent_module) { function alerts_validate_alert_agent_module ($id_alert_agent_module, $noACLs = false) {
global $config; global $config;
require_once ("include/functions_events.php"); include_once ("include/functions_events.php");
$alerts = safe_int ($id_alert_agent_module, 1); $alerts = safe_int ($id_alert_agent_module, 1);
if (empty ($alerts)) { if (empty ($alerts)) {
@ -1153,8 +1154,10 @@ function alerts_validate_alert_agent_module ($id_alert_agent_module) {
$agent_id = modules_get_agentmodule_agent ($alert["id_agent_module"]); $agent_id = modules_get_agentmodule_agent ($alert["id_agent_module"]);
$group_id = agents_get_agentmodule_group ($agent_id); $group_id = agents_get_agentmodule_group ($agent_id);
if (! check_acl ($config['id_user'], $group_id, "AW")) { if (!$noACLs){
continue; if (! check_acl ($config['id_user'], $group_id, "AW")) {
continue;
}
} }
$result = db_process_sql_update ('talert_template_modules', $result = db_process_sql_update ('talert_template_modules',
array ('times_fired' => 0, array ('times_fired' => 0,

734
pandora_console/include/functions_api.php
View File

@ -659,7 +659,7 @@ function get_tree_agents($trash1, $trahs2, $other, $returnType)
'alert_templates_id_group', 'alert_templates_id_group',
'alert_actions_id_group' 'alert_actions_id_group'
); );
returnData($returnType, $data, $separator); returnData($returnType, $data, $separator);
} }
@ -754,6 +754,245 @@ function set_delete_agent($id, $thrash1, $thrast2, $thrash3) {
returnData('string', array('type' => 'string', 'data' => __('Correct Delete'))); returnData('string', array('type' => 'string', 'data' => __('Correct Delete')));
} }
/**
* Get all agents, and print all the result like a csv.
*
* @param $thrash1 Don't use.
* @param $thrash2 Don't use.
* @param array $other it's array, $other as param are the filters available <filter_so>;<filter_group>;<filter_modules_states>;<filter_name>;<filter_policy> in this order
* and separator char (after text ; ) and separator (pass in param othermode as othermode=url_encode_separator_<separator>)
* example:
*
* api.php?op=get&op2=all_agents&return_type=csv&other=1|2|warning|j|2&other_mode=url_encode_separator_|
*
* @param $thrash3 Don't use.
*/
function get_all_agents($thrash1, $thrash2, $other, $thrash3) {
$where = '';
// Filter by SO
if ($other['data'][0] != ""){
$where .= " AND id_os = " . $other['data'][0];
}
// Filter by group
if ($other['data'][1] != ""){
$where .= " AND id_grupo = " . $other['data'][1];
}
// Filter by name
if ($other['data'][3] != ""){
$where .= " AND nombre LIKE ('%" . $other['data'][3] . "%')";
}
// Filter by policy
if ($other['data'][4] != ""){
$where .= sprintf(" AND id_agente IN (select id_agent from tpolicy_agents where id_policy = %d)", $other['data'][4]);
}
// Filter by state
$sql = "SELECT id_agente, nombre FROM tagente WHERE disabled = 0 " . $where;
$all_agents = db_get_all_rows_sql($sql);
// Filter by status: unknown, warning, critical, without modules
if ($other['data'][2] != "") {
foreach($all_agents as $agent){
$filter_modules['id_agente'] = $agent['id_agente'];
$filter_modules['disabled'] = 0;
$filter_modules['delete_pending'] = 0;
$modules = db_get_all_rows_filter('tagente_modulo', $filter_modules, 'id_agente_modulo');
$result_modules = array();
// Skip non init modules
foreach ($modules as $module){
if (modules_get_agentmodule_is_init($module['id_agente_modulo'])){
$result_modules[] = $module;
}
}
// Without modules NO_MODULES
if ($other['data'][2] == 'no_modules'){
if (empty($result_modules) and $other['data'][2] == 'no_modules'){
$result_agents[] = $agent;
}
}
// filter by NORMAL, WARNING, CRITICAL, UNKNOWN
else {
$status = agents_get_status($agent['id_agente'], true);
// Filter by status
switch ($other['data'][2]){
case 'warning':
if ($status == 2){
$result_agents[] = $agent;
}
break;
case 'critical':
if ($status == 1){
$result_agents[] = $agent;
}
break;
case 'unknown':
if ($status == 3){
$result_agents[] = $agent;
}
break;
case 'normal':
if ($status == 0){
$result_agents[] = $agent;
}
break;
}
}
}
}
else {
$result_agents = $all_agents;
}
if (count($result_agents) > 0 and $result_agents !== false){
$data = array('type' => 'array', 'data' => $result_agents);
returnData('csv', $data, ';');
}
else {
returnError('error_all_agents', 'No agents retrieved.');
}
}
/**
* Get modules for an agent, and print all the result like a csv.
*
* @param $thrash1 Don't use.
* @param $thrash2 Don't use.
* @param array $other it's array, $other as param are the filters available <id_agent> in this order
* and separator char (after text ; ) and separator (pass in param othermode as othermode=url_encode_separator_<separator>)
* example:
*
* api.php?op=get&op2=agents_modules&return_type=csv&other=14&other_mode=url_encode_separator_|
*
* @param $thrash3 Don't use.
*/
function get_agent_modules($thrash1, $thrash2, $other, $thrash3) {
$sql = sprintf("SELECT id_agente, id_agente_modulo, nombre
FROM tagente_modulo WHERE id_agente = %d AND disabled = 0 AND delete_pending = 0", $other['data'][0]);
$all_modules = db_get_all_rows_sql($sql);
if (count($all_modules) > 0 and $all_modules !== false){
$data = array('type' => 'array', 'data' => $all_modules);
returnData('csv', $data, ';');
}
else {
returnError('error_agent_modules', 'No modules retrieved.');
}
}
/**
* Get modules for an agent, and print all the result like a csv.
*
* @param $thrash1 Don't use.
* @param $thrash2 Don't use.
* @param array $other it's array, $other as param are the filters available <id_agent> in this order
* and separator char (after text ; ) and separator (pass in param othermode as othermode=url_encode_separator_<separator>)
* example:
*
* api.php?op=get&op2=group_agent&return_type=csv&other=14&other_mode=url_encode_separator_|
*
* @param $thrash3 Don't use.
*/
function get_group_agent($thrash1, $thrash2, $other, $thrash3) {
$sql = sprintf("SELECT groups.nombre nombre
FROM tagente agents, tgrupo groups WHERE id_agente = %d AND agents.disabled = 0 AND groups.disabled = 0
AND agents.id_grupo = groups.id_grupo", $other['data'][0]);
$group_names = db_get_all_rows_sql($sql);
if (count($group_names) > 0 and $group_names !== false){
$data = array('type' => 'array', 'data' => $group_names);
returnData('csv', $data, ';');
}
else {
returnError('error_group_agent', 'No groups retrieved.');
}
}
/**
* Get all policies, possible filtered by agent, and print all the result like a csv.
*
* @param $thrash1 Don't use.
* @param $thrash2 Don't use.
* @param array $other it's array, $other as param are the filters available <id_agent> in this order
* and separator char (after text ; ) and separator (pass in param othermode as othermode=url_encode_separator_<separator>)
* example:
*
* api.php?op=get&op2=policies&return_type=csv&other=&other_mode=url_encode_separator_|
*
* @param $thrash3 Don't use.
*/
function get_policies($thrash1, $thrash2, $other, $thrash3) {
$where = '';
if ($other['data'][0] != ""){
$where .= ' AND id_agent = ' . $other['data'][0];
$sql = sprintf("SELECT policy.id, name, id_agent FROM tpolicies policy, tpolicy_agents pol_agents
WHERE policy.id = pol_agents.id %s", $where);
} else {
$sql = "SELECT id, name FROM tpolicies policy";
}
$policies = db_get_all_rows_sql($sql);
if (count($policies) > 0 and $policies !== false){
$data = array('type' => 'array', 'data' => $policies);
returnData('csv', $data, ';');
}
else {
returnError('error_get_policies', 'No policies retrieved.');
}
}
/**
* Get policy modules, possible filtered by agent, and print all the result like a csv.
*
* @param $thrash1 Don't use.
* @param $thrash2 Don't use.
* @param array $other it's array, $other as param are the filters available <id_agent> in this order
* and separator char (after text ; ) and separator (pass in param othermode as othermode=url_encode_separator_<separator>)
* example:
*
* api.php?op=get&op2=policy_modules&return_type=csv&other=2&other_mode=url_encode_separator_|
*
* @param $thrash3 Don't use.
*/
function get_policy_modules($thrash1, $thrash2, $other, $thrash3) {
$where = '';
if ($other['data'][0] == ""){
returnError('error_policy_modules', 'Error retrieving policy modules. Id_policy cannot be left blank.');
return;
}
$sql = sprintf("select policy.id, policy.name, pol_modules.id id_module FROM tpolicies policy, tpolicy_modules pol_modules where policy.id = pol_modules.id_policy AND policy.id = %d", $other['data'][0]);
$policies = db_get_all_rows_sql($sql);
if (count($policies) > 0 and $policies !== false){
$data = array('type' => 'array', 'data' => $policies);
returnData('csv', $data, ';');
}
else {
returnError('error_policy_modules', 'No policy modules retrieved.');
}
}
/** /**
* Create a network module in agent. And return the id_agent_module of new module. * Create a network module in agent. And return the id_agent_module of new module.
* *
@ -1722,6 +1961,47 @@ function set_new_local_component($id, $thrash1, $other, $thrash2) {
returnData('string', array('type' => 'string', 'data' => $id)); returnData('string', array('type' => 'string', 'data' => $id));
} }
/**
* Get module data value from all agents filter by module name. And return id_agents, agent_name and module value.
*
* @param $id string Name of the module.
* @param $thrash1 Don't use.
* @param array $other Don't use.
* example:
*
* api.php?op=get&op2=module_value_all_agents&id=example_module_name
*
* @param $thrash2 Don't use.
*/
function get_module_value_all_agents($id, $thrash1, $other, $thrash2) {
if ($id == ""){
returnError('error_get_module_value_all_agents', __('Error getting module value from all agents. Module name cannot be left blank.'));
return;
}
$id_module = db_get_value ('id_agente_modulo', 'tagente_modulo', 'nombre', $id);
if ($id_module === false){
returnError('error_get_module_value_all_agents', __('Error getting module value from all agents. Module name doesn\'t exists.'));
return;
}
$sql = sprintf("SELECT agent.id_agente, agent.nombre, module_state.datos FROM tagente agent, tagente_modulo module, tagente_estado module_state WHERE agent.id_agente = module.id_agente AND module.id_agente_modulo=module_state.id_agente_modulo AND module.nombre = '%s'", $id);
$module_values = db_get_all_rows_sql($sql);
if (!$module_values){
returnError('error_get_module_value_all_agents', 'Error getting module values from all agents.');
}
else{
$data = array('type' => 'array', 'data' => $module_values);
returnData('csv', $data, ';');
}
}
/** /**
* Create an alert template. And return the id of new template. * Create an alert template. And return the id of new template.
* *
@ -1923,7 +2203,7 @@ function set_delete_alert_template($id_template, $thrash1, $other, $thrash3) {
* @param $thrash3 Don't use * @param $thrash3 Don't use
*/ */
function set_create_module_template($id, $thrash1, $other, $thrash3) { function set_create_module_template($id, $thrash1, $other, $thrash3) {
if ($id_template == "") { if ($id == "") {
returnError('error_module_to_template', __('Error assigning module to template. Id_template cannot be left blank.')); returnError('error_module_to_template', __('Error assigning module to template. Id_template cannot be left blank.'));
return; return;
} }
@ -1938,7 +2218,7 @@ function set_create_module_template($id, $thrash1, $other, $thrash3) {
return; return;
} }
$result_template = alerts_get_alert_template($id_template); $result_template = alerts_get_alert_template($id);
if (!$result_template){ if (!$result_template){
returnError('error_module_to_template', __('Error assigning module to template. Id_template doensn\'t exists.')); returnError('error_module_to_template', __('Error assigning module to template. Id_template doensn\'t exists.'));
@ -1962,8 +2242,8 @@ function set_create_module_template($id, $thrash1, $other, $thrash3) {
return; return;
} }
$id_template_module = alerts_create_alert_agent_module($id_module, $id_template); $id_template_module = alerts_create_alert_agent_module($id_module, $id);
if (is_error($id_template_module)) { if (is_error($id_template_module)) {
// TODO: Improve the error returning more info // TODO: Improve the error returning more info
returnError('error_module_to_template', __('Error assigning module to template.')); returnError('error_module_to_template', __('Error assigning module to template.'));
@ -2011,6 +2291,164 @@ function set_delete_module_template($id, $thrash1, $other, $thrash3) {
} }
} }
/**
* Validate all alerts. And return a message with the result of the operation.
*
* @param string Don't use.
* @param $thrash1 Don't use.
* @param array $other Don't use
*
* example:
*
* api.php?op=set&op2=validate_all_alerts
*
* @param $thrash3 Don't use
*/
function set_validate_all_alerts($id, $thrash1, $other, $thrash3) {
// Return all groups
$allGroups = db_get_all_rows_filter('tgrupo', array(), 'id_grupo');
$groups = array();
foreach ($allGroups as $row) {
$groups[] = $row['id_grupo'];
}
// Added group All
$groups[] = 0;
$id_groups = implode(',', $groups);
$sql = sprintf ("SELECT id_agente
FROM tagente
WHERE id_grupo IN (%s) AND disabled = 0",
$id_groups);
$id_agents = array();
$result_agents = array();
$id_agents = db_get_all_rows_sql($sql);
foreach ($id_agents as $id_agent){
$result_agents[] = $id_agent['id_agente'];
}
$agents_string = implode(',', $result_agents);
$sql = sprintf ("SELECT talert_template_modules.id
FROM talert_template_modules
INNER JOIN tagente_modulo t2
ON talert_template_modules.id_agent_module = t2.id_agente_modulo
INNER JOIN tagente t3
ON t2.id_agente = t3.id_agente
INNER JOIN talert_templates t4
ON talert_template_modules.id_alert_template = t4.id
WHERE id_agent_module in (%s)", $agents_string);
$alerts = db_get_all_rows_sql($sql);
$total_alerts = count($alerts);
$count_results = 0;
foreach ($alerts as $alert) {
$result = alerts_validate_alert_agent_module($alert['id'], true);
if ($result){
$count_results++;
}
}
if ($total_alerts > $count_results){
$errors = $total_alerts - $count_results;
returnError('error_validate_all_alerts', __('Error validate all alerts. Failed ' . $errors . '.'));
}
else{
returnData('string', array('type' => 'string', 'data' => __('Correct validating of all alerts.')));
}
}
/**
* Validate all policy alerts. And return a message with the result of the operation.
*
* @param string Don't use.
* @param $thrash1 Don't use.
* @param array $other Don't use
*
* example:
*
* api.php?op=set&op2=validate_all_policy_alerts
*
* @param $thrash3 Don't use
*/
function set_validate_all_policy_alerts($id, $thrash1, $other, $thrash3) {
# Get all policies
$policies = enterprise_hook('policies_get_policies', array(false, false, false, true));
if ($duplicated === ENTERPRISE_NOT_HOOK) {
returnError('error_validate_all_policy_alerts', __('Error validating all alert policies.'));
return;
}
// Count of valid results
$total_alerts = 0;
$count_results = 0;
// Check all policies
foreach ($policies as $policy){
$policy_alerts = array();
$policy_alerts = enterprise_hook('policies_get_alerts', array($policy['id'], false, false, true));
// Number of alerts in this policy
if ($policy_alerts != false){
$partial_alerts = count($policy_alerts);
// Added alerts of this policy to the total
$total_alerts = $total_alerts + $partial_alerts;
}
$result_pol_alerts = array();
foreach ($policy_alerts as $policy_alert){
$result_pol_alerts[] = $policy_alert['id'];
}
$id_pol_alerts = implode(',', $result_pol_alerts);
// If the policy has alerts
if (count($result_pol_alerts) != 0){
$sql = sprintf ("SELECT id
FROM talert_template_modules
WHERE id_policy_alerts IN (%s)",
$id_pol_alerts);
$id_alerts = db_get_all_rows_sql($sql);
$result_alerts = array();
foreach ($id_alerts as $id_alert){
$result_alerts[] = $id_alert['id'];
}
// Validate alerts of these modules
foreach ($result_alerts as $result_alert){
$result = alerts_validate_alert_agent_module($result_alert, true);
if ($result){
$count_results++;
}
}
}
}
// Check results
if ($total_alerts > $count_results){
$errors = $total_alerts - $count_results;
returnError('error_validate_all_alerts', __('Error validate all policy alerts. Failed ' . $errors . '.'));
}
else {
returnData('string', array('type' => 'string', 'data' => __('Correct validating of all policy alerts.')));
}
}
/** /**
* Stop a schedule downtime. And return a message with the result of the operation. * Stop a schedule downtime. And return a message with the result of the operation.
* *
@ -2173,7 +2611,71 @@ function set_add_data_module_policy($id, $thrash1, $other, $thrash3) {
} }
/** /**
* Add network module to policy. And return id from new module. * Update data module in policy. And return id from new module.
*
* @param string $id Id of the target policy module.
* @param $thrash1 Don't use.
* @param array $other it's array, $other as param is <id_policy_module>;<description>;
* <id_module_group>;<min>;<max>;<post_process>;<module_interval>;<min_warning>;<max_warning>;<str_warning>;
* <min_critical>;<max_critical>;<str_critical>;<history_data>;<configuration_data> in this order
* and separator char (after text ; ) and separator (pass in param othermode as othermode=url_encode_separator_<separator>)
* example:
*
* example:
*
* api.php?op=set&op2=update_data_module_policy&id=1&other=10~data%20module%20updated%20by%20Api~2~0~0~50.00~10~20~180~~21~35~~1~module_begin%0dmodule_name%20pandora_process%0dmodule_type%20generic_data%0dmodule_exec%20ps%20aux%20|%20grep%20pandora%20|%20wc%20-l%0dmodule_end&other_mode=url_encode_separator_~
*
* @param $thrash3 Don't use
*/
function set_update_data_module_policy($id, $thrash1, $other, $thrash3) {
if ($id == ""){
returnError('error_update_data_module_policy', __('Error updating data module in policy. Id_policy cannot be left blank.'));
return;
}
if ($other['data'][0] == ""){
returnError('error_update_data_module_policy', __('Error updating data module in policy. Id_policy_module cannot be left blank.'));
return;
}
// Check if the module exists
$module_policy = enterprise_hook('policies_get_modules', array($id, array('id' => $other['data'][0]), 'id_module', true));
if ($module_policy === false) {
returnError('error_update_data_module_policy', __('Error updating data module in policy. Module doesn\'t exists.'));
return;
}
if ($module_policy[0]['id_module'] != 1){
returnError('error_update_network_module_policy', __('Error updating network module in policy. Module type is not network type.'));
return;
}
$fields_data_module = array('id','description', 'id_module_group', 'min', 'max', 'post_process', 'module_interval',
'min_warning', 'max_warning', 'str_warning', 'min_critical', 'max_critical', 'str_critical',
'history_data', 'configuration_data');
$cont = 0;
foreach ($fields_data_module as $field){
if ($other['data'][$cont] != "" and $field != 'id'){
$values[$field] = $other['data'][$cont];
}
$cont++;
}
$result_update = enterprise_hook('policies_update_module', array($other['data'][0], $values, false));
if ($result_update < 0)
returnError('error_update_data_module_policy', 'Error updating policy module.');
else
returnData('string', array('type' => 'string', 'data' => __('Data policy module updated.')));
}
/**
* Add network module to policy. And return a result message.
* *
* @param string $id Id of the target policy. * @param string $id Id of the target policy.
* @param $thrash1 Don't use. * @param $thrash1 Don't use.
@ -2249,7 +2751,71 @@ function set_add_network_module_policy($id, $thrash1, $other, $thrash3) {
returnData('string', array('type' => 'string', 'data' => $success)); returnData('string', array('type' => 'string', 'data' => $success));
else else
returnError('error_add_network_module_policy', 'Error adding network module to policy.'); returnError('error_add_network_module_policy', 'Error adding network module to policy.');
}
/**
* Update network module in policy. And return a result message.
*
* @param string $id Id of the target policy module.
* @param $thrash1 Don't use.
* @param array $other it's array, $other as param is <id_policy_module>;<description>;
* <id_module_group>;<min>;<max>;<post_process>;<module_interval>;<min_warning>;<max_warning>;<str_warning>;
* <min_critical>;<max_critical>;<str_critical>;<history_data>;<time_threshold>;<disabled>;<module_port>;
* <snmp_community>;<snmp_oid>;<custom_id> in this order
* and separator char (after text ; ) and separator (pass in param othermode as othermode=url_encode_separator_<separator>)
* example:
*
* example:
*
* api.php?op=set&op2=update_network_module_policy&id=1&other=14|network%20module%20updated%20by%20Api|2|0|0|150.00|300|10|20||21|35||1|15|0|66|||0&other_mode=url_encode_separator_|
*
* @param $thrash3 Don't use
*/
function set_update_network_module_policy($id, $thrash1, $other, $thrash3) {
if ($id == ""){
returnError('error_update_network_module_policy', __('Error updating network module in policy. Id_policy cannot be left blank.'));
return;
}
if ($other['data'][0] == ""){
returnError('error_update_network_module_policy', __('Error updating network module in policy. Id_policy_module cannot be left blank.'));
return;
}
// Check if the module exists
$module_policy = enterprise_hook('policies_get_modules', array($id, array('id' => $other['data'][0]), 'id_module', true));
if ($module_policy === false) {
returnError('error_update_network_module_policy', __('Error updating network module in policy. Module doesn\'t exists.'));
return;
}
if ($module_policy[0]['id_module'] != 2){
returnError('error_update_network_module_policy', __('Error updating network module in policy. Module type is not network type.'));
return;
}
$fields_network_module = array('id','description', 'id_module_group', 'min', 'max', 'post_process', 'module_interval',
'min_warning', 'max_warning', 'str_warning', 'min_critical', 'max_critical', 'str_critical',
'history_data', 'min_ff_event', 'disabled', 'tcp_port', 'snmp_community', 'snmp_oid', 'custom_id');
$cont = 0;
foreach ($fields_network_module as $field){
if ($other['data'][$cont] != "" and $field != 'id'){
$values[$field] = $other['data'][$cont];
}
$cont++;
}
$result_update = enterprise_hook('policies_update_module', array($other['data'][0], $values, false));
if ($result_update < 0)
returnError('error_update_network_module_policy', 'Error updating policy module.');
else
returnData('string', array('type' => 'string', 'data' => __('Network policy module updated.')));
} }
/** /**
@ -2334,6 +2900,71 @@ function set_add_plugin_module_policy($id, $thrash1, $other, $thrash3) {
} }
/**
* Update plugin module in policy. And return a result message.
*
* @param string $id Id of the target policy module.
* @param $thrash1 Don't use.
* @param array $other it's array, $other as param is <id_policy_module>;<disabled>;
* <id_module_group>;<min_warning>;<max_warning>;<str_warning>;<min_critical>;<max_critical>;<str_critical>;<ff_threshold>;
* <history_data>;<module_port>;<snmp_community>;<snmp_oid>;<module_interval>;<post_process>;
* <min>;<max>;<custom_id>;<description>;<id_plugin>;<plugin_user>;<plugin_pass>;<plugin_parameter> in this order
* and separator char (after text ; ) and separator (pass in param othermode as othermode=url_encode_separator_<separator>)
* example:
*
* example:
*
* api.php?op=set&op2=update_plugin_module_policy&id=1&other=23|0|1|0|0||0|0||15|0|166|||180|150.00|0|0|0|plugin%20module%20updated%20from%20api|2|example_user|pass|-p%20min&other_mode=url_encode_separator_|
*
* @param $thrash3 Don't use
*/
function set_update_plugin_module_policy($id, $thrash1, $other, $thrash3) {
if ($id == ""){
returnError('error_update_plugin_module_policy', __('Error updating plugin module in policy. Id_policy cannot be left blank.'));
return;
}
if ($other['data'][0] == ""){
returnError('error_update_plugin_module_policy', __('Error updating plugin module in policy. Id_policy_module cannot be left blank.'));
return;
}
// Check if the module exists
$module_policy = enterprise_hook('policies_get_modules', array($id, array('id' => $other['data'][0]), 'id_module', true));
if ($module_policy === false) {
returnError('error_updating_plugin_module_policy', __('Error updating plugin module in policy. Module doesn\'t exists.'));
return;
}
if ($module_policy[0]['id_module'] != 4){
returnError('error_updating_plugin_module_policy', __('Error updating plugin module in policy. Module type is not network type.'));
return;
}
$fields_plugin_module = array('id','disabled', 'id_module_group', 'min_warning', 'max_warning', 'str_warning', 'min_critical',
'max_critical', 'str_critical', 'min_ff_event', 'history_data', 'tcp_port', 'snmp_community',
'snmp_oid', 'module_interval', 'post_process', 'min', 'max', 'custom_id', 'description', 'id_plugin', 'plugin_user',
'plugin_pass', 'plugin_parameter');
$cont = 0;
foreach ($fields_plugin_module as $field){
if ($other['data'][$cont] != "" and $field != 'id'){
$values[$field] = $other['data'][$cont];
}
$cont++;
}
$result_update = enterprise_hook('policies_update_module', array($other['data'][0], $values, false));
if ($result_update < 0)
returnError('error_update_plugin_module_policy', 'Error updating policy module.');
else
returnData('string', array('type' => 'string', 'data' => __('Plugin policy module updated.')));
}
/** /**
* Add SNMP module to policy. And return id from new module. * Add SNMP module to policy. And return id from new module.
* *
@ -2465,6 +3096,97 @@ function set_add_snmp_module_policy($id, $thrash1, $other, $thrash3) {
} }
/**
* Update SNMP module in policy. And return a result message.
*
* @param string $id Id of the target policy module.
* @param $thrash1 Don't use.
* @param array $other it's array, $other as param is <id_policy_module>;<disabled>;
* <id_module_group>;<min_warning>;<max_warning>;<str_warning>;<min_critical>;<max_critical>;<str_critical>;<ff_threshold>;
* <history_data>;<module_port>;<snmp_version>;<snmp_community>;<snmp_oid>;<module_interval>;<post_process>;
* <min>;<max>;<custom_id>;<description>;<snmp3_priv_method>;<snmp3_priv_pass>;<snmp3_sec_level>;<snmp3_auth_method>;
* <snmp3_auth_user>;<snmp3_auth_pass> in this order
* and separator char (after text ; ) and separator (pass in param othermode as othermode=url_encode_separator_<separator>)
* example:
*
* example:
*
* api.php?op=set&op2=update_snmp_module_policy&id=1&other=14|0|2|0|0||0|0||30|1|66|3|nonpublic|.1.3.6.1.2.1.1.1.0|300|150.00|10|60|0|SNMP%20module%20updated%20by%20API|DES|example_priv_passw|authPriv|MD5|pepito_user|example_auth_passw&other_mode=url_encode_separator_|
*
* @param $thrash3 Don't use
*/
function set_update_snmp_module_policy($id, $thrash1, $other, $thrash3) {
if ($id == ""){
returnError('error_update_snmp_module_policy', __('Error updating SNMP module in policy. Id_policy cannot be left blank.'));
return;
}
if ($other['data'][0] == ""){
returnError('error_update_snmp_module_policy', __('Error updating SNMP module in policy. Id_policy_module cannot be left blank.'));
return;
}
// Check if the module exists
$module_policy = enterprise_hook('policies_get_modules', array($id, array('id' => $other['data'][0]), 'id_module', true));
if ($module_policy === false) {
returnError('error_update_snmp_module_policy', __('Error updating SNMP module in policy. Module doesn\'t exists.'));
return;
}
if ($module_policy[0]['id_module'] != 2){
returnError('error_update_snmp_module_policy', __('Error updating SNMP module in policy. Module type is not SNMP type.'));
return;
}
# SNMP version 3
if ($other['data'][12] == "3"){
if ($other['data'][21] != "AES" and $other['data'][21] != "DES"){
returnError('error_update_snmp_module_policy', __('Error updating SNMP module. snmp3_priv_method doesn\'t exists. Set it to \'AES\' or \'DES\'. '));
return;
}
if ($other['data'][23] != "authNoPriv" and $other['data'][23] != "authPriv" and $other['data'][23] != "noAuthNoPriv"){
returnError('error_update_snmp_module_policy', __('Error updating SNMP module. snmp3_sec_level doesn\'t exists. Set it to \'authNoPriv\' or \'authPriv\' or \'noAuthNoPriv\'. '));
return;
}
if ($other['data'][24] != "MD5" and $other['data'][24] != "SHA"){
returnError('error_update_snmp_module_policy', __('Error updating SNMP module. snmp3_auth_method doesn\'t exists. Set it to \'MD5\' or \'SHA\'. '));
return;
}
$fields_snmp_module = array('id','disabled', 'id_module_group', 'min_warning', 'max_warning', 'str_warning', 'min_critical',
'max_critical', 'str_critical', 'min_ff_event', 'history_data', 'tcp_port', 'tcp_send', 'snmp_community',
'snmp_oid', 'module_interval', 'post_process', 'min', 'max', 'custom_id', 'description', 'custom_string_1',
'custom_string_2', 'custom_string_3', 'plugin_parameter', 'plugin_user', 'plugin_pass');
}
else {
$fields_snmp_module = array('id','disabled', 'id_module_group', 'min_warning', 'max_warning', 'str_warning', 'min_critical',
'max_critical', 'str_critical', 'min_ff_event', 'history_data', 'tcp_port', 'tcp_send', 'snmp_community',
'snmp_oid', 'module_interval', 'post_process', 'min', 'max', 'custom_id', 'description');
}
$cont = 0;
foreach ($fields_snmp_module as $field){
if ($other['data'][$cont] != "" and $field != 'id'){
$values[$field] = $other['data'][$cont];
}
$cont++;
}
$result_update = enterprise_hook('policies_update_module', array($other['data'][0], $values, false));
if ($result_update < 0)
returnError('error_update_snmp_module_policy', 'Error updating policy module.');
else
returnData('string', array('type' => 'string', 'data' => __('SNMP policy module updated.')));
}
/** /**
* Apply policy. And return id from the applying operation. * Apply policy. And return id from the applying operation.