mirror of
https://github.com/Cacti/cacti.git
synced 2026-10-28 23:57:30 +09:00
869 lines
27 KiB
PHP
869 lines
27 KiB
PHP
<?php
|
|
/*
|
|
+-------------------------------------------------------------------------+
|
|
| Copyright (C) 2004-2025 The Cacti Group |
|
|
| |
|
|
| 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. |
|
|
+-------------------------------------------------------------------------+
|
|
| Cacti: The Complete RRDtool-based Graphing Solution |
|
|
+-------------------------------------------------------------------------+
|
|
| This code is designed, written, and maintained by the Cacti Group. See |
|
|
| about.php and/or the AUTHORS file for specific developer information. |
|
|
+-------------------------------------------------------------------------+
|
|
| http://www.cacti.net/ |
|
|
+-------------------------------------------------------------------------+
|
|
*/
|
|
|
|
/* api_data_source_crc_update - update hash stored in settings table to inform
|
|
remote pollers to update their caches
|
|
@arg $poller_id - the id of the poller impacted by hash update
|
|
@arg $variable - the hash variable prefix for the replication setting. */
|
|
function api_data_source_cache_crc_update($poller_id, $variable = 'poller_replicate_data_source_cache_crc') {
|
|
$hash = hash('ripemd160', date('Y-m-d H:i:s') . random_int(0, mt_getrandmax()) . $poller_id);
|
|
|
|
db_execute_prepared("REPLACE INTO settings
|
|
SET value = ?, name='$variable" . '_' . "$poller_id'",
|
|
[$hash]);
|
|
}
|
|
|
|
/* api_data_source_deletable - tells you if a data source can be removed
|
|
@arg $local_data_id - the id of the poller impacted by hash update */
|
|
function api_data_source_deletable($local_data_id) {
|
|
$graphs = db_fetch_cell_prepared('SELECT COUNT(DISTINCT gti.local_graph_id)
|
|
FROM data_local AS dl
|
|
INNER JOIN data_template_rrd AS dtr
|
|
ON dl.id = dtr.local_data_id
|
|
LEFT JOIN graph_templates_item AS gti
|
|
ON gti.task_item_id = dtr.id
|
|
WHERE dl.id = ?
|
|
AND gti.id IS NOT NULL',
|
|
[$local_data_id]);
|
|
|
|
if ($graphs > 0) {
|
|
return false;
|
|
} else {
|
|
return true;
|
|
}
|
|
}
|
|
|
|
function api_data_source_remove($local_data_id, $update_totals = true) {
|
|
if (empty($local_data_id)) {
|
|
return;
|
|
}
|
|
|
|
api_plugin_hook_function('data_source_remove', [$local_data_id]);
|
|
|
|
$autoclean = read_config_option('rrd_autoclean');
|
|
$acmethod = read_config_option('rrd_autoclean_method');
|
|
|
|
if ($update_totals) {
|
|
object_cache_get_totals('data_source', $local_data_id);
|
|
}
|
|
|
|
if ($autoclean == 'on') {
|
|
$dsinfo = db_fetch_row_prepared('SELECT local_data_id, data_source_path
|
|
FROM data_template_data
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
if (cacti_sizeof($dsinfo)) {
|
|
$filename = str_replace('<path_rra>/', '', $dsinfo['data_source_path']);
|
|
db_execute_prepared('INSERT INTO data_source_purge_action
|
|
(local_data_id, name, action) VALUES (?, ?, ?)
|
|
ON DUPLICATE KEY UPDATE action=VALUES(action)',
|
|
[$local_data_id, $filename, $acmethod]);
|
|
}
|
|
}
|
|
|
|
$data_template_data_id = db_fetch_cell_prepared('SELECT id
|
|
FROM data_template_data
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
$poller_id = db_fetch_cell_prepared('SELECT poller_id
|
|
FROM host AS h
|
|
INNER JOIN data_local AS dl
|
|
ON h.id=dl.host_id
|
|
WHERE dl.id = ?',
|
|
[$local_data_id]);
|
|
|
|
if (!empty($data_template_data_id)) {
|
|
db_execute_prepared('DELETE
|
|
FROM data_input_data
|
|
WHERE data_template_data_id = ?',
|
|
[$data_template_data_id]);
|
|
|
|
if (($rcnn_id = poller_push_to_remote_db_connect($poller_id, true)) !== false) {
|
|
db_execute_prepared('DELETE
|
|
FROM data_input_data
|
|
WHERE data_template_data_id = ?',
|
|
[$data_template_data_id], true, $rcnn_id);
|
|
}
|
|
}
|
|
|
|
/* base data */
|
|
db_execute_prepared('DELETE FROM data_template_data
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
db_execute_prepared('DELETE FROM data_template_rrd
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
db_execute_prepared('DELETE FROM poller_item
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
db_execute_prepared('DELETE FROM data_local
|
|
WHERE id = ?', [$local_data_id]);
|
|
|
|
db_execute_prepared('DELETE FROM data_debug
|
|
WHERE datasource = ?', [$local_data_id]);
|
|
|
|
/* dsstats */
|
|
db_execute_prepared('DELETE FROM data_source_stats_daily
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
db_execute_prepared('DELETE FROM data_source_stats_hourly
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
db_execute_prepared('DELETE FROM data_source_stats_hourly_cache
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
db_execute_prepared('DELETE FROM data_source_stats_hourly_last
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
db_execute_prepared('DELETE FROM data_source_stats_monthly
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
db_execute_prepared('DELETE FROM data_source_stats_weekly
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
db_execute_prepared('DELETE FROM data_source_stats_yearly
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
db_execute_prepared('DELETE FROM data_source_stats_command_cache
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
/* boost */
|
|
db_execute_prepared('DELETE FROM poller_output
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
db_execute_prepared('DELETE FROM poller_output_boost
|
|
WHERE local_data_id = ?', [$local_data_id]);
|
|
|
|
if (($rcnn_id = poller_push_to_remote_db_connect($poller_id, true)) !== false) {
|
|
/* base data */
|
|
db_execute_prepared('DELETE FROM data_template_data
|
|
WHERE local_data_id = ?', [$local_data_id], true, $rcnn_id);
|
|
|
|
db_execute_prepared('DELETE FROM data_template_rrd
|
|
WHERE local_data_id = ?', [$local_data_id], true, $rcnn_id);
|
|
|
|
db_execute_prepared('DELETE FROM poller_item
|
|
WHERE local_data_id = ?', [$local_data_id], true, $rcnn_id);
|
|
|
|
db_execute_prepared('DELETE FROM data_local
|
|
WHERE id = ?', [$local_data_id], true, $rcnn_id);
|
|
|
|
/* boost */
|
|
db_execute_prepared('DELETE FROM poller_output
|
|
WHERE local_data_id = ?', [$local_data_id], true, $rcnn_id);
|
|
|
|
db_execute_prepared('DELETE FROM poller_output_boost
|
|
WHERE local_data_id = ?', [$local_data_id], true, $rcnn_id);
|
|
}
|
|
|
|
/* update the database to document the cache change */
|
|
api_data_source_cache_crc_update($poller_id);
|
|
|
|
if ($update_totals) {
|
|
object_cache_update_totals('delete');
|
|
}
|
|
}
|
|
|
|
function api_data_source_remove_multi($local_data_ids, $update_totals = true) {
|
|
// Shortcut out if no data
|
|
if (!cacti_sizeof($local_data_ids)) {
|
|
return;
|
|
}
|
|
|
|
if ($update_totals) {
|
|
object_cache_get_totals('data_source', $local_data_ids);
|
|
}
|
|
|
|
api_plugin_hook_function('data_source_remove', $local_data_ids);
|
|
|
|
$autoclean = read_config_option('rrd_autoclean');
|
|
$acmethod = read_config_option('rrd_autoclean_method');
|
|
|
|
$local_data_ids_chunks = array_chunk($local_data_ids, 1000);
|
|
|
|
foreach ($local_data_ids_chunks as $ids_to_delete) {
|
|
$poller_ids = get_remote_poller_ids_from_data_sources($ids_to_delete);
|
|
|
|
if (is_array($ids_to_delete)) {
|
|
cacti_log('Found as an array');
|
|
$ids_to_delete = implode(', ', $ids_to_delete);
|
|
}
|
|
|
|
$data_template_data_ids = db_fetch_assoc('SELECT id
|
|
FROM data_template_data
|
|
WHERE local_data_id IN (' . $ids_to_delete . ')');
|
|
|
|
if (cacti_sizeof($data_template_data_ids)) {
|
|
$dtd_ids_to_delete = [];
|
|
|
|
foreach ($data_template_data_ids as $data_template_data_id) {
|
|
$dtd_ids_to_delete[] = $data_template_data_id['id'];
|
|
|
|
if (cacti_sizeof($dtd_ids_to_delete) >= 1000) {
|
|
db_execute('DELETE FROM data_input_data
|
|
WHERE data_template_data_id IN (' . implode(',', $dtd_ids_to_delete) . ')');
|
|
|
|
if (cacti_sizeof($poller_ids)) {
|
|
foreach ($poller_ids as $poller_id) {
|
|
if (($rcnn_id = poller_push_to_remote_db_connect($poller_id, true)) !== false) {
|
|
db_execute('DELETE FROM data_input_data
|
|
WHERE data_template_data_id IN (' . implode(',', $dtd_ids_to_delete) . ')', true, $rcnn_id);
|
|
}
|
|
}
|
|
}
|
|
|
|
$dtd_ids_to_delete = [];
|
|
}
|
|
}
|
|
|
|
if (cacti_sizeof($dtd_ids_to_delete)) {
|
|
db_execute('DELETE FROM data_input_data
|
|
WHERE data_template_data_id IN (' . implode(',', $dtd_ids_to_delete) . ')');
|
|
|
|
if (cacti_sizeof($poller_ids)) {
|
|
foreach ($poller_ids as $poller_id) {
|
|
if (($rcnn_id = poller_push_to_remote_db_connect($poller_id, true)) !== false) {
|
|
db_execute('DELETE FROM data_input_data
|
|
WHERE data_template_data_id IN (' . implode(',', $dtd_ids_to_delete) . ')', true, $rcnn_id);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/* prepare auto-clean if enabled */
|
|
if ($autoclean == 'on') {
|
|
db_execute("INSERT INTO data_source_purge_action (local_data_id, name, action)
|
|
SELECT local_data_id, REPLACE(data_source_path, '<path_rra>/', ''), '" . $acmethod . "'
|
|
FROM data_template_data
|
|
WHERE local_data_id IN (" . $ids_to_delete . ')
|
|
ON DUPLICATE KEY UPDATE action=VALUES(action)');
|
|
}
|
|
|
|
/* core data */
|
|
db_execute('DELETE FROM data_template_data
|
|
WHERE local_data_id IN (' . $ids_to_delete . ')');
|
|
|
|
db_execute('DELETE FROM data_template_rrd
|
|
WHERE local_data_id IN (' . $ids_to_delete . ')');
|
|
|
|
db_execute('DELETE FROM poller_item
|
|
WHERE local_data_id IN (' . $ids_to_delete . ')');
|
|
|
|
db_execute('DELETE FROM data_local
|
|
WHERE id IN (' . $ids_to_delete . ')');
|
|
|
|
db_execute('DELETE FROM data_debug
|
|
WHERE datasource IN (' . $ids_to_delete . ')');
|
|
|
|
/* dsstats */
|
|
db_execute('DELETE FROM data_source_stats_daily
|
|
WHERE local_data_id IN(' . $ids_to_delete . ')');
|
|
|
|
db_execute('DELETE FROM data_source_stats_hourly
|
|
WHERE local_data_id IN(' . $ids_to_delete . ')');
|
|
|
|
db_execute('DELETE FROM data_source_stats_hourly_cache
|
|
WHERE local_data_id IN(' . $ids_to_delete . ')');
|
|
|
|
db_execute('DELETE FROM data_source_stats_hourly_last
|
|
WHERE local_data_id IN(' . $ids_to_delete . ')');
|
|
|
|
db_execute('DELETE FROM data_source_stats_monthly
|
|
WHERE local_data_id IN(' . $ids_to_delete . ')');
|
|
|
|
db_execute('DELETE FROM data_source_stats_weekly
|
|
WHERE local_data_id IN(' . $ids_to_delete . ')');
|
|
|
|
db_execute('DELETE FROM data_source_stats_yearly
|
|
WHERE local_data_id IN(' . $ids_to_delete . ')');
|
|
|
|
/* boost */
|
|
db_execute('DELETE FROM poller_output
|
|
WHERE local_data_id IN (' . $ids_to_delete . ')');
|
|
|
|
db_execute('DELETE FROM poller_output_boost
|
|
WHERE local_data_id IN (' . $ids_to_delete . ')');
|
|
|
|
if (cacti_sizeof($poller_ids)) {
|
|
foreach ($poller_ids as $poller_id) {
|
|
if (($rcnn_id = poller_push_to_remote_db_connect($poller_id, true)) !== false) {
|
|
/* core data */
|
|
db_execute('DELETE FROM data_template_data
|
|
WHERE local_data_id IN (' . $ids_to_delete . ')', true, $rcnn_id);
|
|
|
|
db_execute('DELETE FROM data_template_rrd
|
|
WHERE local_data_id IN (' . $ids_to_delete . ')', true, $rcnn_id);
|
|
|
|
db_execute('DELETE FROM poller_item
|
|
WHERE local_data_id IN (' . $ids_to_delete . ')', true, $rcnn_id);
|
|
|
|
db_execute('DELETE FROM data_local
|
|
WHERE id IN (' . $ids_to_delete . ')', true, $rcnn_id);
|
|
|
|
/* boost */
|
|
db_execute('DELETE FROM poller_output
|
|
WHERE local_data_id IN (' . $ids_to_delete . ')', true, $rcnn_id);
|
|
|
|
db_execute('DELETE FROM poller_output_boost
|
|
WHERE local_data_id IN (' . $ids_to_delete . ')', true, $rcnn_id);
|
|
}
|
|
|
|
api_data_source_cache_crc_update($poller_id);
|
|
}
|
|
}
|
|
}
|
|
|
|
if ($update_totals) {
|
|
object_cache_update_totals('delete');
|
|
}
|
|
}
|
|
|
|
function api_data_source_enable($local_data_id) {
|
|
db_execute_prepared("UPDATE data_template_data
|
|
SET active = 'on'
|
|
WHERE local_data_id = ?",
|
|
[$local_data_id]);
|
|
|
|
$device_id = db_fetch_cell_prepared('SELECT host_id
|
|
FROM data_local
|
|
WHERE id = ?',
|
|
[$local_data_id]);
|
|
|
|
if (($rcnn_id = poller_push_to_remote_db_connect($device_id)) !== false) {
|
|
db_execute_prepared("UPDATE data_template_data
|
|
SET active = 'on'
|
|
WHERE local_data_id = ?",
|
|
[$local_data_id], true, $rcnn_id);
|
|
}
|
|
|
|
update_poller_cache($local_data_id, true);
|
|
}
|
|
|
|
function api_data_source_disable($local_data_id) {
|
|
db_execute_prepared('DELETE FROM poller_item
|
|
WHERE local_data_id = ?',
|
|
[$local_data_id]);
|
|
|
|
db_execute_prepared("UPDATE data_template_data
|
|
SET active=''
|
|
WHERE local_data_id = ?",
|
|
[$local_data_id]);
|
|
|
|
$device_id = db_fetch_cell_prepared('SELECT host_id
|
|
FROM data_local
|
|
WHERE id = ?',
|
|
[$local_data_id]);
|
|
|
|
if (($rcnn_id = poller_push_to_remote_db_connect($device_id)) !== false) {
|
|
db_execute_prepared('DELETE FROM poller_item
|
|
WHERE local_data_id = ?',
|
|
[$local_data_id], true, $rcnn_id);
|
|
|
|
db_execute_prepared("UPDATE data_template_data
|
|
SET active=''
|
|
WHERE local_data_id = ?",
|
|
[$local_data_id], true, $rcnn_id);
|
|
}
|
|
}
|
|
|
|
function api_data_source_disable_multi($local_data_ids) {
|
|
/* initialize variables */
|
|
$ids_to_disable = '';
|
|
$poller_ids = [];
|
|
|
|
$i = 0;
|
|
|
|
/* build the array */
|
|
if (cacti_sizeof($local_data_ids)) {
|
|
foreach ($local_data_ids as $local_data_id) {
|
|
if ($i == 0) {
|
|
$ids_to_disable .= $local_data_id;
|
|
} else {
|
|
$ids_to_disable .= ', ' . $local_data_id;
|
|
}
|
|
|
|
$i++;
|
|
|
|
if (!($i % 1000)) {
|
|
$poller_ids += array_rekey(
|
|
db_fetch_assoc('SELECT poller_id
|
|
FROM poller_item
|
|
WHERE local_data_id IN(' . $ids_to_disable . ')'),
|
|
'poller_id', 'poller_id'
|
|
);
|
|
|
|
db_execute("DELETE FROM poller_item WHERE local_data_id IN ($ids_to_disable)");
|
|
db_execute("UPDATE data_template_data SET active='' WHERE local_data_id IN ($ids_to_disable)");
|
|
|
|
if (cacti_sizeof($poller_ids)) {
|
|
foreach ($poller_ids as $poller_id) {
|
|
if (($rcnn_id = poller_push_to_remote_db_connect($poller_id, true)) !== false) {
|
|
db_execute("DELETE FROM poller_item WHERE local_data_id IN ($ids_to_disable)", true, $rcnn_id);
|
|
db_execute("UPDATE data_template_data SET active='' WHERE local_data_id IN ($ids_to_disable)", true, $rcnn_id);
|
|
}
|
|
}
|
|
}
|
|
|
|
$i = 0;
|
|
$ids_to_disable = '';
|
|
}
|
|
}
|
|
|
|
if ($i > 0) {
|
|
$poller_ids += array_rekey(
|
|
db_fetch_assoc('SELECT poller_id
|
|
FROM poller_item
|
|
WHERE local_data_id IN(' . $ids_to_disable .')'),
|
|
'poller_id', 'poller_id'
|
|
);
|
|
|
|
db_execute("DELETE FROM poller_item WHERE local_data_id IN ($ids_to_disable)");
|
|
db_execute("UPDATE data_template_data SET active='' WHERE local_data_id IN ($ids_to_disable)");
|
|
|
|
if (cacti_sizeof($poller_ids)) {
|
|
foreach ($poller_ids as $poller_id) {
|
|
if (($rcnn_id = poller_push_to_remote_db_connect($poller_id, true)) !== false) {
|
|
db_execute("DELETE FROM poller_item WHERE local_data_id IN ($ids_to_disable)", true, $rcnn_id);
|
|
db_execute("UPDATE data_template_data SET active='' WHERE local_data_id IN ($ids_to_disable)", true, $rcnn_id);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (cacti_sizeof($poller_ids)) {
|
|
foreach ($poller_ids as $poller_id) {
|
|
api_data_source_cache_crc_update($poller_id);
|
|
}
|
|
}
|
|
}
|
|
|
|
function api_data_source_get_interface_speed($data_local) {
|
|
$ifHighSpeed = db_fetch_cell_prepared('SELECT field_value
|
|
FROM host_snmp_cache
|
|
WHERE host_id = ?
|
|
AND snmp_query_id = ?
|
|
AND snmp_index = ?
|
|
AND field_name="ifHighSpeed"',
|
|
[$data_local['host_id'], $data_local['snmp_query_id'], $data_local['snmp_index']]
|
|
);
|
|
|
|
$ifSpeed = db_fetch_cell_prepared('SELECT field_value
|
|
FROM host_snmp_cache
|
|
WHERE host_id = ?
|
|
AND snmp_query_id = ?
|
|
AND snmp_index = ?
|
|
AND field_name="ifSpeed"',
|
|
[$data_local['host_id'], $data_local['snmp_query_id'], $data_local['snmp_index']]
|
|
);
|
|
|
|
if (!empty($ifHighSpeed)) {
|
|
$speed = $ifHighSpeed * 1000000;
|
|
|
|
if (read_config_option('data_source_trace') == 'on') {
|
|
cacti_log('Interface Speed Detected by ifHighSpeed: "' . $speed . '"', false, 'DSTRACE');
|
|
}
|
|
} elseif (!empty($ifSpeed)) {
|
|
$speed = $ifSpeed;
|
|
|
|
if (read_config_option('data_source_trace') == 'on') {
|
|
cacti_log('Interface Speed Detected by ifSpeed: "' . $speed . '"', false, 'DSTRACE');
|
|
}
|
|
} else {
|
|
$speed = read_config_option('default_interface_speed');
|
|
|
|
if (empty($speed)) {
|
|
$speed = '10000000000000';
|
|
|
|
if (read_config_option('data_source_trace') == 'on') {
|
|
cacti_log('Interface Speed Detected by Default: "' . $speed . '"', false, 'DSTRACE');
|
|
}
|
|
} else {
|
|
$speed *= 1000000;
|
|
|
|
if (read_config_option('data_source_trace') == 'on') {
|
|
cacti_log('Interface Speed Detected by Settings: "' . $speed . '"', false, 'DSTRACE');
|
|
}
|
|
}
|
|
}
|
|
|
|
return $speed;
|
|
}
|
|
|
|
function api_data_source_change_host($data_sources, $device_id) {
|
|
if (cacti_sizeof($data_sources)) {
|
|
foreach ($data_sources as $data_source) {
|
|
db_execute_prepared('UPDATE data_local
|
|
SET host_id = ?
|
|
WHERE id = ?',
|
|
[$device_id, $data_source]);
|
|
|
|
if (($rcnn_id = poller_push_to_remote_db_connect($device_id)) !== false) {
|
|
db_execute_prepared('UPDATE data_local
|
|
SET host_id = ?
|
|
WHERE id = ?',
|
|
[$device_id, $data_source], true, $rcnn_id);
|
|
}
|
|
|
|
push_out_host($device_id, $data_source);
|
|
|
|
update_data_source_title_cache($data_source);
|
|
}
|
|
}
|
|
}
|
|
|
|
function api_reapply_suggested_data_source_data($local_data_id) {
|
|
$data_template_data_id = db_fetch_cell_prepared('SELECT id
|
|
FROM data_template_data
|
|
WHERE local_data_id = ?',
|
|
[$local_data_id]);
|
|
|
|
if (empty($data_template_data_id)) {
|
|
return;
|
|
}
|
|
|
|
/* require query type data sources only (snmp_query_id > 0) */
|
|
$data_local = db_fetch_row_prepared('SELECT id, host_id,
|
|
data_template_id, snmp_query_id, snmp_index
|
|
FROM data_local
|
|
WHERE snmp_query_id > 0
|
|
AND id = ?',
|
|
[$local_data_id]);
|
|
|
|
/* if this is not a data query graph, simply return */
|
|
if (!isset($data_local['host_id'])) {
|
|
return;
|
|
}
|
|
|
|
$snmp_query_graph_id = db_fetch_cell_prepared("SELECT did.value
|
|
FROM data_input_data AS did
|
|
INNER JOIN data_input_fields AS dif
|
|
ON did.data_input_field_id = dif.id
|
|
INNER JOIN data_template_data AS dtd
|
|
ON dtd.id = did.data_template_data_id
|
|
WHERE dif.type_code = 'output_type'
|
|
AND dtd.local_data_id = ?",
|
|
[$data_local['id']]);
|
|
|
|
/* no snmp query graph id found */
|
|
if ($snmp_query_graph_id == 0) {
|
|
return;
|
|
}
|
|
|
|
$svs = db_fetch_assoc_prepared('SELECT
|
|
text, field_name
|
|
FROM snmp_query_graph_rrd_sv
|
|
WHERE snmp_query_graph_id = ?
|
|
AND data_template_id = ?
|
|
ORDER BY sequence',
|
|
[$snmp_query_graph_id, $data_local['data_template_id']]);
|
|
|
|
$matches = [];
|
|
|
|
if (cacti_sizeof($svs)) {
|
|
foreach ($svs as $sv) {
|
|
$sv['text'] = trim($sv['text']);
|
|
|
|
if (($sv['text'] == '|query_ifSpeed|' || $sv['text'] == '|query_ifHighSpeed|') && $sv['field_name'] == 'rrd_maximum') {
|
|
$subs_string = api_data_source_get_interface_speed($data_local);
|
|
$sv['text'] = $subs_string;
|
|
} else {
|
|
$subs_string = substitute_snmp_query_data($sv['text'],$data_local['host_id'],
|
|
$data_local['snmp_query_id'], $data_local['snmp_index'],
|
|
read_config_option('max_data_query_field_length'));
|
|
}
|
|
|
|
/* if there are no '|query' characters, all of the substitutions were successful */
|
|
if (!str_contains($subs_string, '|query')) {
|
|
if (in_array($sv['field_name'], $matches, true)) {
|
|
continue;
|
|
}
|
|
|
|
if (db_column_exists('data_template_data', $sv['field_name'])) {
|
|
$matches[] = $sv['field_name'];
|
|
db_execute_prepared('UPDATE data_template_data
|
|
SET ' . $sv['field_name'] . ' = ?
|
|
WHERE local_data_id = ?',
|
|
[$sv['text'], $local_data_id]);
|
|
} elseif (db_column_exists('data_template_rrd', $sv['field_name'])) {
|
|
$matches[] = $sv['field_name'];
|
|
db_execute_prepared('UPDATE data_template_rrd
|
|
SET ' . $sv['field_name'] . ' = ?
|
|
WHERE local_data_id = ?',
|
|
[$sv['text'], $local_data_id]);
|
|
} else {
|
|
cacti_log('ERROR: Suggested value column error. Column ' . $sv['field_name'] . ' for Data Template ID ' . $data_local['data_template_id'] . ' is not a compatible field name for tables data_template_data and data_template_rrd. Please correct this suggested value mapping', false);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
function api_data_source_duplicate($_local_data_id, $_data_template_id, $data_source_title) {
|
|
global $struct_data_source, $struct_data_source_item;
|
|
|
|
if (!empty($_local_data_id)) {
|
|
$data_local = db_fetch_row_prepared('SELECT *
|
|
FROM data_local
|
|
WHERE id = ?',
|
|
[$_local_data_id]);
|
|
|
|
if (!cacti_sizeof($data_local)) {
|
|
return false;
|
|
}
|
|
|
|
$data_template_data = db_fetch_row_prepared('SELECT *
|
|
FROM data_template_data
|
|
WHERE local_data_id = ?',
|
|
[$_local_data_id]);
|
|
|
|
$data_template_rrds = db_fetch_assoc_prepared('SELECT *
|
|
FROM data_template_rrd
|
|
WHERE local_data_id = ?',
|
|
[$_local_data_id]);
|
|
|
|
$data_input_datas = db_fetch_assoc_prepared('SELECT *
|
|
FROM data_input_data
|
|
WHERE data_template_data_id = ?',
|
|
[$data_template_data['id']]);
|
|
|
|
/* create new entry: data_local */
|
|
$save['id'] = 0;
|
|
$save['data_template_id'] = $data_local['data_template_id'];
|
|
$save['host_id'] = $data_local['host_id'];
|
|
$save['snmp_query_id'] = $data_local['snmp_query_id'];
|
|
$save['snmp_index'] = $data_local['snmp_index'];
|
|
|
|
$local_data_id = sql_save($save, 'data_local');
|
|
|
|
$data_template_data['name'] = str_replace('<ds_title>', $data_template_data['name'], $data_source_title);
|
|
} elseif (!empty($_data_template_id)) {
|
|
$data_template = db_fetch_row_prepared('SELECT *
|
|
FROM data_template
|
|
WHERE id = ?',
|
|
[$_data_template_id]);
|
|
|
|
if (!cacti_sizeof($data_template)) {
|
|
return false;
|
|
}
|
|
|
|
$data_template_data = db_fetch_row_prepared('SELECT *
|
|
FROM data_template_data
|
|
WHERE data_template_id = ?
|
|
AND local_data_id = 0',
|
|
[$_data_template_id]);
|
|
|
|
$data_template_rrds = db_fetch_assoc_prepared('SELECT *
|
|
FROM data_template_rrd
|
|
WHERE data_template_id = ?
|
|
AND local_data_id = 0',
|
|
[$_data_template_id]);
|
|
|
|
$data_input_datas = db_fetch_assoc_prepared('SELECT *
|
|
FROM data_input_data
|
|
WHERE data_template_data_id = ?',
|
|
[$data_template_data['id']]);
|
|
|
|
/* create new entry: data_template */
|
|
$save['id'] = 0;
|
|
$save['hash'] = get_hash_data_template(0);
|
|
$save['name'] = str_replace('<template_title>', $data_template['name'], $data_source_title);
|
|
|
|
$data_template_id = sql_save($save, 'data_template');
|
|
}
|
|
|
|
unset($save);
|
|
unset($struct_data_source['data_source_path']);
|
|
|
|
/* create new entry: data_template_data */
|
|
$save['id'] = 0;
|
|
$save['local_data_id'] = ($local_data_id ?? 0);
|
|
$save['local_data_template_data_id'] = ($data_template_data['local_data_template_data_id'] ?? 0);
|
|
$save['data_template_id'] = (!empty($_local_data_id) ? $data_template_data['data_template_id'] : $data_template_id);
|
|
$save['name_cache'] = $data_template_data['name_cache'];
|
|
|
|
foreach ($struct_data_source as $field => $array) {
|
|
$save[$field] = $data_template_data[$field];
|
|
|
|
if ($array['flags'] != 'ALWAYSTEMPLATE') {
|
|
$save['t_' . $field] = $data_template_data['t_' . $field];
|
|
}
|
|
}
|
|
|
|
$data_template_data_id = sql_save($save, 'data_template_data');
|
|
|
|
/* create new entry(s): data_template_rrd */
|
|
if (cacti_sizeof($data_template_rrds)) {
|
|
foreach ($data_template_rrds as $data_template_rrd) {
|
|
unset($save);
|
|
|
|
$save['id'] = 0;
|
|
$save['local_data_id'] = ($local_data_id ?? 0);
|
|
$save['local_data_template_rrd_id'] = ($data_template_rrd['local_data_template_rrd_id'] ?? 0);
|
|
$save['data_template_id'] = (!empty($_local_data_id) ? $data_template_rrd['data_template_id'] : $data_template_id);
|
|
|
|
if ($save['local_data_id'] == 0) {
|
|
$save['hash'] = get_hash_data_template($data_template_rrd['local_data_template_rrd_id'], 'data_template_item');
|
|
} else {
|
|
$save['hash'] = '';
|
|
}
|
|
|
|
foreach ($struct_data_source_item as $field => $array) {
|
|
$save[$field] = $data_template_rrd[$field];
|
|
|
|
if (isset($data_template_rrd['t_' . $field])) {
|
|
$save['t_' . $field] = $data_template_rrd['t_' . $field];
|
|
}
|
|
}
|
|
|
|
$data_template_rrd_id = sql_save($save, 'data_template_rrd');
|
|
}
|
|
}
|
|
|
|
/* create new entry(s): data_input_data */
|
|
if (cacti_sizeof($data_input_datas)) {
|
|
foreach ($data_input_datas as $data_input_data) {
|
|
db_execute_prepared('INSERT IGNORE INTO data_input_data
|
|
(data_input_field_id, data_template_data_id, data_template_id, local_data_id, host_id, t_value, value)
|
|
VALUES (?, ?, ?, ?)',
|
|
[
|
|
$data_input_data['data_input_field_id'],
|
|
$data_template_data_id,
|
|
$data_input_data['data_template_id'],
|
|
$data_input_data['local_data_id'],
|
|
$data_input_data['host_id'],
|
|
$data_input_data['t_value'],
|
|
$data_input_data['value']
|
|
]
|
|
);
|
|
}
|
|
}
|
|
|
|
if (!empty($_local_data_id)) {
|
|
update_data_source_title_cache($local_data_id);
|
|
}
|
|
|
|
if ($_local_data_id > 0) {
|
|
return $local_data_id;
|
|
}
|
|
|
|
if ($_data_template_id > 0) {
|
|
return $data_template_id;
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
function api_data_input_duplicate($_data_input_id, $input_title) {
|
|
$orig_input = db_fetch_row_prepared('SELECT *
|
|
FROM data_input
|
|
WHERE id = ?',
|
|
[$_data_input_id]);
|
|
|
|
if (cacti_sizeof($orig_input)) {
|
|
unset($save);
|
|
$save['id'] = 0;
|
|
$save['hash'] = get_hash_data_input(0);
|
|
$save['name'] = str_replace('<input_title>', $orig_input['name'], $input_title);
|
|
$save['input_string'] = $orig_input['input_string'];
|
|
$save['type_id'] = $orig_input['type_id'];
|
|
|
|
$data_input_id = sql_save($save, 'data_input');
|
|
|
|
if (!empty($data_input_id)) {
|
|
$data_input_fields = db_fetch_assoc_prepared('SELECT *
|
|
FROM data_input_fields
|
|
WHERE data_input_id = ?',
|
|
[$_data_input_id]);
|
|
|
|
if (cacti_sizeof($data_input_fields)) {
|
|
foreach ($data_input_fields as $dif) {
|
|
unset($save);
|
|
$save['id'] = 0;
|
|
$save['hash'] = get_hash_data_input(0, 'data_input_field');
|
|
$save['data_input_id'] = $data_input_id;
|
|
$save['name'] = $dif['name'];
|
|
$save['data_name'] = $dif['data_name'];
|
|
$save['input_output'] = $dif['input_output'];
|
|
$save['update_rra'] = $dif['update_rra'];
|
|
$save['sequence'] = $dif['sequence'];
|
|
$save['type_code'] = $dif['type_code'];
|
|
$save['regexp_match'] = $dif['regexp_match'];
|
|
$save['allow_nulls'] = $dif['allow_nulls'];
|
|
|
|
$data_input_field_id = sql_save($save, 'data_input_fields');
|
|
}
|
|
}
|
|
}
|
|
|
|
return $data_input_id;
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
function api_data_input_remove($id) {
|
|
$data_input_fields = db_fetch_assoc_prepared('SELECT id
|
|
FROM data_input_fields
|
|
WHERE data_input_id = ?',
|
|
[$id]);
|
|
|
|
if (is_array($data_input_fields)) {
|
|
foreach ($data_input_fields as $data_input_field) {
|
|
db_execute_prepared('DELETE FROM data_input_data
|
|
WHERE data_input_field_id = ?',
|
|
[$data_input_field['id']]);
|
|
}
|
|
}
|
|
|
|
db_execute_prepared('DELETE FROM data_input
|
|
WHERE id = ?',
|
|
[$id]);
|
|
|
|
db_execute_prepared('DELETE FROM data_input_fields
|
|
WHERE data_input_id = ?',
|
|
[$id]);
|
|
|
|
update_replication_crc(0, 'poller_replicate_data_input_fields_crc');
|
|
update_replication_crc(0, 'poller_replicate_data_input_crc');
|
|
}
|
|
|
|
function api_data_input_more_inputs($id, $input_string) {
|
|
$input_string = str_replace('<path_cacti>', '', $input_string);
|
|
$inputs = substr_count($input_string, '<');
|
|
|
|
$existing = db_fetch_cell_prepared('SELECT COUNT(*)
|
|
FROM data_input_fields
|
|
WHERE data_input_id = ?
|
|
AND input_output = "in"',
|
|
[$id]);
|
|
|
|
if ($inputs > $existing) {
|
|
return true;
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|