0 ? 'updated':'unchanged'));
$import_debug_info['title'] = $xml_array['name'];
$import_debug_info['result'] = ($preview_only ? 'preview':(empty($host_template_id) ? 'fail' : 'success'));
return $hash_cache;
}
function xml_to_cdef($hash, &$xml_array, &$hash_cache) {
global $fields_cdef_edit, $preview_only, $import_debug_info;
/* track changes */
$status = 0;
$fields_cdef_item_edit = array(
'sequence' => 'sequence',
'type' => 'type',
'value' => 'value'
);
/* import into: cdef */
$_cdef_id = db_fetch_cell_prepared('SELECT id
FROM cdef
WHERE hash = ?',
array($hash));
if (!empty($_cdef_id)) {
$previous_data = db_fetch_row_prepared('SELECT *
FROM cdef
WHERE id = ?',
array($_cdef_id));
} else {
$previous_data = array();
}
$save['id'] = (empty($_cdef_id) ? '0' : $_cdef_id);
$save['hash'] = $hash;
foreach ($fields_cdef_edit as $field_name => $field_array) {
/* make sure this field exists in the xml array first */
if (isset($xml_array[$field_name])) {
$save[$field_name] = xml_character_decode($xml_array[$field_name]);
}
}
/* check for status changes */
$status += compare_data($save, $previous_data, 'cdef');
if (!$preview_only) {
$cdef_id = sql_save($save, 'cdef');
$hash_cache['cdef'][$hash] = $cdef_id;
} else {
$cdef_id = $_cdef_id;
$hash_cache['cdef'][$hash] = $_cdef_id;
}
/* import into: cdef_items */
if (is_array($xml_array['items'])) {
foreach ($xml_array['items'] as $item_hash => $item_array) {
/* parse information from the hash */
$parsed_hash = parse_xml_hash($item_hash);
/* invalid/wrong hash */
if ($parsed_hash == false) { return false; }
unset($save);
$_cdef_item_id = db_fetch_cell_prepared('SELECT id
FROM cdef_items
WHERE hash= ?
AND cdef_id = ?',
array($parsed_hash['hash'], $cdef_id));
if (!empty($_cdef_item_id)) {
$previous_data = db_fetch_row_prepared('SELECT *
FROM cdef_items
WHERE id = ?',
array($_cdef_item_id));
} else {
$previous_data = array();
}
$save['id'] = (empty($_cdef_item_id) ? '0' : $_cdef_item_id);
$save['hash'] = $parsed_hash['hash'];
$save['cdef_id'] = $cdef_id;
foreach ($fields_cdef_item_edit as $field_name => $field_array) {
/* make sure this field exists in the xml array first */
if (isset($item_array[$field_name])) {
/* check, if an inherited cdef as to be decoded (value == 5)
* this whole procedure relies on the sequence during template export
* inherited cdef's must come first, this has to be taken care of during export
* so we do not have any specific dependency checks here */
if (($field_name == 'value') && ($item_array['type'] == '5')) {
/* parse information from the hash, which in this case
* is stored as a value of the current item being processed */
$parsed_item_hash = parse_xml_hash($item_array['value']);
/* invalid/wrong hash */
if ($parsed_item_hash == false) { return false; }
$_cdef_id = db_fetch_cell_prepared('SELECT id
FROM cdef
WHERE hash = ?',
array($parsed_item_hash['hash']));
$save[$field_name] = $_cdef_id;
} else {
$save[$field_name] = xml_character_decode($item_array[$field_name]);
}
}
}
/* check for status changes */
$status += compare_data($save, $previous_data, 'cdef_items');
if (!$preview_only) {
$cdef_item_id = sql_save($save, 'cdef_items');
$hash_cache['cdef_item'][$parsed_hash['hash']] = $cdef_item_id;
} else {
$hash_cache['cdef_item'][$parsed_hash['hash']] = $_cdef_item_id;
}
}
}
/* status information that will be presented to the user */
$import_debug_info['type'] = (empty($_cdef_id) ? 'new' : ($status > 0 ? 'updated':'unchanged'));
$import_debug_info['title'] = $xml_array['name'];
$import_debug_info['result'] = ($preview_only ? 'preview':(empty($cdef_id) ? 'fail' : 'success'));
return $hash_cache;
}
function xml_to_vdef($hash, &$xml_array, &$hash_cache) {
global $config, $preview_only, $import_debug_info;
include_once($config['library_path'] . '/vdef.php');
/* track changes */
$status = 0;
/* import into: vdef */
$_vdef_id = db_fetch_cell_prepared('SELECT id
FROM vdef
WHERE hash = ?',
array($hash));
if (!empty($_vdef_id)) {
$previous_data = db_fetch_row_prepared('SELECT *
FROM vdef
WHERE id = ?',
array($_vdef_id));
} else {
$previous_data = array();
}
$save['id'] = (empty($_vdef_id) ? '0' : $_vdef_id);
$save['hash'] = $hash;
$fields_vdef_edit = preset_vdef_form_list();
foreach ($fields_vdef_edit as $field_name => $field_array) {
/* make sure this field exists in the xml array first */
if (isset($xml_array[$field_name])) {
$save[$field_name] = xml_character_decode($xml_array[$field_name]);
}
}
/* check for status changes */
$status += compare_data($save, $previous_data, 'vdef');
if (!$preview_only) {
$vdef_id = sql_save($save, 'vdef');
$hash_cache['vdef'][$hash] = $vdef_id;
} else {
$vdef_id = $_vdef_id;
$hash_cache['vdef'][$hash] = $_vdef_id;
}
/* import into: vdef_items */
if (is_array($xml_array['items'])) {
foreach ($xml_array['items'] as $item_hash => $item_array) {
/* parse information from the hash */
$parsed_hash = parse_xml_hash($item_hash);
/* invalid/wrong hash */
if ($parsed_hash == false) { return false; }
unset($save);
$_vdef_item_id = db_fetch_cell_prepared('SELECT id
FROM vdef_items
WHERE hash = ?
AND vdef_id = ?',
array($parsed_hash['hash'], $vdef_id));
if (!empty($_vdef_item_id)) {
$previous_data = db_fetch_row_prepared('SELECT *
FROM vdef_items
WHERE id = ?',
array($_vdef_item_id));
} else {
$previous_data = array();
}
$save['id'] = (empty($_vdef_item_id) ? '0' : $_vdef_item_id);
$save['hash'] = $parsed_hash['hash'];
$save['vdef_id'] = $vdef_id;
$fields_vdef_item_edit = preset_vdef_item_form_list();
foreach ($fields_vdef_item_edit as $field_name => $field_array) {
/* make sure this field exists in the xml array first */
if (isset($item_array[$field_name])) {
$save[$field_name] = xml_character_decode($item_array[$field_name]);
}
}
/* check for status changes */
$status += compare_data($save, $previous_data, 'vdef_items');
if (!$preview_only) {
$vdef_item_id = sql_save($save, 'vdef_items');
$hash_cache['vdef_item'][$parsed_hash['hash']] = $vdef_item_id;
} else {
$hash_cache['vdef_item'][$parsed_hash['hash']] = $_vdef_item_id;
}
}
}
/* status information that will be presented to the user */
$import_debug_info['type'] = (empty($_vdef_id) ? 'new' : ($status > 0 ? 'updated':'unchanged'));
$import_debug_info['title'] = $xml_array['name'];
$import_debug_info['result'] = ($preview_only ? 'preview':(empty($vdef_id) ? 'fail' : 'success'));
return $hash_cache;
}
function xml_to_data_input_method($hash, &$xml_array, &$hash_cache) {
global $fields_data_input_edit, $fields_data_input_field_edit, $fields_data_input_field_edit_1, $preview_only, $import_debug_info;
/* track changes */
$status = 0;
$system_hashes = array(
'3eb92bb845b9660a7445cf9740726522', // Get SNMP Data
'bf566c869ac6443b0c75d1c32b5a350e', // Get SNMP Data (Indexed)
'80e9e4c4191a5da189ae26d0e237f015', // Get Script Data (Indexed)
'332111d8b54ac8ce939af87a7eac0c06', // Get Script Server Data (Indexed)
);
// Leave system data input methods alone
if (array_search($hash, $system_hashes) !== false) {
return $hash_cache;
}
/* aggregate field arrays */
$fields_data_input_field_edit += $fields_data_input_field_edit_1;
/* import into: data_input */
$_data_input_id = db_fetch_cell_prepared('SELECT id
FROM data_input
WHERE hash = ?',
array($hash));
if (!empty($_data_input_id)) {
$previous_data = db_fetch_row_prepared('SELECT *
FROM data_input
WHERE id = ?',
array($_data_input_id));
} else {
$previous_data = array();
}
$save['id'] = (empty($_data_input_id) ? '0' : $_data_input_id);
$save['hash'] = $hash;
foreach ($fields_data_input_edit as $field_name => $field_array) {
/* make sure this field exists in the xml array first */
if (isset($xml_array[$field_name])) {
if ($field_name == 'input_string' && import_is_base64_encoded($xml_array[$field_name])) {
$save[$field_name] = base64_decode($xml_array[$field_name]);
} else {
$save[$field_name] = xml_character_decode($xml_array[$field_name]);
/* fix issue with data input method importing and white spaces */
if ($field_name == 'input_string') {
$save[$field_name] = str_replace('><', '> <', $save[$field_name]);
$save[$field_name] = str_replace('>""<', '>" "<', $save[$field_name]);
$save[$field_name] = str_replace('>\'\'<', '>\' \'<', $save[$field_name]);
}
}
}
}
/* check for status changes */
$status += compare_data($save, $previous_data, 'data_input');
if (!$preview_only) {
$data_input_id = sql_save($save, 'data_input');
$hash_cache['data_input_method'][$hash] = $data_input_id;
update_replication_crc(0, 'poller_replicate_data_input_crc');
} else {
$data_input_id = $_data_input_id;
$hash_cache['data_input_method'][$hash] = $_data_input_id;
}
/* import into: data_input_fields */
if (is_array($xml_array['fields'])) {
foreach ($xml_array['fields'] as $item_hash => $item_array) {
/* parse information from the hash */
$parsed_hash = parse_xml_hash($item_hash);
/* invalid/wrong hash */
if ($parsed_hash == false) { return false; }
/* bad snmp port hashes */
if ($parsed_hash['hash'] == '5240353b8f7f259acaf30e6229bc14e7') {
continue;
} elseif ($parsed_hash['hash'] == 'd94caa7cc3733bd95ee00a3917fdcbb5') {
continue;
}
unset($save);
$_data_input_field_id = db_fetch_cell_prepared('SELECT id
FROM data_input_fields
WHERE hash= ?
AND data_input_id = ?',
array($parsed_hash['hash'], $data_input_id));
if (!empty($_data_input_field_id)) {
$previous_data = db_fetch_row_prepared('SELECT *
FROM data_input_fields
WHERE id = ?',
array($_data_input_field_id));
} else {
$previous_data = array();
}
$save['id'] = (empty($_data_input_field_id) ? '0' : $_data_input_field_id);
$save['hash'] = $parsed_hash['hash'];
$save['data_input_id'] = $data_input_id;
foreach ($fields_data_input_field_edit as $field_name => $field_array) {
/* make sure this field exists in the xml array first */
if (isset($item_array[$field_name])) {
$save[$field_name] = xml_character_decode($item_array[$field_name]);
}
}
/* check for status changes */
$status += compare_data($save, $previous_data, 'data_input_fields');
if (!$preview_only) {
$data_input_field_id = sql_save($save, 'data_input_fields');
$hash_cache['data_input_field'][$parsed_hash['hash']] = $data_input_field_id;
update_replication_crc(0, 'poller_replicate_data_input_fields_crc');
} else {
$hash_cache['data_input_field'][$parsed_hash['hash']] = $_data_input_field_id;
}
}
}
/* update field use counter cache if possible */
if (!$preview_only) {
if ((isset($xml_array['input_string'])) && (!empty($data_input_id))) {
generate_data_input_field_sequences($xml_array['input_string'], $data_input_id);
}
}
/* status information that will be presented to the user */
$import_debug_info['type'] = (empty($_data_input_id) ? 'new' : ($status > 0 ? 'updated':'unchanged'));
$import_debug_info['title'] = $xml_array['name'];
$import_debug_info['result'] = ($preview_only ? 'preview':(empty($data_input_id) ? 'fail' : 'success'));
return $hash_cache;
}
function compare_data($save, $previous_data, $table) {
global $preview_only, $import_debug_info;
if ($preview_only) {
$ignores = array(
'task_item_id',
'gprint_id',
'cdef_id',
'vdef_id',
'consolidation_function_id',
'data_input_id',
'graph_template_id',
'data_template_id',
'data_input_field_id'
);
} else {
$ignores = array();
}
if (!cacti_sizeof($previous_data)) {
return 0;
} else {
$different = 0;
foreach($save as $column => $value) {
if (array_search($column, $ignores) !== false) continue;
if ($previous_data[$column] != $value) {
$cols = db_get_table_column_types($table);
if (strstr($cols[$column]['type'], 'int') !== false ||
strstr($cols[$column]['type'], 'float') !== false ||
strstr($cols[$column]['type'], 'decimal') !== false ||
strstr($cols[$column]['type'], 'double') !== false) {
if (empty($previous_data[$column]) && empty($value)) {
continue;
} elseif ($table == 'data_template_rrd' && $column == 'rrd_heartbeat') {
continue;
} elseif ($table == 'data_template_data' && $column == 'rrd_step') {
continue;
}
} elseif (empty($previous_data[$column]) && empty($value)) {
continue;
}
$different++;
$import_debug_info['differences'][] = 'Table: ' . $table . ', Column: ' . $column . ', New Value: ' . $value . ', Old Value: ' . $previous_data[$column];
}
}
return $different;
}
}
function hash_to_friendly_name($hash, $display_type_name) {
global $hash_type_names;
/* parse information from the hash */
$parsed_hash = parse_xml_hash($hash);
/* invalid/wrong hash */
if ($parsed_hash == false) {
return __('Unknown Field');
}
if ($display_type_name == true) {
$prepend = '(' . $hash_type_names[$parsed_hash['type']] . ') ';
} else {
$prepend = '';
}
switch ($parsed_hash['type']) {
case 'graph_template':
return $prepend . db_fetch_cell_prepared('SELECT name
FROM graph_templates
WHERE hash = ?',
array($parsed_hash['hash']));
case 'data_template':
return $prepend . db_fetch_cell_prepared('SELECT name
FROM data_template
WHERE hash = ?',
array($parsed_hash['hash']));
case 'data_template_item':
return $prepend . db_fetch_cell_prepared('SELECT data_source_name
FROM data_template_rrd
WHERE hash = ?',
array($parsed_hash['hash']));
case 'host_template':
return $prepend . db_fetch_cell_prepared('SELECT name
FROM host_template
WHERE hash = ?',
array($parsed_hash['hash']));
case 'data_input_method':
return $prepend . db_fetch_cell_prepared('SELECT name
FROM data_input
WHERE hash = ?',
array($parsed_hash['hash']));
case 'data_input_field':
return $prepend . db_fetch_cell_prepared('SELECT name
FROM data_input_fields
WHERE hash = ?',
array($parsed_hash['hash']));
case 'data_query':
return $prepend . db_fetch_cell_prepared('SELECT name
FROM snmp_query
WHERE hash = ?',
array($parsed_hash['hash']));
case 'gprint_preset':
return $prepend . db_fetch_cell_prepared('SELECT name
FROM graph_templates_gprint
WHERE hash = ?',
array($parsed_hash['hash']));
case 'cdef':
return $prepend . db_fetch_cell_prepared('SELECT name
FROM cdef
WHERE hash = ?',
array($parsed_hash['hash']));
case 'vdef':
return $prepend . db_fetch_cell_prepared('SELECT name
FROM vdef
WHERE hash = ?',
array($parsed_hash['hash']));
case 'data_source_profile':
return $prepend . db_fetch_cell_prepared('SELECT name
FROM data_source_profile
WHERE hash = ?',
array($parsed_hash['hash']));
case 'round_robin_archive':
return $prepend;
default:
$param = array();
$param['hash'] = $parsed_hash['hash'];
$param['type'] = $parsed_hash['type'];
$param['prepend'] = $prepend;
api_plugin_hook_function('get_friendly_name', $param);
return $param['prepend'];
}
}
function resolve_hash_to_id($hash, &$hash_cache_array) {
global $import_debug_info;
/* parse information from the hash */
$parsed_hash = parse_xml_hash($hash);
/* invalid/wrong hash */
if ($parsed_hash == false) { return false; }
if (isset($hash_cache_array[$parsed_hash['type']][$parsed_hash['hash']])) {
$import_debug_info['dep'][$hash] = 'met';
return $hash_cache_array[$parsed_hash['type']][$parsed_hash['hash']];
} else {
/* bad snmp port hashes */
if ($parsed_hash['hash'] == '5240353b8f7f259acaf30e6229bc14e7') {
return 0;
} elseif ($parsed_hash['hash'] == 'd94caa7cc3733bd95ee00a3917fdcbb5') {
return 0;
} elseif ($parsed_hash['hash'] == 'cbbe5c1ddfb264a6e5d509ce1c78c95f') {
return 0;
}
cacti_log("Import Error: Import found an invalid dependency hash of :" . $parsed_hash['hash'] . ". Please open bug on GitHub.");
$import_debug_info['dep'][$hash] = 'unmet';
return 0;
}
}
function parse_xml_hash($hash) {
global $legacy_template;
if (preg_match('/hash_([a-f0-9]{2})([a-f0-9]{4})([a-f0-9]{32})/', $hash, $matches)) {
$parsed_hash['type'] = check_hash_type($matches[1]);
$parsed_hash['version'] = strval(check_hash_version($matches[2]));
$parsed_hash['hash'] = $matches[3];
/* an error has occurred */
if (($parsed_hash['type'] === false) || ($parsed_hash['version'] === false)) {
raise_message(7); /* xml parse error */
cacti_log(__FUNCTION__ . ' ERROR type or version not found for hash: ' . $hash, false, 'IMPORT', POLLER_VERBOSITY_LOW);
return false;
}
} elseif (preg_match('/hash_([a-f0-9]{2})([a-f0-9]{32})/', $hash, $matches)) {
$parsed_hash['type'] = check_hash_type($matches[1]);
$parsed_hash['version'] = strval(check_hash_version('0101'));
$parsed_hash['hash'] = $matches[2];
/* an error has occurred */
if (($parsed_hash['type'] === false) || ($parsed_hash['version'] === false)) {
raise_message(7); /* xml parse error */
cacti_log(__FUNCTION__ . ' ERROR type or version not found for hash: ' . $hash, false, 'IMPORT', POLLER_VERBOSITY_LOW);
return false;
}
} else {
/* bad snmp port hashes */
if ($hash == '5240353b8f7f259acaf30e6229bc14e7') {
return false;
} elseif ($hash == 'd94caa7cc3733bd95ee00a3917fdcbb5') {
return false;
}
raise_message(7); /* xml parse error */
cacti_log(__FUNCTION__ . ' ERROR wrong hash format for hash: ' . $hash, false, 'IMPORT', POLLER_VERBOSITY_LOW);
return false;
}
if (cacti_version_compare($parsed_hash['version'], '1.2.3', '<')) {
$legacy_template = true;
}
return $parsed_hash;
}
function check_hash_type($hash_type) {
global $hash_type_codes;
/* lets not mess up the pointer for other people */
$local_hash_type_codes = $hash_type_codes;
foreach ($local_hash_type_codes as $type => $code) {
if ($code == $hash_type) {
$current_type = $type;
}
}
if (!isset($current_type)) {
raise_message(18); /* error: cannot find type */
return false;
}
return $current_type;
}
function check_hash_version($hash_version) {
global $cacti_version_codes, $config;
$i = 0;
foreach ($cacti_version_codes as $version => $code) {
if ($version == CACTI_VERSION) {
$current_version_index = $i;
}
if ($code == $hash_version) {
$hash_version_index = $i;
$current_version = $version;
}
$i++;
}
if (!isset($current_version_index)) {
cacti_log("ERROR: $hash_version Current Cacti Version does not exist!", false, 'IMPORT', POLLER_VERBOSITY_HIGH);
raise_message(15); /* error: current cacti version does not exist! */
return false;
} elseif (!isset($hash_version_index)) {
cacti_log("ERROR: $hash_version hash version does not exist!", false, 'IMPORT', POLLER_VERBOSITY_HIGH);
raise_message(16); /* error: hash version does not exist! */
return false;
} elseif ($hash_version_index > $current_version_index) {
cacti_log("ERROR: $hash_version hash version is for a newer Cacti!", false, 'IMPORT', POLLER_VERBOSITY_HIGH);
raise_message(17); /* error: hash made with a newer version of cacti */
return false;
}
return $current_version;
}
function get_version_index($string_version) {
global $cacti_version_codes;
$i = 0;
foreach ($cacti_version_codes as $version => $code) {
if ($string_version == $version) {
return $i;
}
$i++;
}
/* version index not found */
return -1;
}
function xml_character_decode($text) {
if (function_exists('html_entity_decode')) {
return html_entity_decode($text, ENT_QUOTES, 'UTF-8');
} else {
$trans_tbl = get_html_translation_table(HTML_ENTITIES);
$trans_tbl = array_flip($trans_tbl);
return strtr($text, $trans_tbl);
}
}
function import_display_results($import_debug_info, $filestatus, $web = false, $preview = false) {
global $hash_type_names;
// Capture to a buffer
ob_start();
if (cacti_sizeof($import_debug_info)) {
html_start_box(($preview ? __('Import Preview Results'):__('Import Results')), '100%', '', '3', 'center', '');
if (cacti_sizeof($filestatus)) {
if ($preview) {
print "" . __('Cacti would make the following changes if the Package was imported:') . " \n";
} else {
print " |
" . __('Cacti has imported the following items for the Package:') . " \n";
}
print "" . __('Package Files') . " \n";
print "";
foreach($filestatus as $filename => $status) {
print "- " . ($preview ? __("[preview] "):"") . $filename . " [" . $status . "]
\n";
}
print " ";
} else {
if ($preview) {
print " |
" . __('Cacti would make the following changes if the Template was imported:') . " \n";
} else {
print " |
" . __('Cacti has imported the following items for the Template:') . " \n";
}
}
foreach ($import_debug_info as $type => $type_array) {
print "" . $hash_type_names[$type] . " \n";
foreach ($type_array as $index => $vals) {
if ($vals['result'] == 'success') {
$result_text = "" . __('[success]') . "";
} elseif ($vals['result'] == 'fail') {
$result_text = "" . __('[fail]') . "";
} else {
$result_text = "" . __('[preview]') . "";
}
if ($vals['type'] == 'updated') {
$type_text = "" . __('[updated]') . "\n";
} elseif ($vals['type'] == 'new') {
$type_text = "" . __('[new]') . "\n";
} else {
$type_text = "" . __('[unchanged]') . "\n";
}
print "$result_text " . html_escape($vals['title']) . " $type_text
\n";
if (isset($vals['orphans'])) {
print '';
foreach($vals['orphans'] as $orphan) {
print "- " . html_escape($orphan) . "
\n";
}
print ' ';
}
if (isset($vals['new_items'])) {
print '';
foreach($vals['new_items'] as $item) {
print "- " . html_escape($item) . "
\n";
}
print ' ';
}
if (isset($vals['differences'])) {
print '';
foreach($vals['differences'] as $diff) {
print "- " . html_escape($diff) . "
\n";
}
print ' ';
}
if (!$preview) {
$dep_text = '';
$dep_errors = false;
if ((isset($vals['dep'])) && (cacti_sizeof($vals['dep']) > 0)) {
foreach ($vals['dep'] as $dep_hash => $dep_status) {
if ($dep_status == 'met') {
$dep_status_text = "" . __('Found Dependency:') . "";
} else {
$dep_status_text = "" . __('Unmet Dependency:') . "";
$dep_errors = true;
}
$dep_text .= " + $dep_status_text " . hash_to_friendly_name($dep_hash, true) . "
\n";
}
}
/* only print out dependency details if they contain errors; otherwise it would get too long */
if ($dep_errors == true) {
print $dep_text;
}
}
}
}
print ' |
';
html_end_box();
}
if ($web) {
print ob_get_clean();
} else {
$output = ob_get_clean();
$output = explode("\n", $output);
if (cacti_sizeof($output)) {
foreach($output as $line) {
$line = trim(str_replace(' ', '', strip_tags($line)));
if ($line != '') {
print $line . "\n";
}
}
}
}
}
function xml_to_array($data) {
if (is_object($data)) {
$data = get_object_vars($data);
}
return (is_array($data)) ? array_map(__FUNCTION__,$data) : $data;
}
function import_is_base64_encoded($string) {
if (preg_match('%^[a-zA-Z0-9/+]*={0,2}$%', $string)) {
return true;
} else {
return false;
}
}